| 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.RestChannels"]){dojo._hasResource["dojox.cometd.RestChannels"]=true;dojo.provide("dojox.cometd.RestChannels");dojo.require("dojox.rpc.Client");dojo.requireIf(dojox.data&&!!dojox.data.JsonRestStore,"dojox.data.restListener");(function(){dojo.declare("dojox.cometd.RestChannels",null,{constructor:function(_1){dojo.mixin(this,_1);if(dojox.rpc.Rest&&this.autoSubscribeRoot){var _2=dojox.rpc.Rest._get;var _3=this;dojox.rpc.Rest._get=function(_4,id){var _5=dojo.xhrGet;dojo.xhrGet=function(r){var _6=_3.autoSubscribeRoot;return (_6&&r.url.substring(0,_6.length)==_6)?_3.get(r.url,r):_5(r);};var _7=_2.apply(this,arguments);dojo.xhrGet=_5;return _7;};}},absoluteUrl:function(_8,_9){return new dojo._Url(_8,_9)+"";},acceptType:"application/rest+json,application/http;q=0.9,*/*;q=0.7",subscriptions:{},subCallbacks:{},autoReconnectTime:3000,reloadDataOnReconnect:true,sendAsJson:false,url:"/channels",autoSubscribeRoot:"/",open:function(){this.started=true;if(!this.connected){this.connectionId=dojox.rpc.Client.clientId;var _a=this.createdClientId?"Client-Id":"Create-Client-Id";this.createdClientId=true;var _b={Accept:this.acceptType};_b[_a]=this.connectionId;var _c=dojo.xhrPost({headers:_b,url:this.url,noStatus:true});var _d=this;this.lastIndex=0;var _e,_f=function(_10){if(typeof dojo=="undefined"){return null;}if(xhr&&xhr.status>400){return _e(true);}if(typeof _10=="string"){_10=_10.substring(_d.lastIndex);}var _11=xhr&&(xhr.contentType||xhr.getResponseHeader("Content-Type"))||(typeof _10!="string"&&"already json");var _12=_d.onprogress(xhr,_10,_11);if(_12){if(_e()){return new Error(_12);}}if(!xhr||xhr.readyState==4){xhr=null;if(_d.connected){_d.connected=false;_d.open();}}return _10;};_e=function(_13){if(xhr&&xhr.status==409){_d.disconnected();return null;}_d.createdClientId=false;_d.disconnected();return _13;};_c.addCallbacks(_f,_e);var xhr=_c.ioArgs.xhr;if(xhr){xhr.onreadystatechange=function(){var _14;try{if(xhr.readyState==3){_d.readyState=3;_14=xhr.responseText;}}catch(e){}if(typeof _14=="string"){_f(_14);}};}if(window.attachEvent){window.attachEvent("onunload",function(){_d.connected=false;if(xhr){xhr.abort();}});}this.connected=true;}},_send:function(_15,_16,_17){if(this.sendAsJson){_16.postData=dojo.toJson({target:_16.url,method:_15,content:_17,params:_16.content,subscribe:_16.headers["Subscribe"]});_16.url=this.url;_15="POST";}else{_16.postData=dojo.toJson(_17);}return dojo.xhr(_15,_16,_16.postData);},subscribe:function(_18,_19){_19=_19||{};_19.url=this.absoluteUrl(this.url,_18);if(_19.headers){delete _19.headers.Range;}var _1a=this.subscriptions[_18];var _1b=_19.method||"HEAD";var _1c=_19.since;var _1d=_19.callback;var _1e=_19.headers||(_19.headers={});this.subscriptions[_18]=_1c||_1a||0;var _1f=this.subCallbacks[_18];if(_1d){this.subCallbacks[_18]=_1f?function(m){_1f(m);_1d(m);}:_1d;}if(!this.connected){this.open();}if(_1a===undefined||_1a!=_1c){_1e["Cache-Control"]="max-age=0";_1c=typeof _1c=="number"?new Date(_1c).toUTCString():_1c;if(_1c){_1e["Subscribe-Since"]=_1c;}_1e["Subscribe"]=_19.unsubscribe?"none":"*";var dfd=this._send(_1b,_19);var _20=this;dfd.addBoth(function(_21){var xhr=dfd.ioArgs.xhr;if(!(_21 instanceof Error)){if(_19.confirmation){_19.confirmation();}}if(xhr&&xhr.getResponseHeader("Subscribed")=="OK"){var _22=xhr.getResponseHeader("Last-Modified");if(xhr.responseText){_20.subscriptions[_18]=_22||new Date().toUTCString();}else{return null;}}else{if(xhr&&!(_21 instanceof Error)){delete _20.subscriptions[_18];}}if(!(_21 instanceof Error)){var _23={responseText:xhr&&xhr.responseText,channel:_18,getResponseHeader:function(_24){return xhr.getResponseHeader(_24);},getAllResponseHeaders:function(){return xhr.getAllResponseHeaders();},result:_21};if(_20.subCallbacks[_18]){_20.subCallbacks[_18](_23);}}else{if(_20.subCallbacks[_18]){_20.subCallbacks[_18](xhr);}}return _21;});return dfd;}return null;},publish:function(_25,_26){return this._send("POST",{url:_25,contentType:"application/json"},_26);},_processMessage:function(_27){_27.event=_27.event||_27.getResponseHeader("Event");if(_27.event=="connection-conflict"){return "conflict";}try{_27.result=_27.result||dojo.fromJson(_27.responseText);}catch(e){}var _28=this;var loc=_27.channel=new dojo._Url(this.url,_27.source||_27.getResponseHeader("Content-Location"))+"";if(loc in this.subscriptions&&_27.getResponseHeader){this.subscriptions[loc]=_27.getResponseHeader("Last-Modified");}if(this.subCallbacks[loc]){setTimeout(function(){_28.subCallbacks[loc](_27);},0);}this.receive(_27);return null;},onprogress:function(xhr,_29,_2a){if(!_2a||_2a.match(/application\/rest\+json/)){var _2b=_29.length;_29=_29.replace(/^\s*[,\[]?/,"[").replace(/[,\]]?\s*$/,"]");try{var _2c=dojo.fromJson(_29);this.lastIndex+=_2b;}catch(e){}}else{if(dojox.io&&dojox.io.httpParse&&_2a.match(/application\/http/)){var _2d="";if(xhr&&xhr.getAllResponseHeaders){_2d=xhr.getAllResponseHeaders();}_2c=dojox.io.httpParse(_29,_2d,xhr.readyState!=4);}else{if(typeof _29=="object"){_2c=_29;}}}if(_2c){for(var i=0;i<_2c.length;i++){if(this._processMessage(_2c[i])){return "conflict";}}return null;}if(!xhr){return "error";}if(xhr.readyState!=4){return null;}if(xhr.__proto__){xhr={channel:"channel",__proto__:xhr};}return this._processMessage(xhr);},get:function(_2e,_2f){(_2f=_2f||{}).method="GET";return this.subscribe(_2e,_2f);},receive:function(_30){if(dojox.data&&dojox.data.restListener){dojox.data.restListener(_30);}},disconnected:function(){var _31=this;if(this.connected){this.connected=false;if(this.started){setTimeout(function(){var _32=_31.subscriptions;_31.subscriptions={};for(var i in _32){if(_31.reloadDataOnReconnect&&dojox.rpc.JsonRest){delete dojox.rpc.Rest._index[i];dojox.rpc.JsonRest.fetch(i);}else{_31.subscribe(i,{since:_32[i]});}}_31.open();},this.autoReconnectTime);}}},unsubscribe:function(_33,_34){_34=_34||{};_34.unsubscribe=true;this.subscribe(_33,_34);},disconnect:function(){this.started=false;this.xhr.abort();}});var _35=dojox.cometd.RestChannels.defaultInstance=new dojox.cometd.RestChannels();if(dojox.cometd.connectionTypes){_35.startup=function(_36){_35.open();this._cometd._deliver({channel:"/meta/connect",successful:true});};_35.check=function(_37,_38,_39){for(var i=0;i<_37.length;i++){if(_37[i]=="rest-channels"){return !_39;}}return false;};_35.deliver=function(_3a){};dojo.connect(this,"receive",null,function(_3b){_3b.data=_3b.result;this._cometd._deliver(_3b);});_35.sendMessages=function(_3c){for(var i=0;i<_3c.length;i++){var _3d=_3c[i];var _3e=_3d.channel;var _3f=this._cometd;var _40={confirmation:function(){_3f._deliver({channel:_3e,successful:true});}};if(_3e=="/meta/subscribe"){this.subscribe(_3d.subscription,_40);}else{if(_3e=="/meta/unsubscribe"){this.unsubscribe(_3d.subscription,_40);}else{if(_3e=="/meta/connect"){_40.confirmation();}else{if(_3e=="/meta/disconnect"){_35.disconnect();_40.confirmation();}else{if(_3e.substring(0,6)!="/meta/"){this.publish(_3e,_3d.data);}}}}}}};dojox.cometd.connectionTypes.register("rest-channels",_35.check,_35,false,true);}})();}
|
