var winston = require('winston');
  var soap = require('soap');

  var crypto = require('crypto');
  var strftime = require('strftime');

  var easysoap = require('easysoap');

  
  var max_retry = 10;
  var sleep_before_retry = 5000;
  
  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 topupRequest(task, retry) {
      if (retry === undefined) {
          retry = max_retry;
      }

      var remoteProduct = task.remoteProduct.split(',');

      var args = {
          userName: config.h2h_out.userid,
          productCode: remoteProduct[0] ,
          terminal: 'terminal0',
          transactionType: '50',
          billNumber: createBillNumber(task.destination),
          amount: remoteProduct[1],
          bit61: createBillNumber(task.destination),
          reff: task.requestId,
          timeStamp: strftime('%d-%m-%Y %H:%M:%S', new Date()),
      }
  
      var signature = createSignature(args, config.h2h_out.password);
      args.signature = signature;
  
      topupRequestEasySoap(task, args, retry);
  }
  
  function topupRequestEasySoap(task, args, retry) {
      //partner=http://203.130.243.155/ApiH2H/index.php?wsdl
  
      var params = {
          host: '203.130.243.155',
          path: '/ApiH2H/index.php'
          wsdl: '/ApiH2H/index.php?wsdl'
      }
  
      var soapClient = easysoap.createClient(params);
      soapClient.call({
              method: 'billpayment',
              params: args,
          })
          .then((callResponse) => {
              console.log(callResponse.data); // response data as json
              console.log(callResponse.body); // response body
              console.log(callResponse.header);  //response header
          })
          .catch((err) => { throw new Error(err); });
  
          callbackReport(task.requestId, '68', 'debug');
  
  }
  
  function topupRequestSoap(task, args, retry) {

      soap.createClient(config.h2h_out.partner, function(err, client) {

          logger.info('Requesting to service', {url: config.h2h_out.partner, args: args});

  
          client.apih2h.apih2hPort.billpayment(args, function(err, result) {

              if (err) {
                  logger.warn('Error requesting service', {err: err});
                  callbackReport(task.requestId, '68', 'something wrong');
                  return;
              }

              var responseMessageToST24 = result.outputParameter.resultCode.$value + ' - ' + result.outputParameter.resultDesc.$value;
  
              logger.info('Got result: ' + responseMessageToST24, {result: result});
  
              callbackReport(task.requestId, '68', responseMessageToST24);

          });
      });
  }

  function createSignature(args, password) {
      var passwordHash = crypto.createHash('sha256').update(password).digest().toString('hex');

      var plain =

          args.userName
          + passwordHash
          + args.productCode
          + args.terminal
          + args.transactionType
          + args.billNumber
          + args.amount

          + args.reff
          + args.timeStamp;
  
      var result = crypto.createHash('sha1').update(plain).digest().toString('hex');

      if (logger) {

          logger.verbose('Calculating signature', {plain: plain, result: result, args: args, password: password});

      }

      return result;
  }
  
  function createBillNumber(destination) {
      return ("0000000000000" + destination).slice(-13);

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

  exports.createSignature = createSignature;
  exports.createBillNumber = createBillNumber;