@smartface/library-manager/client.js

#!/usr/bin/env node

const args = require('minimist')(process.argv.slice(2));
const ipc = require('node-ipc');
const BRACKET_END = '$(B_R-A_C-K_E-T)';

ipc.config.id = 'sfLibraryManagerClient';
ipc.config.port = 8001;
ipc.config.encoding = "binary";
ipc.config.retry = 5000;
ipc.config.logger = function() {};

var stdinData = '';
process.stdin.setEncoding('binary');
process.stdin.on('data', message => {
    stdinData += message;
    if (stdinData.endsWith(BRACKET_END)) {
        var splitted = stdinData.split(BRACKET_END);
        splitted = splitted[splitted.length - 2];
        writeTask(splitted);
        stdinData = "";
    }
});

function writeTask(data) {
    ipc.of.sfLibraryManager.emit(
        'writeTask',
        data
    );
}
//console.error(args);
ipc.connectTo(
    "sfLibraryManager",
    "/tmp/app.sfLibraryManager",
    function() {
        ipc.of.sfLibraryManager.on(
            'connect',
            function() {
                //console.error("connected",args);
                if (args.task) {
                    ipc.of.sfLibraryManager.emit(
                        args.task, { libraryFolder: args.libraryFolder, name: args.name }
                    );
                }
                else {
                    ipc.of.sfLibraryManager.emit(
                        'init', {
                            initialLibraryData: args.initialLibraryData,
                            libraryFolder: args.libraryFolder,
                            name: args.name
                        }
                    );

                }
            }
        );
        ipc.of.sfLibraryManager.on(
            'read',
            function(data) {
                process.stdout.write(data + BRACKET_END);
            }
        );
        ipc.of.sfLibraryManager.on(
            'error',
            function(data) {
                process.stderr.write(data.toString());
            }
        );
    }
);