| /* |
| Copyright (c) 2004-2009, The Dojo Foundation All Rights Reserved. |
| Available via Academic Free License >= 2.1 OR the modified BSD license. |
| see: http://dojotoolkit.org/license for details |
| */ |
| |
| |
| if(!dojo._hasResource["dojox.xmpp.TransportSession"]){ |
| dojo._hasResource["dojox.xmpp.TransportSession"]=true; |
| dojo.provide("dojox.xmpp.TransportSession"); |
| dojo.require("dojox.xmpp.bosh"); |
| dojo.require("dojox.xmpp.util"); |
| dojo.require("dojox.data.dom"); |
| dojox.xmpp.TransportSession=function(_1){ |
| this.sendTimeout=(this.wait+20)*1000; |
| if(_1&&dojo.isObject(_1)){ |
| dojo.mixin(this,_1); |
| if(this.useScriptSrcTransport){ |
| this.transportIframes=[]; |
| } |
| } |
| }; |
| dojo.extend(dojox.xmpp.TransportSession,{rid:0,hold:1,polling:1000,secure:false,wait:60,lang:"en",submitContentType:"text/xml; charset=utf=8",serviceUrl:"/httpbind",defaultResource:"dojoIm",domain:"imserver.com",sendTimeout:0,useScriptSrcTransport:false,keepAliveTimer:null,state:"NotReady",transmitState:"Idle",protocolPacketQueue:[],outboundQueue:[],outboundRequests:{},inboundQueue:[],deferredRequests:{},matchTypeIdAttribute:{},open:function(){ |
| this.status="notReady"; |
| this.rid=Math.round(Math.random()*1000000000); |
| this.protocolPacketQueue=[]; |
| this.outboundQueue=[]; |
| this.outboundRequests={}; |
| this.inboundQueue=[]; |
| this.deferredRequests={}; |
| this.matchTypeIdAttribute={}; |
| this.keepAliveTimer=setTimeout(dojo.hitch(this,"_keepAlive"),10000); |
| if(this.useScriptSrcTransport){ |
| dojox.xmpp.bosh.initialize({iframes:this.hold+1,load:dojo.hitch(this,function(){ |
| this._sendLogin(); |
| })}); |
| }else{ |
| this._sendLogin(); |
| } |
| },_sendLogin:function(){ |
| var _2=this.rid++; |
| var _3={content:this.submitContentType,hold:this.hold,rid:_2,to:this.domain,secure:this.secure,wait:this.wait,"xml:lang":this.lang,"xmpp:version":"1.0",xmlns:dojox.xmpp.xmpp.BODY_NS,"xmlns:xmpp":"urn:xmpp:xbosh"}; |
| var _4=dojox.xmpp.util.createElement("body",_3,true); |
| this.addToOutboundQueue(_4,_2); |
| },_sendRestart:function(){ |
| var _5=this.rid++; |
| var _6={rid:_5,sid:this.sid,to:this.domain,"xmpp:restart":"true","xml:lang":this.lang,xmlns:dojox.xmpp.xmpp.BODY_NS,"xmlns:xmpp":"urn:xmpp:xbosh"}; |
| var _7=dojox.xmpp.util.createElement("body",_6,true); |
| this.addToOutboundQueue(_7,_5); |
| },processScriptSrc:function(_8,_9){ |
| var _a=dojox.xml.parser.parse(_8,"text/xml"); |
| if(_a){ |
| this.processDocument(_a,_9); |
| }else{ |
| } |
| },_keepAlive:function(){ |
| if(this.state=="wait"||this.isTerminated()){ |
| return; |
| } |
| this._dispatchPacket(); |
| this.keepAliveTimer=setTimeout(dojo.hitch(this,"_keepAlive"),10000); |
| },close:function(_b){ |
| var _c=this.rid++; |
| var _d={sid:this.sid,rid:_c,type:"terminate"}; |
| var _e=null; |
| if(_b){ |
| _e=new dojox.string.Builder(dojox.xmpp.util.createElement("body",_d,false)); |
| _e.append(_b); |
| _e.append("</body>"); |
| }else{ |
| _e=new dojox.string.Builder(dojox.xmpp.util.createElement("body",_d,false)); |
| } |
| this.addToOutboundQueue(_e.toString(),_c); |
| this.state=="Terminate"; |
| },dispatchPacket:function(_f,_10,_11,_12){ |
| if(_f){ |
| this.protocolPacketQueue.push(_f); |
| } |
| var def=new dojo.Deferred(); |
| if(_10&&_11){ |
| def.protocolMatchType=_10; |
| def.matchId=_11; |
| def.matchProperty=_12||"id"; |
| if(def.matchProperty!="id"){ |
| this.matchTypeIdAttribute[_10]=def.matchProperty; |
| } |
| } |
| this.deferredRequests[def.protocolMatchType+"-"+def.matchId]=def; |
| if(!this.dispatchTimer){ |
| this.dispatchTimer=setTimeout(dojo.hitch(this,"_dispatchPacket"),600); |
| } |
| return def; |
| },_dispatchPacket:function(){ |
| clearTimeout(this.dispatchTimer); |
| delete this.dispatchTimer; |
| if(!this.sid){ |
| return; |
| } |
| if(!this.authId){ |
| return; |
| } |
| if(this.transmitState!="error"&&(this.protocolPacketQueue.length==0)&&(this.outboundQueue.length>0)){ |
| return; |
| } |
| if(this.state=="wait"||this.isTerminated()){ |
| return; |
| } |
| var req={sid:this.sid,xmlns:dojox.xmpp.xmpp.BODY_NS}; |
| var _13; |
| if(this.protocolPacketQueue.length>0){ |
| req.rid=this.rid++; |
| _13=new dojox.string.Builder(dojox.xmpp.util.createElement("body",req,false)); |
| _13.append(this.processProtocolPacketQueue()); |
| _13.append("</body>"); |
| delete this.lastPollTime; |
| }else{ |
| if(this.lastPollTime){ |
| var now=new Date().getTime(); |
| if(now-this.lastPollTime<this.polling){ |
| this.dispatchTimer=setTimeout(dojo.hitch(this,"_dispatchPacket"),this.polling-(now-this.lastPollTime)+10); |
| return; |
| } |
| } |
| req.rid=this.rid++; |
| this.lastPollTime=new Date().getTime(); |
| _13=new dojox.string.Builder(dojox.xmpp.util.createElement("body",req,true)); |
| } |
| this.addToOutboundQueue(_13.toString(),req.rid); |
| },redispatchPacket:function(rid){ |
| var env=this.outboundRequests[rid]; |
| this.sendXml(env,rid); |
| },addToOutboundQueue:function(msg,rid){ |
| this.outboundQueue.push({msg:msg,rid:rid}); |
| this.outboundRequests[rid]=msg; |
| this.sendXml(msg,rid); |
| },removeFromOutboundQueue:function(rid){ |
| for(var i=0;i<this.outboundQueue.length;i++){ |
| if(rid==this.outboundQueue[i]["rid"]){ |
| this.outboundQueue.splice(i,1); |
| break; |
| } |
| } |
| delete this.outboundRequests[rid]; |
| },processProtocolPacketQueue:function(){ |
| var _14=new dojox.string.Builder(); |
| for(var i=0;i<this.protocolPacketQueue.length;i++){ |
| _14.append(this.protocolPacketQueue[i]); |
| } |
| this.protocolPacketQueue=[]; |
| return _14.toString(); |
| },sendXml:function(_15,rid){ |
| if(this.isTerminated()){ |
| return false; |
| } |
| this.transmitState="transmitting"; |
| var def=null; |
| if(this.useScriptSrcTransport){ |
| def=dojox.xmpp.bosh.get({rid:rid,url:this.serviceUrl+"?"+encodeURIComponent(_15),error:dojo.hitch(this,function(res,io){ |
| this.setState("Terminate","error"); |
| return false; |
| }),timeout:this.sendTimeout}); |
| }else{ |
| def=dojo.rawXhrPost({contentType:"text/xml",url:this.serviceUrl,postData:_15,handleAs:"xml",error:dojo.hitch(this,function(res,io){ |
| return this.processError(io.xhr.responseXML,io.xhr.status,rid); |
| }),timeout:this.sendTimeout}); |
| } |
| def.addCallback(this,function(res){ |
| return this.processDocument(res,rid); |
| }); |
| return def; |
| },processDocument:function(doc,rid){ |
| if(this.isTerminated()||!doc.firstChild){ |
| return false; |
| } |
| this.transmitState="idle"; |
| var _16=doc.firstChild; |
| if(_16.nodeName!="body"){ |
| } |
| if(this.outboundQueue.length<1){ |
| return false; |
| } |
| var _17=this.outboundQueue[0]["rid"]; |
| if(rid==_17){ |
| this.removeFromOutboundQueue(rid); |
| this.processResponse(_16,rid); |
| this.processInboundQueue(); |
| }else{ |
| var gap=rid-_17; |
| if(gap<this.hold+2){ |
| this.addToInboundQueue(doc,rid); |
| }else{ |
| } |
| } |
| return doc; |
| },processInboundQueue:function(){ |
| while(this.inboundQueue.length>0){ |
| var _18=this.inboundQueue.shift(); |
| this.processDocument(_18["doc"],_18["rid"]); |
| } |
| },addToInboundQueue:function(doc,rid){ |
| for(var i=0;i<this.inboundQueue.length;i++){ |
| if(rid<this.inboundQueue[i]["rid"]){ |
| continue; |
| } |
| this.inboundQueue.splice(i,0,{doc:doc,rid:rid}); |
| } |
| },processResponse:function(_19,rid){ |
| if(_19.getAttribute("type")=="terminate"){ |
| var _1a=_19.firstChild.firstChild; |
| var _1b=""; |
| if(_1a.nodeName=="conflict"){ |
| _1b="conflict"; |
| } |
| this.setState("Terminate",_1b); |
| return; |
| } |
| if((this.state!="Ready")&&(this.state!="Terminate")){ |
| var sid=_19.getAttribute("sid"); |
| if(sid){ |
| this.sid=sid; |
| }else{ |
| throw new Error("No sid returned during xmpp session startup"); |
| } |
| this.authId=_19.getAttribute("authid"); |
| if(this.authId==""){ |
| if(this.authRetries--<1){ |
| console.error("Unable to obtain Authorization ID"); |
| this.terminateSession(); |
| } |
| } |
| this.wait=_19.getAttribute("wait"); |
| if(_19.getAttribute("polling")){ |
| this.polling=parseInt(_19.getAttribute("polling"))*1000; |
| } |
| this.inactivity=_19.getAttribute("inactivity"); |
| this.setState("Ready"); |
| } |
| dojo.forEach(_19.childNodes,function(_1c){ |
| this.processProtocolResponse(_1c,rid); |
| },this); |
| if(this.transmitState=="idle"){ |
| this.dispatchPacket(); |
| } |
| },processProtocolResponse:function(msg,rid){ |
| this.onProcessProtocolResponse(msg); |
| var key=msg.nodeName+"-"+msg.getAttribute("id"); |
| var def=this.deferredRequests[key]; |
| if(def){ |
| def.callback(msg); |
| delete this.deferredRequests[key]; |
| } |
| },setState:function(_1d,_1e){ |
| if(this.state!=_1d){ |
| if(this["on"+_1d]){ |
| this["on"+_1d](_1d,this.state,_1e); |
| } |
| this.state=_1d; |
| } |
| },isTerminated:function(){ |
| return this.state=="Terminate"; |
| },processError:function(err,_1f,rid){ |
| if(this.isTerminated()){ |
| return false; |
| } |
| if(_1f!=200){ |
| if(_1f>=400&&_1f<500){ |
| this.setState("Terminate",_20); |
| return false; |
| }else{ |
| this.removeFromOutboundQueue(rid); |
| setTimeout(dojo.hitch(this,function(){ |
| this.dispatchPacket(); |
| }),200); |
| return true; |
| } |
| return false; |
| } |
| if(err&&err.dojoType&&err.dojoType=="timeout"){ |
| } |
| this.removeFromOutboundQueue(rid); |
| if(err&&err.firstChild){ |
| if(err.firstChild.getAttribute("type")=="terminate"){ |
| var _21=err.firstChild.firstChild; |
| var _20=""; |
| if(_21&&_21.nodeName=="conflict"){ |
| _20="conflict"; |
| } |
| this.setState("Terminate",_20); |
| return false; |
| } |
| } |
| this.transmitState="error"; |
| setTimeout(dojo.hitch(this,function(){ |
| this.dispatchPacket(); |
| }),200); |
| return true; |
| },onTerminate:function(_22,_23,_24){ |
| },onProcessProtocolResponse:function(msg){ |
| },onReady:function(_25,_26){ |
| }}); |
| } |
