karmia-express-middleware-jsonrpc

JSON-RPC 2.0 middleware for Express

Installation

npm install karmia-express-middleware-jsonrpc

Example

Server

const karmia_express_middleware_jsonrpc = require('karmia-express-middleware-jsonrpc'),
    jsonrpc = new karmia_express_middleware_jsonrpc();
jsonrpc.methods.set('method', function () {
    return Promise.resolve({success: true});
});

const body_parser = require('body-parser'),
    express = require('express'),
    karmia_context = require('karmia-context'),
    app = express(),
    context = new karmia_context();

app.use(function (req, res, next) {
    req.context = context.child();

    next();
});
app.use(body_parser.json());
app.post('/', jsonrpc.middleware());
app.use(function (req, res) {
    if (204 === res.code) {
        return res.status(res.code).end();
    }

    res.status(res.code).end(JSON.strintify(res.body));
});

app.listen(3000);

Client

const http = require('http'),
    request = (parameters) => {
        const body = JSON.stringify(parameters),
            options = {
                hostname: 'localhost',
                port: 3000,
                method: 'POST',
                path: '/',
                headers: {
                    'Content-Type': 'application/json; charset=UTF-8',
                    'Content-Length': Buffer.byteLength(body)
                }
        };

        return new Promise(function (resolve) {
            const request = http.request(options, (response) => {
                response.setEncoding('UTF-8');
                response.data = '';

                response.on('data', (chunk) => {
                    response.data = response.data + chunk;
                });

                response.on('end', function () {
                    resolve(JSON.parse(response.data));
                });
            });

            request.write(body);
            request.end();
        });
    };

request({id: 'id', method: 'method', params: {}).then(function (result) {
    console.log(result);
});