/**
 * HTTP Response Server
 *
 * Untuk menangkap respon dari core
 */


const module_name = require('path').basename(__filename);

const http = require('http');
const url = require('url');

const config = require('../config');
const logger = require('tektrans-logger');

let transport;

function onRequest(request, response) {
    const method_name = 'onRequest';

    response.end('OK');

    const qs = url.parse(request.url, true).query;

    logger.verbose('Got reverse report from CORE', {module_name: module_name, method_name: method_name, url: request.url, qs: qs});

    if (!transport || !transport.send) {
        logger.warn('UNDEFINED TRANSPORT, not forwarding message from CORE');
        return;
    }

    if (!qs.terminal_name || !qs.message) {
        return;
    }

    transport.send(qs.terminal_name, qs.message, qs);
}

function setTransport(newTransport) {
    transport = newTransport;
}

function create() {
    let listenPort = config.listen_port;

    http.createServer(onRequest).listen(listenPort, function() {
        logger.info('HTTP Reverse/Report server listen on port ' + listenPort + ' to process CORE message');
    });
}

create();

exports.setTransport = setTransport;