Komodo / komodo-gw-komodo-httpgex

Browse Code »

Commit 442388f0b247f677677dc1213d9a137b6fabd66d

Authored by Adhidarma Hadiwinoto 8 months ago

1 parent c7906ddf24

Exists in master

Debug full endpoint url

Showing 2 changed files with 12 additions and 0 deletions Inline Diff

lib/hit/dump-req-res.js
lib/hit/prepaid-topup.js

lib/hit/dump-req-res.js

Diff comments View file @ 442388f

 const MODULE_NAME = 'DUMP-REQ-RES';
+const querystring = require('querystring');
 const fs = require('fs');
 const path = require('path');
 const fsPromise = require('fs').promises;
 const moment = require('moment');
 const config = require('komodo-sdk/config');
 const logger = require('tektrans-logger');
 const baseDumpDir = 'dump';
 const requestDumpDir = path.join(baseDumpDir, 'request');
 if (!fs.existsSync(baseDumpDir)) {
     logger.verbose(`${MODULE_NAME} 51105314: Creating base dump dir`);
     fs.mkdirSync(baseDumpDir);
 }
 if (!fs.existsSync(requestDumpDir)) {
     logger.verbose(`${MODULE_NAME} 8A52891B: Creating request dump dir`);
     fs.mkdirSync(requestDumpDir);
 }
 module.exports = async (
     xid, task, httpMethod, endpointUrl, params, responseBody, responseStatus, isAdvice,
 ) => {
     if (
         !config
         || !config.partner
         || !config.partner.dump_request
     ) {
         return;
     }
     const data = `--------
 XID: ${xid}
 PID: ${process.pid}
 DATE: ${moment().format('YYYY-MM-DD HH:mm:ss.SSS')}
 TASK:
 ${JSON.stringify(task, null, 2)}
 IS-ADVICE: ${!!isAdvice}
 HTTP-METHOD: ${httpMethod}
 URL: ${endpointUrl}
 PARAMS:
 ${
     params && (
         (typeof params === 'string' && params)
         || JSON.stringify(params, null, 2)
     )
 }
+${httpMethod === 'GET' ? '' : `FULL URL: ${endpointUrl}?${querystring.stringify(params)}`}
 RESPONSE-STATUS: ${responseStatus}
 RESPONSE-BODY:
 ${
     responseBody && (
         (typeof responseBody === 'string' && responseBody)
         || JSON.stringify(responseBody, null, 2)
     )
 }
 `;
     const dumpDir = path.join(
         requestDumpDir,
         moment().format('YYYY-MM-DD'),
     );
     try {
         await fsPromise.stat(dumpDir);
     } catch {
         await fsPromise.mkdir(dumpDir, { recursive: true });
     }
     await fsPromise.appendFile(
         path.join(
             dumpDir,
             `trx_${task.trx_id}`,
         ),
         data,
     );
     await fsPromise.writeFile(
         path.join(requestDumpDir, 'last'),
         data,
     );
 };

lib/hit/prepaid-topup.js

Diff comments View file @ 442388f

 const MODULE_NAME = 'HIT.PREPAID-TOPUP';
 const axios = require('axios');
 const urljoin = require('url-join');
+const querystring = require('querystring');
 const config = require('komodo-sdk/config');
 const logger = require('tektrans-logger');
 const report = require('../report/prepaid');
 const translateRc = require('../translate-rc');
 const composeCallbackUrl = require('./compose-callback-url');
 const dumpReqRes = require('./dump-req-res');
 const axiosErrorIsSafe = require('./axios-error-is-safe');
 module.exports = async (xid, task) => {
     logger.verbose(`${MODULE_NAME} 2272F01F: Processing task`, {
         xid,
         task,
     });
     const params = {
         request_id: task.trx_id,
         terminal_name: config.partner.terminal_name,
         password: config.partner.password,
         destination: task.destination,
         product_name: task.remote_product,
         reverse_url: composeCallbackUrl(xid, task, false),
     };
     const endpointUrl = urljoin(config.partner.url, '/topup');
+    const fullEndpointUrl = urljoin(
+        endpointUrl,
+        [
+            '?',
+            querystring.stringify(params),
+        ],
+    );
     let lastResponse = null;
     try {
         logger.verbose(`${MODULE_NAME} 4AAD4F99: Going to HIT prepaid endpoint`, {
             xid,
             endpointUrl,
             params,
+            fullEndpointUrl,
         });
         report(xid, {
             trx_id: task.trx_id,
             rc: '68',
             message: {
                 xid,
                 msg: 'Sending request to partner',
                 endpointUrl,
             },
         });
         const response = await axios.get(endpointUrl, {
             headers: {
                 'User-Agent': 'KOMODO-GW-HTTPGETX',
             },
             timeout: config.partner.hit_timeout_ms || 60 * 1000,
             params,
         });
         if (!response) {
             const e = new Error(`${MODULE_NAME} 8CF4E04D: Empty response`);
             e.rc = '68';
             e.response = response;
             throw e;
         }
         if (!response.data) {
             const e = new Error(`${MODULE_NAME} E72B5A53: Empty response data`);
             e.rc = '68';
             e.response = response;
             throw e;
         }
         if (typeof response.data !== 'object') {
             const e = new Error(`${MODULE_NAME} 507680AB: Response data is not a JSON`);
             e.rc = '68';
             e.response = response;
             throw e;
         }
         lastResponse = response;
         logger.verbose(`${MODULE_NAME} E51AFBBA: Got a direct response`, {
             xid,
             responseBody: response.data,
         });
         report(xid, {
             trx_id: task.trx_id,
             rc: response.data.rc ? translateRc[response.data.rc] || response.data.rc
                 : '68',
             sn: response.data.sn || null,
             amount: Number(response.data.amount) || undefined,
             balance: Number(response.data.ending_balance) || undefined,
             message: {
                 xid,
                 'DIRECT-RESPONSE': response.data,
             },
         });
     } catch (e) {
         const rc = e.rc
             || (axiosErrorIsSafe(e) && '91')
             || '68';
         logger.warn(`${MODULE_NAME} 8E8E49F5: Exception`, {
             xid,
             eCode: e.code,
             eMessage: e.message,
             eRc: e.rc,
             rc,
             responseHttpStatus: e.response && e.response.status,
             responseBody: e.response && e.response.data,
         });
         lastResponse = e.response;
         report(xid, {
             trx_id: task.trx_id,
             rc,
             message: {
                 xid,
                 'KOMODO-GW-ERROR': {
                     eCode: e.code,
                     eMessage: e.message,
                     responseHttpStatus: e.response && e.response.status,
                     responseBody: e.response && e.response.data,
                 },
             },
         });
     } finally {
         dumpReqRes(
             xid,
             task,
             'GET',
             endpointUrl,
             params,
             lastResponse && lastResponse.data,
             lastResponse && lastResponse.status,
             lastResponse,
             false,
         );
     }
 };