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