Reload97 / sate24-to-datacell

Blame view

partner-datacell.js 3.93 KB
edit raw normal view history
d2933ca99   Adhidarma Hadiwinoto   require http 
1
 
  var http = require('http');
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
2
3
4
 
  var url = require('url');
  var math = require('mathjs');
  var xml = require('xml');
f53f2def0   Adhidarma Hadiwinoto   mulai tangani dir... 
5
 
  var xml2js = require('xml2js').parseString;
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
6
7
8
9
10
11
12
13
14
15
16
17
 
  var strftime = require('strftime');
  var xor = require('base64-xor');
  var request = require('request');
  
  var config;
  var callbackReport;
  
  var max_retry = 2;
  var sleep_before_retry = 2000;
  
  function calculateSignature(userid, password, msisdn, timestamp) {
      var a = msisdn.substr(msisdn.length - 4) + timestamp;
e7725f72e   Adhidarma Hadiwinoto   debug sig 
18
 
      console.log(a);
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
19
 
      var b = userid.substr(0, 4) + password;
e7725f72e   Adhidarma Hadiwinoto   debug sig 
20
 
      console.log(b);
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
21
22
23
24
25
26
27
28
 
      
      return xor.encode(a,b);
  }
  
  function createPayload(task) {
      var timestamp = strftime('%H%M%S');
      
      var payload = {
9de9fde1f   Adhidarma Hadiwinoto   curly 
29
30
31
32
33
34
35
36
37
 
          datacell: [
              { perintah: 'charge'},
              {oprcode: task['remoteProduct']},
              {userid: config.h2h_out.userid},
              {time: timestamp},
              {msisdn: task['destination']},
              {ref_trxid: task['requestId']},
              {sgn: calculateSignature(config.h2h_out.userid, config.h2h_out.password, task['destination'], timestamp)}
          ]
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
38
39
40
 
      };
      
      console.log(payload);
c66f76c6e   Adhidarma Hadiwinoto   top level element 
41
42
 
      return "<?xml version=\"1.0\" ?>
  " + xml(payload);
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
 
  }
  
  function topupRequest(task, retry) {
      if (config.globals.requests_count == undefined) {
          config.globals.requests_count = 1;
      } else {
          config.globals.requests_count++;
      }
      
      if (config.globals.active_requests_count == undefined) {
          config.globals.active_requests_count = 1;
      } else {
          config.globals.active_requests_count++;
      }
      
      if (config.globals.max_active_requests_count == undefined) {
          config.globals.max_active_requests_count = config.globals.active_requests_count;
      } else {
          config.globals.max_active_requests_count = math.max(config.globals.max_active_requests_count, config.globals.active_requests_count);
      }
      
      
      if (retry === undefined) {
          retry = max_retry;
      }
      
      var payload_xml = createPayload(task);
40eead5f7   Adhidarma Hadiwinoto   debug payload_xml 
70
 
      console.log(payload_xml);
88b4e0d50   Adhidarma Hadiwinoto   gunakan req.end 
71
7e26aeff4   Adhidarma Hadiwinoto   coba plain http req 
72
73
74
75
 
      var postRequest = {
          host: "202.152.62.2",
          path: "/RELOAD97.php",
          port: 7713,
a1b7fb567   Adhidarma Hadiwinoto   coba pakai header 
76
77
78
79
80
 
          method: "POST",
          headers: {
              'Content-Type': 'text/xml',
              'Content-Length': Buffer.byteLength(payload_xml)
          }
7e26aeff4   Adhidarma Hadiwinoto   coba plain http req 
81
82
83
84
 
      };
      
      var buffer = "";
      var req = http.request( postRequest, function( res )    {
f53f2def0   Adhidarma Hadiwinoto   mulai tangani dir... 
85
86
87
88
89
90
91
92
93
94
95
96
97
 
          console.log('Status code: ' + res.statusCode );
          var buffer = "";
          res.on( "data", function( data ) { buffer = buffer + data; } );
          res.on( "end", function( data ) { 
              
              xml2js(buffer, function (err, result) {
                  if (err) {
                      console.log(buffer);
                      callbackReport(task['requestId'], '40', buffer);
                      return;
                  }
                  
                  console.log(result);
93f2552cc   Adhidarma Hadiwinoto   error code 
98
99
100
101
102
103
104
105
 
                  
                  var response_code = '68';
                  var message = result.datacell.resultcode.message[0].trim();
                  if (result.datacell.resultcode[0] == '999') {
                      response_code = '40';
                  }
                  
                  callbackReport(task['requestId'], response_code, message);
76325823c   Adhidarma Hadiwinoto   kekurangan kurung... 
106
 
              });
f53f2def0   Adhidarma Hadiwinoto   mulai tangani dir... 
107
108
 
              
          });
7e26aeff4   Adhidarma Hadiwinoto   coba plain http req 
109
110
111
112
113
114
115
116
117
 
  
      });
  
      req.on('error', function(e) {
          console.log('problem with request: ' + e.message);
      });
  
      req.write( payload_xml );
      req.end();
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
118
119
120
 
  }
  
  function createServer() {
e556ce560   Adhidarma Hadiwinoto   refactor nama var... 
121
 
      var httpServer = http.createServer(function(req, res) {
77ce67db6   Adhidarma Hadiwinoto   verbose on req 
122
123
124
 
          console.log('Got request from partner, url: ' + req.url);
          console.log('REQ:');
          console.log(req);
e556ce560   Adhidarma Hadiwinoto   refactor nama var... 
125
 
          res.end('OK');
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
 
      });
      
      httpServer.listen(config.h2h_out.listen_port, function() {
          console.log('HTTP Reverse/Report server listen on port ' + config.h2h_out.listen_port);
      });
  }
  
  
  function start(_config, _callbackReport) {
      config = _config;
      callbackReport = _callbackReport
  
      createServer();
  }
  
  exports.start = start;
  exports.topupRequest = topupRequest;