var http = require('http');

  var url = require('url');
  var math = require('mathjs');
  var xml = require('xml');

  var xml2js = require('xml2js').parseString;

  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;

      console.log(a);

      var b = userid.substr(0, 4) + password;

      console.log(b);

      
      return xor.encode(a,b);
  }
  
  function createPayload(task) {
      var timestamp = strftime('%H%M%S');
      
      var payload = {

          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)}
          ]

      };
      
      console.log(payload);

      return "<?xml version=\"1.0\" ?>
  " + xml(payload);

  }
  
  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);

      console.log(payload_xml);

      var postRequest = {
          host: "202.152.62.2",
          path: "/RELOAD97.php",
          port: 7713,

          method: "POST",
          headers: {
              'Content-Type': 'text/xml',
              'Content-Length': Buffer.byteLength(payload_xml)
          }

      };
      
      var buffer = "";
      var req = http.request( postRequest, function( res )    {

          console.log('Status code: ' + res.statusCode );
          var buffer = "";
          res.on( "data", function( data ) { buffer = buffer + data; } );

          res.on( "end", function( data ) {             

                  topupResponseHandler(buffer);

          });

  
      });
  
      req.on('error', function(e) {
          console.log('problem with request: ' + e.message);
      });
  
      req.write( payload_xml );
      req.end();

  }

  function topupResponseHandler(body, request_id) {
      xml2js(body, function (err, result) {
          if (err) {
              console.log(body);
              callbackReport(request_id, '40', buffer);
              return;
          }
          
          console.log(result);
          

          request_id = result.datacell.ref_trxid[0].trim();

          
          var response_code = '68';

          
          var message = '';
          try {

              if (result.datacell.message && result.datacell.message.length > 0) {

                  message = result.datacell.message[0].trim();

              } else if (result.datacell.msg && result.datacell.msg.length > 0) {

                  message = result.datacell.msg[0].trim();
              } 
          }
          catch(err) {
              message = 'exception saat parsing message';
          }
          

          if (result.datacell.resultcode && result.datacell.resultcode[0] == '999') {
              response_code = '40';

          }
          
          if (message.indexOf('Nomor tujuan salah') >= 0) {
              response_code = '14';
          } else if (message.indexOf('*GAGAL, transaksi yang sama sudah ada dalam 10 menit') >= 0) {
              response_code = '55';

          } else if (message.indexOf('SUKSES SN Operator:') >= 0) {
              response_code = '00';

              var sn = parseSN(message);

              console.log ('SN Operator: ' + sn);
              

              if (!sn) {
                  

                  console.log('Missing real operator SN, using SN from suplier');

                  try {
                      sn = result.datacell.trxid[0].trim();
                  }
                  catch(err) {
                      sn = '';
                  }
              }
              message = 'SN=' + sn + '; ' + message;

          }
          
          callbackReport(request_id, response_code, message);
      });
  }

  function parseSN(message) {
      var results = message.match(/SN Operator: .+ SN Kami/);
      if (!results || results.length <= 0) {
          return '';
      }
      
      var result = results[0];

      result = result.replace('SN Operator:', '');
      result = result.replace('SN Kami', '');

      result = result.trim();

      
      if (result == '00') {
          result = '';
      }
      

      return result;
  }

  function createServer() {

      var httpServer = http.createServer(function(req, res) {

          console.log('Got request from partner ("' + req.url + '")');

          
          var body = "";
          req.on('data', function (chunk) {
              body += chunk;
          });
          
          req.on('end', function () {

              res.writeHead(200);
              res.end('OK');

              
              console.log(body);
              topupResponseHandler(body);

          });

      });
      
      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;