| /* |
| 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.cometd._base"]){ |
| dojo._hasResource["dojox.cometd._base"]=true; |
| dojo.provide("dojox.cometd._base"); |
| dojo.require("dojo.AdapterRegistry"); |
| dojox.cometd={Connection:function(_1){ |
| dojo.mixin(this,{prefix:_1,_status:"unconnected",_handshook:false,_initialized:false,_polling:false,expectedNetworkDelay:10000,connectTimeout:0,version:"1.0",minimumVersion:"0.9",clientId:null,messageId:0,batch:0,_isXD:false,handshakeReturn:null,currentTransport:null,url:null,lastMessage:null,_messageQ:[],handleAs:"json",_advice:{},_backoffInterval:0,_backoffIncrement:1000,_backoffMax:60000,_deferredSubscribes:{},_deferredUnsubscribes:{},_subscriptions:[],_extendInList:[],_extendOutList:[]}); |
| this.state=function(){ |
| return this._status; |
| }; |
| this.init=function(_2,_3,_4){ |
| _3=_3||{}; |
| _3.version=this.version; |
| _3.minimumVersion=this.minimumVersion; |
| _3.channel="/meta/handshake"; |
| _3.id=""+this.messageId++; |
| this.url=_2||dojo.config["cometdRoot"]; |
| if(!this.url){ |
| throw "no cometd root"; |
| return null; |
| } |
| var _5="^(([^:/?#]+):)?(//([^/?#]*))?([^?#]*)(\\?([^#]*))?(#(.*))?$"; |
| var _6=(""+window.location).match(new RegExp(_5)); |
| if(_6[4]){ |
| var _7=_6[4].split(":"); |
| var _8=_7[0]; |
| var _9=_7[1]||"80"; |
| _6=this.url.match(new RegExp(_5)); |
| if(_6[4]){ |
| _7=_6[4].split(":"); |
| var _a=_7[0]; |
| var _b=_7[1]||"80"; |
| this._isXD=((_a!=_8)||(_b!=_9)); |
| } |
| } |
| if(!this._isXD){ |
| _3.supportedConnectionTypes=dojo.map(dojox.cometd.connectionTypes.pairs,"return item[0]"); |
| } |
| _3=this._extendOut(_3); |
| var _c={url:this.url,handleAs:this.handleAs,content:{"message":dojo.toJson([_3])},load:dojo.hitch(this,function(_d){ |
| this._backon(); |
| this._finishInit(_d); |
| }),error:dojo.hitch(this,function(e){ |
| this._backoff(); |
| this._finishInit(e); |
| }),timeout:this.expectedNetworkDelay}; |
| if(_4){ |
| dojo.mixin(_c,_4); |
| } |
| this._props=_3; |
| for(var _e in this._subscriptions){ |
| for(var _f in this._subscriptions[_e]){ |
| if(this._subscriptions[_e][_f].topic){ |
| dojo.unsubscribe(this._subscriptions[_e][_f].topic); |
| } |
| } |
| } |
| this._messageQ=[]; |
| this._subscriptions=[]; |
| this._initialized=true; |
| this._status="handshaking"; |
| this.batch=0; |
| this.startBatch(); |
| var r; |
| if(this._isXD){ |
| _c.callbackParamName="jsonp"; |
| r=dojo.io.script.get(_c); |
| }else{ |
| r=dojo.xhrPost(_c); |
| } |
| return r; |
| }; |
| this.publish=function(_10,_11,_12){ |
| var _13={data:_11,channel:_10}; |
| if(_12){ |
| dojo.mixin(_13,_12); |
| } |
| this._sendMessage(_13); |
| }; |
| this.subscribe=function(_14,_15,_16,_17){ |
| _17=_17||{}; |
| if(_15){ |
| var _18=_1+_14; |
| var _19=this._subscriptions[_18]; |
| if(!_19||_19.length==0){ |
| _19=[]; |
| _17.channel="/meta/subscribe"; |
| _17.subscription=_14; |
| this._sendMessage(_17); |
| var _1a=this._deferredSubscribes; |
| if(_1a[_14]){ |
| _1a[_14].cancel(); |
| delete _1a[_14]; |
| } |
| _1a[_14]=new dojo.Deferred(); |
| } |
| for(var i in _19){ |
| if(_19[i].objOrFunc===_15&&(!_19[i].funcName&&!_16||_19[i].funcName==_16)){ |
| return null; |
| } |
| } |
| var _1b=dojo.subscribe(_18,_15,_16); |
| _19.push({topic:_1b,objOrFunc:_15,funcName:_16}); |
| this._subscriptions[_18]=_19; |
| } |
| var ret=this._deferredSubscribes[_14]||{}; |
| ret.args=dojo._toArray(arguments); |
| return ret; |
| }; |
| this.unsubscribe=function(_1c,_1d,_1e,_1f){ |
| if((arguments.length==1)&&(!dojo.isString(_1c))&&(_1c.args)){ |
| return this.unsubscribe.apply(this,_1c.args); |
| } |
| var _20=_1+_1c; |
| var _21=this._subscriptions[_20]; |
| if(!_21||_21.length==0){ |
| return null; |
| } |
| var s=0; |
| for(var i in _21){ |
| var sb=_21[i]; |
| if((!_1d)||(sb.objOrFunc===_1d&&(!sb.funcName&&!_1e||sb.funcName==_1e))){ |
| dojo.unsubscribe(_21[i].topic); |
| delete _21[i]; |
| }else{ |
| s++; |
| } |
| } |
| if(s==0){ |
| _1f=_1f||{}; |
| _1f.channel="/meta/unsubscribe"; |
| _1f.subscription=_1c; |
| delete this._subscriptions[_20]; |
| this._sendMessage(_1f); |
| this._deferredUnsubscribes[_1c]=new dojo.Deferred(); |
| if(this._deferredSubscribes[_1c]){ |
| this._deferredSubscribes[_1c].cancel(); |
| delete this._deferredSubscribes[_1c]; |
| } |
| } |
| return this._deferredUnsubscribes[_1c]; |
| }; |
| this.disconnect=function(){ |
| for(var _22 in this._subscriptions){ |
| for(var sub in this._subscriptions[_22]){ |
| if(this._subscriptions[_22][sub].topic){ |
| dojo.unsubscribe(this._subscriptions[_22][sub].topic); |
| } |
| } |
| } |
| this._subscriptions=[]; |
| this._messageQ=[]; |
| if(this._initialized&&this.currentTransport){ |
| this._initialized=false; |
| this.currentTransport.disconnect(); |
| } |
| if(!this._polling){ |
| this._publishMeta("connect",false); |
| } |
| this._initialized=false; |
| this._handshook=false; |
| this._status="disconnected"; |
| this._publishMeta("disconnect",true); |
| }; |
| this.subscribed=function(_23,_24){ |
| }; |
| this.unsubscribed=function(_25,_26){ |
| }; |
| this.tunnelInit=function(_27,_28){ |
| }; |
| this.tunnelCollapse=function(){ |
| }; |
| this._backoff=function(){ |
| if(!this._advice){ |
| this._advice={reconnect:"retry",interval:0}; |
| }else{ |
| if(!this._advice.interval){ |
| this._advice.interval=0; |
| } |
| } |
| if(this._backoffInterval<this._backoffMax){ |
| this._backoffInterval+=this._backoffIncrement; |
| } |
| }; |
| this._backon=function(){ |
| this._backoffInterval=0; |
| }; |
| this._interval=function(){ |
| var i=this._backoffInterval+(this._advice?(this._advice.interval?this._advice.interval:0):0); |
| if(i>0){ |
| } |
| return i; |
| }; |
| this._publishMeta=function(_29,_2a,_2b){ |
| try{ |
| var _2c={cometd:this,action:_29,successful:_2a,state:this.state()}; |
| if(_2b){ |
| dojo.mixin(_2c,_2b); |
| } |
| dojo.publish(this.prefix+"/meta",[_2c]); |
| } |
| catch(e){ |
| } |
| }; |
| this._finishInit=function(_2d){ |
| if(this._status!="handshaking"){ |
| return; |
| } |
| var _2e=this._handshook; |
| var _2f=false; |
| var _30={}; |
| if(_2d instanceof Error){ |
| dojo.mixin(_30,{reestablish:false,failure:true,error:_2d,advice:this._advice}); |
| }else{ |
| _2d=_2d[0]; |
| _2d=this._extendIn(_2d); |
| this.handshakeReturn=_2d; |
| if(_2d["advice"]){ |
| this._advice=_2d.advice; |
| } |
| _2f=_2d.successful?_2d.successful:false; |
| if(_2d.version<this.minimumVersion){ |
| if(console.log){ |
| } |
| _2f=false; |
| this._advice.reconnect="none"; |
| } |
| dojo.mixin(_30,{reestablish:_2f&&_2e,response:_2d}); |
| } |
| this._publishMeta("handshake",_2f,_30); |
| if(this._status!="handshaking"){ |
| return; |
| } |
| if(_2f){ |
| this._status="connecting"; |
| this._handshook=true; |
| this.currentTransport=dojox.cometd.connectionTypes.match(_2d.supportedConnectionTypes,_2d.version,this._isXD); |
| var _31=this.currentTransport; |
| _31._cometd=this; |
| _31.version=_2d.version; |
| this.clientId=_2d.clientId; |
| this.tunnelInit=_31.tunnelInit&&dojo.hitch(_31,"tunnelInit"); |
| this.tunnelCollapse=_31.tunnelCollapse&&dojo.hitch(_31,"tunnelCollapse"); |
| _31.startup(_2d); |
| }else{ |
| if(!this._advice||this._advice["reconnect"]!="none"){ |
| setTimeout(dojo.hitch(this,"init",this.url,this._props),this._interval()); |
| } |
| } |
| }; |
| this._extendIn=function(_32){ |
| dojo.forEach(dojox.cometd._extendInList,function(f){ |
| _32=f(_32)||_32; |
| }); |
| return _32; |
| }; |
| this._extendOut=function(_33){ |
| dojo.forEach(dojox.cometd._extendOutList,function(f){ |
| _33=f(_33)||_33; |
| }); |
| return _33; |
| }; |
| this.deliver=function(_34){ |
| dojo.forEach(_34,this._deliver,this); |
| return _34; |
| }; |
| this._deliver=function(_35){ |
| _35=this._extendIn(_35); |
| if(!_35["channel"]){ |
| if(_35["success"]!==true){ |
| return; |
| } |
| } |
| this.lastMessage=_35; |
| if(_35.advice){ |
| this._advice=_35.advice; |
| } |
| var _36=null; |
| if((_35["channel"])&&(_35.channel.length>5)&&(_35.channel.substr(0,5)=="/meta")){ |
| switch(_35.channel){ |
| case "/meta/connect": |
| var _37={response:_35}; |
| if(_35.successful){ |
| if(this._status!="connected"){ |
| this._status="connected"; |
| this.endBatch(); |
| } |
| } |
| if(this._initialized){ |
| this._publishMeta("connect",_35.successful,_37); |
| } |
| break; |
| case "/meta/subscribe": |
| _36=this._deferredSubscribes[_35.subscription]; |
| try{ |
| if(!_35.successful){ |
| if(_36){ |
| _36.errback(new Error(_35.error)); |
| } |
| this.currentTransport.cancelConnect(); |
| return; |
| } |
| if(_36){ |
| _36.callback(true); |
| } |
| this.subscribed(_35.subscription,_35); |
| } |
| catch(e){ |
| log.warn(e); |
| } |
| break; |
| case "/meta/unsubscribe": |
| _36=this._deferredUnsubscribes[_35.subscription]; |
| try{ |
| if(!_35.successful){ |
| if(_36){ |
| _36.errback(new Error(_35.error)); |
| } |
| this.currentTransport.cancelConnect(); |
| return; |
| } |
| if(_36){ |
| _36.callback(true); |
| } |
| this.unsubscribed(_35.subscription,_35); |
| } |
| catch(e){ |
| log.warn(e); |
| } |
| break; |
| default: |
| if(_35.successful&&!_35.successful){ |
| this.currentTransport.cancelConnect(); |
| return; |
| } |
| } |
| } |
| this.currentTransport.deliver(_35); |
| if(_35.data){ |
| try{ |
| var _38=[_35]; |
| var _39=_1+_35.channel; |
| var _3a=_35.channel.split("/"); |
| var _3b=_1; |
| for(var i=1;i<_3a.length-1;i++){ |
| dojo.publish(_3b+"/**",_38); |
| _3b+="/"+_3a[i]; |
| } |
| dojo.publish(_3b+"/**",_38); |
| dojo.publish(_3b+"/*",_38); |
| dojo.publish(_39,_38); |
| } |
| catch(e){ |
| } |
| } |
| }; |
| this._sendMessage=function(_3c){ |
| if(this.currentTransport&&!this.batch){ |
| return this.currentTransport.sendMessages([_3c]); |
| }else{ |
| this._messageQ.push(_3c); |
| return null; |
| } |
| }; |
| this.startBatch=function(){ |
| this.batch++; |
| }; |
| this.endBatch=function(){ |
| if(--this.batch<=0&&this.currentTransport&&this._status=="connected"){ |
| this.batch=0; |
| var _3d=this._messageQ; |
| this._messageQ=[]; |
| if(_3d.length>0){ |
| this.currentTransport.sendMessages(_3d); |
| } |
| } |
| }; |
| this._onUnload=function(){ |
| dojo.addOnUnload(dojox.cometd,"disconnect"); |
| }; |
| this._connectTimeout=function(){ |
| var _3e=0; |
| if(this._advice&&this._advice.timeout&&this.expectedNetworkDelay>0){ |
| _3e=this._advice.timeout+this.expectedNetworkDelay; |
| } |
| if(this.connectTimeout>0&&this.connectTimeout<_3e){ |
| return this.connectTimeout; |
| } |
| return _3e; |
| }; |
| },connectionTypes:new dojo.AdapterRegistry(true)}; |
| dojox.cometd.Connection.call(dojox.cometd,"/cometd"); |
| dojo.addOnUnload(dojox.cometd,"_onUnload"); |
| } |
