_base.js

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