chromesoul/lib/client.js

//
// Copyright (c) 2013 Rodolphe Breard
// 
// Permission to use, copy, modify, and/or distribute this software for any
// purpose with or without fee is hereby granted, provided that the above
// copyright notice and this permission notice appear in all copies.
// 
// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
// WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
// MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
// ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
// WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
// ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
// OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
//

var Client = function() {
    this.socket = null;
    this.is_connected = false;
    this.client = null;
    this.ui = null;
    this.status = null;
    this.contacts = [];
    this.waiting_contacts = [];
};

Client.prototype.createSocket = function() {
    if (this.socket === null) {
	this.socket = new TxtSocket();
	this.socket.onError = (function(elem) {
	    return function() {
		elem.is_connected = false;
		elem.connect();
	    };
	})(this);
    }
};

Client.prototype.connect = function() {
    if (!this.is_connected) {
	this.createSocket();
	this.socket.connect(this.client.host, this.client.port, (function(elem) {
	    return function() {
		elem.client.connect(elem, function() {
		    if (elem.is_connected) {
			elem.daemonize();
			elem.changeStatus();
			elem.addContact();
		    } else {
			elem.disconnect();
		    }
		});
	    };
	})(this));
    }
}

Client.prototype.disconnect = function() {
    if (this.is_connected) {
	this.is_connected = false;
	this.client.disconnect(this);
	this.socket.disconnect();
	this.socket = null;
    }
    this.changeStatus(this.client.status_disconnected);
};

Client.prototype.reconnect = function() {
    this.disconnect();
    this.connect();
};

Client.prototype.daemonize = function() {
    this.socket.read((function(elem) {
	return function(data) {
	    elem.client.recv(elem, data);
	    elem.daemonize();
	};
    })(this));
};

Client.prototype.changeStatus = function(status) {
    if (typeof status === 'undefined') {
	status = this.client.default_status;
    }
    if (status !== this.status) {
	this.status = status;
	this.updateStatus();
    }
};

Client.prototype.updateStatus = function() {
    if (this.status !== null) {
	this.client.changeStatus(this);
    }
};

Client.prototype.addContact = function(name) {
    if (typeof name !== 'undefined') {
	this.waiting_contacts.push(name);
    }
    if (this.is_connected) {
	var tmp = this.waiting_contacts;
	this.waiting_contacts = [];
	this.client.addContact(this, tmp);
    }
};

Client.prototype.rmContact = function(name) {
    if (this.is_connected) {
	this.client.rmContact(this, name);
    }
};

Client.prototype.speak = function(to, msg) {
    if (this.is_connected) {
	this.client.speak(this, to, msg);
    }
};

Client.prototype.init = function(client, ui) {
    this.client = client;
    this.ui = ui;

    this.connect();
    setInterval((function(elem) {
	return function() {
	    elem.connect();
	};
    })(this), 10000);

    setInterval((function(elem) {
	return function() {
	    elem.updateStatus();
	};
    })(this), 180000);
};