OSQuery queryScript

// Connect to dataBridges. If any runtime error it will be caught in catch().
dbridge.connect().catch((err) => {
    console.log('dBridge Connection exception..', err);
});

//Bind to disconnected event, to get intimation about dataBridges network disconnection. 
dbridge.connectionstate.bind("disconnected", () => {
    console.log('dataBridges network', 'disconnected');
});

# Bind to connected event, to get intimation about dataBridges network connected.
self.dbridge.connectionstate.bind("connected", self.connected)
# Bind to disconnected event, to get intimation about dataBridges network disconnection.
self.dbridge.connectionstate.bind("disconnected", self.disconnected)
# Connect to dataBridges. If any runtime error it will be caught in Exception. 
try:
    await asyncio.sleep(0.0001)
    await self.dbridge.connect()
except Exception as e:
    print(e)

# Bind to disconnected event, to get intimation about dataBridges network disconnection.
async def disconnected(self):
    try:
        print('dBridge Event Bind', 'disconnected');
        quit()
    except Exception as e:
        print(e)

//Bind to connected event.
dbridge.connectionstate.bind("connected", async () => {
    console.log('dBridge Event Bind', 'connected');

    // Subscribe to channel 'sys:' + osGroupName,
    subscribe_channel = await dbridge.channel.subscribe("sys:" + osGroupName);

    // Bind to subscribe.success event
    subscribe_channel.bind("dbridges:subscribe.success", (payload, metadata) => {
        console.log('Subscribed to :', 'sys:' + osGroupName)
    });

    // Bind to subscribe.fail event
    subscribe_channel.bind("dbridges:subscribe.fail", (payload, metadata) => {
        console.log('Subscription failed for ', 'sys:' + osGroupName, payload.source, payload.code, payload.message)
    });
});

# Bind to connected event.
async def connected(self):
    try:
        print("dBridge Event Bind", "connected")
        # Subscribe to channel 'sys:' + osGroupName,
        self.subscribe_channel = await self.dbridge.channel.subscribe("sys:" +  self.osGroupName)
        # Bind to subscribe.success event
        self.subscribe_channel.bind("dbridges:subscribe.success", self.subscribe_success)
        # Bind to subscribe.fail event
        self.subscribe_channel.bind("dbridges:subscribe.fail", self.subscribe_fail)
    except Exception as e:
        print(e)

#  Bind to subscribe.success event
async  def subscribe_success(self, payload , metadata):
    try:
        print('Subscribed to :', 'sys:' + self.osGroupName)
    except Exception as e:
        print(e)

# Bind to subscribe.fail event
async def subscribe_fail(self, payload, metadata):
    print('Subscription failed for ', 'sys:' + self.osGroupName, payload.source, payload.code, payload.message)

// Bind to participant.joined event
subscribe_channel.bind('dbridges:participant.joined', (payload, metadata) => {
    const sysInfo = JSON.parse(payload.sysinfo)
    const clientOS = sysInfo.sysinfo.os;
    console.log('Participant Joined ', clientOS, sysInfo.sysid);
    let osquery = null;
    osquery = queryJson[clientOS];
    if(!osquery){
        console.log(queryFileName ,' dose not contain query for OS:',clientOS);
    }else {
        // databridge client function call with the recieved sessionid 
        dbridge.cf.call(metadata.sessionid, "osquery", JSON.stringify(osquery), 1000 * 60 * 2).then((payload) => {
            console.log('OSQuery Result for', sysInfo.sysid, JSON.parse(payload).osqueryresult);
        }).catch((err) => {
            console.log('OSQuery call => exception', sysInfo.sysid, err.source, err.code, err.message);
        });
    }
});

// Bind to participant.left event
subscribe_channel.bind('dbridges:participant.left', (payload, metadata) => {
    console.log('Participant Left : ', metadata.sourcesysid)
});

# Bind to participant.join event
self.subscribe_channel.bind("dbridges:participant.joined", self.participant_join)
# Bind to participant.left event
self.subscribe_channel.bind("dbridges:participant.left", self.participant_left)

# Bind to participant.joined event
async  def participant_join(self, payload , metadata):
    try:

        sysInfo = json.loads(payload["sysinfo"])
        clientOS = sysInfo["sysinfo"]["os"]
        print('Participant Joined ', clientOS, sysInfo["sysid"])

        osquery = queryDB[clientOS]
        if not osquery:
            print(queryFileName ," dose not contain query for OS:",clientOS)
        else:
            # databridge client function call with the recieved sessionid
            p =  await self.dbridge.cf.call(metadata["sessionid"],  "osquery" , json.dumps(osquery), 1000*60*2, None )

            def onResult(res):
                jres = json.loads(res)
                print('OSQuery Result for', sysInfo["sysid"], "\n", jres["osqueryresult"])

            def onError(err):
                print('OSQuery call => exception', sysInfo["sysid"], err.source, err.code, err.message);

            p.then(onResult).catch(onError)

    except Exception as e:
        print(e)

# Bind to participant left event
async  def participant_left(self, payload , metadata):
    try:
        print('Participant Left : ', metadata["sourcesysid"])
    except Exception as e:
        print(e)