hobbyquaker / binrpc Goto Github PK

        const thisHost = '192.168.1.2';

        const rpcServer = rpc.createServer({host: thisHost, port: '2031'});    // Host running rpc server
        const rpcClient = rpc.createClient({host: this.config.host, port: '2001'});      // CCU

        rpcServer.on('system.listMethods', function (err, params, callback) {
            console.log(' <  system.listMethods');
            callback(null, ['system.listMethods', 'system.multicall', 'event', 'listDevices', "newDevices", "deletedDevices"]);
        });

        rpcServer.on('NotFound', function (method, params) {
            console.log("Notfound: " + method + " with " + params);
        });

        rpcServer.on('newDevices', function (err, params, callback) {
            console.log("newDevices", params);
            callback(null, '');
        });

        rpcServer.on('deletedDevices', function (err, params, callback) {
            console.log("deletedDevices", params);
            callback(null, '');
        });

        rpcServer.on('listDevices', function (err, params, callback) {
            console.log("list devices");
            callback(null, []);
        });

        rpcServer.on('event', function (err, params, callback) {
            console.log(' < event', JSON.stringify(params));
            callback(null, '');
        });

        rpcServer.on('system.multicall', function (err, params, callback) {
            console.log(' < system.multicall', JSON.stringify(params));
            const response = [];
            params[0].forEach(function (call) {
                console.log(' <', call.methodName, JSON.stringify(call.params));
                response.push('');
            });
            callback(null, '');
        });

        function subscribe() {
            console.log(' > ', 'init', ['xmlrpc_bin://' + thisHost + ':2031', 'rf2wired']);
            rpcClient.methodCall('init', ['xmlrpc_bin://' + thisHost + ':2031', 'rf2wired'], function (err, res) {
                console.log("init sub res", err, res);
            });
        }

        process.on('SIGINT', function () {
            unsubscribe();
        });

        function unsubscribe() {
            console.log(' > ', 'init', ['xmlrpc_bin://' + thisHost + ':2031', '']);
            rpcClient.methodCall('init', ['xmlrpc_bin://' + thisHost + ':2031', ''], function (err, res) {
                console.log(err, res);

                process.exit(0);
            });
            setTimeout(function () {
                console.log('force quit');
                process.exit(1);
            }, 1000);
        }

       subscribe();