function listenForAnnounce()

in application-workloads/pubnub/pubnub-eventhub-bridge/tools/provisioningListener.js [30:82]
17 lines of code
1 McCabe index (conditional complexity)

function listenForAnnounce() {

    console.log("Subscribe Key: ", PNSubscribeKey);
    console.log("Announce Channel: ", PNAnnounceChannel);

    var uuid = "provisioning-" + (Math.random() * 1000);
    console.log("\nSetting UUID to " + uuid);

    var pubnub = require("pubnub")({
        ssl: true,
        subscribeKey: PNSubscribeKey,
        uuid: uuid
    });

    pubnub.addListener({
        status: function(message) {
            // optionally, handle status events here
        },
        message: function(message) {
            console.log("Received Message: ", JSON.stringify(message, null, 4));
        },
        presence: function(message) {
            if (message.action == "state-change") {
                console.log("\nReceived auto-provisioning payload from " + message.uuid);

                EHInConnectionString = message.data.EHInConnectionString;
                EHOutConnectionString = message.data.EHOutConnectionString;

                //console.log("EHInConnectionString: ", EHInConnectionString);
                //console.log();
                //console.log("EHOutConnectionString: ", EHOutConnectionString);
                console.log();
                console.log("In the future, use the below command to monitor these Event Hubs: ");
                console.log();
                console.log("node provisioningListener.js monitor " + '"' + EHInConnectionString + '" "' + EHOutConnectionString + '"');
                console.log();

                pubnub.unsubscribe({
                    "channel": PNAnnounceChannel,
                    // "callback": fireEHListeners
                });
                // 'callback' is no longer supported in 'unsubscribe'
                // so it might be desirable to use a 'await' to call this next line
                fireEHListeners();
            }
        }
    });

    console.log("\nListening for new PN/Azure Web Job Announce...");
    pubnub.subscribe({
        channels: [PNAnnounceChannel]
    });
}