bootstrap-test-client

client.js

const host = process.argv[3];
const port = process.argv[5];

const socketAddress = {
    host: host || 'localhost',
    port: port || 8989
};

const net = require('net');
const client = new net.Socket();

const start = (message) => {
    return new Promise((resolve) => {
        const connect = (options = {}) => {
            let wasResolved = false;

            const waitTimeout = setTimeout(() => {
                console.log('Bootstrap socket timed out.');

                if (!client.destroyed) {
                    client.destroy();
                }

                if (wasResolved) {
                    return;
                }

                wasResolved = true;
                resolve();
            }, 1000 * 5);
            
            client.connect(socketAddress.port, socketAddress.host, () => {
                if (waitTimeout) {
                    clearTimeout(waitTimeout);
                }

            		client.write(JSON.stringify(message));

                if (wasResolved) {
                    return;
                }

                wasResolved = true;
            		resolve();
            });

            client.on('close', () => {
            		console.log('Bootstrap client was closed.');

                if (waitTimeout) {
                    clearTimeout(waitTimeout);
            		}
            });
            
            client.on('error', (err) => {
                console.log(`Can\'t connect to the bootstrap socket (${socketAddress.host} ${socketAddress.port}) ${err.code}`);

            		client.removeAllListeners();

                if (waitTimeout) {
                    clearTimeout(waitTimeout);
                }

                if (options.tries < 3) {
            		    console.log(`Tries: ${options.tries}`);

                    // retry
                    console.log('Retrying...');

                    options.tries = options.tries + 1;
                    const retryTimeout = setTimeout(() => {
                        clearTimeout(retryTimeout);
          		        connect(options);
                    }, 500);
            		} else {
                    if (wasResolved) {
                        return;
                    }

                    wasResolved = true;
                    resolve();
                }
            });
      	};
  
      	connect({tries: 0});
    });
};

start({
    started: true
});