/*
	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){
}});
}