var winston = require('winston');
  var crypto = require('crypto');
  var xml = require('xml');
  var url = require('url');

  var http = require('http');

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

  
  var config;
  var callbackReport;
  var aaa;
  var logger;
  var options;
  
  function start(_config, _callbackReport, options) {
      config = _config;
      callbackReport = _callbackReport
      
      if (options && options.aaa) {
              aaa = options.aaa;
      }
      
      if (options && options.logger) {
          logger = options.logger;
      } else {
          logger = new winston.Logger({
              transports: [
                new (winston.transports.Console)()
              ]
          });
      }
  }
  
  function calculateSignature(params) {

      var passwordHash = crypto.createHash('sha1').update(params.password).digest().toString('hex');
      var plain = params.trxtype + params.prdcode + params.value + params.msisdn + params.trxid + params.uid + passwordHash;

      var signature = crypto.createHash('sha256').update(plain).digest().toString('hex');
      
      try {
          logger.verbose('Signature calculated', {plain: plain, signature: signature});
      }
      catch(err) {}
      
      return signature;

  }
  
  function createXmlPayload(params) {

      var payload = "<?xml version=\"1.0\" ?>
  " + xml({

          ciwaru: [
              {trxtype: params.trxtype},
              {prdcode: params.prdcode},
              {value: params.value},
              {msisdn: params.msisdn},
              {trxid: params.trxid},
              {uid: params.uid},
              {hash: calculateSignature(params)}
          ]
      });

      
      logger.verbose(payload);

      return payload;

  }
  
  function getSNFromMessage(message) {

      try {

          var sn_match = message.match(/SN: (\w+)/);

          return sn_match[1];
      }
      catch(err) {
          return '';
      }

  }

  function hasSuccessKeywords(message) {
      var keywords = ['SUKSES', 'Finish'];
      
      var count = keywords.length;
      for (var i=0; i < count; i++) {
          if (message.indexOf(keywords[i]) >= 0) {
              return true;
          }
      }
      return false;
  }

  function topupResponseHandler(body) {
      logger.info('Got reply from partner', {body: body});
      xml2js(body, function(err, result) {
          if (err) {
              logger.warn('XML parsing error', {err: err});
          }
          logger.info('XML message from partner', {result: result});

          var rc = '40';
          var message = result.ciwaru.msg[0];

          var trxid = result.ciwaru.trxid[0];

          if (hasSuccessKeywords(message)) {

              var sn = getSNFromMessage(result.ciwaru.msg);
              message = 'SN=' + sn + '; ' + message;
              rc = '00';
          }
          

          callbackReport(trxid, rc, message);

      });
  }
  
  function topupRequest(task, retry) {
      var remoteProduct = task.remoteProduct.split(',');
      
      var params = {
          trxtype: '01',
          prdcode: remoteProduct[0],
          value: remoteProduct[1],
          msisdn: task.destination,
          trxid: task.requestId,
          uid: config.h2h_out.userid,

          password: config.h2h_out.password,

      };
      
      var postBody = createXmlPayload(params);
      
      var partnerUrl = url.parse(config.h2h_out.partner);
      var postRequest = {
          host: partnerUrl.hostname,
          path: partnerUrl.path,
          port: partnerUrl.port,
          method: "POST",
          headers: {
              'Content-Type': 'text/xml',
              'Content-Length': Buffer.byteLength(postBody)
          }
      };
      
      logger.info('POST to partner', {postRequest: postRequest});
      var req = http.request(postRequest, function( res ) {
          
          logger.info('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) {
          logger.warn('problem with request: ' + e.message);
          callbackReport(task['requestId'], '40', e.message);
      });
  
      req.write(postBody);
      req.end();
  }

  exports.start = start;
  exports.topupRequest = topupRequest;

  exports.calculateSignature = calculateSignature;
  exports.createXmlPayload = createXmlPayload;
  exports.getSNFromMessage = getSNFromMessage;