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