socket helper

socketHelper.js

var socketHelper = function() {

	this.clientId = "";

	this.getClientId = function() {
		return this.clientId;
	}

	this.address = "localhost";

	this.socket = new WebSocket(this.address);

	/** Keep messages in queue until socket connection is established */
	this.deferredMessages = [];
	this.deferredMessagesRun = function() {
		console.log("--- - deferredMessagesRun");

		if (this.deferredMessages.length > 0) {
			this.deferredMessages.forEach(function(id) {
				var shift = this.deferredMessages.shift();
				console.log("SHIFT", shift);
				
				var item = this.journalGet(shift);

				console.log(item);
				this.sendMessage(item);

			}, this);
		}
	}

	/** General message sending */
	this.sendMessage = function(message, cb, context) {
		if (message) {
			message.id = this.getClientId() + "%%" + Date.now();
		}
		if (typeof cb !== "function") {
			cb = false;
		}
		this.journalAdd(message, cb, context);

		if (this.socket.readyState === 1) {
			message = JSON.stringify(message);
			this.socket.send(message);
			$(".b_notifyze_loading").fadeIn("fast");
		} else {
			console.log('Defer message', message.id);
			this.deferredMessages.push(message.id);
		}
	}


	this.journal = {'_timer': {}};;

	/** Journal clear */
	this.journalClear = function() {
		// cleared on connection restart
		this.journal = {'_timer': {}};
		return true;
	}

	/** Journal Add */
	this.journalAdd = function(message, cb, context) {
		var _this = this;
		this.journal[message.id] = message;
		if (typeof cb === "function") {
			this.journal[message.id + '_cb'] = cb;
			if (typeof context != "undefined") {
				this.journal[message.id + '_cb_context'] = context;
			}
		}

	}
	/** Journal item getter */
	this.journalGet = function(messageId) {
		return this.journal[messageId];
	}

	return this;

}