@connectterou/tsock NPM

@connectterou/Tsock

Tsock is a node.js tcp server & client library

Installation

Use the package manager npm to install @connectterou/tsock.

npm i @connectterou/tsock

Usage

'use strict';
const { Tserver, Tclient, RedisAdapter } = require('@connectterou/tsock');
const server = new Tserver(8080);
const PASS = '1234';

async function main() {
    server.adapter(new RedisAdapter({ host: 'localhost', port: 6379 })); // redis adapter (optional) (cluster mode)
    server.use(async (socket, next) => { // middleware
        let [password] = await socket.onceAsync('password');
        if (password !== PASS) {
            return;
        }

        socket.join('testto'); // join room
        //socket.leave('testto') // leave room
        next();
    });

    server.on('connection', async sock => {
        console.log(sock.id); // socket id
        server.clients('testto').then(console.log); //connected client ids
        server.emit('room1', 'test', 'okokook'); // goes to clients in room1 room
        sock.on('test', (msg, res) => { // bind test event
            console.log(msg); // message
            res('okokokok'); // response
        });

        for await (let [msg] of sock.onAsync('test')) { // asyncIterable event
            console.log(msg);
        }

        let [msg, reply] = await sock.onceAsync('test'); // once async event;
        console.log(msg);


        sock.emit('hello', 'hhhello', true).then(console.log); // hello => event name, hhhello => message, true => wait response
        setInterval(() => server.emit('testto', 'hello', 'hhhello'), 500);
        sock.on('disconnect', () => console.log('disconnect', sock.id)); // disconnect event
    });

    await server.listen();

    let tclient = new Tclient('127.0.0.1', 8080);
    await tclient.onceAsync('connect');
    tclient.emit('password', '1234');
    await tclient.onceAsync('ready');
    for await (let [x, res] of tclient.onAsync('hello')) {
        console.log(x);
        res('response');
    }

    tclient.on('hello', (msg, res) => {
        console.log(msg);
    });

    let response = await sock.emit('hello', 'hhhello', true);
    console.log(response);
}

main();