| /* |
| 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 _f in this._subscriptions){ |
| for(var sub in this._subscriptions[_f]){ |
| if(this._subscriptions[_f][sub].topic){ |
| dojo.unsubscribe(this._subscriptions[_f][sub].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(_12,_13,_14){ |
| var _15={data:_13,channel:_12}; |
| if(_14){ |
| dojo.mixin(_15,_14); |
| } |
| this._sendMessage(_15); |
| }; |
| this.subscribe=function(_16,_17,_18,_19){ |
| _19=_19||{}; |
| if(_17){ |
| var _1a=_1+_16; |
| var _1b=this._subscriptions[_1a]; |
| if(!_1b||_1b.length==0){ |
| _1b=[]; |
| _19.channel="/meta/subscribe"; |
| _19.subscription=_16; |
| this._sendMessage(_19); |
| var _ds=this._deferredSubscribes; |
| if(_ds[_16]){ |
| _ds[_16].cancel(); |
| delete _ds[_16]; |
| } |
| _ds[_16]=new dojo.Deferred(); |
| } |
| for(var i in _1b){ |
| if(_1b[i].objOrFunc===_17&&(!_1b[i].funcName&&!_18||_1b[i].funcName==_18)){ |
| return null; |
| } |
| } |
| var _1e=dojo.subscribe(_1a,_17,_18); |
| _1b.push({topic:_1e,objOrFunc:_17,funcName:_18}); |
| this._subscriptions[_1a]=_1b; |
| } |
| var ret=this._deferredSubscribes[_16]||{}; |
| ret.args=dojo._toArray(arguments); |
| return ret; |
| }; |
| this.unsubscribe=function(_20,_21,_22,_23){ |
| if((arguments.length==1)&&(!dojo.isString(_20))&&(_20.args)){ |
| return this.unsubscribe.apply(this,_20.args); |
| } |
| var _24=_1+_20; |
| var _25=this._subscriptions[_24]; |
| if(!_25||_25.length==0){ |
| return null; |
| } |
| var s=0; |
| for(var i in _25){ |
| var sb=_25[i]; |
| if((!_21)||(sb.objOrFunc===_21&&(!sb.funcName&&!_22||sb.funcName==_22))){ |
| dojo.unsubscribe(_25[i].topic); |
| delete _25[i]; |
| }else{ |
| s++; |
| } |
| } |
| if(s==0){ |
| _23=_23||{}; |
| _23.channel="/meta/unsubscribe"; |
| _23.subscription=_20; |
| delete this._subscriptions[_24]; |
| this._sendMessage(_23); |
| this._deferredUnsubscribes[_20]=new dojo.Deferred(); |
| if(this._deferredSubscribes[_20]){ |
| this._deferredSubscribes[_20].cancel(); |
| delete this._deferredSubscribes[_20]; |
| } |
| } |
| return this._deferredUnsubscribes[_20]; |
| }; |
| this.disconnect=function(){ |
| for(var _29 in this._subscriptions){ |
| for(var sub in this._subscriptions[_29]){ |
| if(this._subscriptions[_29][sub].topic){ |
| dojo.unsubscribe(this._subscriptions[_29][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(_2b,_2c){ |
| }; |
| this.unsubscribed=function(_2d,_2e){ |
| }; |
| this.tunnelInit=function(_2f,_30){ |
| }; |
| 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(_32,_33,_34){ |
| try{ |
| var _35={cometd:this,action:_32,successful:_33,state:this.state()}; |
| if(_34){ |
| dojo.mixin(_35,_34); |
| } |
| dojo.publish(this.prefix+"/meta",[_35]); |
| } |
| catch(e){ |
| |
| } |
| }; |
| this._finishInit=function(_36){ |
| if(this._status!="handshaking"){ |
| return; |
| } |
| var _37=this._handshook; |
| var _38=false; |
| var _39={}; |
| if(_36 instanceof Error){ |
| dojo.mixin(_39,{reestablish:false,failure:true,error:_36,advice:this._advice}); |
| }else{ |
| _36=_36[0]; |
| _36=this._extendIn(_36); |
| this.handshakeReturn=_36; |
| if(_36["advice"]){ |
| this._advice=_36.advice; |
| } |
| _38=_36.successful?_36.successful:false; |
| if(_36.version<this.minimumVersion){ |
| if(console.log){ |
| |
| } |
| _38=false; |
| this._advice.reconnect="none"; |
| } |
| dojo.mixin(_39,{reestablish:_38&&_37,response:_36}); |
| } |
| this._publishMeta("handshake",_38,_39); |
| if(this._status!="handshaking"){ |
| return; |
| } |
| if(_38){ |
| this._status="connecting"; |
| this._handshook=true; |
| this.currentTransport=dojox.cometd.connectionTypes.match(_36.supportedConnectionTypes,_36.version,this._isXD); |
| var _3a=this.currentTransport; |
| _3a._cometd=this; |
| _3a.version=_36.version; |
| this.clientId=_36.clientId; |
| this.tunnelInit=_3a.tunnelInit&&dojo.hitch(_3a,"tunnelInit"); |
| this.tunnelCollapse=_3a.tunnelCollapse&&dojo.hitch(_3a,"tunnelCollapse"); |
| _3a.startup(_36); |
| }else{ |
| if(!this._advice||this._advice["reconnect"]!="none"){ |
| setTimeout(dojo.hitch(this,"init",this.url,this._props),this._interval()); |
| } |
| } |
| }; |
| this._extendIn=function(_3b){ |
| dojo.forEach(dojox.cometd._extendInList,function(f){ |
| _3b=f(_3b)||_3b; |
| }); |
| return _3b; |
| }; |
| this._extendOut=function(_3d){ |
| dojo.forEach(dojox.cometd._extendOutList,function(f){ |
| _3d=f(_3d)||_3d; |
| }); |
| return _3d; |
| }; |
| this.deliver=function(_3f){ |
| dojo.forEach(_3f,this._deliver,this); |
| return _3f; |
| }; |
| this._deliver=function(_40){ |
| _40=this._extendIn(_40); |
| if(!_40["channel"]){ |
| if(_40["success"]!==true){ |
| return; |
| } |
| } |
| this.lastMessage=_40; |
| if(_40.advice){ |
| this._advice=_40.advice; |
| } |
| var _41=null; |
| if((_40["channel"])&&(_40.channel.length>5)&&(_40.channel.substr(0,5)=="/meta")){ |
| switch(_40.channel){ |
| case "/meta/connect": |
| var _42={response:_40}; |
| if(_40.successful){ |
| if(this._status!="connected"){ |
| this._status="connected"; |
| this.endBatch(); |
| } |
| } |
| if(this._initialized){ |
| this._publishMeta("connect",_40.successful,_42); |
| } |
| break; |
| case "/meta/subscribe": |
| _41=this._deferredSubscribes[_40.subscription]; |
| try{ |
| if(!_40.successful){ |
| if(_41){ |
| _41.errback(new Error(_40.error)); |
| } |
| this.currentTransport.cancelConnect(); |
| return; |
| } |
| if(_41){ |
| _41.callback(true); |
| } |
| this.subscribed(_40.subscription,_40); |
| } |
| catch(e){ |
| log.warn(e); |
| } |
| break; |
| case "/meta/unsubscribe": |
| _41=this._deferredUnsubscribes[_40.subscription]; |
| try{ |
| if(!_40.successful){ |
| if(_41){ |
| _41.errback(new Error(_40.error)); |
| } |
| this.currentTransport.cancelConnect(); |
| return; |
| } |
| if(_41){ |
| _41.callback(true); |
| } |
| this.unsubscribed(_40.subscription,_40); |
| } |
| catch(e){ |
| log.warn(e); |
| } |
| break; |
| default: |
| if(_40.successful&&!_40.successful){ |
| this.currentTransport.cancelConnect(); |
| return; |
| } |
| } |
| } |
| this.currentTransport.deliver(_40); |
| if(_40.data){ |
| try{ |
| var _43=[_40]; |
| var _44=_1+_40.channel; |
| var _45=_40.channel.split("/"); |
| var _46=_1; |
| for(var i=1;i<_45.length-1;i++){ |
| dojo.publish(_46+"/**",_43); |
| _46+="/"+_45[i]; |
| } |
| dojo.publish(_46+"/**",_43); |
| dojo.publish(_46+"/*",_43); |
| dojo.publish(_44,_43); |
| } |
| catch(e){ |
| |
| } |
| } |
| }; |
| this._sendMessage=function(_48){ |
| if(this.currentTransport&&!this.batch){ |
| return this.currentTransport.sendMessages([_48]); |
| }else{ |
| this._messageQ.push(_48); |
| return null; |
| } |
| }; |
| this.startBatch=function(){ |
| this.batch++; |
| }; |
| this.endBatch=function(){ |
| if(--this.batch<=0&&this.currentTransport&&this._status=="connected"){ |
| this.batch=0; |
| var _49=this._messageQ; |
| this._messageQ=[]; |
| if(_49.length>0){ |
| this.currentTransport.sendMessages(_49); |
| } |
| } |
| }; |
| this._onUnload=function(){ |
| dojo.addOnUnload(dojox.cometd,"disconnect"); |
| }; |
| this._connectTimeout=function(){ |
| var _4a=0; |
| if(this._advice&&this._advice.timeout&&this.expectedNetworkDelay>0){ |
| _4a=this._advice.timeout+this.expectedNetworkDelay; |
| } |
| if(this.connectTimeout>0&&this.connectTimeout<_4a){ |
| return this.connectTimeout; |
| } |
| return _4a; |
| }; |
| },connectionTypes:new dojo.AdapterRegistry(true)}; |
| dojox.cometd.Connection.call(dojox.cometd,"/cometd"); |
| dojo.addOnUnload(dojox.cometd,"_onUnload"); |
| } |
