ci/socket-io.js

const server = require('http').createServer();
const io = require('socket.io')(server);

console.log('Started');
var callback = client => {
    console.log('Connected!');
    client.on('test', data => {
        // Send a message back to the server to confirm the message was received
        client.emit('test-received', data);
        console.log(['test', data]);
    });
    client.on('message', data => {
        client.emit('message-received', data);
        console.log(['message', data]);
    });
    client.on('test', function (arg, ack) {
        console.log('Ack received')
        if (ack) {
            ack('woot');
        }
    });

    client.on('binary', data => {
        var bufView = new Uint8Array(data);
        console.log(['binary', 'Yehaa binary payload!']);
        for (elem in bufView) {
            console.log(['binary', elem]);
        }
        client.emit('binary-received', data);
        console.log(['binary', data]);
    });

    client.on('binary', function (arg, ack) {
        console.log(['binary', 'Ack received, answer with binary'])
        if (ack) {
            ack(Buffer.from([1, 2, 3]));
        }
    });
    client.emit('Hello from the message event!');
    client.emit('test', 'Hello from the test event!');
    client.emit(Buffer.from([4, 5, 6]));
    client.emit('test', Buffer.from([1, 2, 3]));
};
io.on('connection', callback);
io.of('/admin').on('connection', callback);
// the socket.io client runs on port 4201
server.listen(4200);