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\" ?>\n" + 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;