Reload97 / sate24-to-datacell

Blame view

partner-datacell.js 4.01 KB
edit raw normal view history
d2933ca99   Adhidarma Hadiwinoto   require http 
1
 
  var http = require('http');
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 
  var url = require('url');
  var math = require('mathjs');
  var xml = require('xml');
  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 
17
 
      console.log(a);
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
18
 
      var b = userid.substr(0, 4) + password;
e7725f72e   Adhidarma Hadiwinoto   debug sig 
19
 
      console.log(b);
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
20
21
22
23
24
25
26
27
 
      
      return xor.encode(a,b);
  }
  
  function createPayload(task) {
      var timestamp = strftime('%H%M%S');
      
      var payload = {
9de9fde1f   Adhidarma Hadiwinoto   curly 
28
29
30
31
32
33
34
35
36
 
          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... 
37
38
39
 
      };
      
      console.log(payload);
c66f76c6e   Adhidarma Hadiwinoto   top level element 
40
41
 
      return "<?xml version=\"1.0\" ?>
  " + xml(payload);
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
42
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
 
  }
  
  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 
69
 
      console.log(payload_xml);
88b4e0d50   Adhidarma Hadiwinoto   gunakan req.end 
70
7e26aeff4   Adhidarma Hadiwinoto   coba plain http req 
71
 
      /*
88b4e0d50   Adhidarma Hadiwinoto   gunakan req.end 
72
 
      request({uri: config.h2h_out.partner, method: 'POST'}, function(error, response, body) {
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
 
          if (error) {
              var error_mesasge = 'Error requesting to partner: ' + error;
              console.log(error_message);
              callbackReport(task['requestId'], '40', error_message);
              return;
          }
          
          if (response.statusCode != 200) {
              var error_mesasge = 'HTTP status code =  ' + response.statusCode;
              console.log(error_message);
              callbackReport(task['requestId'], '40', error_message);
              return;
          }
          
          console.log('Direct response from partner:');
          console.log(body);
          callbackReport(task['requestId'], '68', 'cek');
7e26aeff4   Adhidarma Hadiwinoto   coba plain http req 
91
92
 
      }).end(payload_xml);
      */
274f90989   Adhidarma Hadiwinoto   coba multipart 
93
7e26aeff4   Adhidarma Hadiwinoto   coba plain http req 
94
95
96
97
 
      var postRequest = {
          host: "202.152.62.2",
          path: "/RELOAD97.php",
          port: 7713,
a1b7fb567   Adhidarma Hadiwinoto   coba pakai header 
98
99
100
101
102
 
          method: "POST",
          headers: {
              'Content-Type': 'text/xml',
              'Content-Length': Buffer.byteLength(payload_xml)
          }
7e26aeff4   Adhidarma Hadiwinoto   coba plain http req 
103
104
105
106
 
      };
      
      var buffer = "";
      var req = http.request( postRequest, function( res )    {
a1b7fb567   Adhidarma Hadiwinoto   coba pakai header 
107
 
         console.log('Status code: ' + res.statusCode );
7e26aeff4   Adhidarma Hadiwinoto   coba plain http req 
108
109
110
111
112
113
114
115
116
117
118
119
 
         var buffer = "";
         res.on( "data", function( data ) { buffer = buffer + data; } );
         res.on( "end", function( data ) { console.log( buffer ); } );
  
      });
  
      req.on('error', function(e) {
          console.log('problem with request: ' + e.message);
      });
  
      req.write( payload_xml );
      req.end();
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
120
121
122
 
  }
  
  function createServer() {
e556ce560   Adhidarma Hadiwinoto   refactor nama var... 
123
 
      var httpServer = http.createServer(function(req, res) {
77ce67db6   Adhidarma Hadiwinoto   verbose on req 
124
125
126
 
          console.log('Got request from partner, url: ' + req.url);
          console.log('REQ:');
          console.log(req);
e556ce560   Adhidarma Hadiwinoto   refactor nama var... 
127
 
          res.end('OK');
ff32317e9   Adhidarma Hadiwinoto   prototype partner... 
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
 
      });
      
      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;