AccessoryController.js

AccessoryController.prototype = {
	addService: function addService(service) {
		service.instanceID = this.instanceID;
		service.accessoryController = this;
		this.objects[service.instanceID] = service;
		this.instanceID += 1;
		this.services.push(service);
		if (service.characteristics.length > 0) {
			for (var i = 0; i < service.characteristics.length; i++) {
				var characteristic = service.characteristics[i];
				characteristic.instanceID = this.instanceID;
				characteristic.accessoryID = 1;
				characteristic.accessoryController = this;
				this.objects[characteristic.instanceID] = characteristic;
				this.instanceID += 1;
			};
		}
	},
	accessoryJsonPresentation: function accessoryJsonPresentation() {
		var servicesObjects = [];
		for (var i = 0; i < this.services.length; i++) {
			var service = this.services[i];
			servicesObjects.push(service.objectsPresentation());
		};
		var accessory = {
			aid: this.accessoryID,
			services: servicesObjects
		}
		return accessory;
	},
	jsonPresentation: function jsonPresentation() {
		var servicesObjects = [];
		for (var i = 0; i < this.services.length; i++) {
			var service = this.services[i];
			servicesObjects.push(service.objectsPresentation());
		};
		var accessory = {
			aid: this.accessoryID,
			services: servicesObjects
		}
		var dict = {
			accessories: [accessory]
		}
		return JSON.stringify(dict);
	},
	jsonForCharacteristicUpdate: function jsonForCharacteristicUpdate(aid, iid, callback) {
		var charObject = this.objects[iid];
		var charValue = charObject.valueForUpdate(function(value){
			var respDict = {
				characteristics: [
					{
						aid: aid,
						iid: iid,
						value: value
					}
				]
			}
			callback(JSON.stringify(respDict));
		});
	},
	processSingleCharacteristicsValueWrite: function processSingleCharacteristicsValueWrite(update, peer) {
		var update_char = update;
		var update_char_iid = update_char["iid"];
		var update_char_value = update_char["value"];
		var update_char_event = update_char["ev"];
		var charObject = this.objects[update_char_iid];
		if (update_char_value !== undefined) {
			charObject.updateCharacteristicValue(update_char_value, peer);
		}
		if (update_char_event !== undefined) {
			charObject.updateCharacteristicEvent(update_char_event, peer);
		}
	},
	processCharacteristicsValueWrite: function processCharacteristicsValueWrite(updates, peer) {
		var updates_objects = JSON.parse(updates.toString());
		console.log(updates_objects);
		var update_characteristics = updates_objects["characteristics"];
		for (var i = 0; i < update_characteristics.length; i++) {
			var update_char = update_characteristics[i];
			var update_char_iid = update_char["iid"];
			var update_char_value = update_char["value"];
			var update_char_event = update_char["ev"];
			var charObject = this.objects[update_char_iid];
			if (update_char_value !== undefined) {
				charObject.updateCharacteristicValue(update_char_value, peer);
			}
			if (update_char_event !== undefined) {
				charObject.updateCharacteristicEvent(update_char_event, peer);
			}
		}
	},
	broadcastEvent: function broadcastEvent(data, subscribedPeers, peer) {
		if (this.tcpServer !== undefined) {
			this.tcpServer.broadcastEvent(data, subscribedPeers, peer);
		} else if (this.bridgeController !== undefined) {
			this.bridgeController.broadcastEvent(data, subscribedPeers, peer);
		}
	}
}

function AccessoryController() {
	if (!(this instanceof AccessoryController))  {
		return new AccessoryController();
	}
	this.accessoryID = 1;
	this.instanceID = 1;
	this.objects = {};
	this.services = [];
}

module.exports = {
	AccessoryController: AccessoryController
};