ichnaea/client/services/socket.js

const io = require('socket.io-client');
const chalk = require('chalk')
const {server_url} = require('../config/keys');

const socket = io(server_url);

socket.on('connect', () => {
    console.log(chalk.green('Connected to server!'));
    socket.emit('subscribe', 'pi-iot');
});

socket.on('disconnect', (reason) => {
    console.log(chalk.red('Lost connection!'));

    if (reason === 'io server disconnect') socket.connect();

    if (reason === 'io client disconnect') {
        console.log(chalk.red('Server kicked you!'));
        exit(1);
    }

    console.log(chalk.yellow('Reconnecting...'));
});

socket.on('closeConn', () => {
    closeConn();
});

setInterval(() => {
    socket.emit('data', {measurement: 123, pointName: 'hey-ho'});
}, 3 * 1000);