| <library> | |
| <!-- | |
| Licensed to the Apache Software Foundation (ASF) under one | |
| or more contributor license agreements. See the NOTICE file | |
| distributed with this work for additional information | |
| regarding copyright ownership. The ASF licenses this file | |
| to you under the Apache License, Version 2.0 (the | |
| "License"); you may not use this file except in compliance | |
| with the License. You may obtain a copy of the License at | |
| http://www.apache.org/licenses/LICENSE-2.0 | |
| Unless required by applicable law or agreed to in writing, | |
| software distributed under the License is distributed on an | |
| "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY | |
| KIND, either express or implied. See the License for the | |
| specific language governing permissions and limitations | |
| under the License. | |
| --> | |
| <class name="rtmpConnection" extends="node"> | |
| <switch> | |
| <when property="$as3"> | |
| <passthrough> | |
| import flash.net.NetConnection; | |
| import flash.events.NetStatusEvent; | |
| </passthrough> | |
| </when> | |
| </switch> | |
| <attribute name="debug" value="false" type="boolean" /> | |
| <event name="onconnect"/> | |
| <event name="onerror"/> | |
| <!-- this attribute holds a reference to the current/last called netremoteCall, | |
| in case of error you can debug that way which call did fail --> | |
| <attribute name="lastCalled" value="null" /> | |
| <attribute name="src" value="" type="string"/> | |
| <method name="connect"> | |
| this._nc = new NetConnection(); | |
| // local reference to rtmpconnection | |
| //this._nc.t = this; | |
| this._nc.proxyType = canvas.proxyType; | |
| var ok = this._nc.connect(src == "null" ? null : src, true); //isAVClient = true | |
| if (this.debug) { | |
| if($debug) Debug.write("*** debug ***"); | |
| } | |
| this._nc.addEventListener(NetStatusEvent.NET_STATUS, _onStatus); | |
| if($debug) Debug.write("devRtmpConnection/registerMethods()"); | |
| var clientObj = {}; | |
| clientObj.setId = this.setId; | |
| this._nc.client = clientObj; | |
| //Register Methods | |
| //this.registerMethods(); | |
| </method> | |
| <method name="setId" args="tId"> | |
| if ($debug) Debug.write("setId ", tId); | |
| </method> | |
| <method name="_onStatus" args="stats"><![CDATA[ | |
| if ($debug) { | |
| Debug.write("devrtmpconnection", this, "_onStatus", stats.info.code); | |
| } | |
| var msg = ""; | |
| var s; | |
| switch (stats.info.code) { | |
| case "NetConnection.Connect.Success": { | |
| // The connection attempt succeeded. | |
| //canvas.currentNC is the reference to the NetConnection that is used in the NetStream | |
| msg = stats.info.code; | |
| canvas.currentNC = this._nc; | |
| s = 2; | |
| break; | |
| } | |
| case "NetConnection.Connect.Closed": { | |
| msg = stats.info.code; | |
| this._nc = null; | |
| canvas.currentNC = null; | |
| s = 0; | |
| break; | |
| } | |
| default: { | |
| msg = stats.info.code; | |
| s = 0; | |
| break; | |
| } | |
| } | |
| this.setAttribute("status", msg); | |
| if (s == 2) { | |
| this.onconnect.sendEvent(); | |
| } else { | |
| this.onerror.sendEvent(); | |
| } | |
| ]]> | |
| </method> | |
| <method name="disconnect"> | |
| if ($debug) Debug.write(" DISCONNECT "); | |
| if (this._nc != null) { | |
| this._nc.close(); | |
| } | |
| </method> | |
| <!--- | |
| With this function all methods are registered to the NetConnection | |
| A server can invoke this Method with a call for it from the Client | |
| Only subnodes of rtmpconnections which are a instance of netRemoteCallHib | |
| are registered, to add dynamically methods to the remotefunction you will | |
| have to invoke this method once again | |
| -swagner | |
| --> | |
| <method name="registerMethods"> | |
| <![CDATA[ | |
| if (this.subnodes!=null){ | |
| var clientObj = {}; | |
| //Register all methods which are onstanceof netRemoteCallHib | |
| for (var i=0;i<this.subnodes.length;i++){ | |
| //If it is of Type netRemoteCallHib then register it to the NetConnection | |
| if (this.subnodes[i] instanceof lz.netRemoteCallHib){ | |
| clientObj[this.subnodes[i].funcname] = function( args ){ | |
| return canvas.thishib.remoteCallMethod(arguments.callee,arguments); | |
| //return hib.remoteCallMethod(arguments.callee,args); | |
| } | |
| } | |
| } | |
| this._nc.client = clientObj; | |
| } | |
| ]]> | |
| </method> | |
| <!-- | |
| Process the RemoteCall to the Right Funtion | |
| -swagner | |
| --> | |
| <method name="remoteCallMethod" args="callee,args"> | |
| <![CDATA[ | |
| for (var eg in this._nc){ | |
| if (this._nc[eg]==callee){ | |
| if (this.debug) { | |
| //_root.Debug.write.write("DEBUG invoked a function remotely: ",eg,args); | |
| } | |
| if (args.length == 1) { | |
| return this.callFuntion(eg,args[0]); | |
| } else { | |
| return this.callFuntion(eg,args); | |
| } | |
| //return this.callFuntion(eg,args); | |
| } | |
| } | |
| ]]> | |
| </method> | |
| <!-- | |
| Map the Function to a netRemoteCallHib | |
| -swagner | |
| --> | |
| <method name="callFuntion" args="funcname,args"> | |
| <![CDATA[ | |
| for (var i=0;i<this.subnodes.length;i++){ | |
| if (this.subnodes[i].funcname==funcname){ | |
| return this.subnodes[i].onResult(args); | |
| } | |
| } | |
| ]]> | |
| </method> | |
| <method name="callRPC" args="func, obj, params"> | |
| //if ($debug) Debug.write("*** call: func, obj, params",func,obj, typeof (params) ,params.length); | |
| if (params.length != 0){ | |
| //does this really work? | |
| //ASSetPropFlags(_global, null, 8, 1); | |
| //setPropertyIsEnumerable(8, 1); | |
| //Debug.write("does it work?",arguments); | |
| <!-- | |
| this._nc.call.apply(this._nc,arguments); | |
| --> | |
| if (params.length==1){ | |
| this._nc.call(func, obj,params[0]); | |
| } else if (params.length==2){ | |
| this._nc.call(func, obj,params[0],params[1]); | |
| } else if (params.length==3){ | |
| this._nc.call(func, obj,params[0],params[1],params[2]); | |
| } else if (params.length==4){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3]); | |
| } else if (params.length==5){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4]); | |
| } else if (params.length==6){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5]); | |
| } else if (params.length==7){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6]); | |
| } else if (params.length==8){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7]); | |
| } else if (params.length==9){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8]); | |
| } else if (params.length==10){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8],params[9]); | |
| } else if (params.length==11){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8],params[9],params[10]); | |
| } else if (params.length==12){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8],params[9],params[10],params[11]); | |
| } else if (params.length==13){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8],params[9],params[10],params[11],params[12]); | |
| } else if (params.length==14){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8],params[9],params[10],params[11],params[12],params[13]); | |
| } else if (params.length==15){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8],params[9],params[10],params[11],params[12],params[13],params[14]); | |
| } else if (params.length==16){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8],params[9],params[10],params[11],params[12],params[13],params[14],params[15]); | |
| } else if (params.length==17){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8],params[9],params[10],params[11],params[12],params[13],params[14],params[15],params[16]); | |
| } else if (params.length==18){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8],params[9],params[10],params[11],params[12],params[13],params[14],params[15],params[16],params[17]); | |
| } else if (params.length==19){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8],params[9],params[10],params[11],params[12],params[13],params[14],params[15],params[16],params[17],params[18]); | |
| } else if (params.length==20){ | |
| this._nc.call(func, obj,params[0],params[1],params[2],params[3],params[4],params[5],params[6],params[7],params[8],params[9],params[10],params[11],params[12],params[13],params[14],params[15],params[16],params[17],params[18],params[19]); | |
| } | |
| } else { | |
| this._nc.call(func, obj); | |
| } | |
| </method> | |
| </class> | |
| <!--- | |
| Net remote call. | |
| @todo Document netremotecall class. | |
| --> | |
| <class name="netremotecall" extends="node"> | |
| <switch> | |
| <when property="$as3"> | |
| <passthrough> | |
| import flash.net.Responder; | |
| </passthrough> | |
| </when> | |
| </switch> | |
| <!--- Name of the remote function. --> | |
| <attribute name="funcname" value="$once{null}" type="string" /> | |
| <attribute name="remotecontext" value="null" /> | |
| <attribute name="dataobject" value="null" /> | |
| <attribute name="responder" value="null" /> | |
| <!--- Data handling event. args="value" --> | |
| <event name="ondata" /> | |
| <!--- Error handling event. --> | |
| <event name="onerror"/> | |
| <!--- Call the remote method, passing the array of params. --> | |
| <method name="callRPC" args="params"><![CDATA[ | |
| if (this.funcname == null) { | |
| //Debug.write("No funcname given"); | |
| if (this.onerror) this.onerror.sendEvent("No funcname given"); | |
| return; | |
| } | |
| if (params == null) { | |
| params = new Array(); | |
| var subnodes = this.subnodes; | |
| if (subnodes != null) { | |
| var i; | |
| var n = subnodes.length; | |
| for (i = 0; i < n; i++) { | |
| // If getValue method is declared in param, call that | |
| // instead to get value. | |
| var tsi = subnodes[i]; | |
| //TODO: fixme | |
| //if ((tsi["getValue"] != null) && (tsi.getValue["prototype"] != null)) { | |
| // params[i] = tsi.getValue(); | |
| // Debug.write("tsi.getValue():", tsi.getValue()); | |
| //} else { | |
| // params[i] = tsi.value; | |
| //} | |
| params[i] = tsi.getValue(); | |
| } | |
| } | |
| } else if (params.__proto__ != Array.prototype) { | |
| //Debug.write(this.name, "error: first argument (params) is not an array"); | |
| return -1; | |
| } | |
| //if ($debug) Debug.write("call", this, this.parent, this.parent.status); | |
| var rtmpObject = null; | |
| if (this.parent instanceof lz.rtmpConnection){ | |
| rtmpObject = this.parent; | |
| } else if(this.remotecontext instanceof lz.rtmpConnection){ | |
| rtmpObject = this.remotecontext; | |
| } else { | |
| if ($debug) Debug.warn("ERROR: no remotecontext availible abort call", this.funcname, this); | |
| return; | |
| } | |
| //Debug.write('call', this, rtmpObject, rtmpObject.status); | |
| //Debug.write('call', this.remotecontext); | |
| if (rtmpObject.debug) Debug.write('call', this, rtmpObject, rtmpObject.status); | |
| rtmpObject.lastCalled = this; | |
| this.responder = new Responder(onResult); | |
| rtmpObject.callRPC(this.funcname, this.responder, params); | |
| ]]> | |
| </method> | |
| <!--- Handle the result returned from the remote method. --> | |
| <method name="onResult" args="value"><![CDATA[ | |
| // Can be overriden. | |
| // Would be great if it can be used with dataobject, | |
| // but I don't know how to convert Array/primitive to LzDataset/LzDataPointer. | |
| ////Debug.write("netremotecall", this, "onResult", value); | |
| if (this.dataobject!=null) { | |
| if ( this.dataobject instanceof LzDataset ) { | |
| //Debug.write("onResult: ",this,value,dataobject); | |
| var element = LzDataElement.valueToElement(value); | |
| this.dataobject.setData(element.childNodes); | |
| } else if ( this.dataobject instanceof LzDataElement ) { | |
| var element = LzDataElement.valueToElement(value); | |
| this.dataobject.appendChild( element ); | |
| } else { | |
| //TODO:fixme | |
| //Debug.warn("dataobject is not LzDataset or LzDataElement: ",this,this.dataobject,delegate); | |
| } | |
| } | |
| this.ondata.sendEvent(value); | |
| ]]> | |
| </method> | |
| </class> | |
| <!--- | |
| Net parameter. | |
| Element to use inside netremotecall. | |
| @todo Document netparam class. | |
| --> | |
| <class name="netparam" extends="node"> | |
| <!--- The value of the netparam. --> | |
| <attribute name="value" value="null"/> | |
| </class> | |
| </library> |