Komodo / komodo-gw-st24b

Browse Code »

Commit 8ea2305a03ccb6ed8dbc25b68a3ccb9deeb0c063

Authored by Adhidarma Hadiwinoto 4 years ago

1 parent 4e75594977

Exists in master

Perbaikan dump request

Showing 2 changed files with 2 additions and 1 deletions Inline Diff

lib/dumper/request.js
lib/hit.js

lib/dumper/request.js

Diff comments View file @ 8ea2305

 const MODULE_NAME = 'DUMPER.REQUEST';
 const fs = require('fs');
 const fsPromise = fs.promises;
 const moment = require('moment');
 const config = require('komodo-sdk/config');
 const logger = require('komodo-sdk/logger');
 const path = require('path');
 const mkdirIfNotExists = require('../mkdir-if-not-exists');
 require('./init');
 const vars = require('./vars');
 const { baseDumpDir } = vars;
 const baseRequestDumpDir = path.join(baseDumpDir, 'request');
 if (!fs.existsSync(baseRequestDumpDir)) {
     fs.mkdirSync(baseRequestDumpDir, { recursive: true });
 }
 const doNotDump = !config.partner.dump_request;
 module.exports = async (
     xid, task, endpointUrl, payload, axiosConfig, axiosResponse, exceptionOnHit,
 ) => {
     if (doNotDump) return;
     const {
         trx_id: trxId,
     } = task;
     logger.verbose(`${MODULE_NAME} 826334AF: Dumping`, {
         xid,
         trxId,
     });
     const dumpDir = path.join(
         baseRequestDumpDir,
         moment().format('YYYY-MM-DD'),
     );
     await mkdirIfNotExists(xid, dumpDir);
     const dumpFileName = path.join(
         dumpDir,
         `trx_${trxId}_${xid}.txt`,
     );
     const data = `-------- BEGIN OF REQUEST DUMP --------
 ${moment().format('YYYY-MM-DD HH:mm:ss')}
 XID: ${xid}
 TRX ID: ${trxId}
 TRX DATE: ${task.created}
 DESTINATION: ${task.destination}
 LOCAL PRODUCT: ${task.product}
 REMOTE PRODUCT: ${task.remote_product}
 HTTP METHOD: POST
 ENDPOINT URL: ${endpointUrl}
 HIT CONFIG: ${(axiosConfig && JSON.stringify(axiosConfig, null, 2)) || '-'}
 PAYLOAD:
 ${payload}
 RESPONSE HEADERS:
 ${axiosResponse && axiosResponse.headers && JSON.stringify(axiosResponse.headers)}
 HTTP STATUS: ${axiosResponse && axiosResponse.status} ${(axiosResponse && axiosResponse.statusText) || ''}
 HIT EXCEPTION: ${
     exceptionOnHit
         ? JSON.stringify({ code: exceptionOnHit.code, message: exceptionOnHit.message }, null, 2)
         : '-'
 }
+TYPE OF RESPONSE BODY: ${typeof axiosResponse.data}
 RESPONSE BODY:
 ${
     (
         axiosResponse && axiosResponse.data
         && (
             (typeof axiosResponse.data === 'string' && axiosResponse.data)
             || JSON.stringify(axiosResponse.data, null, 2)
         )
     ) || ''
 }
 -------- END OF REQUEST DUMP --------
 `;
     try {
         logger.verbose(`${MODULE_NAME} E915E0D8: Writing file`, {
             xid,
             dumpFileName,
         });
         await fsPromise.writeFile(dumpFileName, data);
         logger.verbose(`${MODULE_NAME} 7275A26C: Writing last dump file`, { xid });
         await fsPromise.writeFile(
             path.join(baseDumpDir, 'last-request.txt'),
             data,
         );
     } catch (e) {
         logger.warn(`${MODULE_NAME} 29212E93: Exception on writing dump file`, {
             xid,
             eCode: e.code,
             eMessage: e.message,
         });
     }
 };

lib/hit.js

Diff comments View file @ 8ea2305

 const MODULE_NAME = 'HIT';
 const axios = require('axios').default;
 const config = require('komodo-sdk/config');
 const logger = require('komodo-sdk/logger');
 const composePayload = require('./generic-xmlrpc/compose-payload');
 const report = require('./report');
 const dumper = require('./dumper/request');
 const axiosSafeFailed = require('./axios-safe-failed');
 const parseResult = require('./parse-result');
 const defaultAxiosConfig = {
     headers: {
         'User-Agent': 'Komodo-GW-ST24B',
         'Content-Type': 'text/xml',
     },
     timeout: config.partner.hit_timeout = 2 * 60 * 120,
 };
 module.exports = async (xid, task) => {
     const methodName = config.partner.topuprequest_method_name || 'topUpRequest';
     logger.verbose(`${MODULE_NAME} E4F52474: Processing task`, {
         xid, methodName, task,
     });
     const params = {
         MSISDN: config.partner.msisdn,
         REQUESTID: task.trx_id,
         PIN: config.partner.pin,
         NOHP: task.destination,
         NOM: task.remote_product,
     };
     const payload = composePayload(methodName, params);
     const axiosConfig = JSON.parse(JSON.stringify(defaultAxiosConfig));
     axiosConfig.headers['Content-length'] = payload.length;
     let response;
     let eToDump;
     const endpointUrl = config.partner.url;
     try {
         logger.verbose(`${MODULE_NAME} 47FDCA85: Going to HIT partner`, {
             xid,
             endpointUrl,
             methodName,
             params,
         });
         response = await axios.post(endpointUrl, params, axiosConfig);
         if (!response) {
             const e = new Error(`${MODULE_NAME} BAACC918: Empty response`);
             e.rc = '90';
             logger.warn(e.message, { xid });
             throw e;
         }
         if (!response.data) {
             const e = new Error(`${MODULE_NAME} C816D842: Empty response data`);
             e.rc = '90';
             logger.warn(e.message, { xid });
             throw e;
         }
         if (typeof response.data !== 'string') {
             const e = new Error(`${MODULE_NAME} 32A75E8E: Response data is not a string`);
             e.rc = '90';
             logger.warn(e.message, { xid });
             throw e;
         }
         logger.verbose(`${MODULE_NAME} D0CBD82A: Parsing response`, { xid });
         parseResult(xid, task.trx_id, response.data, false);
     } catch (e) {
         eToDump = e;
         logger.warn(`${MODULE_NAME} 2653B932: Got an exception`, {
             xid,
             eCode: e.code,
             eMessage: e.message,
             eRc: e.rc,
             responseStatus: e.response && e.response.status,
             responseStatusText: e.response && e.response.statusText,
             responseContentType: e.response && e.response.headers && e.response.headers['content-type'],
             responseBody: e.response && e.response.data,
         });
         if (e.response) response = e.response;
         const rc = e.rc
             || (axiosSafeFailed(e) || '91')
             || '68';
         report(xid, {
             trx_id: task.trx_id,
             rc,
             message: {
                 xid,
                 'GW-ERROR': {
                     code: e.code,
                     message: e.message,
                     endpointUrl,
                     httpStatus: (e.response && e.response.status) || null,
                     httpStatusText: (e.response && e.response.statusText) || null,
                     responseBody: e.response && e.response.data,
                 },
             },
         });
     } finally {
         dumper(
             xid,
             task,
             endpointUrl,
             payload,
-            axiosConfig,
             response.config || axiosConfig,
+            response,
             eToDump,
         );
     }
 };