var connectToIoTHub = function()

in device/node-red/azureiothub/azureiothub.js [86:124]
31 lines of code
3 McCabe index (conditional complexity)

        var connectToIoTHub = function (pendingMessage) {
            node.log('Connecting to Azure IoT Hub:\n   Protocol: ' + clientProtocol + '\n   Connection string :' + clientConnectionString);
            client = Client.fromConnectionString(clientConnectionString, Protocols[clientProtocol]);
            client.open(function (err) {
                if (err) {
                    node.error('Could not connect: ' + err.message);
                    setStatus(statusEnum.disconnected);
                } else {
                    node.log('Connected to Azure IoT Hub.');
                    setStatus(statusEnum.connected);

                    // Check if a message is pending and send it 
                    if (pendingMessage) {
                        node.log('Message is pending. Sending it to Azure IoT Hub.');
                        // Send the pending message
                        sendData(pendingMessage);
                    }

                    client.on('message', function (msg) {
                        // We received a message
                        node.log('Message received from Azure IoT Hub\n   Id: ' + msg.messageId + '\n   Payload: ' + msg.data);
                        var outpuMessage = new Message();
                        outpuMessage.payload = msg.data;
                        setStatus(statusEnum.received);
                        node.send(outpuMessage);
                        client.complete(msg, printResultFor('Completed'));
                    });

                    client.on('error', function (err) {
                        node.error(err.message);

                    });

                    client.on('disconnect', function () {
                        disconnectFromIoTHub();
                    });
                }
            });
        };