Normalizing Callback returns on Subscribe and Presence

normalize_callback.js

function normalize_subscribe_message_callback_object(msg, envelope) {
    var result = {
        channel_group: null,
        channel: null,
        message: msg
    };
    // if the message received through channel group
    if (envelope.length === 4) {
        result.channel_group = envelope[2];
        result.channel = envelope[3];
    }
    // if message received through channel only
    else if (envelope.length === 3) {
        result.channel = envelope[2];
    }
    else {
        console.error("Subscribe Message Callback envelope parameter array length NOT IN [3,4]")
    }

    return result;
}

function normalize_presence_message_callback_object(msg, envelope) {
    var result = {
        channel_group: null,
        channel: null,
        message: msg
    };
    // if the message received through channel group
    if (envelope.length === 4) {
        result.channel_group = envelope[2].slice(0, envelope[2].length - 7);
        result.channel = envelope[3].slice(0, envelope[3].length - 7);
    }
    // if message received through channel only
    else if (envelope.length === 3) {
        result.channel = envelope[2].slice(0, envelope[2].length - 7);
    }
    else {
        console.error("Presence Message Callback envelope parameter array length NOT IN [3,4]")
    }

    return result;
}

subscribe_channelgroup_example.js

p.subscribe({
    channel_group: "my_channel_group",
    message: function(msg, env, a, b) {
        // You can remove this log statement
        console.log("\tMESSAGE: ", msg, env, a, b);
        var result = normalize_subscribe_message_callback_object(msg, env);

        // Do Something with normalized result object
        // ...
    },
    presence: function(msg, env, a, b) {
        // You can remove this log statement
        console.log("\tPRESENCE: ", msg, env, a, b);
        var result = normalize_presence_message_callback_object(msg, env);

        // Do Something with normalized result object
        // ...
    },
    connect: function() {
        console.log("\tCONNECTED: ", chan);
    }
});

subscribe_example.js

p.subscribe({
    channel: "my_channel",
    message: function(msg, env, a, b) {
        // You can remove this log statement
        console.log("\tMESSAGE: ", msg, env, a, b);
        var result = normalize_subscribe_message_callback_object(msg, env);

        // Do Something with normalized result object
        // ...
    },
    presence: function(msg, env, a, b) {
        // You can remove this log statement
        console.log("\tPRESENCE: ", msg, env, a, b);
        var result = normalize_presence_message_callback_object(msg, env);

        // Do Something with normalized result object
        // ...
    },
    connect: function() {
        console.log("\tCONNECTED: ", chan);
    }
});