connection.js

const Request = require('./request');
const TabSeparatedInputStreamParser = require('./tab-separated-input-stream-parser');

function Connection(outStream, inStream) {
    const responseHandlersQueue = [];
    const inputStreamParser = new TabSeparatedInputStreamParser();

    inStream.setEncoding('utf8');
    inStream.on('data', (chunk) => {
        inputStreamParser.addPartial(chunk);
    });

    inStream.on('close', () => {
        if (this.onDisconnect) {
            this.onDisconnect();
        }
    });

    inputStreamParser.onResponse(response => {
        const responseIds = responseHandlersQueue.map(r => r.id);
        if (responseIds.indexOf(response.id) !== -1) {
            responseHandlersQueue.splice(responseIds.indexOf(response.id), 1)[0].onResponse(response.result);
        }
    });

    const send = (request, onResponse) => {
        outStream.write(`${JSON.stringify(request)}\t`);
        if (onResponse) {
            responseHandlersQueue.push({
                id: request.id,
                onResponse
            });
        }
    };

    this.onDisconnect = null;

    this.send = (type, args = {}, onResponse = null) => {
        send(new Request(type, args), onResponse);
    };

    this.close = () => {
        outStream.end();
    };
}

module.exports = Connection;