var winston = require('winston');
var soap = require('soap');
var crypto = require('crypto');
var strftime = require('strftime');
var fs = require("fs");
var whiskers = require("whiskers");
var http = require("http");
var url = require("url");

process.chdir(__dirname);
var soapTemplate = fs.readFileSync("message.xml");

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 params = {
        userName: config.h2h_out.userid,
        productCode: remoteProduct[0] ,
        terminal: 'H2HIPN10',
        transactionType: '50',
        billNumber: createBillNumber(task.destination),
        amount: remoteProduct[1],
        bit61: createBillNumber(task.destination),
        reff: task.requestId,
        timeStamp: strftime('%Y-%m-%d %H:%M:%S', new Date())
    }

    var signature = createSignature(params, config.h2h_out.password);
    params.signature = signature;

    //topupRequestSoapDIY(task, params, retry);
    topupRequestSoap(task, params, retry);
}

function topupRequestSoap(task, params, retry) {

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

        var _params = {
            userName: params.userName,
            signature: params.signature,
            productCode: params.productCode,
            terminal: params.terminal,
            transactionType: params.transactionType,
            billNumber: params.billNumber,
            amount: params.amount,
            bit61: params.bit61,
            reff: params.reff,
            timeStamp: params.timeStamp
        }

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

        soapClient.apih2h.apih2hPort.billpayment({ inputCheck: _params }, function(err, result) {
            logger.verbose(
                'Got response',
                {
                    lastEndpoint: soapClient.lastEndpoint,
                    lastRequest: soapClient.lastRequest,
                    lastMessage: soapClient.lastMessage,
                    lastResponse: soapClient.lastResponse,
                }
            );

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

            topupResponseHandler(task, result);
        });
    });
}

function topupResponseHandler(task, response) {
    var st24rc = '68';
    var st24message = response.outputParameter.resultDesc.$value;

    if ( response.outputParameter.resultCode.$value == '001' ) {
        // product disabled
        st24rc = '13';
    }
    else if ( response.outputParameter.resultCode.$value == '002' ) {
        // prodcode disable
        st24rc = '13';
    }
    else if ( response.outputParameter.resultCode.$value == '003' ) {
        // duplicate reff
        st24rc = '55';
    }
    else if ( response.outputParameter.resultCode.$value == '004' ) {
        // not enough balance
        st24rc = '40';
    }
    else if ( response.outputParameter.resultCode.$value == '005' ) {
        // username blocked
        st24rc = '40';
    }
    else if ( response.outputParameter.resultCode.$value == '006' ) {
        // not exists username
        st24rc = '40';
    }
    else if ( response.outputParameter.resultCode.$value == '011' ) {
        // invalid request
        st24rc = '40'
    }
    else if ( response.outputParameter.resultCode.$value == '012' ) {
        // no route to host
        st24rc = '40'
    }
    else if ( response.outputParameter.resultCode.$value == '013' ) {
        // invalid signature
        st24rc = '40'
    }
    else if ( response.outputParameter.bit39.$value == '06' ) {
        st24rc = '40';
        st24message = 'Error Transaksi ditolak karena terjadi error di H2H dengan response code diluar daftar ini. Silahkan hubungi H2H';
    }
    else if ( response.outputParameter.bit39.$value == '12' ) {
        st24rc = '40';
        st24message = 'Invalid Transaction Transaksi ditolak karena flow transaksi tidak valid';
    }
    else if ( response.outputParameter.bit39.$value == '13' ) {
        st24rc = '13';
        st24message = 'Invalid voucher nominal';
    }
    else if ( response.outputParameter.bit39.$value == '14' ) {
        st24rc = '14';
        st24message = 'MSISDN tidak ditemukan';
    }
    else if ( response.outputParameter.bit39.$value == '30' ) {
        st24rc = '40';
        st24message = 'Format Error';
    }
    else if ( response.outputParameter.bit39.$value == '31' ) {
        st24rc = '40';
        st24message = 'Kode bank tidak terdaftar';
    }
    else if ( response.outputParameter.bit39.$value == '63' ) {
        st24rc = '40';
        st24message = 'Reversal denied';
    }
    else if ( response.outputParameter.bit39.$value == '68' ) {
        st24rc = '68';
        st24message = 'Transaksi sedang dalam proses';
    }
    else if ( response.outputParameter.bit39.$value == '69' ) {
        st24rc = '68';
        st24message = 'Respon Ok lebih dari 24 detik';
    }
    else if ( response.outputParameter.bit39.$value == '70' ) {
        st24rc = '13';
        st24message = 'Voucher out of stock';
    }
    else if ( response.outputParameter.bit39.$value == '79' ) {
        st24rc = '14';
        st24message = 'Phone number is blocked by Telkomsel';
    }
    else if ( response.outputParameter.bit39.$value == '81' ) {
        st24rc = '14';
        st24message = 'Phone number is expired';
    }
    else if ( response.outputParameter.bit39.$value == '89' ) {
        st24rc = '40';
        st24message = 'Link to billing provider is down';
    }
    else if ( response.outputParameter.bit39.$value == '91' ) {
        st24rc = '40';
        st24message = 'Database problem';
    }
    else if ( response.outputParameter.bit39.$value == '92' ) {
        st24rc = '40';
        st24message = 'Unable to route transaction';
    }
    else if ( response.outputParameter.bit39.$value == '94' ) {
        st24rc = '40';
        st24message = 'Duplicate reversal request';
    }

    var message =
        response.outputParameter.resultCode.$value
        + " " + response.outputParameter.resultDesc.$value
        + "; " + response.outputParameter.bit39.$value
        ;

    if (response.outputParameter.resultDesc.$value != st24message) {
        var message = message + " " + st24message;
    }

    logger.info('Got result: ' + message, {result: result});
    callbackReport(task.requestId, st24rc, st24message);
}

function topupRequestRetry(task) {
    task.retry--;

    if (task.retry > 0) {
        logger.info('Retrying in ' +  sleepBeforeRetry + 's');
        setTimeout(topupRequest, sleepBeforeRetry * 1000, task, task.retry);
    }
    else {
        logger.warn('Maximum retry for pending status exceeded', {task: task});
    }
}


function createSignature(params, password) {
    var passwordHash = crypto.createHash('sha256').update(password).digest().toString('hex');
    var plain =
        params.userName
        + passwordHash
        + params.productCode
        + params.terminal
        + params.transactionType
        + params.billNumber
        + params.amount
        + params.reff
        + params.timeStamp;

    return crypto.createHash('sha1').update(plain).digest().toString('hex');
}

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

exports.start = start;
exports.topupRequest = topupRequest;
exports.createSignature = createSignature;
exports.createBillNumber = createBillNumber;