How to use deviceListener method in devicefarmer-stf

Best JavaScript code snippet using devicefarmer-stf

listener.js

Source:listener.js

1//Please excuse my spellin.2/********************************************************3 *	Controlers for device listeners						*4 *		Listener::fire sets up fire-scenario listeners	*5 *		Listener::test sets up test-scenario listeners	*6 ********************************************************/7exports.fire=function(req, res){8	var fireListener = new DeviceListener("c.DO9loqF7AV9t1Pm4WgiNFtKGIDsPhnQrlXU3MjMO9PVhK85by0Pj1WNpPHvueUMiu23JbpPAEs6Z1iwXodlgG6CBIV5klpS4K898ln9hmTbevWutbt0eOCGteuAHUxPHZ5Jc6NLU2Zno6hST", "7IuDdtUG8YxzNn1JHtEW82stXYWgXYx0", "smoke_co_alarms")9	fireListener.onFire();10	res.redirect('/');11}12exports.test=function(req, res){13	var listener = new DeviceListener("c.DO9loqF7AV9t1Pm4WgiNFtKGIDsPhnQrlXU3MjMO9PVhK85by0Pj1WNpPHvueUMiu23JbpPAEs6Z1iwXodlgG6CBIV5klpS4K898ln9hmTbevWutbt0eOCGteuAHUxPHZ5Jc6NLU2Zno6hST", "yJfKse_UO_S8XJ3MQz3AQGstXYWgXYx0", "thermostats");14	listener.test();15	res.redirect('/');16}17exports.callForwarding=function(req, res){18	var listener = new DeviceListener("c.DO9loqF7AV9t1Pm4WgiNFtKGIDsPhnQrlXU3MjMO9PVhK85by0Pj1WNpPHvueUMiu23JbpPAEs6Z1iwXodlgG6CBIV5klpS4K898ln9hmTbevWutbt0eOCGteuAHUxPHZ5Jc6NLU2Zno6hST", "BiIlek5WGd7N48bVuCdoFCehp508sfE4UHC3ojwE4ps6qw9aratTGw", "structures");19	listener.forwarding();20	res.redirect('/');21}22exports.checkin=function(req, res){23	var listener = new DeviceListener("c.DO9loqF7AV9t1Pm4WgiNFtKGIDsPhnQrlXU3MjMO9PVhK85by0Pj1WNpPHvueUMiu23JbpPAEs6Z1iwXodlgG6CBIV5klpS4K898ln9hmTbevWutbt0eOCGteuAHUxPHZ5Jc6NLU2Zno6hST", "BiIlek5WGd7N48bVuCdoFCehp508sfE4UHC3ojwE4ps6qw9aratTGw", "structures");24	listener.monitor(new Date()+60000, new Date() + 60000);25	res.redirect('/');26}27//modules28var Firebase = require('firebase');29var CronJob = require('cron').CronJob;30var Time =require('time');31/************************************************************************32 *  Device Listener Declaration											*33 *		DeviceListener::onFire sets up device listeners for smoke		*34 *		alarms. If a smoke alarm state==emergency || warning, sends	 	*35 *		a text message alert to the home owner.							*36 *																		*37 *		DeviceListener::test sets up device listeners that listen for	*38 *		any status changes to the account and add it to log.			*39 *																		*40 *		DeviceListener::forwarding monitors home/away status and turns	*41 *		call forwarding on/off correspondingly.							*42 *		DeviceListener::43 ************************************************************************/44 // Constructor for the DeviceListener object45function DeviceListener (auth_token, device_id, device_type){46	this.token =auth_token;47	this.device_id =device_id;48	this.device_type =device_type;49	// When developing, will probably want to create a this.DataRef here.50	// Then you can use 1 dataRef monitor for all user's monitoring needs.51	// Also will make the error checks obsolete, but will also require .child("child's name").on("child_added", . . .);52}53// OnFire listens for a fire warning or emergency from a device.54DeviceListener.prototype.onFire = function() {55	if (this.device_type != "smoke_co_alarms") {	// Check that onFire is being called on a smoke detector.56		console.log("onFire can only be called on a device listener that has been initialized for a smoke_co_alarm.");57		return;58	}59	var url ='wss://developer-api.nest.com/devices/'+this.device_type+"/"+this.device_id;	60	var dataRef =new Firebase(url);61	dataRef.auth(this.token, function (error) {		// Authenticates the firebase connection.62		if (error) console.log("Firebase Authentication Error: " +error);63	});64	var alarmState;65	console.log('Setting up Device Listeners for fire.')66	dataRef.on('child_changed', function (snapshot) {67		checkFire(snapshot.val(), alarmState);		// Check if the change is due to fire68		alarmState = snapshot.val();				// Don't register duplicate statuses.69	});70}71// Test function that listens for any changes to user's account.72DeviceListener.prototype.test = function() {73	var url = 'wss://developer-api.nest.com/';74	var dataRef =new Firebase(url);75	dataRef.auth(this.token, function (error, result) {76		if (error) console.log("Firebase Authentication Error: " + error);77		else {78			console.log("Firebase authentication success");79			dataRef.on("child_changed", function(snapshot){80				var device_data = snapshot.val();81				console.log(JSON.stringify(device_data));82				console.log("Device Changed");83			});84		}85	});86}87// Monitors home's away status and turns on/off call forwarding.88DeviceListener.prototype.forwarding = function() {89	if (this.device_type != "structures") {		// Error check that the method is being called on the correct device.90		console.log('onAway: Invalid device type. May only be called on a structure.');91		return;92	}93	var url = 'wss://developer-api.nest.com/structures/'+this.device_id+'/away';94	var dataRef = new Firebase(url);95	dataRef.auth(this.token, function (error, result){96		if (error) console.log("Firebase authentication error: " + error);97		else {98			console.log("Firebase authentication success.");99			dataRef.on("value", callForwardingLogic);100		}101	});102}103// Monitor checks home's away status to determine presence during a given time.104DeviceListener.prototype.monitor = function(start, stop) {105	if (this.device_type != "structures") {		//error check to make sure device is a structure, not thermostat or smoke_co_alarm106		console.log('Monitor: Invalid device type. May only be called on a structure.');107		return;108	}109	var device = this;							//establishes context110	var url = 'wss://developer-api.nest.com/structures/'+device.device_id+'/away';111	var dataRef = new Firebase(url);112	device.dataRef = dataRef;113	var start_monitor = new CronJob('00 00 12 * * 1-5', function () {this.start_monitor();}, null, true, "America/Los_Angeles", device);		// Cron-job schedules monitoring.114	var stop_monitor  = new CronJob('00 05 12 * * 1-5', function () {this.stop_monitor(); }, null, true, "America/Los_Angeles", device);		// Cron-job schedules monitoring.115}116// Called by Cron-job to begin monitoring home for away status.117DeviceListener.prototype.start_monitor = function() {118	console.log("Listening Job started.");119	var device = this;120		device.home_yet = false;121	this.dataRef.auth(this.token, function (error, result) {122		if (error) console.log("Firebase authentication error: " + error);123		else {124			console.log("Firebase authentication success.");125			device.dataRef.on("value", function(snapshot){126				var data = snapshot.val();127				if (data == "home") {128					device.home_yet = true;129				}130				console.log("Data:: "+data);131			});132		}133	});134}135// Called by Cron-job to stop monitoring home and report findings.136DeviceListener.prototype.stop_monitor = function() {137	console.log("Stopping job started");138	this.dataRef.off();139	if (this.home_yet) sendTextNotification("Timmy came home today.", "+17576347081");140	else sendTextNotification("Timmy hasn't come home from school yet.", "+17576347081");141}142/********************************143 *	Helper Function Declaration	*144 ********************************/145// Checks data to see if it is a fire, and if so raises an alarm.146function checkFire(data, alarmState) {			// Setup listeners on the firebase connection for any child that changes147	switch (data) {								// Responds to a 'warning' or 'emergency' status, and calls sendTextNotification to send the appropriate message.148	case 'warning':149		if (alarmState !== 'warning') { 		// Only alert the first change150			console.log('WARNING: Smoke has been detected. Press 1 to call home, Press 2 to call 911 from your home phone.');151			sendTextNotification('WARNING: Smoke has been detected. Press 1 to call home, Press 2 to call 911 from your home phone number.', '+17576347081');152		}153		break;154	case 'emergency':155		if (alarmState !== 'emergency') { 		// Only alert the first change156			console.log('EMERGENCY: Smoke has been detected. Press 1 to call home, Press 2 to call 911 from your home phone number.');157			sendTextNotification('EMERGENCY: Smoke has been detected. Press 1 to call home, Press 2 to call 911 from your home phone number.', '+17576347081');158		}159		break;160	}161}162// Takes snapshot and determines call-forwarding mode.163function callForwardingLogic(snapshot) {164	console.log("FORWARDING SNAPSHOT VALUE: "+JSON.stringify(snapshot.val()));165	var device_data = snapshot.val(),166		device_name = snapshot.name();167	if (device_name == "away"){168		if (device_data == "home") callForwarding(false);169		if (device_data == "away") callForwarding(true);170		if (device_data == "auto-away") callForwarding(true);171	}172}173// Stub of implimentation for turning call forwarding on/off.174function callForwarding(on) {175	if (on)  console.log("Turning call forwarding on");176	if (!on) console.log("Turning call forwarding off");177}178// SendTextNotification uses Twilio to send a given SMS message given phone number179function sendTextNotification(message, phone_num) {180	var accountSid = "AC35fd5b6818d52e3f97d95a1f6c437a08",181		authToken = "2020f777c02282f892f1df7acf307af8";182	var client = require('twilio')(accountSid, authToken);183	client.messages.create({184		body: message,185		to: phone_num,186		from: "+16505674422"187	}, function (error, message) {188		if (error) console.log("Error: "+JSON.stringify(error));189		else process.stdout.write(message.sid);190	});...

query-device.processor.ts

Source:query-device.processor.ts

1import { Injectable } from '@nestjs/common';2import { CheckpointService } from '../../commons/event-processing/checkpoint/checkpoint.service';3import { DeviceProcessor } from '../../commons/event-processing/device.processor';4import { EventStorePublisher } from '../../commons/event-store/event-store.publisher';5import {6    DatastreamAdded,7    DatastreamRemoved,8    DatastreamUpdated,9    DeviceLocated,10    DeviceRegistered,11    DeviceRelocated,12    DeviceRemoved,13    DeviceUpdated,14    ObservationGoalLinked,15    ObservationGoalUnlinked,16    SensorAdded,17    sensorDeviceStreamRootValue,18    SensorRemoved,19    SensorUpdated,20} from '../../commons/events/sensordevice';21import { SensorDeviceEvent } from '../../commons/events/sensordevice/sensordevice.event';22import { Gateway } from '../gateway/gateway';23import { IDevice } from '../model/device.schema';24import { DeviceEsListener } from './device.es.listener';25@Injectable()26export class QueryDeviceProcessor extends DeviceProcessor {27    constructor(28        eventStore: EventStorePublisher,29        checkpointService: CheckpointService,30        private readonly gateway: Gateway,31        private readonly deviceListener: DeviceEsListener,32    ) {33        super(`backend-${sensorDeviceStreamRootValue}-es`, eventStore, checkpointService);34    }35    async process(event: SensorDeviceEvent): Promise<void> {36        let device: IDevice;37        let legalEntityIds: string[];38        if (event instanceof DeviceRegistered) {39            device = await this.deviceListener.processDeviceRegistered(event);40            legalEntityIds = await this.deviceListener.getDeviceLegalEntityIds(event);41        } else if (event instanceof DeviceUpdated) {42            device = await this.deviceListener.processDeviceUpdated(event);43            legalEntityIds = await this.deviceListener.getDeviceLegalEntityIds(event);44        } else if (event instanceof DeviceRemoved) {45            legalEntityIds = await this.deviceListener.getDeviceLegalEntityIds(event);46            device = await this.deviceListener.processDeviceDeleted(event);47        } else if (event instanceof DeviceLocated) {48            device = await this.deviceListener.processDeviceLocated(event);49            legalEntityIds = await this.deviceListener.getDeviceLegalEntityIds(event);50        } else if (event instanceof DeviceRelocated) {51            device = await this.deviceListener.processDeviceRelocated(event);52            legalEntityIds = await this.deviceListener.getDeviceLegalEntityIds(event);53        } else if (event instanceof SensorAdded) {54            await this.deviceListener.processSensorAdded(event);55        } else if (event instanceof SensorUpdated) {56            await this.deviceListener.processSensorUpdated(event);57        } else if (event instanceof SensorRemoved) {58            await this.deviceListener.processSensorRemoved(event);59        } else if (event instanceof DatastreamAdded) {60            device = await this.deviceListener.processDatastreamAdded(event);61            legalEntityIds = await this.deviceListener.getDeviceLegalEntityIds(event);62        } else if (event instanceof DatastreamUpdated) {63            device = await this.deviceListener.processDatastreamUpdated(event);64            legalEntityIds = await this.deviceListener.getDeviceLegalEntityIds(event);65        } else if (event instanceof DatastreamRemoved) {66            device = await this.deviceListener.processDatastreamRemoved(event);67            legalEntityIds = await this.deviceListener.getDeviceLegalEntityIds(event);68        } else if (event instanceof ObservationGoalLinked) {69            await this.deviceListener.processObservationGoalLinked(event);70        } else if (event instanceof ObservationGoalUnlinked) {71            await this.deviceListener.processObservationGoalUnlinked(event);72        }73        if (device && legalEntityIds) {74            this.gateway.emit(event.constructor.name, legalEntityIds, { canEdit: true, ...device.toObject() });75        }76    }...

EventBus.ts

Source:EventBus.ts

1import consolaGlobalInstance from "consola";2import EventEmitter from "events";3import { MqttClient } from "mqtt";4import Device from "../devices/Device";5import { ISenses } from "./Senses";6import IService from "./Service";7export type DeviceListener = (device: Device, senses: ISenses) => void;8export type SensesListener = (senses: ISenses) => void;9export type MqttConnectListener = (mqtt: MqttClient) => void;10export type ServiceCallListener = (service: IService, params: unknown, result: boolean) => void;11export type DeviceStateChangeListener<TState = {}> = (12    device: Device<TState>,13    newState: Readonly<TState>,14    oldState: Readonly<TState>,15) => void;16declare interface EventBus {17    emit(event: "setup", ...args: Parameters<SensesListener>): boolean;18    emit(event: "start", ...args: Parameters<SensesListener>): boolean;19    emit(event: "update"): boolean;20    emit(event: "mqtt.connect", mqtt: MqttClient): boolean;21    emit(event: "mqtt.message", topic: string, message: string): boolean;22    emit(event: "device.add", ...args: Parameters<DeviceListener>): boolean;23    emit(event: "device.updated", ...args: Parameters<DeviceListener>): boolean;24    emit(event: "device.state_changed", ...args: Parameters<DeviceStateChangeListener>): boolean;25    emit(event: "service.called", ...args: Parameters<ServiceCallListener>): boolean;26    emit(event: string, ...args: any[]): boolean;27    on(event: "setup", listener: SensesListener): this;28    on(event: "start", listener: SensesListener): this;29    on(event: "update"): this;30    on(event: "mqtt.connect", listener: MqttConnectListener): this;31    on(event: "mqtt.message", listener: (topic: string, message: string) => void): this;32    on(event: "device.add", listener: DeviceListener): this;33    on(event: "device.updated", listener: DeviceListener): this;34    on(event: "device.state_changed", listener: DeviceStateChangeListener): this;35    on(event: "service.called", listener: ServiceCallListener): this;36    on(event: string, listener: (...args: any[]) => void): this;37}38class EventBus extends EventEmitter {39    senses: ISenses;40    constructor(senses: ISenses) {41        super();42        this.senses = senses;43    }44    override emit(event: string, ...args: any[]): boolean {45        consolaGlobalInstance.withScope("eventbus").trace(`Emitting event ${event}`);46        return super.emit(event, ...args);47    }48}...

Using AI Code Generation

1var devicelistener = require('devicefarmer-stf').deviceListener;2var devicelistener = require('devicefarmer-stf').deviceListener;3devicelistener.on('deviceConnected', function(device) {4    console.log('device connected event', device);5});6devicelistener.on('deviceDisconnected', function(device) {7    console.log('device disconnected event', device);8});9devicelistener.on('deviceRemoved', function(device) {10    console.log('device removed event', device);11});12var devicelistener = require('devicefarmer-stf').deviceListener;13devicelistener.on('deviceConnected', function(device) {14    console.log('device connected event', device);15});16devicelistener.on('deviceDisconnected', function(device) {17    console.log('device disconnected event', device);18});19devicelistener.on('deviceRemoved', function(device) {20    console.log('device removed event', device);21});22var devicelistener = require('devicefarmer-stf').deviceListener;23devicelistener.on('deviceConnected', function(device) {24    console.log('device connected event', device);25});26devicelistener.on('deviceDisconnected', function(device) {27    console.log('device disconnected event', device);28});29devicelistener.on('deviceRemoved', function(device) {30    console.log('device removed event', device);31});32var devicelistener = require('devicefarmer-stf').deviceListener;33devicelistener.on('deviceConnected', function(device) {34    console.log('device connected event', device);35});36devicelistener.on('deviceDisconnected', function(device) {37    console.log('device disconnected event', device);38});39devicelistener.on('deviceRemoved', function(device) {40    console.log('device removed event', device);41});42var devicelistener = require('devicefarmer-stf').deviceListener;43devicelistener.on('deviceConnected', function(device) {44    console.log('device connected event', device);45});46devicelistener.on('deviceDisconnected', function(device) {

Using AI Code Generation

1var DeviceFarmer = require('devicefarmer-stf-client');2var deviceFarmer = new DeviceFarmer();3deviceFarmer.deviceListener(function(err, device){4    if (err) {5        console.log(err);6    } else {7        console.log("device connected: " + device);8    }9});10var DeviceFarmer = require('devicefarmer-stf-client');11var deviceFarmer = new DeviceFarmer();12deviceFarmer.deviceListener(function(err, device){13    if (err) {14        console.log(err);15    } else {16        console.log("device connected: " + device);17    }18});19var DeviceFarmer = require('devicefarmer-stf-client');20var deviceFarmer = new DeviceFarmer();21deviceFarmer.deviceListener(function(err, device){22    if (err) {23        console.log(err);24    } else {25        console.log("device connected: " + device);26    }27});28var DeviceFarmer = require('devicefarmer-stf-client');29var deviceFarmer = new DeviceFarmer();30deviceFarmer.deviceListener(function(err, device){31    if (err) {32        console.log(err);33    } else {34        console.log("device connected: " + device);35    }36});37var DeviceFarmer = require('devicefarmer-stf-client');38var deviceFarmer = new DeviceFarmer();39deviceFarmer.deviceListener(function(err, device){40    if (err) {41        console.log(err);42    } else {43        console.log("device connected: " + device);44    }45});46var DeviceFarmer = require('devicefarmer-stf-client');47var deviceFarmer = new DeviceFarmer();48deviceFarmer.deviceListener(function(err, device){49    if (err) {50        console.log(err);51    } else {52        console.log("device connected: " + device);53    }54});

Using AI Code Generation

1const DeviceListener = require('devicefarmer-stf-client').DeviceListener;2const deviceListener = new DeviceListener();3deviceListener.on('deviceConnected', function(device){4    console.log("Device Connected");5});6deviceListener.on('deviceDisconnected', function(device){7    console.log("Device Disconnected");8});9deviceListener.on('deviceChanged', function(device){10    console.log("Device Changed");11});12deviceListener.on('deviceAdded', function(device){13    console.log("Device Added");14});15deviceListener.on('deviceRemoved', function(device){16    console.log("Device Removed");17});18deviceListener.on('deviceMessage', function(device, message){19    console.log("Device Message");20});21deviceListener.on('deviceLog', function(device, log){22    console.log("Device Log");23});24deviceListener.on('deviceError', function(device, error){25    console.log("Device Error");26});27deviceListener.on('deviceLogcat', function(device, log){28    console.log("Device Logcat");29});30deviceListener.on('deviceLogcatMessage', function(device, logcatMessage){31    console.log("Device Logcat Message");32});33deviceListener.on('deviceLogcatError', function(device, logcatError){34    console.log("Device Logcat Error");35});36deviceListener.on('deviceScreenshot', function(device, screenshot){37    console.log("Device Screenshot");38});39deviceListener.on('deviceVideo', function(device, video){40    console.log("Device Video");41});42deviceListener.on('deviceReverseForwards', function(device, reverseForwards){43    console.log("Device Reverse Forwards");44});45deviceListener.on('deviceReverseForward', function(device, reverseForward){46    console.log("Device Reverse Forward");47});48deviceListener.on('deviceReverseForwardError', function(device, reverseForwardError){49    console.log("Device Reverse Forward Error");50});51deviceListener.on('deviceReverseForwardRemoved', function(device, reverseForwardRemoved){52    console.log("Device Reverse Forward Removed");53});54deviceListener.on('deviceReverseForwardAdded', function(device, reverseForwardAdded){55    console.log("Device Reverse Forward Added");56});57deviceListener.on('deviceReverseForwardChanged', function(device, reverseForwardChanged){58    console.log("Device Reverse Forward Changed");59});60deviceListener.on('deviceReverseForwardMessage', function(device, reverseForwardMessage){61    console.log("Device Reverse Forward Message");62});63deviceListener.on('deviceReverseForwardLog', function(device, reverseForwardLog){64    console.log("Device Reverse Forward Log");65});

Using AI Code Generation

1var deviceFarmer = require('devicefarmer-stf.js');2var deviceListener = deviceFarmer.deviceListener;3deviceListener(function(device){4});5var deviceFarmer = require('devicefarmer-stf.js');6var deviceListener = deviceFarmer.deviceListener;7deviceListener(function(device){8});9var deviceFarmer = require('devicefarmer-stf.js');10var deviceListener = deviceFarmer.deviceListener;11deviceListener(function(device){12});13var deviceFarmer = require('devicefarmer-stf.js');14var deviceListener = deviceFarmer.deviceListener;15deviceListener(function(device){16});17var deviceFarmer = require('devicefarmer-stf.js');18var deviceListener = deviceFarmer.deviceListener;19deviceListener(function(device){20});21var deviceFarmer = require('devicefarmer-stf.js');22var deviceListener = deviceFarmer.deviceListener;23deviceListener(function(device){24});25var deviceFarmer = require('devicefarmer-stf.js');26var deviceListener = deviceFarmer.deviceListener;27deviceListener(function(device){28});29var deviceFarmer = require('devicefarmer-stf.js');30var deviceListener = deviceFarmer.deviceListener;31deviceListener(function(device){32});33var deviceFarmer = require('devicefarmer-stf.js');34var deviceListener = deviceFarmer.deviceListener;35deviceListener(function(device){

Using AI Code Generation

1var devicefarmer = require('devicefarmer-stf-client');2client.getDeviceListener('1234567890', function(err, device) {3  if (err) {4    console.error(err);5    process.exit(1);6  }7  device.on('deviceConnect', function(device) {8    console.log('device connected');9  });10  device.on('deviceDisconnect', function(device) {11    console.log('device disconnected');12  });13});14var devicefarmer = require('devicefarmer-stf-client');15client.getDeviceListener('1234567890', function(err, device) {16  if (err) {17    console.error(err);18    process.exit(1);19  }20  device.on('deviceConnect', function(device) {21    console.log('device connected');22  });23  device.on('deviceDisconnect', function(device) {24    console.log('device disconnected');25  });26});27var devicefarmer = require('devicefarmer-stf-client');28client.getDeviceListener('1234567890', function(err, device) {29  if (err) {30    console.error(err);31    process.exit(1);32  }33  device.on('deviceConnect', function(device) {34    console.log('device connected');35  });36  device.on('deviceDisconnect', function(device) {37    console.log('device disconnected');38  });39});40var devicefarmer = require('devicefarmer-stf-client');41client.getDeviceListener('1234567890', function(err, device) {42  if (err) {43    console.error(err);44    process.exit(1);45  }46  device.on('deviceConnect', function(device) {47    console.log('device connected');48  });49  device.on('deviceDisconnect', function(device) {50    console.log('device disconnected');51  });52});

Using AI Code Generation

1var DeviceFarmerClient = require('devicefarmer-stf-client');2var DeviceFarmer = new DeviceFarmerClient();3DeviceFarmer.deviceListener(function(device) {4  console.log(device);5});6var DeviceFarmerClient = require('devicefarmer-stf-client');7var DeviceFarmer = new DeviceFarmerClient();8DeviceFarmer.deviceListener(function(device) {9  console.log(device);10}

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.