2011-04-07 02:31:22 +04:00
|
|
|
/**
|
|
|
|
|
* @preserve This file is part of Mibew Messenger project.
|
|
|
|
|
* http://mibew.org
|
|
|
|
|
*
|
|
|
|
|
* Copyright (c) 2005-2011 Mibew Messenger Community
|
|
|
|
|
* License: http://mibew.org/license.php
|
|
|
|
|
*/
|
|
|
|
|
|
2008-09-29 20:10:06 +04:00
|
|
|
var FrameUtils = {
|
|
|
|
|
getDocument: function(frm) {
|
|
|
|
|
if (frm.contentDocument) {
|
2008-09-30 03:24:18 +04:00
|
|
|
return frm.contentDocument;
|
2008-09-29 20:10:06 +04:00
|
|
|
} else if (frm.contentWindow) {
|
|
|
|
|
return frm.contentWindow.document;
|
|
|
|
|
} else if (frm.document) {
|
|
|
|
|
return frm.document;
|
|
|
|
|
} else {
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
},
|
2008-09-30 03:24:18 +04:00
|
|
|
|
2008-09-29 20:10:06 +04:00
|
|
|
initFrame: function(frm) {
|
|
|
|
|
var doc = this.getDocument(frm);
|
|
|
|
|
doc.open();
|
|
|
|
|
doc.write("<html><head>");
|
2009-06-05 19:49:51 +04:00
|
|
|
doc.write("<link rel=\"stylesheet\" type=\"text/css\" media=\"all\" href=\""+Chat.cssfile+"\">");
|
|
|
|
|
doc.write("</head><body bgcolor='#FFFFFF' text='#000000' link='#C28400' vlink='#C28400' alink='#C28400'>");
|
2011-03-30 02:01:04 +04:00
|
|
|
doc.write("<table width='100%' cellspacing='0' cellpadding='0' border='0'><tr><td valign='top' class='message' id='content'></td></tr></table><a id='bottom' name='bottom'></a>");
|
2008-09-29 20:10:06 +04:00
|
|
|
doc.write("</body></html>");
|
|
|
|
|
doc.close();
|
|
|
|
|
frm.onload = function() {
|
2011-04-07 02:31:22 +04:00
|
|
|
if( frm.myHtml ) {
|
2008-09-29 20:10:06 +04:00
|
|
|
FrameUtils.getDocument(frm).getElementById('content').innerHTML += frm.myHtml;
|
|
|
|
|
FrameUtils.scrollDown(frm);
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
insertIntoFrame: function(frm, htmlcontent) {
|
|
|
|
|
var vcontent = this.getDocument(frm).getElementById('content');
|
|
|
|
|
if( vcontent == null ) {
|
|
|
|
|
if( !frm.myHtml ) frm.myHtml = "";
|
|
|
|
|
frm.myHtml += htmlcontent;
|
|
|
|
|
} else {
|
|
|
|
|
vcontent.innerHTML += htmlcontent;
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
scrollDown: function(frm) {
|
|
|
|
|
var vbottom = this.getDocument(frm).getElementById('bottom');
|
|
|
|
|
if( myAgent == 'opera' ) {
|
2009-04-24 19:09:46 +04:00
|
|
|
try {
|
|
|
|
|
frm.contentWindow.scrollTo(0,this.getDocument(frm).getElementById('content').clientHeight);
|
|
|
|
|
} catch(e) {}
|
|
|
|
|
}
|
|
|
|
|
if( vbottom ) {
|
2008-09-29 20:10:06 +04:00
|
|
|
vbottom.scrollIntoView(false);
|
2009-04-24 19:09:46 +04:00
|
|
|
}
|
2008-09-29 20:10:06 +04:00
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
ChatServer = Class.create();
|
|
|
|
|
/**
|
|
|
|
|
* @todo Think about error handling
|
|
|
|
|
*/
|
|
|
|
|
ChatServer.prototype = {
|
|
|
|
|
/**
|
|
|
|
|
* @constructor
|
|
|
|
|
*/
|
|
|
|
|
initialize: function(options) {
|
|
|
|
|
var chatServer = this;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Update timer
|
|
|
|
|
*/
|
|
|
|
|
this.updateTimer = null;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Options for the ChatServer object
|
|
|
|
|
* @private
|
|
|
|
|
* @todo Check onResponseError handler
|
|
|
|
|
*/
|
|
|
|
|
this.options = {
|
|
|
|
|
// Server gateway URL
|
|
|
|
|
servl: "",
|
|
|
|
|
// Frequency for automatic updater
|
|
|
|
|
requestsFrequency: 2,
|
|
|
|
|
// Call on request timeout
|
|
|
|
|
onTimeout: function() {},
|
|
|
|
|
// Call when transport error was caught
|
|
|
|
|
onTransportError: function(e) {},
|
|
|
|
|
// Call when callFunctions related error was caught
|
|
|
|
|
onCallError: function(e) {},
|
|
|
|
|
// Call when update related error was caught
|
|
|
|
|
onUpdateError: function(e) {},
|
|
|
|
|
// Call when response related error was caught
|
|
|
|
|
onResponseError: function(e) {}
|
|
|
|
|
}.extend(options);
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Binds request's token and callback function
|
|
|
|
|
* @type Object
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
this.callbacks = {};
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Array of periodically called functions
|
|
|
|
|
* @type Array
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
this.callPeriodically = [];
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Options for an Ajax.Request object
|
|
|
|
|
* @type Array
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
this.ajaxOptions = {
|
|
|
|
|
_method: 'post',
|
|
|
|
|
asynchronous: true,
|
|
|
|
|
timeout: 5000,
|
|
|
|
|
onComplete: chatServer.receiveResponse.bind(chatServer),
|
|
|
|
|
onException: chatServer.onTransportError.bind(chatServer),
|
|
|
|
|
onTimeout: chatServer.onTimeout.bind(chatServer)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* An object of the Ajax.Request class
|
|
|
|
|
* @type Ajax.Request
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
this.ajaxRequest = null;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* This buffer store requests and responses between sending packages
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
this.buffer = [];
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Contains object of registered functions handlers
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
this.functions = {}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* An instance of the MibewAPI class
|
|
|
|
|
* @type MibewAPI
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
this.mibewAPI = new MibewAPI(new MibewAPICoreInteraction());
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Make call to the chat server
|
|
|
|
|
*
|
|
|
|
|
* @param {Oblect[]} functionsList List of the function objects. See Mibew API
|
|
|
|
|
* for details.
|
|
|
|
|
* @param {Function} callbackFunction
|
|
|
|
|
* @param {Boolean} forceSend Force requests buffer send right after call
|
|
|
|
|
* @returns {Boolean} boolean true on success and false on failure
|
|
|
|
|
*/
|
|
|
|
|
callFunctions: function(functionsList, callbackFunction, forceSend) {
|
|
|
|
|
try {
|
|
|
|
|
// Check function objects
|
|
|
|
|
if (!(functionsList instanceof Array)) {
|
|
|
|
|
throw new Error("The first arguments must be an array");
|
|
|
|
|
}
|
|
|
|
|
for (var i in functionsList) {
|
|
|
|
|
// Filter 'Prototype' properties
|
|
|
|
|
if (! functionsList.hasOwnProperty(i)) {
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
this.mibewAPI.checkFunction(functionsList[i], false);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Generate request token
|
|
|
|
|
var token = this.generateToken();
|
|
|
|
|
// Store callback function
|
|
|
|
|
this.callbacks[token] = callbackFunction;
|
|
|
|
|
|
|
|
|
|
// Add request to buffer
|
|
|
|
|
this.buffer.push({
|
|
|
|
|
'token': token,
|
|
|
|
|
'functions': functionsList
|
|
|
|
|
});
|
|
|
|
|
if (forceSend) {
|
|
|
|
|
// Force update
|
|
|
|
|
this.update();
|
|
|
|
|
}
|
|
|
|
|
} catch (e) {
|
|
|
|
|
// Handle errors
|
|
|
|
|
this.options.onCallError(e);
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
return true;
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Call function at every request to build functions list
|
|
|
|
|
*
|
|
|
|
|
* @param {Function} functionsListBuilder Call before every request to build a
|
|
|
|
|
* list of functions that must be called
|
|
|
|
|
* @param {Function} callbackFunction Call after response received
|
|
|
|
|
*/
|
|
|
|
|
callFunctionsPeriodically: function(functionsListBuilder, callbackFunction) {
|
|
|
|
|
this.callPeriodically.push({
|
|
|
|
|
functionsListBuilder: functionsListBuilder,
|
|
|
|
|
callbackFunction: callbackFunction
|
|
|
|
|
});
|
2008-09-30 03:24:18 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Generates unique request token
|
|
|
|
|
*
|
|
|
|
|
* @private
|
|
|
|
|
* @returns {String} Request token
|
|
|
|
|
*/
|
|
|
|
|
generateToken: function() {
|
|
|
|
|
var token;
|
|
|
|
|
do {
|
|
|
|
|
// Create token
|
|
|
|
|
token = "wnd" +
|
|
|
|
|
(new Date()).getTime().toString() +
|
|
|
|
|
(Math.round(Math.random() * 50)).toString();
|
|
|
|
|
// Check token uniqueness
|
|
|
|
|
} while(token in this.callbacks);
|
|
|
|
|
return token;
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Process request
|
|
|
|
|
*
|
|
|
|
|
* @param {Object} requestObject Request object. See Mibew API for details.
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
processRequest: function(requestObject) {
|
|
|
|
|
var context = new MibewAPIExecutionContext();
|
|
|
|
|
|
|
|
|
|
// Get result function
|
|
|
|
|
var resultFunction = this.mibewAPI.getResultFunction(
|
|
|
|
|
requestObject.functions,
|
|
|
|
|
this.callbacks.hasOwnProperty(requestObject.token)
|
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
if (resultFunction === null) {
|
|
|
|
|
// Result function not found
|
|
|
|
|
for (var i in requestObject.functions) {
|
|
|
|
|
if (! requestObject.functions.hasOwnProperty(i)) {
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
// Execute functions
|
|
|
|
|
this.processFunction(requestObject.functions[i], context);
|
|
|
|
|
// Build and store result
|
|
|
|
|
this.buffer.push(this.mibewAPI.buildResult(
|
|
|
|
|
context.getResults(),
|
|
|
|
|
requestObject.token
|
|
|
|
|
));
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
// Result function found
|
|
|
|
|
if (this.callbacks.hasOwnProperty(requestObject.token)) {
|
|
|
|
|
// Invoke callback
|
|
|
|
|
this.callbacks[requestObject.token](resultFunction.arguments);
|
|
|
|
|
// Remove callback
|
|
|
|
|
delete this.callbacks[requestObject.token];
|
|
|
|
|
}
|
|
|
|
|
}
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
2008-09-30 03:24:18 +04:00
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Process function
|
|
|
|
|
*
|
|
|
|
|
* @param {Object} functionObject Function object. See Mibew API for details
|
|
|
|
|
* @param {MibewAPIExecutionContext} context Execution context
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
processFunction: function(functionObject, context) {
|
|
|
|
|
if (! this.functions.hasOwnProperty(functionObject["function"])) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
// Get function arguments with replaced refences
|
|
|
|
|
var functionArguments = context.getArgumentsList(functionObject);
|
|
|
|
|
|
|
|
|
|
var results = {};
|
|
|
|
|
for (var i in this.functions[functionObject["function"]]) {
|
|
|
|
|
if (! this.functions[functionObject["function"]].hasOwnProperty(i)) {
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
// Get results
|
|
|
|
|
results.extend(this.functions[functionObject["function"]][i](
|
|
|
|
|
functionArguments
|
|
|
|
|
));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Add function results to the execution context
|
|
|
|
|
context.storeFunctionResults(functionObject, results);
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Send the request to the chat server
|
|
|
|
|
*
|
|
|
|
|
* @param {Object[]} requestsList Array of requests that must be sent to the
|
|
|
|
|
* chat server
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
sendRequests: function(requestsList) {
|
|
|
|
|
// Create new AJAX request
|
|
|
|
|
this.ajaxRequest = new Ajax.Request(
|
|
|
|
|
this.options.servl,
|
|
|
|
|
this.ajaxOptions.extend({
|
|
|
|
|
parameters: 'data=' + this.mibewAPI.encodePackage(requestsList)
|
|
|
|
|
})
|
|
|
|
|
);
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Sets up next automatic updater iteration
|
|
|
|
|
*/
|
|
|
|
|
runUpdater: function() {
|
|
|
|
|
if (this.updateTimer == null) {
|
|
|
|
|
this.update();
|
|
|
|
|
}
|
|
|
|
|
this.updateTimer = setTimeout(
|
|
|
|
|
this.update.bind(this),
|
|
|
|
|
this.options.requestsFrequency * 1000
|
|
|
|
|
);
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Restarts the automatic updater
|
|
|
|
|
*/
|
|
|
|
|
restartUpdater: function() {
|
|
|
|
|
// Clear timeout
|
|
|
|
|
if (this.updateTimer) {
|
|
|
|
|
clearTimeout(this.updateTimer);
|
|
|
|
|
}
|
|
|
|
|
// Clear request onComplete callback
|
|
|
|
|
if (this.ajaxRequest._options) {
|
|
|
|
|
this.ajaxRequest._options.onComplete = undefined;
|
|
|
|
|
}
|
|
|
|
|
// Update thread
|
|
|
|
|
this.update();
|
|
|
|
|
// Restart updater. Try to reconnect after a while
|
|
|
|
|
this.updateTimer = setTimeout(
|
|
|
|
|
this.update.bind(this),
|
|
|
|
|
1000
|
|
|
|
|
);
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Send request for update thread and client code's requests
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
2008-09-29 20:10:06 +04:00
|
|
|
update: function() {
|
2012-10-02 14:53:52 +04:00
|
|
|
if (this.updateTimer) {
|
|
|
|
|
clearTimeout(this.updateTimer);
|
|
|
|
|
}
|
|
|
|
|
for (var i = 0; i < this.callPeriodically.length; i++) {
|
|
|
|
|
this.callFunctions(
|
|
|
|
|
this.callPeriodically[i].functionsListBuilder(),
|
|
|
|
|
this.callPeriodically[i].callbackFunction
|
|
|
|
|
);
|
|
|
|
|
}
|
|
|
|
|
// Check buffer length
|
|
|
|
|
if (this.buffer.length == 0) {
|
|
|
|
|
// Rerun updater later
|
|
|
|
|
this.runUpdater();
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
// Send requests
|
|
|
|
|
this.sendRequests(this.buffer);
|
|
|
|
|
// Clear requests buffer
|
|
|
|
|
this.buffer = [];
|
|
|
|
|
} catch (e) {
|
|
|
|
|
// Handle errors
|
|
|
|
|
this.options.onUpdateError(e);
|
|
|
|
|
}
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Process response from the Core
|
|
|
|
|
*
|
|
|
|
|
* @param {String} responseObject The response object provided by
|
|
|
|
|
* Ajax.Request class
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
receiveResponse: function(responseObject) {
|
|
|
|
|
// Do not parse empty responses
|
|
|
|
|
if (responseObject.response == '') {
|
|
|
|
|
this.runUpdater();
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
var packageObject = this.mibewAPI.decodePackage(responseObject.response);
|
|
|
|
|
for (var i in packageObject.requests) {
|
|
|
|
|
this.processRequest(packageObject.requests[i]);
|
|
|
|
|
}
|
|
|
|
|
} catch (e) {
|
|
|
|
|
this.options.onResponseError(e);
|
|
|
|
|
} finally {
|
|
|
|
|
this.runUpdater();
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Add function that can be called by the Core
|
|
|
|
|
*
|
|
|
|
|
* @param {String} functionName Name of the function
|
|
|
|
|
* @param {Function} handler Provided function
|
|
|
|
|
*/
|
|
|
|
|
registerFunction: function(functionName, handler) {
|
|
|
|
|
if (!(functionName in this.functions)) {
|
|
|
|
|
this.functions[functionName] = [];
|
|
|
|
|
}
|
|
|
|
|
this.functions[functionName].push(handler);
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Call on all AJAX transport errors
|
|
|
|
|
* @param {Ajax.Request} transport AJAX Transport object
|
|
|
|
|
* @param {Error} e Error object
|
|
|
|
|
*/
|
|
|
|
|
onTransportError: function (transport, e) {
|
|
|
|
|
this.restartUpdater();
|
|
|
|
|
this.options.onTransportError(e);
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Call on all timeouts
|
|
|
|
|
*/
|
|
|
|
|
onTimeout: function(transport) {
|
|
|
|
|
this.restartUpdater();
|
|
|
|
|
this.options.onTimeout()
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
ChatThreadUpdater = Class.create();
|
|
|
|
|
ChatThreadUpdater.prototype = {
|
|
|
|
|
/**
|
|
|
|
|
* @constructor
|
|
|
|
|
* @todo Add error handlers to chatServer
|
|
|
|
|
* @todo Think about code format
|
|
|
|
|
*/
|
|
|
|
|
initialize: function(chatServer, thread, options) {
|
|
|
|
|
/**
|
|
|
|
|
* Array of options
|
|
|
|
|
* @type Array
|
|
|
|
|
* @private
|
|
|
|
|
*/
|
|
|
|
|
this._options = options;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* An instance of the Thread class
|
|
|
|
|
* @type ChatThread
|
|
|
|
|
*/
|
|
|
|
|
this.thread = {
|
|
|
|
|
threadid: 0,
|
|
|
|
|
token: 0,
|
|
|
|
|
lastid: 0,
|
|
|
|
|
user: false
|
|
|
|
|
}.extend(thread || {});
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* An instance of the ChatServer class
|
|
|
|
|
* @type ChatServer
|
|
|
|
|
*/
|
|
|
|
|
this.chatServer = chatServer;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Indicates if user can post messages
|
|
|
|
|
* @type Boolean
|
|
|
|
|
*/
|
|
|
|
|
this.cansend = true;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Indicates if next message's sound must be skipped
|
|
|
|
|
* @type Boolean
|
|
|
|
|
*/
|
|
|
|
|
this.skipNextsound = true;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Indicates if message input area ihn focus
|
|
|
|
|
* @type Boolean
|
|
|
|
|
*/
|
|
|
|
|
this.focused = true;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Indicates the thread belong to this operator
|
|
|
|
|
* @type Boolean
|
|
|
|
|
*/
|
|
|
|
|
this.ownThread = this._options.message != null;
|
|
|
|
|
|
|
|
|
|
FrameUtils.initFrame(this._options.container);
|
|
|
|
|
if (this._options.message) {
|
|
|
|
|
this._options.message.onkeydown = this.handleKeyDown.bind(this);
|
|
|
|
|
this._options.message.onfocus = (function() {this.focused = true;}).bind(this);
|
|
|
|
|
this._options.message.onblur = (function() {this.focused = false;}).bind(this);
|
2008-09-30 03:24:18 +04:00
|
|
|
}
|
2012-10-02 14:53:52 +04:00
|
|
|
|
|
|
|
|
// Add periodic functions
|
|
|
|
|
this.chatServer.callFunctionsPeriodically(
|
|
|
|
|
this.updateFunctionBuilder.bind(this),
|
|
|
|
|
this.updateChatState.bind(this)
|
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
// Register functions
|
|
|
|
|
this.chatServer.registerFunction(
|
|
|
|
|
'updateMessages',
|
|
|
|
|
this.updateMessages.bind(this)
|
|
|
|
|
);
|
|
|
|
|
this.chatServer.registerFunction(
|
|
|
|
|
'setupAvatar',
|
|
|
|
|
this.setupAvatar.bind(this)
|
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
this.chatServer.runUpdater();
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Exception handler. Updates status message
|
|
|
|
|
*/
|
|
|
|
|
handleException: function(e) {
|
|
|
|
|
this.setStatus("offline, reconnecting");
|
|
|
|
|
this.enableInput(true);
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Timeout handler. Updates status message
|
|
|
|
|
*/
|
|
|
|
|
handleTimeout: function() {
|
|
|
|
|
this.setStatus("timeout, reconnecting");
|
|
|
|
|
this.enableInput(true);
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Enables or disables input field
|
|
|
|
|
* @param {Boolean} val Use boolean true for enable input and false otherwise
|
|
|
|
|
*/
|
|
|
|
|
enableInput: function(val) {
|
|
|
|
|
if( this._options.message ) {
|
|
|
|
|
this._options.message.disabled = !val;
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Load new messages by restarting thread updater.
|
|
|
|
|
*/
|
|
|
|
|
refresh: function() {
|
|
|
|
|
this.chatServer.restartUpdater();
|
|
|
|
|
},
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Sends message to the chat server
|
|
|
|
|
* @param {String} msg Message for send
|
|
|
|
|
*/
|
2008-09-29 20:10:06 +04:00
|
|
|
postMessage: function(msg) {
|
2012-10-02 14:53:52 +04:00
|
|
|
// Check if message can be sent
|
|
|
|
|
if(msg == "" || !this.cansend) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
// Disable message sending
|
|
|
|
|
this.cansend = false;
|
|
|
|
|
// Disable next sound
|
|
|
|
|
this.skipNextsound = true;
|
|
|
|
|
// Disable input
|
|
|
|
|
if(myRealAgent != 'opera') {
|
|
|
|
|
this.enableInput(false);
|
|
|
|
|
}
|
|
|
|
|
// Post message
|
|
|
|
|
this.chatServer.callFunctions(
|
|
|
|
|
[{
|
|
|
|
|
"function": "post",
|
|
|
|
|
"arguments": {
|
|
|
|
|
"references": {},
|
|
|
|
|
"return": {},
|
|
|
|
|
"message": msg,
|
|
|
|
|
"threadId": this.thread.threadid,
|
|
|
|
|
"token": this.thread.token,
|
|
|
|
|
"user": this.thread.user
|
|
|
|
|
}
|
|
|
|
|
}],
|
|
|
|
|
(function(){
|
|
|
|
|
this.enableInput(true);
|
|
|
|
|
this.cansend = true;
|
|
|
|
|
this.skipNextsound = false;
|
|
|
|
|
if(this._options.message) {
|
|
|
|
|
this._options.message.value = '';
|
|
|
|
|
this._options.message.focus();
|
|
|
|
|
}
|
|
|
|
|
}).bind(this),
|
|
|
|
|
true
|
|
|
|
|
);
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Change user name
|
|
|
|
|
* @param {String} newname A new user name
|
|
|
|
|
*/
|
2008-09-29 20:10:06 +04:00
|
|
|
changeName: function(newname) {
|
2012-10-02 14:53:52 +04:00
|
|
|
this.skipNextsound = true;
|
|
|
|
|
this.chatServer.callFunctions(
|
|
|
|
|
[{
|
|
|
|
|
"function": "rename",
|
|
|
|
|
"arguments": {
|
|
|
|
|
"references": {},
|
|
|
|
|
"return": {},
|
|
|
|
|
"threadId": this.thread.threadid,
|
|
|
|
|
"token": this.thread.token,
|
|
|
|
|
"name": newname
|
|
|
|
|
}
|
|
|
|
|
}],
|
|
|
|
|
(function(args){
|
|
|
|
|
if (args.errorCode) {
|
|
|
|
|
this.handleError(args, 'cannot rename');
|
|
|
|
|
}
|
|
|
|
|
}).bind(this),
|
|
|
|
|
true
|
|
|
|
|
);
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
2008-09-30 03:24:18 +04:00
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Send request for close chat to the core
|
|
|
|
|
*/
|
|
|
|
|
closeThread: function() {
|
|
|
|
|
// Show confirmation message if can
|
|
|
|
|
if(this._options.localizedStrings.closeConfirmation){
|
|
|
|
|
if(! confirm(this._options.localizedStrings.closeConfirmation)){
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
// Send request
|
|
|
|
|
this.chatServer.callFunctions(
|
|
|
|
|
[{
|
|
|
|
|
"function": "close",
|
|
|
|
|
"arguments": {
|
|
|
|
|
"references": {},
|
|
|
|
|
"return": {"closed": "closed"},
|
|
|
|
|
"threadId": this.thread.threadid,
|
|
|
|
|
"token": this.thread.token,
|
|
|
|
|
"lastId": this.thread.lastid,
|
|
|
|
|
"user": this.thread.user
|
|
|
|
|
}
|
|
|
|
|
}],
|
|
|
|
|
this.onThreadClosed.bind(this),
|
|
|
|
|
true
|
|
|
|
|
);
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Callback function for close chat request.
|
|
|
|
|
*
|
|
|
|
|
* Close chat window if closing success or warn on fail
|
|
|
|
|
*/
|
|
|
|
|
onThreadClosed: function(args) {
|
|
|
|
|
if (args.closed) {
|
|
|
|
|
window.close();
|
|
|
|
|
} else {
|
|
|
|
|
this.handleError(args, 'cannot close');
|
|
|
|
|
}
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Add message to the message window
|
|
|
|
|
* @param {Object} _target Target DOM element
|
|
|
|
|
* @param {String} message HTML message to insert
|
|
|
|
|
*/
|
2008-09-29 20:10:06 +04:00
|
|
|
processMessage: function(_target, message) {
|
2012-10-02 14:53:52 +04:00
|
|
|
FrameUtils.insertIntoFrame(_target, message);
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Displays typing status
|
|
|
|
|
* @param {Boolean} istyping Indicates the other side of conversation is
|
|
|
|
|
* typing a message or not
|
|
|
|
|
*/
|
2008-09-29 20:10:06 +04:00
|
|
|
showTyping: function(istyping) {
|
|
|
|
|
if( $("typingdiv") ) {
|
|
|
|
|
$("typingdiv").style.display=istyping ? 'inline' : 'none';
|
2008-09-30 03:24:18 +04:00
|
|
|
}
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Update operator's avatar
|
|
|
|
|
* @param {Array} args Array of arguments passed from the core
|
|
|
|
|
*/
|
|
|
|
|
setupAvatar: function(args) {
|
|
|
|
|
if (this._options.avatar && this.thread.user) {
|
|
|
|
|
this._options.avatar.innerHTML = args.imageLink != ""
|
|
|
|
|
? "<img src=\""+this._options.webimRoot+"/images/free.gif\" width=\"7\" height=\"1\" border=\"0\" alt=\"\" /><img src=\""
|
|
|
|
|
+args.imageLink+ "\" border=\"0\" alt=\"\"/>"
|
|
|
|
|
: "";
|
2008-09-29 20:10:06 +04:00
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Add new messages to chat window
|
|
|
|
|
* @param {Object} args object of function arguments passed from the server
|
|
|
|
|
* @todo Fix skipNextSound
|
|
|
|
|
*/
|
|
|
|
|
updateMessages: function(args){
|
|
|
|
|
// Update last message id
|
|
|
|
|
if (args.lastId) {
|
|
|
|
|
this.thread.lastid = args.lastId;
|
|
|
|
|
}
|
|
|
|
|
// Add messages
|
|
|
|
|
for (var i = 0; i < args.messages.length; i++) {
|
|
|
|
|
// TODO: Add template engine
|
|
|
|
|
this.processMessage(this._options.container, args.messages[i]);
|
|
|
|
|
}
|
|
|
|
|
// Clear status string
|
|
|
|
|
this.clearStatus();
|
|
|
|
|
// There are some new messages
|
|
|
|
|
if (args.messages.length > 0) {
|
|
|
|
|
FrameUtils.scrollDown(this._options.container);
|
|
|
|
|
if (!this.skipNextsound) {
|
|
|
|
|
var tsound = $('soundimg');
|
|
|
|
|
if (tsound == null || tsound.className.match(new RegExp("\\bisound\\b"))) {
|
|
|
|
|
playSound(this._options.webimRoot+'/sounds/new_message.wav');
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (!this.focused) {
|
|
|
|
|
window.focus();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
this.skipNextsound = false;
|
|
|
|
|
},
|
2008-09-29 20:10:06 +04:00
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Build update function to call at the core
|
|
|
|
|
*/
|
|
|
|
|
updateFunctionBuilder: function() {
|
|
|
|
|
return [
|
|
|
|
|
{
|
|
|
|
|
"function": "update",
|
|
|
|
|
"arguments": {
|
|
|
|
|
"return": {'typing': 'typing', 'canPost': 'canPost'},
|
|
|
|
|
"references": {},
|
|
|
|
|
"threadId": this.thread.threadid,
|
|
|
|
|
"token": this.thread.token,
|
|
|
|
|
"lastId": this.thread.lastid,
|
|
|
|
|
"typed": (this._options.message && this._options.message.value != ''),
|
|
|
|
|
"user": this.thread.user
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
];
|
|
|
|
|
},
|
2008-10-03 02:41:35 +04:00
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Set current chat state message
|
|
|
|
|
* @param {Array} args Array of arguments passed from the core
|
|
|
|
|
*/
|
|
|
|
|
updateChatState: function(args) {
|
|
|
|
|
if (args.errorCode) {
|
|
|
|
|
// Something went wrong
|
|
|
|
|
this.handleError(args, 'refresh failed');
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
// Update typing indicator
|
|
|
|
|
if (typeof args.typing != 'undefined') {
|
|
|
|
|
this.showTyping(args.typing);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Check if user can post messages
|
|
|
|
|
if (typeof args.canPost != 'undefined') {
|
|
|
|
|
if ((args.canPost && !this.ownThread) || (this.ownThread && ! args.canPost)) {
|
|
|
|
|
// Refresh the page
|
|
|
|
|
window.location.href = window.location.href;
|
|
|
|
|
}
|
|
|
|
|
}
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
2008-09-30 03:24:18 +04:00
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Check if send key (Enter or Ctrl+Enter) pressed
|
|
|
|
|
* @param {Boolean} ctrlpressed Indicates ctrl key is pressed or not
|
|
|
|
|
* @param {Number} key Key code
|
|
|
|
|
*/
|
2009-04-24 19:09:46 +04:00
|
|
|
isSendkey: function(ctrlpressed, key) {
|
|
|
|
|
return ((key==13 && (ctrlpressed || this._options.ignorectrl)) || (key==10));
|
|
|
|
|
},
|
2012-10-02 14:53:52 +04:00
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Key down handler
|
|
|
|
|
*
|
|
|
|
|
* @param {Object} k Event object
|
|
|
|
|
*/
|
2008-09-29 20:10:06 +04:00
|
|
|
handleKeyDown: function(k) {
|
2012-10-02 14:53:52 +04:00
|
|
|
if( k ){ctrl=k.ctrlKey;k=k.which;} else {k=event.keyCode;ctrl=event.ctrlKey;}
|
2009-04-24 19:09:46 +04:00
|
|
|
if( this._options.message && this.isSendkey(ctrl, k) ) {
|
2008-09-29 20:10:06 +04:00
|
|
|
var mmsg = this._options.message.value;
|
2009-04-24 19:09:46 +04:00
|
|
|
if( this._options.ignorectrl ) {
|
2008-09-29 20:10:06 +04:00
|
|
|
mmsg = mmsg.replace(/[\r\n]+$/,'');
|
|
|
|
|
}
|
|
|
|
|
this.postMessage( mmsg );
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
return true;
|
|
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Update status message
|
|
|
|
|
*
|
|
|
|
|
* @param {Array} args Array of arguments. Must contain 'errorCode' and
|
|
|
|
|
* 'errorMessage' keys
|
|
|
|
|
* @param {String} descr Error description
|
|
|
|
|
*/
|
|
|
|
|
handleError: function(args, descr) {
|
|
|
|
|
if (args.errorCode) {
|
|
|
|
|
this.setStatus(args.errorMessage);
|
|
|
|
|
} else {
|
|
|
|
|
this.setStatus('reconnecting');
|
|
|
|
|
}
|
2008-09-30 03:24:18 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Displays status div and sets the status string into it
|
|
|
|
|
*
|
|
|
|
|
* @param {String} k Status string
|
|
|
|
|
*/
|
2008-09-30 03:24:18 +04:00
|
|
|
showStatusDiv: function(k) {
|
|
|
|
|
if( $("engineinfo") ) {
|
|
|
|
|
$("engineinfo").style.display='inline';
|
|
|
|
|
$("engineinfo").innerHTML = k;
|
|
|
|
|
}
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Sets the status
|
|
|
|
|
*
|
|
|
|
|
* @param {String} k Status string
|
|
|
|
|
*/
|
2008-09-29 20:10:06 +04:00
|
|
|
setStatus: function(k) {
|
|
|
|
|
if( this.statusTimeout )
|
|
|
|
|
clearTimeout(this.statusTimeout);
|
2008-09-30 03:24:18 +04:00
|
|
|
this.showStatusDiv(k);
|
2008-09-29 20:10:06 +04:00
|
|
|
this.statusTimeout = setTimeout(this.clearStatus.bind(this), 4000);
|
|
|
|
|
},
|
|
|
|
|
|
2012-10-02 14:53:52 +04:00
|
|
|
/**
|
|
|
|
|
* Hide the status string
|
|
|
|
|
*/
|
2008-09-29 20:10:06 +04:00
|
|
|
clearStatus: function() {
|
2008-09-30 03:24:18 +04:00
|
|
|
$("engineinfo").style.display='none';
|
2008-09-29 20:10:06 +04:00
|
|
|
}
|
2012-10-02 14:53:52 +04:00
|
|
|
}
|
2008-09-29 20:10:06 +04:00
|
|
|
|
|
|
|
|
var Chat = {
|
|
|
|
|
threadUpdater : {},
|
2008-09-30 03:24:18 +04:00
|
|
|
|
2008-09-29 20:10:06 +04:00
|
|
|
applyName: function() {
|
|
|
|
|
Chat.threadUpdater.changeName($('uname').value);
|
|
|
|
|
$('changename1').style.display='none';
|
|
|
|
|
$('changename2').style.display='inline';
|
2009-04-05 18:14:34 +04:00
|
|
|
$('unamelink').innerHTML = htmlescape($('uname').value);
|
2008-09-29 20:10:06 +04:00
|
|
|
},
|
2008-09-30 03:24:18 +04:00
|
|
|
|
2008-09-29 20:10:06 +04:00
|
|
|
showNameField: function() {
|
|
|
|
|
$('changename1').style.display='inline';
|
|
|
|
|
$('changename2').style.display='none';
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
Behaviour.register({
|
|
|
|
|
'#postmessage a' : function(el) {
|
|
|
|
|
el.onclick = function() {
|
|
|
|
|
var message = $('msgwnd');
|
|
|
|
|
if( message )
|
|
|
|
|
Chat.threadUpdater.postMessage(message.value);
|
|
|
|
|
};
|
|
|
|
|
},
|
|
|
|
|
'select#predefined' : function(el) {
|
|
|
|
|
el.onchange = function() {
|
|
|
|
|
var message = $('msgwnd');
|
2008-10-02 15:53:54 +04:00
|
|
|
if(this.selectedIndex!=0) {
|
2012-01-29 01:52:44 +04:00
|
|
|
message.value = Chat.predefinedAnswers[this.selectedIndex-1];
|
2008-10-02 15:53:54 +04:00
|
|
|
}
|
2008-09-29 20:10:06 +04:00
|
|
|
this.selectedIndex = 0;
|
|
|
|
|
message.focus();
|
|
|
|
|
};
|
|
|
|
|
},
|
|
|
|
|
'div#changename2 a' : function(el) {
|
|
|
|
|
el.onclick = function() {
|
|
|
|
|
Chat.showNameField();
|
|
|
|
|
return false;
|
|
|
|
|
};
|
|
|
|
|
},
|
|
|
|
|
'div#changename1 a' : function(el) {
|
|
|
|
|
el.onclick = function() {
|
|
|
|
|
Chat.applyName();
|
|
|
|
|
return false;
|
|
|
|
|
};
|
|
|
|
|
},
|
|
|
|
|
'div#changename1 input#uname' : function(el) {
|
|
|
|
|
el.onkeydown = function(e) {
|
|
|
|
|
var ev = e || event;
|
|
|
|
|
if( ev.keyCode == 13 ) {
|
|
|
|
|
Chat.applyName();
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
},
|
|
|
|
|
'a#refresh' : function(el) {
|
|
|
|
|
el.onclick = function() {
|
2012-10-02 14:53:52 +04:00
|
|
|
Chat.threadUpdater.refresh();
|
2008-09-29 20:10:06 +04:00
|
|
|
};
|
|
|
|
|
},
|
2009-03-08 23:53:16 +03:00
|
|
|
'a#togglesound' : function(el) {
|
|
|
|
|
el.onclick = function() {
|
|
|
|
|
var tsound = $('soundimg');
|
|
|
|
|
if(!tsound) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
if(tsound.className.match(new RegExp("\\bisound\\b"))) {
|
|
|
|
|
tsound.className = "tplimage inosound";
|
|
|
|
|
} else {
|
|
|
|
|
tsound.className = "tplimage isound";
|
|
|
|
|
}
|
|
|
|
|
var messagePane = $('msgwnd');
|
|
|
|
|
if(messagePane)
|
|
|
|
|
messagePane.focus();
|
|
|
|
|
};
|
|
|
|
|
},
|
2008-09-29 20:10:06 +04:00
|
|
|
'a.closethread' : function(el) {
|
|
|
|
|
el.onclick = function() {
|
|
|
|
|
Chat.threadUpdater.closeThread();
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
EventHelper.register(window, 'onload', function(){
|
2012-10-02 14:53:52 +04:00
|
|
|
Chat.cssfile = chatParams.cssfile;
|
|
|
|
|
Chat.predefinedAnswers = chatParams.predefinedAnswers || [];
|
|
|
|
|
Chat.localizedStrings = chatParams.localizedStrings;
|
|
|
|
|
Chat.threadUpdater = new ChatThreadUpdater(
|
|
|
|
|
new ChatServer(chatParams.serverParams),
|
|
|
|
|
chatParams.threadParams,
|
|
|
|
|
{
|
|
|
|
|
ignorectrl: -1,
|
|
|
|
|
container: myRealAgent=='safari'?self.frames[0]:$("chatwnd"),
|
|
|
|
|
avatar: $("avatarwnd"),
|
|
|
|
|
message: $("msgwnd")
|
|
|
|
|
}.extend(chatParams.threadUpdaterParams || {})
|
|
|
|
|
);
|
2008-09-30 03:24:18 +04:00
|
|
|
});
|
