Openservice Websocket Server

ratelimits, rpc, event batching, session management

Config Definition

{
    port: 3000,
    host: '127.0.0.1',
    channels: ['public'],
    rateLimitDuration: 1000,
    rateLimitCount: 10,
    parallel: 1, 
    batchTime: 1, 
    batchLength: 10,
}

Service Example

// service.js
module.exports = (config, services, emit) => {

    const public = {
        ping: ({ ... }) => {
            return 'pong'
        }
    }

    const actions = (sessionid, channel, action, args) => {
        // call remote service
        switch(channel) {
            case 'public': {
                return public(args)
            }
        }
    }

    // create server
    const socket = await Socket(config, { actions }, (event, ...args) => {
        switch(event){
            case 'connect': {}
            case 'disconnect': {}
            case 'err': {}
            default: 
                console.log(event, args)
        }    
    });

    return socket
}