@smartface/library-manager/client.js

#!/usr/bin/env node

const args = require('minimist')(process.argv.slice(2));
const ipc = require('node-ipc');
const CONSTANTS = require("./constants");

const BRACKET_END = CONSTANTS.BRACKET_END;
const SERVER_PORT = CONSTANTS.SERVER_PORT;
const APP_NAME = CONSTANTS.CLIENT_APP_NAME;
const SERVER_APP_NAME = CONSTANTS.SERVER_APP_NAME;

ipc.config.id = APP_NAME;
ipc.config.encoding = "utf8";
ipc.config.retry = 5000;
ipc.config.logger = function() {};

var stdinData = '';
process.stdin.setEncoding('utf8');
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.connectToNet(
    SERVER_APP_NAME,
    SERVER_PORT,
    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);
                process.stdout.write("\r\n" + BRACKET_END);
            }
        );
        ipc.of.sfLibraryManager.on(
            'error',
            function(data) {
                process.stderr.write(data.toString());
            }
        );
    }
);