Reload97 / sate24-to-komodo

Browse Code »

Commit 1f196f6de5e79a4061a4fa549c55710c9d9ad389

Authored by Adhidarma Hadiwinoto 8 years ago

1 parent f673862b49

Exists in master

reverse result

Showing 1 changed file with 44 additions and 15 deletions Inline Diff

partner-komodo.js

partner-komodo.js

Diff comments View file @ 1f196f6

 "use strict";
 process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0";
+const url = require('url');
 const request = require('request');
 const resendDelay = require('sate24/resend-delay')
 var config;
 var aaa;
 var logger;
 let komodoRc = {
     '03': '40',
     '13': '13',
     '14': '14',
     '30': '40',
     '68': '68',
     '55': '55',
     '91': '91',
     '92': '40',
     '96': '68'
 }
 function start(options) {
     if (!options) {
         console.log('Undefined options, terminating....');
         process.exit(1);
     }
     if (options.config) {
         config = options.config;
     } else {
         console.log('Undefined options.config, terminating....')
         process.exit(1);
     }
     if (options.aaa) {
         aaa = options.aaa;
     } else {
         console.log('Undefined options.aaa, terminating....')
         process.exit(1);
     }
     if (options && options.logger) {
         logger = options.logger;
     } else {
         console.log('Undefined options.logger, terminating....')
         process.exit(1);
     }
     resendDelay.init({config: config, logger: logger, topupRequest: topupAdvice});
 }
 function callbackReport(requestId, rc, message, options) {
     aaa.callbackReportWithPushToMongoDb(requestId, rc, message);
     if (!options.task) {
         return;
     }
     if (rc == '68') {
         resendDelay.register(options.task);
     } else {
         resendDelay.cancel(options.task)
     }
 }
 function topupRequest(task, pendingOnConnectError) {
     aaa.insertTaskToMongoDb(task);
     const requestOptions = {
         url: config.h2h_out.partner,
         qs: {
             terminal_name: config.h2h_out.username,
             password: config.h2h_out.password,
             product_name: task.remoteProduct,
             destination: task.destination,
             request_id: task.requestId
         }
     }
     request(requestOptions, function(err, response, body) {
         if (err) {
             logger.warn('Error requesting to partner', {err: err});
             let rc = '68';
             if (err.syscall == 'connect' && !pendingOnConnectError) {
                 rc = '91';
             }
             callbackReport(task.requestId, rc, 'Error requesting to partner: ' + err);
             return;
         }
         if (response.statusCode != 200) {
             let rc = '68';
             callbackReport(task.requestId, rc, 'Partner returning HTTP status code ' + response.statusCode + ', not 200');
             return;
         }
         let result = parsePartnerMessage(body);
-        if (!result) {
+        processPartnerResponse(result);
+    })
+}
+function topupAdvice(task) {
+    topupRequest(task, true);
+}
+function processPartnerResponse(resObj, task) {
+    if (!resObj) {
+        if (task.requestId) {
             callbackReport(task.requestId, '40', 'Error parsing response from partner. Partner response: ' + body);
-            return;
+        }
+        else {
+            logger.warn('UNDEFINED REQUEST ID');
         }
-        let st24Rc = '68';
+        return;
+    }
-        if (komodoRc[result.rc]) {
+    let st24Rc = '68';
-            st24Rc = komodoRc[result.rc];
-        }
-        let st24Message = result.message;
+    if (komodoRc[resObj.rc]) {
-        if (result.sn) {
+        st24Rc = komodoRc[resObj.rc];
-            st24Message = 'SN=' + result.sn + '; ' + st24Message;
+    }
-        }
-        callbackReport(task.requestId, st24Rc, st24Message);
+    let st24Message = resObj.message;
-    })
+    if (resObj.sn) {
-}
+        st24Message = 'SN=' + resObj.sn + '; ' + st24Message;
+    }
-function topupAdvice(task) {
+    callbackReport(resObj.request_id, st24Rc, st24Message);
-    topupRequest(task, true);
 }
 function parsePartnerMessage(partner_message) {
     let result;
     try {
         result = JSON.parse(partner_message);
     }
     catch(e) {
         result = null;
     }
     return result;
 }
+function createReverseHttpServer() {
+    let listenPort = config.h2h_out.listen_port;
+    http.createServer(onReverseReport).listen(listenPort, function() {
+        logger.info('HTTP Reverse/Report server listen on port ' + listenPort);
+    });
+}
+function onReverseReport(request, response) {
+    response.end('OK');
+    const qs = url.parse(request.url, true).query;
+    logger.verbose('Got reverse report from partner', {qs: qs});
+    processPartnerResponse(qs);
+}