telldus/telldus-gui/Plugins/Live/__init__.js

__setupPackage__( __extension__ );

com.telldus.live = function() {
	var socket = null;
	var menuId = 0;
	var separatorId = 0;
	var isRegistered = false;
	var supportedMethods = 0;
	var configUI = null;

	function init() {
		configUI = application.configuration.addPage('Telldus Live!', 'configuration.ui', 'icon.png');
		socket = new LiveSocket();
		socket.errorChanged.connect(errorChanged);
		socket.statusChanged.connect(statusChanged);
		socket.notRegistered.connect(notRegistered);
		socket.registered.connect(registered);
		socket.messageReceived.connect(messageReceived);
		socket.connectToServer();
		com.telldus.core.deviceEvent.connect(deviceEvent);
		com.telldus.core.deviceChange.connect(sendDevicesReport);
		configUI.findChild('registrationLink').clicked.connect(socket.activate);
		configUI.findChild('registrationLink').visible = false;
	}

	function notRegistered() {
		isRegistered = false;
		if (com.telldus.systray && !menuId) {
			separatorId = com.telldus.systray.addSeparator();
			menuId = com.telldus.systray.addMenuItem( qsTr("Activate Telldus Live!") );
			com.telldus.systray.menuItem(menuId).triggered.connect(socket.activate);
		}
		registrationLinkVisible(true);
	}

	function deviceEvent(deviceId, method, data) {
		msg = new LiveMessage("DeviceEvent");
		msg.append(deviceId);
		msg.append(method);
		msg.append(data);
		socket.sendMessage(msg);
	}

	function deviceChangeEvent() {
	}

	function messageReceived(msg) {
		if (msg.name() == "command") {
			handleCommand(msg.argument(0));
		}
	}

	function handleCommand(msg) {
		var action = msg.getString('action');
		if (action == "turnon") {
			com.telldus.core.turnOn( msg.getInt('id') );
		} else if (action == "turnoff") {
			com.telldus.core.turnOff( msg.getInt('id') );
		} else if (action == "dim") {
			com.telldus.core.dim( msg.getInt('id'), msg.getInt('value') );
		} else if (action == "bell") {
			com.telldus.core.bell( msg.getInt('id') );
		} else if (action == "up") {
			com.telldus.core.up( msg.getInt('id') );
		} else if (action == "down") {
			com.telldus.core.down( msg.getInt('id') );
		} else if (action == "stop") {
			com.telldus.core.stop( msg.getInt('id') );
		}
	}

	function isRegisteredToLive(){
		return isRegistered;
	}

	function registered(msg) {
		if (menuId > 0) {
			com.telldus.systray.removeMenuItem(menuId);
			com.telldus.systray.removeMenuItem(separatorId);
			menuId = 0;
			separatorId = 0;
		}
		//Mask to lowest common denominator
		supportedMethods =
			com.telldus.core.TELLSTICK_TURNON |
			com.telldus.core.TELLSTICK_TURNOFF |
			com.telldus.core.TELLSTICK_DIM |
			com.telldus.core.TELLSTICK_BELL |
			com.telldus.core.TELLSTICK_UP |
			com.telldus.core.TELLSTICK_DOWN |
			com.telldus.core.TELLSTICK_STOP;
		supportedMethods = supportedMethods & msg.getInt('supportedMethods');
		isRegistered = true;
		registrationLinkVisible(false);
		sendDevicesReport();
	}

	function registrationLinkVisible(visibleParam){
		configUI.findChild('registrationLink').visible = visibleParam;
		if (com.telldus.sensors) {
			com.telldus.sensors.showLiveOptions(!visibleParam);
		}
	}

	function sendDevicesReport() {
		if (!isRegistered) {
			return;
		}
		msg = new LiveMessage("DevicesReport");
		var deviceList = com.telldus.core.deviceList.getList();
		list = new LiveMessageToken();
		for( i in deviceList ) {
			device = new LiveMessageToken();
			device.set('id', deviceList[i].id);
			device.set('name', deviceList[i].name);
			device.set('methods', com.telldus.core.methods(deviceList[i].id, supportedMethods) );
			device.set('state', com.telldus.core.lastSentCommand(deviceList[i].id, supportedMethods) );
			device.set('stateValue', com.telldus.core.lastSentValue(deviceList[i].id, supportedMethods) );
			list.add(device);
		}
		msg.appendToken(list);
		socket.sendMessage(msg);
	}

	function sendSensorsReport(sensorList) {
		if (!isRegistered) {
			return;
		}
		msg = new LiveMessage("SensorsReport");

		list = new LiveMessageToken();
		for( i in sensorList ) {
			sensorFrame = new LiveMessageToken();
			sensor = new LiveMessageToken();
			sensor.set('name', sensorList[i].name);
			sensor.set('protocol', sensorList[i].protocol);
			sensor.set('model', sensorList[i].model);
			sensor.set('sensor_id', sensorList[i].id);
			var valueList = new LiveMessageToken();
			for( j in sensorList[i].values ){
				valueElement = new LiveMessageToken()
				valueElement.set('type', sensorList[i].values[j].type);
				valueElement.set('lastUp', sensorList[i].values[j].lastUpdated);
				valueElement.set('value', sensorList[i].values[j].value);
				valueList.add(valueElement);
			}
			sensorFrame.add(sensor);
			sensorFrame.add(valueList);
			list.add(sensorFrame);
		}
		msg.appendToken(list);
		socket.sendMessage(msg);
	}

	function sendSensorValues(sensor, sensorvalues){
		if (!isRegistered) {
			return;
		}
		msg = new LiveMessage("SensorEvent");
		sensortoken = new LiveMessageToken();
		sensortoken.set('protocol', sensor.protocol);
		sensortoken.set('model', sensor.model);
		sensortoken.set('sensor_id', sensor.id);
		var valueList = new LiveMessageToken();
		for( j=0; j<sensorvalues.length; j++ ) {
			valueElement = new LiveMessageToken()
			valueElement.set('type', sensorvalues[j].type);
			valueElement.set('lastUp', sensorvalues[j].lastUpdated);
			valueElement.set('value', sensorvalues[j].value);
			valueList.add(valueElement);
		}
		msg.appendToken(sensortoken);
		msg.appendToken(valueList);
		socket.sendMessage(msg);
	}

	function errorChanged(msg) {
		configUI.findChild('errorLabel').text = msg;
	}

	function statusChanged(msg) {
		configUI.findChild('statusLabel').text = msg;
	}

	return { //Public functions
		init:init,
		sendSensorsReport:sendSensorsReport,
		isRegisteredToLive:isRegisteredToLive,
		sendSensorValues:sendSensorValues
	}
}();

__postInit__ = function() {
	application.allDoneLoading.connect( com.telldus.live.init );
}