Pub / Sub app

// Initialize dataBridges client
const dbridge = new dbridges.dBridges();

// Replace your application key below, which you have received from dataBridges management portal.
// use session variables for greater security of your keys
dbridge.appkey = '____appKey______';

// Replace your authentication url below, which you have received from dataBridges management portal.
// example https://endpoint01.databridges.io/client/v1/authenticate
// use session variables for greater security of your keys
dbridge.auth_url = '_____URL_____';

// lets create a sessionID
const sessionID = Math.random().toString(36).substring(2, 7);
logit(['sessionID is ' + sessionID]);

// Connect to dataBridges. If any runtime error it will be caught in catch().
dbridge.connect().catch((err) => {
    logit(['dataBridges Connection exception..', err.source, err.code, err.message]);
});

//Bind to disconnected event, to get intimation about dbrdige network disconnection.
dbridge.connectionstate.bind("disconnected", () => {
    logit(['disconnected from dataBridges real-time network']);
});

dbridge.connectionstate.bind("connected", () => {
    logit(['Connected to dataBridges real-time network !!!']);
    let helloWorld = null;
    try {
        // Subscribe to channel 'Hello-World',
        helloWorld = dbridge.channel.subscribe('Hello-World')
    } catch (err) {
        // Connect errors will be handled here.
        logit(['Channel subscription faced an exception: ', err.source, err.code, err.message]);
    }

    // We will bind to subscription success event. On success, we will publish event messages.
    helloWorld.bind("dbridges:subscribe.success", (payload, metadata) => {
        // we can also check if the helloWorld subscription isOnline.
        if (helloWorld.isOnline()) {
            try {
                logit(['Publishing greetings ']);
                helloWorld.publish('greetings', 'Greetings from ' + sessionID);

            } catch (err) {
                // Any publish error will be caught here.
                logit(['Publishing messages faced an exception:  ', err.source, err.code, err.message]);
            }
        }
    });

    //Bind to the channel.event that you want to process. Here we will bind to 'greetings'
    helloWorld.bind('greetings', (payload) => {
        logit(['received greeting message : ', payload]);
    });

    // Bind to Subscription failure event, to get notified if subscription to channel has been rejected by dataBridges network
    helloWorld.bind("dbridges:subscribe.fail", (payload, metadata) => {
        logit(['Channel subscription faced an exception:', payload.source, payload.code, payload.message]);
    });

});