Komodo / komodo-center-httpget-x

Browse Code »

Commit 732c359a73db49f1ca33fbc55cb2fcc276daee91

Authored by Adhidarma Hadiwinoto 4 years ago

1 parent c6a2bf27de

Exists in master and in 1 other branch

Partner listener dumper

Showing 5 changed files with 107 additions and 11 deletions Inline Diff

lib/partner-listener/dumper/index.js
lib/partner-listener/routers/inquiry.js
lib/partner-listener/routers/pay.js
lib/partner-listener/routers/topup.js
lib/partner-listener/routers/trx-status.js

lib/partner-listener/dumper/index.js

Diff comments View file @ 732c359

File was created	1	const MODULE_NAME = 'PARTNER-LISTENER.DUMPER';
	2
	3	const fsPromise = require('fs').promises;
	4	const path = require('path');
	5	const moment = require('moment');
	6	const config = require('komodo-sdk/config');
	7	const logger = require('komodo-sdk/logger');
	8
	9	const mkdirIfNotExists = require('../../utils/mkdir-if-not-exists');
	10
	11	const baseDumpDir = path.join('dump', 'partner-listener');
	12	const lastDumpFileName = path.join(baseDumpDir, 'last');
	13
	14	module.exports = async (xid, req, responseBody) => {
	15	if (
	16	!config
	17	\|\| !config.listener
	18	\|\| !config.listener.partner
	19	\|\| !config.listener.partner.dump
	20	) return;
	21
	22	const data = `--------
	23	XID: ${xid}
	24	TS: ${moment().format('YYYY-MM-DD HH:mm:ss')}
	25
	26	REQ FROM: ${req.ip}
	27	REQ CONTENT-TYPE: ${req.get('content-type')}
	28	REQ METHOD: ${req.method}
	29	REQ URL: ${req.url}
	30
	31	REQ QUERY-STRING:
	32	${JSON.stringify(req.query, null, 2)}
	33
	34	REQ BODY:
	35	${typeof req.body === 'string' ? req.body : JSON.stringify(req.body, null, 2)}
	36
	37	RES BODY:
	38	${typeof responseBody === 'string' ? responseBody : JSON.stringify(responseBody, null, 2)}
	39	`;
	40
	41	const dumpFileName = path.join(
	42	baseDumpDir,
	43	moment().format('YYYY-MM-DD'),
	44	[
	45	moment().format('YYMMDD_HHmmss_SSS'),
	46	xid,
	47	].join('_'),
	48	);
	49
	50	try {
	51	await mkdirIfNotExists(xid, path.basename(dumpFileName));
	52	await fsPromise.writeFile(lastDumpFileName, data);
	53	await fsPromise.writeFile(dumpFileName, data);
	54	} catch (e) {
	55	logger.warn(`${MODULE_NAME} FBC46420: Exception on dumping file`, {
	56	xid,
	57	eCode: e.code,
	58	eMessage: e.eMessage,
	59	});
	60	}
	61	};
	62

lib/partner-listener/routers/inquiry.js

Diff comments View file @ 732c359

 const axios = require('axios').default;
 const express = require('express');
 const coreUrl = require('komodo-sdk/core-url');
 const config = require('komodo-sdk/config');
 const logger = require('komodo-sdk/logger');
 const getFromBodyQsParams = require('../../get-from-body-qs-params');
 const ipv6ToIpv4 = require('../../ipv6-to-ipv4');
+const dumper = require('../dumper');
 const router = express.Router();
 module.exports = router;
 const CORE_ENDPOINT = `${coreUrl}/postpaid2/inquiry`;
 const mainHandler = async (req, res) => {
     const { xid } = res.locals;
     const requestId = (getFromBodyQsParams(req, 'request_id') || '').toString().trim();
     const terminalNameWithoutIp = (getFromBodyQsParams(req, 'terminal_name') || '').toString().trim();
     const terminalName = `${terminalNameWithoutIp}@${ipv6ToIpv4(req.ip)}`;
     const productName = (getFromBodyQsParams(req, 'product_name') || '').trim().toUpperCase();
     const destination = (getFromBodyQsParams(req, 'destination') || '').toString().trim();
     const password = getFromBodyQsParams(req, 'password');
     const reverseUrl = getFromBodyQsParams(req, 'reverse_url');
     if (!requestId || !terminalNameWithoutIp || !productName || !destination) {
-        res.end('INVALID REQUEST. Missing request_id or terminal_name or product_name or destination.');
+        const msg = 'INVALID REQUEST. Missing request_id or terminal_name or product_name or destination.';
+        res.end(msg);
+        dumper(xid, req, msg);
         return;
     }
     const params = {
         origin: config.name,
         report_ip: config.listener.core.from_ip,
         report_port: config.listener.core.port || 25614,
         request_id: requestId,
         terminal_name: terminalName,
         product_name: productName,
         destination,
         terminal_password: password,
         reverse_url: reverseUrl,
     };
     logger.info('Forwarding INQUIRY request to CORE', { xid, params });
     try {
         const result = await axios.get(CORE_ENDPOINT, {
             params,
             timeout: 10000,
         });
         if (!result || !result.data) {
             const newError = new Error('8002EB0D: Empty CORE INQUIRY direct-response');
             logger.warn(newError.message, { xid });
             throw newError;
         }
         logger.verbose('Got INQUIRY direct-response from CORE', {
             xid,
             coreResponse: result.data,
         });
         const resultForPartner = {
             httpgetx_xid: xid,
             command: result.data.command,
             request_id: result.data.request_id && result.data.request_id.toString(),
             transaction_id: result.data.transaction_id && result.data.transaction_id.toString(),
             transaction_date: result.data.transaction_date,
             store_name: result.data.store_name,
             terminal_name: result.data.terminal_name,
             product_name: result.data.product_name,
             destination: result.data.destination,
             rc: result.data.rc,
             sn: result.data.sn,
             message: result.data.message,
             amount: result.data.amount,
             ending_balance: result.data.ending_balance,
             amount_to_charge: result.data.amount_to_charge,
         };
         logger.verbose('Forwarding CORE direct-response to partner', {
             xid,
             resultForPartner,
         });
         res.json(resultForPartner);
+        dumper(xid, req, resultForPartner);
     } catch (e) {
         logger.warn('EXCEPTION on forwarding INQUIRY request to CORE', {
             xid,
             errCode: e.code,
             errMessage: e.message,
         });
-        res.json({
+        const resultForPartner = {
             httpgetx_xid: xid,
             command: 'INQUIRY',
             request_id: requestId,
             terminal_name: terminalName,
             product_name: productName,
             destination,
             rc: '68',
             message: 'CORE tidak merespon dengan benar, tidak dapat mengetahui status request anda',
-        });
+        };
+        res.json(resultForPartner);
+        dumper(xid, req, resultForPartner);
     }
 };
 router.all('/', mainHandler);

lib/partner-listener/routers/pay.js

Diff comments View file @ 732c359

 const axios = require('axios').default;
 const express = require('express');
 const coreUrl = require('komodo-sdk/core-url');
 const config = require('komodo-sdk/config');
 const logger = require('komodo-sdk/logger');
 const getFromBodyQsParams = require('../../get-from-body-qs-params');
 const ipv6ToIpv4 = require('../../ipv6-to-ipv4');
+const dumper = require('../dumper');
 const router = express.Router();
 module.exports = router;
 const CORE_ENDPOINT = `${coreUrl}/postpaid2/pay`;
 const mainHandler = async (req, res) => {
     const { xid } = res.locals;
     const requestId = (getFromBodyQsParams(req, 'request_id') || '').toString().trim();
     const terminalNameWithoutIp = (getFromBodyQsParams(req, 'terminal_name') || '').toString().trim();
     const terminalName = `${terminalNameWithoutIp}@${ipv6ToIpv4(req.ip)}`;
     const productName = (getFromBodyQsParams(req, 'product_name') || '').trim().toUpperCase();
     const destination = (getFromBodyQsParams(req, 'destination') || '').toString().trim();
     const password = getFromBodyQsParams(req, 'password');
     const reverseUrl = getFromBodyQsParams(req, 'reverse_url');
     if (!requestId || !terminalNameWithoutIp || !productName || !destination) {
-        res.end('INVALID REQUEST. Missing request_id or terminal_name or product_name or destination.');
+        const msg = 'INVALID REQUEST. Missing request_id or terminal_name or product_name or destination.';
+        res.end(msg);
+        dumper(xid, req, msg);
         return;
     }
     const params = {
         origin: config.name,
         report_ip: config.listener.core.from_ip,
         report_port: config.listener.core.port || 25614,
         request_id: requestId,
         terminal_name: terminalName,
         product_name: productName,
         destination,
         terminal_password: password,
         reverse_url: reverseUrl,
     };
     logger.info('Forwarding PAY request to CORE', { xid, params });
     try {
         const result = await axios.get(CORE_ENDPOINT, {
             params,
             timeout: 10000,
         });
         if (!result || !result.data) {
             const newError = new Error('0D428E4C: Empty CORE PAY direct-response');
             logger.warn(newError.message, { xid });
             throw newError;
         }
         logger.verbose('Got PAY direct-response from CORE', {
             xid,
             coreResponse: result.data,
         });
         const resultForPartner = {
             httpgetx_xid: xid,
             command: result.data.command,
             request_id: result.data.request_id && result.data.request_id.toString(),
             transaction_id: result.data.transaction_id && result.data.transaction_id.toString(),
             transaction_date: result.data.transaction_date,
             store_name: result.data.store_name,
             terminal_name: result.data.terminal_name,
             product_name: result.data.product_name,
             destination: result.data.destination,
             rc: result.data.rc,
             sn: result.data.sn,
             message: result.data.message,
             amount: result.data.amount,
             ending_balance: result.data.ending_balance,
         };
         logger.verbose('Forwarding CORE PAY direct-response to partner', {
             xid,
             resultForPartner,
         });
         res.json(resultForPartner);
+        dumper(xid, req, resultForPartner);
     } catch (e) {
         logger.warn('EXCEPTION on forwarding PAY request to CORE', {
             xid,
             errCode: e.code,
             errMessage: e.message,
         });
-        res.json({
+        const resultForPartner = {
             httpgetx_xid: xid,
             command: 'PAY',
             request_id: requestId,
             terminal_name: terminalName,
             product_name: productName,
             destination,
             rc: '68',
             message: 'CORE tidak merespon dengan benar, tidak dapat mengetahui status request anda',
-        });
+        };
+        dumper(xid, req, resultForPartner);
     }
 };
 router.all('/', mainHandler);

lib/partner-listener/routers/topup.js

Diff comments View file @ 732c359

 const MODULE_NAME = 'PARTNER-LISTENER.ROUTER.TOPUP';
 const express = require('express');
 const config = require('komodo-sdk/config');
 const logger = require('komodo-sdk/logger');
 const coreapi = require('komodo-sdk/coreapi');
 // const coreapi = require('../../coreapi');
 const matrix = require('../../matrix');
+const dumper = require('../dumper');
 const router = express.Router();
 module.exports = router;
 function onInvalidParameter(missingParameter, req, res) {
     logger.verbose(`${MODULE_NAME} 1536D577: Undefined ${missingParameter} parameter`, {
         xid: res.locals.xid,
         ip: req.ip,
         terminal_name: req.body.terminal_name || req.query.terminal_name,
         request_id: req.body.request_id || req.query.request_id,
         product_name: req.body.product_name || req.query.product_name,
         destination: req.body.destination || req.query.destination,
     });
     res.end('INVALID REQUEST');
 }
 function pagePrerequisite(req, res, next) {
     if (!req.body) req.body = {};
     if (!req.body.terminal_name && !req.query.terminal_name) {
         onInvalidParameter('terminal_name', req, res);
         return;
     }
     if (!req.body.password && !req.query.password) {
         onInvalidParameter('password', req, res);
         return;
     }
     if (!req.body.request_id && !req.query.request_id) {
         onInvalidParameter('request_id', req, res);
         return;
     }
     if (!req.body.product_name && !req.query.product_name) {
         onInvalidParameter('product_name', req, res);
         return;
     }
     if (!req.body.destination && !req.query.destination) {
         onInvalidParameter('destination', req, res);
         return;
     }
     next();
 }
 async function pageIndex(req, res) {
     const { xid } = res.locals;
     const terminalName = `${req.body.terminal_name || req.query.terminal_name}@${req.ip.replace(/^::ffff:/, '')}`;
     matrix.core.sent += 1;
     const [err, coreResponse] = await coreapi({
         xid,
         path: '/prepaid/buy',
         qs: {
             terminal_name: terminalName,
             password: req.body.password || req.query.password,
             request_id: req.body.request_id || req.query.request_id,
             product_name: req.body.product_name || req.query.product_name,
             destination: req.body.destination || req.query.destination,
             origin: config.name || 'HTTPGETX',
             report_ip: config.listener.core.ip || null,
             report_port: config.listener.core.port,
             reverse_url: req.body.reverse_url || req.query.reverse_url || null,
         },
     });
     if (err || !coreResponse) {
         matrix.core.sent_failed += 1;
         matrix.core.last_error = {
             xid,
             ts: new Date(),
             e: err,
             eCode: err.code,
             eMessage: err.message,
         };
         logger.warn(`${MODULE_NAME} 8DEBE15F: ERROR on /prepaid/buy response`, {
             xid,
             err,
             coreResponseTypeof: typeof coreResponse,
             coreResponse,
         });
         res.end('INVALID CORE RESPONSE');
+        dumper(xid, req, 'INVALID CORE RESPONSE');
         return;
     }
     logger.verbose(`${MODULE_NAME} 2528A9B4: Got CORE response`, {
         xid,
         coreResponse,
     });
     const responseToPartner = {
         httpgetx_xid: xid,
         request_id: coreResponse.request_id,
         transaction_id: coreResponse.transaction_id,
         transaction_date: coreResponse.transaction_date,
         store_name: coreResponse.store_name,
         terminal_name: coreResponse.terminal_name,
         product_name: coreResponse.product_name,
         destination: coreResponse.destination,
         rc: coreResponse.rc,
         sn: coreResponse.sn || undefined,
         amount: Number(coreResponse.amount) || undefined,
         ending_balance: Number(coreResponse.ending_balance) || undefined,
         message: coreResponse.message,
     };
     res.json(responseToPartner);
+    dumper(xid, req, responseToPartner);
 }
 // router.all('/', (req, res) => { res.status(404).end('404: Not implemented yet'); });
 router.get('/', pagePrerequisite, pageIndex);

lib/partner-listener/routers/trx-status.js

Diff comments View file @ 732c359

 const MODULE_NAME = 'PARTNER-LISTENER.ROUTERS.TRX-STATUS';
 const express = require('express');
 const moment = require('moment');
 const logger = require('komodo-sdk/logger');
 const coreapi = require('../../coreapi');
+const dumper = require('../dumper');
 const router = express.Router();
 module.exports = router;
 async function pageIndex(req, res) {
     const { xid } = res.locals;
     if (!req.body) req.body = {};
     if (!req.body.terminal_name && !req.query.terminal_name) {
+        const msg = 'Parameter terminal_name tidak terdefinisi';
         res.json({
             httpgetx_xid: xid,
             error: true,
-            message: 'Parameter terminal_name tidak terdefinisi',
+            message: msg,
         });
+        dumper(xid, req, msg);
         return;
     }
     if (!req.body.password && !req.query.password) {
+        const msg = 'Parameter password tidak terdefinisi';
         res.json({
             httpgetx_xid: xid,
             error: true,
-            message: 'Parameter password tidak terdefinisi',
+            message: msg,
         });
+        dumper(xid, req, msg);
         return;
     }
     if (!req.body.request_id && !req.query.request_id) {
+        const msg = 'Parameter request_id tidak terdefinisi';
         res.json({
             httpgetx_xid: xid,
             error: true,
-            message: 'Parameter request_id tidak terdefinisi',
+            message: msg,
         });
+        dumper(xid, req, msg);
         return;
     }
     const remoteIp = req.ip.replace(/^::ffff:/, '');
     const askerTerminalName = `${req.body.terminal_name || req.query.terminal_name}@${remoteIp}`;
     const coreResponse = await coreapi({
         xid,
         path: '/trx-status/view',
         qs: {
             asker_terminal_name: askerTerminalName,
             asker_terminal_password: req.body.password || req.query.password,
             request_id: req.body.request_id || req.query.request_id,
         },
     });
     if (!coreResponse || !coreResponse.status) {
         const msg = 'Status transaksi tidak dapat diketahui karena suatu kesalahan pada sistem';
         logger.warn(`${MODULE_NAME} 9983DB34: ${msg}`, {
             xid,
             ip: req.ip,
             terminal_name: req.body.terminal_name || req.query.terminal_name,
             request_id: req.body.request_id || req.query.request_id,
         });
-        res.json({
+        const responseBody = {
             httpgetx_xid: xid,
             error: true,
             from_ip: remoteIp,
             terminal_name: req.body.terminal_name || req.query.terminal_name,
             full_terminal_name: askerTerminalName,
             password: req.body.password || req.query.password,
             message: msg,
-        });
+        };
+        res.json(responseBody);
+        dumper(xid, req, responseBody);
         return;
     }
     const trx = coreResponse && coreResponse.result ? {
         id: coreResponse.result.id,
         request_id: coreResponse.result.request_id,
         store_id: coreResponse.result.store_id,
         store_name: coreResponse.result.store_name,
         terminal_id: coreResponse.result.terminal_id,
         terminal_name: coreResponse.result.terminal_name,
         created: moment(coreResponse.result.created).format('YYYY-MM-DD HH:mm:ss'),
         modified: moment(coreResponse.result.modified).format('YYYY-MM-DD HH:mm:ss'),
         product_name: coreResponse.result.product_name,
         destination: coreResponse.result.destination,
         amount: coreResponse.result.amount,
         ending_balance: coreResponse.result.ending_balance,
         rc: coreResponse.result.rc,
         message: coreResponse.result.reply_message,
         sn: coreResponse.result.sn,
     }
         : null;
     const result = {
         httpgetx_xid: xid,
         error: coreResponse.status !== 'OK',
         from_ip: remoteIp,
         terminal_name: req.body.terminal_name || req.query.terminal_name,
         full_terminal_name: askerTerminalName,
         message: coreResponse.message,
         trx_found: !!trx,
         trx,
         // original_trx: coreResponse.result,
     };
     res.json(result);
     logger.info(`${MODULE_NAME} 480C4BB0: Partner request responded`, {
         xid,
         processing_time_in_ms: new Date() - res.locals.x_http_request_ts,
         result,
     });
+    dumper(xid, req, result);
 }
 router.get('/', pageIndex);