/*ADOBE SYSTEMS INCORPORATED
|
Copyright 2007 Adobe Systems Incorporated
|
All Rights Reserved.
|
|
NOTICE: Adobe permits you to use, modify, and distribute this file in accordance with the
|
terms of the Adobe license agreement accompanying it. If you have received this file from a
|
source other than Adobe, then your use, modification, or distribution of it requires the prior
|
written permission of Adobe.*/
|
ColdFusion.WebSocket={NS:"coldfusion.websocket.channels",WELCOME:"welcome",AUTHENTICATE:"authenticate",SUBSCRIBE:"subscribe",UNSUBSCRIBE:"unsubscribe",PUBLISH:"publish",INVOKE_AND_PUBLISH:"invokeAndPublish",GET_CHANNELS:"getChannels",GET_SUBSCRIBER_COUNT:"getSubscriberCount",GET_SUBSCRIPTIONS:"getSubscriptions",SEND_MESSAGE:"sendMessage",INVOKE_AND_MESSAGE:"invokeAndSend",INVOKE:"invoke",STOP:"stop",init:function(id,_393,_394,_395,_396,_397,_398,_399,_39a){
|
if(cf_ws.isWebSocketSupported()){
|
lWSC=new cf_ws.CFWebSocketWrapper();
|
ColdFusion.WebSocket[id]=lWSC;
|
lWSC.options={OnWelcome:this.cfonOpencallBk,OnMessage:this.cfMessageHandlerCallBk,OnClose:_398,onError:_399,appName:_393,cfauth:_394,subscribeTo:_395,referrer:_39a};
|
var _39b=self.location.hostname;
|
if(_39b&&_39b=="localhost"){
|
_39b="127.0.0.1";
|
}
|
var lURL="ws://"+(_39b)+":"+_cf_websocket_port+"/cfusion"+"/cfusion";
|
var lRes=lWSC.open(lURL,lWSC.options);
|
lWSC.isOpen=true;
|
lWSC.processConnected=function(_39e){
|
};
|
lWSC.processDisconnected=function(_39f){
|
};
|
lWSC.defaultMessageHandler=_396;
|
if(_397){
|
lWSC.appOnOpenHandler=_397;
|
}
|
lWSC.channelSpecificResHandlers={};
|
lWSC.subscribercount_callbackHandlers={};
|
return lWSC;
|
}else{
|
var _3a0={ns:ColdFusion.WebSocket.NS,reqType:ColdFusion.WebSocket.WELCOME,code:-1,msg:"Browser neither have native WebSocket support nor a flash player for the fallback."};
|
var _3a1=_399!=null?_399:_396;
|
_3a1(_3a0);
|
}
|
},welcome:function(_3a2,_3a3,_3a4){
|
var lRes=this.isConnected();
|
if(lRes==true){
|
this.sendToken({ns:ColdFusion.WebSocket.NS,type:ColdFusion.WebSocket.WELCOME,authKey:_3a2,subscribeTo:_3a3,appName:_3a4});
|
}
|
return lRes;
|
},authenticate:function(_3a6,_3a7){
|
var lRes=this.isConnected();
|
if(lRes==true){
|
this.sendToken({ns:ColdFusion.WebSocket.NS,type:ColdFusion.WebSocket.AUTHENTICATE,username:_3a6,password:_3a7,appName:this.options.appName});
|
}
|
return lRes;
|
},subscribe:function(_3a9,_3aa,_3ab){
|
var lRes=this.isConnected();
|
if(lRes==true){
|
var _3ad={ns:ColdFusion.WebSocket.NS,type:ColdFusion.WebSocket.SUBSCRIBE,channel:_3a9,appName:this.options.appName};
|
if(_3aa!=null&&(typeof _3aa=="object")){
|
_3ad.customOptions=_3aa;
|
}
|
this.sendToken(_3ad);
|
if(_3ab){
|
this.channelSpecificResHandlers[_3a9]=_3ab;
|
this.channelName_subscriptionInProcess=_3a9;
|
}
|
}
|
return lRes;
|
},unsubscribe:function(_3ae){
|
var lRes=this.isConnected();
|
if(lRes==true){
|
var _3b0={ns:ColdFusion.WebSocket.NS,type:ColdFusion.WebSocket.UNSUBSCRIBE,channel:_3ae,appName:this.options.appName};
|
this.sendToken(_3b0);
|
delete this.channelSpecificResHandlers[_3ae];
|
}
|
return lRes;
|
},publish:function(_3b1,_3b2,_3b3){
|
var lRes=this.isConnected();
|
if(lRes==true){
|
var _3b5={ns:ColdFusion.WebSocket.NS,type:ColdFusion.WebSocket.PUBLISH,channel:_3b1,data:_3b2,appName:this.options.appName};
|
if(_3b3!=null&&(typeof _3b3=="object")){
|
_3b5.customOptions=_3b3;
|
}
|
this.sendToken(_3b5);
|
}
|
return lRes;
|
},invokeAndPublish:function(_3b6,_3b7,_3b8,_3b9,_3ba){
|
var lRes=this.isConnected();
|
if(lRes==true){
|
var _3bc={ns:ColdFusion.WebSocket.NS,type:ColdFusion.WebSocket.INVOKE_AND_PUBLISH,channel:_3b6,cfcName:_3b7,cfcMethod:_3b8,methodArguments:_3b9,appName:this.options.appName,referrer:this.options.referrer};
|
if(_3ba!=null&&(typeof _3ba=="object")){
|
_3bc.customOptions=_3ba;
|
}
|
this.sendToken(_3bc);
|
}
|
return lRes;
|
},getSubscriberCount:function(_3bd,_3be){
|
var lRes=this.isConnected();
|
if(lRes==true){
|
var _3c0={ns:ColdFusion.WebSocket.NS,type:ColdFusion.WebSocket.GET_SUBSCRIBER_COUNT,channel:_3bd,appName:this.options.appName};
|
this.sendToken(_3c0);
|
}
|
if(_3be){
|
if(!this.subscribercount_callbackHandlers){
|
this.subscribercount_callbackHandlers={};
|
}
|
this.subscribercount_callbackHandlers[_3bd]=_3be;
|
}
|
return lRes;
|
},getSubscriptions:function(_3c1){
|
var lRes=this.isConnected();
|
if(lRes==true){
|
var _3c3={ns:ColdFusion.WebSocket.NS,type:ColdFusion.WebSocket.GET_SUBSCRIPTIONS,appName:this.options.appName};
|
this.sendToken(_3c3);
|
}
|
if(_3c1){
|
this.subscriptions_callbackHandler=_3c1;
|
}
|
return lRes;
|
},sendMessage:function(_3c4,_3c5,_3c6){
|
var lRes=this.isConnected();
|
if(lRes==true){
|
var _3c8={ns:ColdFusion.WebSocket.NS,type:ColdFusion.WebSocket.SEND_MESSAGE,targetId:_3c4,data:_3c5,appName:this.options.appName};
|
if(_3c6!=null&&(typeof _3c6=="object")){
|
_3c8.customOptions=_3c6;
|
}
|
this.sendToken(_3c8);
|
}
|
return lRes;
|
},invokeAndSend:function(_3c9,_3ca,_3cb,_3cc,_3cd){
|
var lRes=this.isConnected();
|
if(lRes==true){
|
var _3cf={ns:ColdFusion.WebSocket.NS,type:ColdFusion.WebSocket.INVOKE_AND_MESSAGE,target:_3c9,cfcName:_3ca,cfcMethod:_3cb,methodArguments:_3cc,appName:this.options.appName};
|
if(_3cd!=null&&(typeof _3cd=="object")){
|
_3cf.customOptions=_3cd;
|
}
|
this.sendToken(_3cf);
|
}
|
return lRes;
|
},invoke:function(_3d0,_3d1,_3d2,_3d3){
|
var lRes=this.isConnected();
|
if(lRes==true){
|
var _3d5={ns:ColdFusion.WebSocket.NS,type:ColdFusion.WebSocket.INVOKE,cfcName:_3d0,cfcMethod:_3d1,methodArguments:_3d2,appName:this.options.appName,referrer:this.options.referrer};
|
if(_3d3!=null&&(typeof _3d3=="object")){
|
_3d5.customOptions=_3d3;
|
}
|
this.sendToken(_3d5);
|
}
|
return lRes;
|
},openConnection:function(){
|
var lURL=cf_ws.URL_SERVER;
|
this.open(lURL,this.options);
|
},isConnectionOpen:function(){
|
var _3d7=this.isConnected();
|
return _3d7;
|
},closeConnection:function(){
|
this.close({fireClose:true});
|
},cfonOpencallBk:function(_3d8){
|
if(this.cfauth!=null||this.susbcribeTo!=null){
|
_3d8.welcome(this.cfauth,this.subscribeTo,this.appName);
|
}
|
if(_3d8.appOnOpenHandler){
|
_3d8.appOnOpenHandler.call(_3d8);
|
}
|
},cfMessageHandlerCallBk:function(_3d9,_3da){
|
var _3db=_3da.defaultMessageHandler;
|
if((_3d9.type=="event")&&(_3d9.name=="connect"||_3d9.name=="disconnect")){
|
return;
|
}
|
if((_3d9.reqType=="subscribe")&&_3da.channelName_subscriptionInProcess!=null){
|
if(_3d9.code==-1){
|
delete _3da.channelSpecificResHandlers[_3da.channelName_subscriptionInProcess];
|
}
|
delete _3da.channelName_subscriptionInProcess;
|
}
|
if((_3d9.reqType=="getSubscriberCount")&&_3da.subscribercount_callbackHandlers[_3d9.channel]!=null){
|
_3da.subscribercount_callbackHandlers[_3d9.channel].call(this,_3d9);
|
delete _3da.subscribercount_callbackHandlers[_3d9.channelname];
|
return;
|
}
|
if((_3d9.reqType=="getSubscriptions")&&_3da.subscriptions_callbackHandler!=null){
|
_3da.subscriptions_callbackHandler(_3d9);
|
delete _3da.subscriptions_callbackHandler;
|
return;
|
}
|
if(_3d9.type=="data"&&_3d9.channelname){
|
var _3dc=_3d9.channelname;
|
var _3dd=_3da.channelSpecificResHandlers[_3dc];
|
while(_3dd==null){
|
var lPos=_3dc.lastIndexOf(".");
|
if(lPos>0){
|
_3dc=_3dc.substr(0,lPos);
|
_3dd=_3da.channelSpecificResHandlers[_3dc];
|
}else{
|
break;
|
}
|
}
|
if(_3dd){
|
_3db=_3dd;
|
}
|
}
|
_3db.call(this,_3d9);
|
}};
|
function cfwebsocketinit(){
|
var _3df=ColdFusion.WebSocket;
|
ns=cf_ws;
|
for(var _3e0 in _3df){
|
ns["CFWebSocketWrapper"].prototype[_3e0]=_3df[_3e0];
|
}
|
}
|
cfwebsocketinit();
|
