var PNPublish = function()

in application-workloads/pubnub/pubnub-eventhub-bridge/App_Data/jobs/continuous/pnwebjob/PNSubscribeToEH1EH2ToPNPublish.js [50:93]


var PNPublish = function (ehEvent) {
    // console.log('Event Received from Egress EH, Publishing to PN: ');
    // console.log(JSON.stringify(ehEvent.body));
    // console.log("");

    if (Array.isArray(ehEvent.body)){

        ehEvent.body.forEach(function(element){

            pubnub.publish({
                channel: PNPubChannel,
                message: element
            },
            function(status, response) {
                if (status.error) {
                    console.log("PN Array Element Publish Error: ", status);
                    console.log("Message causing error: ", element);
                }
                else {
                    console.log("message published with server response: ", response);
                    console.log("Message published successfully: ", element);
                }
            });
        });

    } else {

        console.log("No array detected.");
        pubnub.publish({
            channel: PNPubChannel,
            message: ehEvent.body
        },
        function(status, response) {
            if (status.error) {
                console.log("PN Array Element Publish Error: ", status);
                console.log("Message causing error: ", ehEvent.body);
            }
            else {
                console.log("message published with server response: ", response);
                console.log("Message published successfully: ", ehEvent.body);
            }
        });
    }
};