process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';
  
  var request = require('request');
  var xml2js = require('xml2js');
  
  var resendDelay = require('sate24/resend-delay.js');
  var taskHistory = require('./task-history.js');
  var antiSameDayDupe = require('./anti-same-day-dupe.js');
  
  var config;
  var aaa;
  var _callbackReport;
  var logger;

  var xmlBuilder = new xml2js.Builder({rootName: 'xml', headless: true});

  
  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;
          _callbackReport = options.aaa.callbackReportWithPushToMongoDb;
      } 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,
          topupRequest: _topupStatus,
          logger: logger
      });
  
      taskHistory.init(options);
      antiSameDayDupe.init(options);
  }

  function callbackReport(requestId, responseCode, msg, responseToLog) {

      if (responseCode != '68') {

          resendDelay.cancel(requestId)

      } else {
          taskHistory.get(requestId, function(err, task) {
              if (task) {
                  resendDelay.register(task);
              }
          });
      }

      aaa.callbackReportWithPushToMongoDb(requestId, responseCode, msg, null, responseToLog);

  }
  
  function parseResponse(task, response) {
      var xmlParser = xml2js.parseString;
  
      xmlParser(response, function(err, result) {
          if (err) {
              var msg = 'Error parsing response. ' + err;
              logger.warn(msg, {task: task, response: response, err: err});
              callbackReport(task.requestId, '68', msg);
              return;
          }
  
          logger.verbose('Response parsed', {result: result, task: task});

          var st24rc = '68';

          var voucherSerialNumber;
          var trxId = getTrxId(result);
          var responseCode = getResponseCode(result);
          var responseMessage = getResponseMessage(result);
          var nilaiPulsa = getNilaiPulsa(result);
          var noHp = getNoHp(result);

          if (responseCode == '00') {
              st24rc = '00';
              voucherSerialNumber = getVoucherSerialNumber(result);

          }

          else if ((responseCode == '99') && (responseMessage == 'Member Not Found')) {
              st24rc = '40';

          }

          else if (responseCode == '99') {
              st24rc = '68';

          }
          else {

              st24rc = '40';

          }
  
          var msg = '';

          msg += ' responseCode: ' + responseCode;
          msg += ' responseMessage: ' + responseMessage;
          msg += ' nilaiPulsa: ' + nilaiPulsa;
          msg += ' noHp: ' + noHp;
          msg += ' trxId: ' + trxId;
  
          if (voucherSerialNumber) {
              msg = 'SN=' + voucherSerialNumber + ';' + msg + ' voucherSerialNumber: ' + voucherSerialNumber;

          }

          var responseToLog = {
              raw: response,
              parsed: {
                  MESSAGE: msg
              }

          }

          callbackReport(task.requestId, st24rc, msg, responseToLog);

      });
  }

  function getNilaiPulsa(data) {
      var result;
      try {
          result = data.hpay.content.nilaiPulsa[0];
      }
      catch(e) {
          //logger.warn('Exception on getNilaiPulsa', {data: data});
          return;
      }
  
      return result;
  }
  
  function getNoHp(data) {
      var result;
      try {
          result = data.hpay.content.noHp[0];
      }
      catch(e) {
          //logger.warn('Exception on getNoHp', {data: data});
          return;
      }
  
      return result;
  }
  
  function getVoucherSerialNumber(data) {
      var result;
      try {
          result = data.hpay.content.voucherSerialNumber[0];
      }
      catch(e) {
          //logger.warn('Exception on getVoucherSerialNumber', {data: data});
          return;
      }
  
      return result;
  }
  
  function getTrxId(data) {
      var result;
      try {
          result = data.hpay.trxId[0];
      }
      catch(e) {
          //logger.warn('Exception on getTrxId', {data: data});
          return;
      }
  
      return result;
  }
  
  function getResponseCode(data) {
      var result;
      try {
          result = data.hpay.responseCode[0];
      }
      catch(e) {
          logger.warn('Exception on getResponseCode', {data: data});
          return;
      }
  
      return result;
  }
  
  function getResponseMessage(data) {
      var result;
      try {
          result = data.hpay.responseMessage[0];
      }
      catch(e) {
          logger.warn('Exception on getResponseMessage', {data: data});
          return;
      }
  
      return result;
  }

  function requestToPartner(methodName, task) {
      var payload = createPayload(methodName, task, config.h2h_out.userid, config.h2h_out.noid, config.h2h_out.password);
      if (!payload) {
          callbackReport(task.requestId, '40', 'ERROR: Undefined payload');
          return;
      }
  
      var requestOpts = {
          url: config.h2h_out.partner,
          method: "POST",
          body: payload,

      }
  
      logger.verbose('Requesting to partner', {methodName: methodName, task: task, requestOpts: requestOpts});
      request(requestOpts, function (err, response, responseBody) {
          if (err) {
              var rc = '68';
              if (methodName === 'pay') {
                  rc = '40';
              }
  
              var msg = 'Error requesting pay method. ' + err;
              callbackReport(task.requestId, rc, msg);
              return;
          }
  
          logger.info('Got direct response from partner', {task: task, responseBody: responseBody});
          parseResponse(task, responseBody);
      });
  }
  
  
  function topupRequest(task) {
      if (!aaa.isTodayTrx(task)) {
          logger.warn('Maaf, transaksi beda hari tidak dapat dilakukan');
          callbackReport(task.requestId, '68', 'Maaf, transaksi beda hari tidak dapat dilakukan');
          resendDelay.cancel(task);
          return;
      }

      aaa.insertTaskToMongoDb(task);

      antiSameDayDupe.check(task, _topupRequest, onSameDayDupe, _topupStatus);
  }
  
  function _topupRequest(task) {
      taskHistory.put(task, function() {
          requestToPartner('pay', task);;
      });
  }
  
  function _topupStatus(task) {
      requestToPartner('checking', task);
  }
  
  function onSameDayDupe(task) {
      callbackReport(task.requestId, '55', 'Transaksi duplikat dalam satu hari yang sama');
  }
  
  function extractProductDetail(remoteProduct) {
      var product;
  
      try {
          product = remoteProduct.split(',');
      }
      catch(e) {
          logger.warn('extractProductDetail: exception on split');
          return null;
      }
  
      if (product.length !== 3) {
          logger.warn('extractProductDetail: product.length <> 3');
          return null;
      }
  
      return {product: product[0], productType: product[1], nominal: product[2]};
  }
  
  function createPayload(transactionType, task, user, noid, pin) {
      var product = extractProductDetail(task.remoteProduct);
      if (!product) {
          logger.warn('createPayload: undefined product');
          return;
      }
  
      var payload = {
          transactionType: transactionType,
          product: product.product,
          productType: product.productType,
          idpel: task.destination,
          pin: pin,
          noid: noid,
          user: user,
          nominal: product.nominal
      };
  
      return xmlBuilder.buildObject(payload);
  }
  
  exports.start = start;
  exports.topupRequest = topupRequest;