/*
* jquery.xmpp.js
*
* Copyright 2011 Alvaro Garcia
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 3 of the License, or
* (at your option) any later version.
*
* This program 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 General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
* MA 02110-1301, USA.
*/
(function($) {
// Intercept XHRs coming from IE8+ and send via XDomainRequest.
$.ajaxTransport("+*", function( options, originalOptions, jqXHR ) {
// If this is IE and XDomainRequest is supported.
if(navigator.appVersion.indexOf("MSIE") != -1 && window.XDomainRequest) {
var xdr;
return {
send: function( headers, completeCallback ) {
// Use Microsoft XDR
xdr = new XDomainRequest();
// Open the remote URL.
xdr.open("post", options.url);
xdr.onload = function() {
completeCallback(200, "success", [this.responseText]);
};
xdr.ontimeout = function(){
completeCallback(408, "error", ["The request timed out."]);
};
xdr.onerror = function(errorText){
completeCallback(404, "error: " + errorText, ["The requested resource could not be found."]);
};
// Submit the data to the site.
xdr.send(options.data);
},
abort: function() {
if(xdr)xdr.abort();
}
};
}
});
$.xmpp ={
rid:null,
sid:null,
jid:null,
url: null,
uri: null,
listening: false,
onMessage: null,
onIq: null,
onPresence: null,
onError: null,
connections: 0,
resource: null,
connected: false,
checkNetorkErrors: false,
wait: 60,
inactivity: 60,
_jsTimeout: null, //Used to save the javascript timeout
_timeoutMilis: 500,
__lastAjaxRequest: null,
/**
* Connect to the server
* @params Object
* {jid:"user@domain.com",
* password:"qwerty",
* resource:"Chat",
* url:"/http-bind",
* wait: 60,
* inactivity: 60,
* onDisconnect:function(){},
* onConnect: function(data){},
* onIq: function(iq){},
* onMessage: function(message){},
* onPresence: function(presence){}
* onError: function(error, data){}
* }
*/
connect: function(options){
this.rid = Math.round(Math.random()*Math.pow(10,10));
this.jid = options.jid;
var split = options.jid.split("@");
var domain = split[1];
var xmpp = this;
if(options.url == null)
this.url = '/http-bind'
else
this.url = options.url;
if(options.checkNetorkErrors != null)
this.checkNetorkErrors = options.checkNetorkErrors
if(!isNaN(options.wait)){
this.wait = options.wait;
}
this._timeoutMilis = xmpp.wait * 1000;
if(!isNaN(options.inactivity)){
this.inactivity = options.inactivity
}
this.uri = this.jid;
if(options.resource == null)
this.resource = "";
else{
this.resource = options.resource;
this.uri += "/" + this.resource;
}
//Events
this.onMessage = options.onMessage;
this.onIq = options.onIq;
this.onPresence = options.onPresence;
this.onError = options.onError;
this.onDisconnect = options.onDisconnect;
this.onConnect = options.onConnect;
//Init connection
var msg = "";
$.post(this.url,msg,function(data){
var response = $(xmpp.fixBody(data));
xmpp.sid = response.attr("sid");
if(response.find("mechanism:contains('PLAIN')").length){
xmpp.loginPlain(options);
}else if(response.find("mechanism:contains('DIGEST-MD5')").length){
xmpp.loginDigestMD5(options);
}else{
if(xmpp.onError != null){
xmpp.onError({error:"No auth method supported", data:data});
}
}
}, 'text');
},
/**
* Attach to existing session
* @params Object
* {jid:"",
* sid:"",
* rid:"",
* resource:"",
* url:"",
* wait: 60,
* onDisconnect:function(){},
* onConnect: function(data){},
* onIq: function(iq){},
* onMessage: function(message){},
* onPresence: function(presence){}
* onError: function(error, data){}
* }
*/
attach: function(options){
this.jid = options.jid;
this.sid = options.sid;
this.rid = options.rid;
var xmpp = this;
if(options.url == null)
this.url = '/http-bind'
else
this.url = options.url;
this.uri = this.jid;
if(options.resource == null)
this.resource = "";
else{
this.resource = options.resource;
this.uri += "/" + this.resource;
}
//Events
this.onMessage = options.onMessage;
this.onIq = options.onIq;
this.onPresence = options.onPresence;
this.onError = options.onError;
this.onDisconnect = options.onDisconnect;
this.onConnect = options.onConnect;
if(!isNaN(options.wait)){
this.wait = options.wait
}
this._timeoutMilis = xmpp.wait * 1000;
if(options.onConnect != null)
xmpp.connected = true;
options.onConnect();
xmpp.listen();
},
/**
* Disconnect from the server using synchronous Ajax
* @params function callback
*/
disconnectSync: function(callback){
var xmpp = this;
xmpp.rid = xmpp.rid + 1;
this.listening = true;
xmpp.connections = xmpp.connections + 1;
var msg = "";
$.ajax({
type: 'POST',
url: this.url,
data: msg,
success: function(data){
xmpp.connections = xmpp.connections - 1;
xmpp.messageHandler(data);
xmpp.listening = false;
//Do not listen anymore!
//Two callbacks
if(callback != null)
callback(data);
if(xmpp.onDisconnect != null)
xmpp.connected = false;
xmpp.onDisconnect(data);
},
dataType: 'text',
async:false
});
},
/**
* Disconnect from the server
* @params function callback
*/
disconnect: function(callback){
var xmpp = this;
xmpp.rid = xmpp.rid + 1;
this.listening = true;
xmpp.connections = xmpp.connections + 1;
var msg = "";
$.post(this.url,msg,function(data){
xmpp.connections = xmpp.connections - 1;
xmpp.messageHandler(data);
xmpp.listening = false;
//Do not listen anymore!
//Two callbacks
if(callback != null)
callback(data);
if(xmpp.onDisconnect != null)
xmpp.connected = false;
xmpp.onDisconnect(data);
}, 'text');
},
/**
* Do a MD5 Digest authentication
*/
loginDigestMD5: function(options){
var xmpp = this;
this.rid++;
var msg = "";
$.post(this.url,msg,function(data){
var response = $(data);
var split = options.jid.split("@");
var domain = split[1];
var username = split[0];
//Code bases on Strophe
var attribMatch = /([a-z]+)=("[^"]+"|[^,"]+)(?:,|$)/;
var challenge = Base64.decode(response.text());
var cnonce = MD5.hexdigest("" + (Math.random() * 1234567890));
var realm = "";
var host = null;
var nonce = "";
var qop = "";
var matches;
while (challenge.match(attribMatch)) {
matches = challenge.match(attribMatch);
challenge = challenge.replace(matches[0], "");
matches[2] = matches[2].replace(/^"(.+)"$/, "$1");
switch (matches[1]) {
case "realm":
realm = matches[2];
break;
case "nonce":
nonce = matches[2];
break;
case "qop":
qop = matches[2];
break;
case "host":
host = matches[2];
break;
}
}
var digest_uri = "xmpp/" + domain;
if (host !== null) {
digest_uri = digest_uri + "/" + host;
}
var A1 = MD5.hash(username + ":" + realm + ":" + options.password) +
":" + nonce + ":" + cnonce;
var A2 = 'AUTHENTICATE:' + digest_uri;
var responseText = "";
responseText += 'username=' + xmpp._quote(username) + ',';
responseText += 'realm=' + xmpp._quote(realm) + ',';
responseText += 'nonce=' + xmpp._quote(nonce) + ',';
responseText += 'cnonce=' + xmpp._quote(cnonce) + ',';
responseText += 'nc="00000001",';
responseText += 'qop="auth",';
responseText += 'digest-uri=' + xmpp._quote(digest_uri) + ',';
responseText += 'response=' + xmpp._quote(
MD5.hexdigest(MD5.hexdigest(A1) + ":" +
nonce + ":00000001:" +
cnonce + ":auth:" +
MD5.hexdigest(A2))) + ',';
responseText += 'charset="utf-8"';
xmpp.rid++;
var msg =""+Base64.encode(responseText)+"";
$.post(this.url,msg,function(data){
var response = $(xmpp.fixBody(data));
if(!response.find("failure").length){
xmpp.rid++;
var msg ="";
$.post(this.url,msg,function(data){
var response = $(xmpp.fixBody(data));
if(response.find("success").length){
xmpp.rid++;
var msg ="";
$.post(this.url,msg,function(data){
xmpp.rid++;
var msg ="