homegear-ws-0.0.1.js

/* Copyright 2013-2015 Sathya Laufer
 *
 * HomegearWS is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 * 
 * HomegearWS is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public
 * License along with HomegearWS.  If not, see
 * <http://www.gnu.org/licenses/>.
 * 
 * In addition, as a special exception, the copyright holders give
 * permission to link the code of portions of this program with the
 * OpenSSL library under certain conditions as described in each
 * individual source file, and distribute linked combinations
 * including the two.
 * You must obey the GNU Lesser General Public License in all respects
 * for all of the code used other than OpenSSL.  If you modify
 * file(s) with this exception, you may extend this exception to your
 * version of the file(s), but you are not obligated to do so.  If you
 * do not wish to do so, delete this exception statement from your
 * version.  If you delete this exception statement from all source
 * files in the program, then also delete it here.
*/

homegearWsSetTimeout = function (vCallback, nDelay) {
  var oThis = this, aArgs = Array.prototype.slice.call(arguments, 2);
  return setTimeout(vCallback instanceof Function ? function () {
    vCallback.apply(oThis, aArgs);
  } : vCallback, nDelay);
};

function HomegearWS(host, port, id, ssl, user, password)
{
	this.host = (typeof host !== 'string') ? 'localhost' : host;
	this.port = (typeof port !== 'undefined') ? port : '2001';
	this.id = (typeof id !== 'undefined') ? id : 'HomegearWS';
	this.id += "-" + this.getGuid();
	this.ssl = (typeof ssl !== 'undefined') ? (ssl === 'true' || ssl === true) : false;
	this.auth = user ? true : false;
	this.user = (typeof user !== 'undefined') ? user : undefined;
	this.password = (typeof password !== 'undefined') ? password : undefined;
	this.client = null;
	this.server = null;
	this.clientAuthenticated = !this.auth;
	this.serverAuthenticated = !this.auth;
	this.onEvent = Array();
	this.onReady = Array();
	this.onError = Array();
	this.peers = Array();
	this.enabled = false;
	this.messageCounter = 1;
	this.requests = {};
	this.sending = false;
	this.connectClientTimer = null;
	this.connectServerTimer = null;
}

HomegearWS.prototype.connect = function() {
	this.disconnect();
	this.enabled = true;
	this.connectClient();
	this.connectServer();
}

HomegearWS.prototype.disconnect = function() {
	this.enabled = false;
	this.sending = false;
	if(this.server) {
		this.server.close();
		this.server = null;
	}
	if(this.client) {
		this.client.close();
		this.client = null;
	}
}

HomegearWS.prototype.error = function(callback) {
	if(typeof callback === 'function') this.onError.push(callback);
}

HomegearWS.prototype.invokeError = function(message) {
	for(i in this.onError) {
		if(typeof this.onError[i] === 'function') this.onError[i](message); 
	}
}

HomegearWS.prototype.ready = function(callback) {
	if(typeof callback === 'function') this.onReady.push(callback);
}

HomegearWS.prototype.invokeReady = function() {
	for(i in this.onReady) {
		if(typeof this.onReady[i] === 'function') this.onReady[i](); 
	}
}

HomegearWS.prototype.event = function(callback) {
	if(typeof callback === 'function') this.onEvent.push(callback);
}

HomegearWS.prototype.invokeEvent = function(data) {
	for(i in this.onEvent) {
		if(typeof this.onEvent[i] === 'function') this.onEvent[i](data); 
	}
}

HomegearWS.prototype.connectServer = function() {
	this.server = new WebSocket(((this.ssl) ? 'wss://' : 'ws://') + this.host + ':' + this.port + '/' + this.id, "client");
	this.server.onmessage = function(event) {
		response = JSON.parse(event.data);
		if(!("auth" in response)) {
			request = {}
			this.server.send(JSON.stringify(request));
			this.invokeEvent(response);
		} else if(response.auth == "success") {
			this.serverAuthenticated = true;
			setTimeout(this.subscribePeers.bind(this), 0);
		} else this.invokeError("Authentication failed.");
	}.bind(this);
	this.server.onopen = function(event) {
		if(this.auth) {
			request = {
				user: this.user,
				password: this.password
			};
			this.server.send(JSON.stringify(request));
		}
		else setTimeout(this.subscribePeers.bind(this), 0);
	}.bind(this);
	this.server.onclose = function(event) {
		if(this.auth) this.serverAuthenticated = false;
		if(this.enabled)
		{
			this.server = null;
			clearTimeout(this.connectServerTimer);
			this.connectServerTimer = homegearWsSetTimeout.call(this, this.connectServer, 5000);
			this.invokeError("Server disconnected.");
		}
	}.bind(this);
	this.server.onerror = function(event)
	{
		this.server = null;
		if(this.auth) this.serverAuthenticated = false;
		clearTimeout(this.connectServerTimer);
		this.connectServerTimer = homegearWsSetTimeout.call(this, this.connectServer, 5000);
		this.invokeError(event.data);
	}.bind(this);
}

HomegearWS.prototype.connectClient = function() {
	this.client = new WebSocket(((this.ssl) ? 'wss://' : 'ws://') + this.host + ':' + this.port + '/' + this.id, 'server');
	this.client.onmessage = function(event) {
		this.sending = false;
		response = JSON.parse(event.data);
		if("auth" in response) {
			if(response.auth == 'success') this.clientAuthenticated = true;
			else this.invokeError("Authentication failed.");
		}
		else if(typeof response.id !== 'undefined' && typeof this.requests['c' + response.id] === 'function')
		{
			this.requests['c' + response.id](response);
			delete this.requests['c' + response.id];
			
		}
	}.bind(this);
	this.client.onopen = function(event) {
		if(this.auth) {
			request = {
				user: this.user,
				password: this.password
			};
			this.send(JSON.stringify(request));
		}
	}.bind(this);
	this.client.onclose = function(event) {
		if(this.auth) this.clientAuthenticated = false;
		if(this.enabled)
		{
			this.client = null;
			clearTimeout(this.connectClientTimer);
			this.connectClientTimer = homegearWsSetTimeout.call(this, this.connectClient, 5000);
			this.invokeError("Client disconnected.");
		}
	}.bind(this);
	this.client.onerror = function(event)
	{
		this.client = null;
		if(this.auth) this.clientAuthenticated = false;
		clearTimeout(this.connectClientTimer);
		this.connectClientTimer = homegearWsSetTimeout.call(this, this.connectClient, 5000);
		this.invokeError(event.data);
	}.bind(this);
}

HomegearWS.prototype.getTwoRandomHeyBytes = function() {
	return Math.floor((1 + Math.random()) * 0x10000).toString(16).substring(1);
}

HomegearWS.prototype.getGuid = function() {
	return this.getTwoRandomHeyBytes() + this.getTwoRandomHeyBytes() + '-' + this.getTwoRandomHeyBytes() + '-' + this.getTwoRandomHeyBytes() + '-' + this.getTwoRandomHeyBytes() + '-' + this.getTwoRandomHeyBytes() + this.getTwoRandomHeyBytes() + this.getTwoRandomHeyBytes();
}


HomegearWS.prototype.addPeers = function(ids) {
	if(!ids.constructor === Array) return;
	var newPeers = Array();
	for(i in ids) {
		var index = this.peers.indexOf(ids[i]);
		if(index == -1) {
			newPeers.push(ids[i]);
			this.peers.push(ids[i]);
		}
	}
	if(!this.isReady() || newPeers.length == 0) return;
	this.send(JSON.stringify({method:"subscribePeers",params:[this.id, newPeers]}));
}

HomegearWS.prototype.removePeers = function(ids) {
	if(!ids.constructor === Array) return;
	var peersToRemove = Array();
	for(i in ids) {
		var index = this.peers.indexOf(ids[i]);
		if(index != -1) {
			peersToRemove.push(ids[i]);
			this.peers.splice(index, 1);
		}
	}
	if(!this.isReady() || peersToRemove.length == 0) return;
	this.send(JSON.stringify({method:"unsubscribePeers",params:[this.id, peersToRemove]}));
}

HomegearWS.prototype.addPeer = function(id) {
	var index = this.peers.indexOf(id);
	if(index > -1) return;
	this.peers.push(id);
	if(!this.isReady()) return;
	this.send(JSON.stringify({method:"subscribePeers",params:[this.id, [id]]}));
}

HomegearWS.prototype.removePeer = function(id) {
	var index = this.peers.indexOf(id);
	if(index > -1) {
		this.peers.splice(index, 1);
	}
	if(!this.isReady()) return;
	this.send(JSON.stringify({method:"unsubscribePeers",params:[this.id, [id]]}));
}

HomegearWS.prototype.isReady = function() {
	return this.server && this.server.readyState === WebSocket.OPEN && this.client && this.client.readyState === WebSocket.OPEN && this.serverAuthenticated && this.clientAuthenticated;
}

HomegearWS.prototype.subscribePeers = function() {
	if(!this.isReady()) return;
	this.send(JSON.stringify({method:"subscribePeers",params:[this.id, this.peers]}));
	this.invokeReady();
}

HomegearWS.prototype.send = function(data) {
	if(this.sending)
	{
		homegearWsSetTimeout.call(this, this.send, 0, data);
		return;
	}
	this.sending = true;
	if(this.client) this.client.send(data);
}

HomegearWS.prototype.invoke = function(methodName) {
	if(!this.isReady()) return;
	var counter = this.messageCounter++;
	if(typeof arguments[0] === 'object' && typeof arguments[0].method !== 'undefined') {
		if(typeof arguments[1] === 'function') this.requests['c' + counter] = arguments[1];
		arguments[0].id = counter;
		this.send(JSON.stringify(arguments[0]));
	} else {
		if(typeof methodName !== 'string') return;
		var request = {
			jsonrpc: "2.0",
			method: methodName,
			id: counter
		}
		if(arguments.length > 1 && typeof arguments[1] === 'function') this.requests['c' + counter] = arguments[1];
		if(arguments.length > 2) request.params = Array.prototype.slice.call(arguments, 2);
		this.send(JSON.stringify(request));
	}
}