multichain-node

"use strict";

const http = require("http");
const https = require("https");

let client = (connection) => {
    let options = {
        host: connection.host,
        port: connection.port,
        method: "POST",
        key: connection.key,
        cert: connection.cert,
        agent: connection.agent,
        pfx: connection.pfx,
        passphrase: connection.passphrase,
        ca: connection.ca,
        ciphers: connection.ciphers,
        rejectUnauthorized: connection.rejectUnauthorized,
        secureProtocol: connection.secureProtocol,
        servername: connection.servername,
        headers: { 'Content-Type': 'application/json', host: connection.host },
        timeout: 6000000
    };

    if (connection.user && connection.pass) {
        options.auth = connection.user + ":" + connection.pass;
    }

    return {
        call: (method, params, cb) => {
            let payload = { method: method, params: [], id: 1, jsonrpc: '2.0' };
            if (params) {
                payload.params = params;
            }
            let body = JSON.stringify(payload);
            options.headers['Content-Length'] = Buffer.byteLength(body, 'utf8');


            var req = http.request(options).setTimeout(options.timeout, () => {
                console.log("Socket Timed Out after", options.timeout/1000, "seconds");
            });

            let data = "";

            req.on('socket', function (socket) {
                socket.setTimeout(options.timeout);
                socket.on('timeout', function () {
                    console.log("Socket Timed Out!");
                    req.abort();
                });
            });

            req.on('error', (e) => {
                console.log("Request Timed Out!");
                cb(e);
            });

            req.write(JSON.stringify(payload));
            req.on("response", (res) => {

                res.on('data', (chunk) => {
                    data += chunk;
                })
                res.on('end', () => {
                    let response;
                    if (res.statusCode === 200) {

                        response = JSON.parse(data);
                        return cb(null, response.result);

                    } else if (res.headers['content-type'] === "application/json") {

                        response = JSON.parse(data);
                        return cb(response.error);

                    } else {

                        return cb(data);

                    }
                })
            })
            req.end();
        }
    }
}

module.exports = client;