function main()

in packages/websocket/sendWebSocketMessageAction.js [25:81]
41 lines of code
4 McCabe index (conditional complexity)

function main(params) {
    var promise = new Promise(function(resolve, reject) {
    	if (!params.uri) {
            reject('You must specify a uri parameter.');
        }
        var uri = params.uri;

        console.log("URI param is " + params.uri);

        if (!params.payload) {
            reject('You must specify a payload parameter.');
        }
        var payload = params.payload;

        console.log("Payload param is " + params.payload);

        var WebSocket = require('ws');

        var connectionEstablished = false;
        var ws = new WebSocket(uri);

        var connectionTimeout = 30 * 1000; // 30 seconds

        setTimeout(function () {
            if (!connectionEstablished) {
                reject('Did not establish websocket connection to ' + uri + ' in a timely manner.');
            }
        }, connectionTimeout);

        ws.on('open', function () {
            connectionEstablished = true;

            console.log("Sending payload: " + payload);
            ws.send(payload, function (error) {
                if (error) {
                    console.log("Error received communicating with websocket: " + error);
                    ws.close();
                    reject(error);
                } else {
                    console.log("Send was successful.");
                    ws.close();
                    resolve({
                        'payload': payload
                    });
                }
            });
        });

        ws.on('error', function (error) {
            console.log("Error communicating with websocket: " + error);
            ws.close();
            reject(error);
        });
    });

    return promise;
}