Komodo / komodo-center-httpget-x

Browse Code »

Commit 9ced2cfdf03e19f6c35901c59076ab1322236d6b

Authored by Adhidarma Hadiwinoto 5 years ago

1 parent 635fc54bfa

Exists in master and in 1 other branch

PAY finished

Showing 3 changed files with 111 additions and 1 deletions Inline Diff

lib/core-callback/sender.js
lib/listener-partner/index.js
lib/listener-partner/routers/pay.js

lib/core-callback/sender.js

Diff comments View file @ 9ced2cf

 const MODULE_NAME = 'CORE-CALLBACK-SENDER';
 const MAX_RETRY = 10;
 const SLEEP_BEFORE_RETRY_MS = 60 * 1000;
 const axios = require('axios').default;
 const logger = require('komodo-sdk/logger');
 const sleep = require('../sleep');
 const urlConcatQs = require('../url-concat-qs');
 const sender = async (data, xid, retry) => {
     if (!data.reverse_url) return;
     const params = {
         httpgetx_xid: xid,
         command: data.command,
         request_id: data.request_id && data.request_id.toString(),
         transaction_id: data.transaction_id && data.transaction_id.toString(),
         transaction_date: data.transaction_date,
         store_name: data.store_name,
         terminal_name: data.terminal_name,
         product_name: data.product_name,
         destination: data.destination,
         rc: data.rc,
         sn: data.sn,
         message: data.message,
         amount: data.amount,
         ending_balance: data.ending_balance,
-        amount_to_charge: data.amount_to_charge,
     };
+    if (data.command === 'INQUIRY' && data.amount_to_charge) {
+        params.amount_to_charge = data.amount_to_charge;
+    }
     const fullUrl = urlConcatQs(data.reverse_url, params);
     logger.info(`${MODULE_NAME} 8B6A4CEC: Sending CORE-CALLBACK to PARTNER`, {
         xid, retry, params, fullUrl,
     });
     try {
         const result = await axios.get(data.reverse_url, {
             params,
             timeout: 60 * 1000,
         });
         logger.info(`${MODULE_NAME} 3641FBD7: CORE-CALLBACK has been sent to PARTNER successfully`, {
             xid, retry, fullUrl, body: result && result.data,
         });
     } catch (e) {
         logger.warn(`${MODULE_NAME} A1EC9E70: Failed on sending CORE-CALLBACK to PARTNER`, {
             xid,
             retry,
             maxRetry: MAX_RETRY,
             errCode: e.code,
             errMessage: e.message,
             reverseUrl: data.reverse_url,
             fullUrl,
             httpStatus: e.response && e.response.status,
             body: e.response && e.response.data,
         });
         if ((retry || 0) < MAX_RETRY) {
             await sleep(SLEEP_BEFORE_RETRY_MS);
             logger.verbose(`${MODULE_NAME} D8958695: Going to retry sending CORE-CALLBACK TO PARTNER`, {
                 xid, sleepTime: SLEEP_BEFORE_RETRY_MS,
             });
             sender(data, xid, (retry || 0) + 1);
         }
     }
 };
 module.exports = sender;

lib/listener-partner/index.js

Diff comments View file @ 9ced2cf

 'use strict';
 const DEFAULT_LISTENER_FROM_PARTNER_PORT = 25614;
 const express = require('express');
 const config = require('komodo-sdk/config');
 const logger = require('komodo-sdk/logger');
 const middlewareCommon = require('../middlewares/common');
 const routerInquiry = require('./routers/inquiry');
+const routerPay = require('./routers/pay');
 const routerTopup = require('./routers/topup');
 const routerTrxStatus = require('./routers/trx-status');
 const app = express();
 app.use(express.json({ extended: true }));
 app.use(express.urlencoded({ extended: true }));
 app.use(middlewareCommon);
 app.use('/inquiry', routerInquiry);
+app.use('/pay', routerPay);
 app.use('/topup', routerTopup);
 app.use('/trx-status', routerTrxStatus);
 app.use((req, res) => {
     const { xid } = res.locals;
     res.status(404).end(`KOMODO-HTTP-GET-X CENTER.\n404: Method not found.\n\nXID: ${xid}.\n`);
 });
 app.listen(config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT, () => {
     logger.info(`Listen from partner request on port ${config.listener.partner.port}`);
 }).on('error', (e) => {
     logger.error(`Can not listen request from partner on port ${config.listener.partner.port || DEFAULT_LISTENER_FROM_PARTNER_PORT}. ${e.toString()}`);
     process.exit(1);
 });

lib/listener-partner/routers/pay.js

Diff comments View file @ 9ced2cf

File was created	1	const axios = require('axios').default;
	2	const express = require('express');
	3	const coreUrl = require('komodo-sdk/core-url');
	4
	5	const config = require('komodo-sdk/config');
	6	const logger = require('komodo-sdk/logger');
	7
	8	const getFromBodyQsParams = require('../../get-from-body-qs-params');
	9	const ipv6ToIpv4 = require('../../ipv6-to-ipv4');
	10
	11	const router = express.Router();
	12	module.exports = router;
	13
	14	const CORE_ENDPOINT = `${coreUrl}/postpaid2/pay`;
	15
	16	const mainHandler = async (req, res) => {
	17	const { xid } = res.locals;
	18
	19	const requestId = (getFromBodyQsParams(req, 'request_id') \|\| '').toString().trim();
	20	const terminalNameWithoutIp = (getFromBodyQsParams(req, 'terminal_name') \|\| '').toString().trim();
	21	const terminalName = `${terminalNameWithoutIp}@${ipv6ToIpv4(req.ip)}`;
	22	const productName = (getFromBodyQsParams(req, 'product_name') \|\| '').trim().toUpperCase();
	23	const destination = (getFromBodyQsParams(req, 'destination') \|\| '').toString().trim();
	24	const password = getFromBodyQsParams(req, 'password');
	25	const reverseUrl = getFromBodyQsParams(req, 'reverse_url');
	26
	27	if (!requestId \|\| !terminalNameWithoutIp \|\| !productName \|\| !destination) {
	28	res.end('INVALID REQUEST. Missing request_id or terminal_name or product_name or destination.');
	29	return;
	30	}
	31
	32	const params = {
	33	origin: config.name,
	34	report_ip: config.listener.core.from_ip,
	35	report_port: config.listener.core.port \|\| 25614,
	36	request_id: requestId,
	37	terminal_name: terminalName,
	38	product_name: productName,
	39	destination,
	40	terminal_password: password,
	41	reverse_url: reverseUrl,
	42	};
	43
	44	logger.info('Forwarding PAY request to CORE', { xid, params });
	45	try {
	46	const result = await axios.get(CORE_ENDPOINT, {
	47	params,
	48	timeout: 10000,
	49	});
	50
	51	if (!result \|\| !result.data) {
	52	const newError = new Error('0D428E4C: Empty CORE PAY direct-response');
	53	logger.warn(newError.message, { xid });
	54	throw newError;
	55	}
	56
	57	logger.verbose('Got PAY direct-response from CORE', {
	58	xid,
	59	coreResponse: result.data,
	60	});
	61
	62	const resultForPartner = {
	63	httpgetx_xid: xid,
	64	command: result.data.command,
	65	request_id: result.data.request_id && result.data.request_id.toString(),
	66	transaction_id: result.data.transaction_id && result.data.transaction_id.toString(),
	67	transaction_date: result.data.transaction_date,
	68	store_name: result.data.store_name,
	69	terminal_name: result.data.terminal_name,
	70	product_name: result.data.product_name,
	71	destination: result.data.destination,
	72	rc: result.data.rc,
	73	sn: result.data.sn,
	74	message: result.data.message,
	75	amount: result.data.amount,
	76	ending_balance: result.data.ending_balance,
	77	};
	78
	79	logger.verbose('Forwarding CORE PAY direct-response to partner', {
	80	xid,
	81	resultForPartner,
	82	});
	83
	84	res.json(resultForPartner);
	85	} catch (e) {
	86	logger.warn('EXCEPTION on forwarding PAY request to CORE', {
	87	xid,
	88	errCode: e.code,
	89	errMessage: e.message,
	90	});
	91
	92	res.json({
	93	httpgetx_xid: xid,
	94	command: 'PAY',
	95	request_id: requestId,
	96	terminal_name: terminalName,
	97	product_name: productName,
	98	destination,
	99	rc: '68',
	100	message: 'CORE tidak merespon dengan benar, tidak dapat mengetahui status request anda',
	101	});
	102	}
	103	};
	104
	105	router.all('/', mainHandler);
	106