var strftime = require('strftime');
var request = require('request');
var xmlparser = require('xml2js').parseString;
var http = require('http');
var url = require('url');

var config;
var logger;

function start(options) {
    if (options && options.config) {
        config = options.config;
    }

    if (options && options.logger) {
        logger = options.logger;
    }

    createHttpServer();
}

function formatTimestamp(ms) {
    return strftime('%F %T', new Date(ms));
}

function onMessage(sender, message, ts, sendMessage) {
    var opts = {
        url: config.evo_url,
        qs: {
            msg: message,
            msisdn: sender,
            smsc: config.smsc,
            ts: formatTimestamp(ts)
        }
    };

    logger.verbose("Forwarding message to evo", {request_opts: opts});
    request(opts, function(err, response, body) {
        if (err) {
            logger.warn('Error forwarding to evo: ' + err);
            return;
        }

        if (response.statusCode != 200) {
            logger.warn('HTTP Status from evo: ' + response.statusCode, {status: response.statusCode, body: body});
            return;
        }

        logger.verbose('Got response from evo', {body: body});

        xmlparser(body, function(xmlerr, parsedResponse) {
            if (xmlerr) {
                logger.verbose('Evo response not in xml format');
                return;
            }

            return;

            logger.info('Evo response in xml format', {response: parsedResponse});
            if (parsedResponse.response.text) {
                sendMessage(sender, parsedResponse.response.text[0].trim());
            }
        });
    });

    // kirim ping 1 detik setelah pesan agar segera diproses
    if (config.send_ping_to_evo == '1') {
        setTimeout(function() {

            var pingOpts = {
                url: config.evo_url,
                qs: {
                    msg: 'S.' + config.ping_pin,
                    msisdn: config.ping_from + config.msisdn_suffix,
                    smsc: config.smsc,
                    ts: strftime('%F %T')
                }
            };

            logger.verbose('Sending ping message', {opts: pingOpts});

            request(pingOpts, function(err, response, body) {
                if (err) {
                    logger.warn('Error send PING to evo: ' + err);
                    return;
                }
            });
        }, 1000);
    }
}

function onHttpIncomingMessage(request, response) {
    var qs = url.parse(request.url, true).query;
    logger.verbose("onHttpIncomingMessage()", {qs: qs});

    // abaikan balikan ping
    if (qs.to == config.ping_from) {
        return;
    }

    var destination = qs.to.replace(config.msisdn_suffix, '');
    logger.info('Sending message to ' + destination + ': ' + qs.msg);
    sendMessage(destination, qs.msg);
    response.end('OK');
}

function createHttpServer() {
    logger.verbose('createHttpServer()');

    var httpServer = http.createServer(onHttpIncomingMessage);
    httpServer.listen(config.listen_port, function(){
        logger.info("HTTP server listening on " + config.listen_port);
    });
}

exports.start = start;
exports.formatTimestamp = formatTimestamp;
exports.onMessage = onMessage;