Installation

npm install databridges-sio-server-lib --save

pip3 install databridges_sio_server_lib

Install-Package Databridges.Sio.Server.Lib

const dBridges = require('databridges-sio-server-lib');
const dbridge = new dBridges();

from databridges_sio_server_lib import dBridges
from databridges_sio_server_lib.exceptions import dBError
dbridge = dBridges()

using dBridges;
dBridges.dBridges dbridge = new dBridges.dBridges();

dbridge.auth_url = 'URL';
dbridge.appkey = 'APP_KEY';
dbridge.appsecret = 'APP_SECRET';

dbridge.auth_url = 'URL'
dbridge.appkey = 'APP_KEY'
dbridge.appsecret = 'APP_SECRET'

dbridge.auth_url = 'URL';
dbridge.appkey = 'APP_KEY';
dbridge.appsecret = 'APP_SECRET';

dbridge.maxReconnectionRetries = 10;
dbridge.maxReconnectionDelay = 120000; 
dbridge.minReconnectionDelay = 1000 + Math.random() * 4000;
dbridge.reconnectionDelayGrowFactor = 1.3;
dbridge.minUptime = 200 ; 
dbridge.connectionTimeout = 10000;
dbridge.autoReconnect = true; 
dbridge.cf.enable = false; 

dbridge.maxReconnectionRetries = 10
dbridge.maxReconnectionDelay = 120000 
dbridge.minReconnectionDelay = 1000 + (new Random()).NextDouble() * 4000
dbridge.reconnectionDelayGrowFactor = 1.3
dbridge.minUptime = 200  
dbridge.connectionTimeout = 10000
dbridge.autoReconnect = true 
dbridge.cf.enable = false 

dbridge.maxReconnectionRetries = 10;
dbridge.maxReconnectionDelay = 120000; 
dbridge.minReconnectionDelay = 1000 + Math.random() * 4000;
dbridge.reconnectionDelayGrowFactor = 1.3;
dbridge.minUptime = 200 ; 
dbridge.connectionTimeout = 10000;
dbridge.autoReconnect = true; 
dbridge.cf.enable = false;

dbridge.connect().catch((err) => {
    console.log('dBridge Connection exception..', err.source, err.code, err.message);
});

try:
    await dbridge.connect()
except Exception as e:
    print("source: {0} ,  code: {1}, message: {2}".format(e.source , e.code , e.message))

try{
    await dbridge.connect();
} catch (dBError err) {
    Console.WriteLine("{0} ,  {1} , {2}" , err.source, err.code, err.message);
}

console.log(dbridge.sessionid);

print("sessionid: {0}".format( dbridge.sessionid))

Console.WriteLine(dbridge.sessionid);

dbridge.disconnect();

await dbridge.disconnect()

dbridge.disconnect();

console.log(dbridge.connectionstate.state);
console.log(dbridge.connectionstate.isconnected);
console.log(dbridge.connectionstate.rttms);
console.log(dbridge.connectionstate.reconnect_attempt);

print(dbridge.connectionstate.state)
print(dbridge.connectionstate.isconnected)
print(dbridge.connectionstate.rttms)
print(dbridge.connectionstate.reconnect_attempt)

Console.WriteLine(dbridge.connectionstate.state);
Console.WriteLine(dbridge.connectionstate.isconnected);
Console.WriteLine(dbridge.connectionstate.rttms);
Console.WriteLine(dbridge.connectionstate.reconnect_attempt);

dbridge.connectionstate.bind(eventName, () => {});
dbridge.connectionstate.unbind(eventName);
dbridge.connectionstate.unbind();

dbridge.connectionstate.bind(eventName, callable)
dbridge.connectionstate.unbind(eventName)
dbridge.connectionstate.unbind()

dbridge.connectionstate.bind(eventName, Action<object>);
dbridge.connectionstate.unbind(eventName);
dbridge.connectionstate.unbind();

dbridge.connectionstate.bind("connecting", () => {
    console.log('connecting');
});
dbridge.connectionstate.bind("reconnecting", () => {
    console.log('reconnecting', "reconnect_attempt=", dbridge.connectionstate.reconnect_attempt);
});
dbridge.connectionstate.bind("disconnected", () => {
    console.log('disconnected');
});
dbridge.connectionstate.bind("reconnected", () => {
    console.log('reconnected');
}); 
dbridge.connectionstate.bind("connection_break", (payload) => {
    console.log('connection_break', payload.source, payload.code, payload.message);
});
dbridge.connectionstate.bind("state_change", (payload) => {
    console.log('state_change', dbridge.connectionstate.state, payload);
});
dbridge.connectionstate.bind("connect_error", (payload) => {
    console.log('connect_error', payload.source, payload.code, payload.message); 
});
dbridge.connectionstate.bind("reconnect_error", (payload) => {
    console.log('reconnect_error', payload.source, payload.code, payload.message);
}); 
dbridge.connectionstate.bind("reconnect_failed", (payload) => {
    console.log('reconnect_failed', payload.source, payload.code, payload.message); 
});
dbridge.connectionstate.bind("rttpong", (payload) => {
    console.log('rttpong', payload, dbridge.connectionstate.rttms);
}); 
dbridge.connectionstate.bind("connected", () => { 
    console.log('connected');
});

async def connecting():
    print("connecting")

async def reconnecting():
    print("reconnecting")

async def connection_break():
    print("connection_break")

async def state_change( data):
    print("state_change:", data)

async def connect_error( data):
    if isinstance(data, str):
        print("connect_error:" + str(data))
    if isinstance(data, dBError.dBError):
        print(data.code, data.source, data.message)

async def reconnect_error(data):
    if isinstance(data, str):
        print("connect_error:" + str(data))
    if isinstance(data, dBError.dBError):
        print(data.code, data.source, data.message)

async def reconnect_failed( data):
    print("reconnect_failed:", data)

async def reconnected():
    print("reconnected:")

async def rttpong(data=None):
    print("rttpong:", .dbridge.connectionstate.rttms)

async def disconnected():
    print("disconnected:")

async def connected():
    print("connected...")

try:
      dbridge.connectionstate.bind("connecting", connecting)
      dbridge.connectionstate.bind("reconnecting", reconnecting)
      dbridge.connectionstate.bind("connection_break", connection_break)
      dbridge.connectionstate.bind("state_change", state_change)
      dbridge.connectionstate.bind("connect_error", connect_error)
      dbridge.connectionstate.bind("reconnect_error", reconnect_error)
      dbridge.connectionstate.bind("reconnect_failed", reconnect_failed)
      dbridge.connectionstate.bind("reconnected", reconnected)
      dbridge.connectionstate.bind("rttpong", rttpong)
      dbridge.connectionstate.bind("connected", connected)
      dbridge.connectionstate.bind("disconnected", disconnected)

except Exception as e:
    print(e.code, e.source, e.message)

Action<object> connecting;
dbridge.connectionstate.bind("connecting", connecting = (object payload) => {
    Console.WriteLine("connecting");
});

Action<object> reconnecting;
dbridge.connectionstate.bind("reconnecting", reconnecting = (object payload) => {
    Console.WriteLine("reconnecting, reconnect_attempt={0}", dbridge.connectionstate.reconnect_attempt);
});

Action<object> disconnected;
dbridge.connectionstate.bind("disconnected", disconnected = (object payload) => {
    Console.WriteLine("disconnected");
});

Action<object> reconnected;
dbridge.connectionstate.bind("reconnected", reconnected = (object payload) => {
   Console.WriteLine("reconnected");
}); 

Action<object> disconnected;
dbridge.connectionstate.bind("connection_break", reconnected = (object payload) => {
    dBError Payload =  payload as dBError
    Console.WriteLine("connection_break {0},{1},{2}", Payload.source, Payload.code, Payload.message);
});

Action<object> state_change;
dbridge.connectionstate.bind("state_change", state_change = (object payload) => {
    stateChange statechange = payload as stateChange;
    Console.WriteLine("state_change {0} , {1}", dbridge.connectionstate.state, payload);
});

Action<object> connect_error;
dbridge.connectionstate.bind("connect_error", connect_error = (object payload) => {
    dBError Payload =  payload as dBError
    Console.WriteLine("connect_error,  {0},{1},{2}", Payload.source, Payload.code, Payload.message); 
});

Action<object> reconnect_error;
dbridge.connectionstate.bind("reconnect_error", reconnect_error = (object payload) => {
    dBError Payload =  payload as dBError
    Console.WriteLine("reconnect_error {0},{1},{2}", Payload.source, Payload.code, Payload.message); 
});

Action<object> reconnect_failed;
dbridge.connectionstate.bind("reconnect_failed", reconnect_failed = (object payload) => {
    dBError Payload =  payload as dBError
    Console.WriteLine("reconnect_failed{0},{1},{2}", Payload.source, Payload.code, Payload.message); 
});

Action<object> rttpong;
dbridge.connectionstate.bind("rttpong", rttpong = (object payload) => {
   Console.WriteLine("rttpong {0} , {1}", payload, dbridge.connectionstate.rttms);
}); 

Action<object> connected;
dbridge.connectionstate.bind("connected", connected = (object payload) => {
    Console.WriteLine("dBridge Event Bind {0}", "connected");
});

// To get the last known Latency in milliseconds between your application and the dBridges router where your application is connected.
// The dBridges library exchanges rttms during the initial dBridges network connection routine.
console.log(dbridge.connectionstate.rttms);

// To get the latest Latency in milliseconds between your application and the dBridges router where your application is connected.
dbridge.connectionstate.rttping();

// Bind to rttpong, to get notified about the latest Latency in milliseconds between your application and the dBridges router where your application is connected.
dbridge.connectionstate.bind("rttpong", (payload) => {
    console.log('rttpong', payload);
    //payload is an integer value is in millisecond which is same as dbridge.connectionstate.rttms.
});

# To get the last known Latency in milliseconds between your application and the dBridges router where your application is connected.
# The dBridges library exchanges rttms during the initial dBridges network connection routine.
print(dbridge.connectionstate.rttms);

# To get the latest Latency in milliseconds between your application and the dBridges router where your application is connected.
try:
    dbridge.connectionstate.rttping();
    expect Exception as err:
        Console.WriteLine("{0} ,  {1} , {2}" , err.source, err.code, err.message);

# Bind to rttpong, to get notified about the latest Latency in milliseconds between your application and the dBridges router where your application is connected.

def rttpong(payload):
    Console.WriteLine(payload);
    //payload is an integer value is in millisecond which is same as dbridge.connectionstate.rttms.

try:
    dbridge.connectionstate.bind("rttpong",rttpong);
    expect Exception as err:
    Console.WriteLine("{0} ,  {1} , {2}" , err.source, err.code, err.message);

// To get the last known Latency in milliseconds between your application and the dBridges router where your application is connected.
// The dBridges library exchanges rttms during the initial dBridges network connection routine.
Console.WriteLine(dbridge.connectionstate.rttms);

// To get the latest Latency in milliseconds between your application and the dBridges router where your application is connected.
try {
    dbridge.connectionstate.rttping();
} catch (dBError err){
    Console.WriteLine("{0} ,  {1} , {2}" , err.source, err.code, err.message);
}
// Bind to rttpong, to get notified about the latest Latency in milliseconds between your application and the dBridges router where your application is connected.

void rttpong(object payload) {
    Console.WriteLine(payload);
    //payload is an integer value is in millisecond which is same as dbridge.connectionstate.rttms.
}
try {
    Action<object> rttpong_callback = rttpong;
    dbridge.connectionstate.bind("rttpong",rttpong_callback);
} catch (dBError err){
    Console.WriteLine("{0} ,  {1} , {2}" , err.source, err.code, err.message);
}