transportsession.js

用最近的dojo1.2.1制作前端的ajax购书网站

/*
	Copyright (c) 2004-2008, 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.util");
dojo.require("dojo.io.script");
dojo.require("dojo.io.iframe");
dojo.require("dojox.data.dom");
dojox.xmpp.TransportSession=function(_1){
if(_1&&dojo.isObject(_1)){
dojo.mixin(this,_1);
if(this.useScriptSrcTransport){
this.transportIframes=[];
}
}
};
dojox.xmpp.TransportSession._iframeOnload=function(_2){
var _3=dojo.io.iframe.doc(dojo.byId("xmpp-transport-"+_2));
_3.write("<script>var isLoaded=true; var rid=0; var transmiting=false; function _BOSH_(msg) { transmiting=false; parent.dojox.xmpp.TransportSession.handleBOSH(msg, rid); } </script>");
};
dojox.xmpp.TransportSession.handleBOSH=function(_4,_5){
};
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:(this.wait+20)*1000,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){
dojo.connect(dojox.xmpp.TransportSession,"handleBOSH",this,"processScriptSrc");
this.transportIframes=[];
for(var i=0;i<=this.hold;i++){
var _7=dojo.io.iframe.create("xmpp-transport-"+i,dojox._scopeName+".xmpp.TransportSession._iframeOnload("+i+");");
this.transportIframes.push(_7);
if(i==0){
dojo.connect(_7,"onload",this,"_sendLogin");
}
}
}else{
this._sendLogin();
}
},_sendLogin:function(){
var _8=this.rid++;
var _9={content:this.submitContentType,hold:this.hold,rid:_8,to:this.domain,secure:this.secure,wait:this.wait,"xml:lang":this.lang,xmlns:dojox.xmpp.xmpp.BODY_NS};
var _a=dojox.xmpp.util.createElement("body",_9,true);
this.addToOutboundQueue(_a,_8);
},processScriptSrc:function(_b,_c){
var _d=dojox.data.dom.createDocument(_b,"text/xml");
if(_d){
this.processDocument(_d,_c);
}else{
}
},_keepAlive:function(){
if(this.state=="wait"||this.isTerminated()){
return;
}
this._dispatchPacket();
this.keepAliveTimer=setTimeout(dojo.hitch(this,"_keepAlive"),10000);
},close:function(_e){
var _f=this.rid++;
var req={sid:this.sid,rid:_f,type:"terminate"};
var _11=null;
if(_e){
_11=new dojox.string.Builder(dojox.xmpp.util.createElement("body",req,false));
_11.append(_e);
_11.append("</body>");
}else{
_11=new dojox.string.Builder(dojox.xmpp.util.createElement("body",req,false));
}
this.addToOutboundQueue(_11.toString(),_f);
this.state=="Terminate";
},dispatchPacket:function(msg,_13,_14,_15){
if(msg){
this.protocolPacketQueue.push(msg);
}
var def=new dojo.Deferred();
if(_13&&_14){
def.protocolMatchType=_13;
def.matchId=_14;
def.matchProperty=_15||"id";
if(def.matchProperty!="id"){
this.matchTypeIdAttribute[_13]=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};
if(this.protocolPacketQueue.length>0){
req.rid=this.rid++;
var _18=new dojox.string.Builder(dojox.xmpp.util.createElement("body",req,false));
_18.append(this.processProtocolPacketQueue());
_18.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();
var _18=new dojox.string.Builder(dojox.xmpp.util.createElement("body",req,true));
}
this.addToOutboundQueue(_18.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 _20=new dojox.string.Builder();
for(var i=0;i<this.protocolPacketQueue.length;i++){
_20.append(this.protocolPacketQueue[i]);
}
this.protocolPacketQueue=[];
return _20.toString();
},findOpenIframe:function(){
for(var i=0;i<this.transportIframes.length;i++){
var _23=this.transportIframes[i];
var win=_23.contentWindow;
if(win.isLoaded&&!win.transmiting){
return _23;
}
}
},sendXml:function(_25,rid){
if(this.isTerminated()){
return;
}
this.transmitState="transmitting";
if(this.useScriptSrcTransport){
var _27=this.findOpenIframe();
var _28=dojo.io.iframe.doc(_27);
_27.contentWindow.rid=rid;
_27.contentWindow.transmiting=true;
dojo.io.script.attach("rid-"+rid,this.serviceUrl+"?"+encodeURIComponent(_25),_28);
}else{
var def=dojo.rawXhrPost({contentType:"text/xml",url:this.serviceUrl,postData:_25,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()){
return;
}
this.transmitState="idle";
var _2f=doc.firstChild;
if(_2f.nodeName!="body"){
}
if(this.outboundQueue.length<1){
return;
}
var _30=this.outboundQueue[0]["rid"];
if(rid==_30){
this.removeFromOutboundQueue(rid);
this.processResponse(_2f,rid);
this.processInboundQueue();
}else{
var gap=rid-_30;
if(gap<this.hold+2){
this.addToInboundQueue(doc,rid);
}else{
}
}
return doc;
},processInboundQueue:function(){
while(this.inboundQueue.length>0){
var _32=this.inboundQueue.shift();
this.processDocument(_32["doc"],_32["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(_36,rid){
if(_36.getAttribute("type")=="terminate"){
var _38=_36.firstChild.firstChild;
var _39="";
if(_38.nodeName=="conflict"){
_39="conflict";
}
this.setState("Terminate",_39);
return;
}
if((this.state!="Ready")&&(this.state!="Terminate")){
var sid=_36.getAttribute("sid");
if(sid){
this.sid=sid;
}else{
throw new Error("No sid returned during xmpp session startup");
}
this.authId=_36.getAttribute("authid");
if(this.authId==""){
if(this.authRetries--<1){
console.error("Unable to obtain Authorization ID");
this.terminateSession();
}
}
this.wait=_36.getAttribute("wait");
if(_36.getAttribute("polling")){
this.polling=parseInt(_36.getAttribute("polling"))*1000;
}
this.inactivity=_36.getAttribute("inactivity");
this.setState("Ready");
}
dojo.forEach(_36.childNodes,function(_3b){
this.processProtocolResponse(_3b,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(_40,_41){
if(this.state!=_40){
if(this["on"+_40]){
this["on"+_40](_40,this.state,_41);
}
this.state=_40;
}
},isTerminated:function(){
return this.state=="Terminate";
},processError:function(err,_43,rid){
if(this.isTerminated()){
return;
}
if(_43!=200){
this.setState("Terminate",_45);
return;
}
if(err&&err.dojoType&&err.dojoType=="timeout"){
}
this.removeFromOutboundQueue(rid);
if(err&&err.firstChild){
if(err.firstChild.getAttribute("type")=="terminate"){
var _46=err.firstChild.firstChild;
var _45="";
if(_46&&_46.nodeName=="conflict"){
_45="conflict";
}
this.setState("Terminate",_45);
return;
}
}
this.transmitState="error";
setTimeout(dojo.hitch(this,function(){
this.dispatchPacket();
}),200);
return true;
},onTerminate:function(_47,_48,_49){
},onProcessProtocolResponse:function(msg){
},onReady:function(_4b,_4c){
}});
}