X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=cloudeebus%2Fcloudeebus.js;h=041c2a62bbe2463caffc46b2c8a58f8f7a47f88c;hb=7c8090b637fe306abbe72c0e913455da1499ed8e;hp=92d31081364efbf75b5c3e0eeda651b1ddcbad79;hpb=3ee6b981ba2fda546bc13051094a4d4511e66b2d;p=contrib%2Fcloudeebus.git diff --git a/cloudeebus/cloudeebus.js b/cloudeebus/cloudeebus.js index 92d3108..041c2a6 100644 --- a/cloudeebus/cloudeebus.js +++ b/cloudeebus/cloudeebus.js @@ -1,5 +1,5 @@ /****************************************************************************** - * Copyright 2012 Intel Corporation. + * Copyright 2012 - 2013 Intel Corporation. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -29,8 +29,8 @@ var dbus = { // hook object for dbus types not translated by python-json /*****************************************************************************/ var cloudeebus = window.cloudeebus = { - version: "0.5.99", - minVersion: "0.3.2" + version: "0.6.1", + minVersion: "0.6.0" }; cloudeebus.reset = function() { @@ -46,18 +46,18 @@ cloudeebus.log = function(msg) { cloudeebus.getError = function(error) { if (error.desc && error.uri) - return error.desc + " : " + error.uri; // error cloudeebus (from python) + return error.desc + " : " + error.uri; // Python exception (cloudeebus.py) if (error.desc) return error.desc; if (error.uri) return error.uri; if (error.name && error.message) - return error.name + " : " + error.message; + return error.name + " : " + error.message; // Javascript exception if (error.message) return error.message; if (error.name) return error.name; - return error; // error from Autobahn + return error; // Autobahn error }; cloudeebus.versionCheck = function(version) { @@ -110,13 +110,12 @@ cloudeebus.connect = function(uri, manifest, successCB, errorCB) { function onWAMPSessionConnectedCB(session) { cloudeebus.wampSession = session; - if (manifest) { + if (manifest) cloudeebus.wampSession.authreq( manifest.name, {permissions: manifest.permissions, services: manifest.services} ).then(onWAMPSessionChallengedCB, onWAMPSessionAuthErrorCB); - } else cloudeebus.wampSession.authreq().then(function() { cloudeebus.wampSession.auth().then(onWAMPSessionAuthenticatedCB, onWAMPSessionAuthErrorCB); @@ -169,22 +168,12 @@ cloudeebus.BusConnection.prototype.getObject = function(busName, objectPath, int cloudeebus.BusConnection.prototype.addService = function(serviceName) { var self = this; - if (!serviceName) - serviceName = ""; - var promise = new cloudeebus.Promise(function (resolver) { var cloudeebusService = new cloudeebus.Service(self.wampSession, self, serviceName); function ServiceAddedSuccessCB(serviceName) { - try { - cloudeebusService.isCreated = true; - resolver.fulfill(cloudeebusService, true); - } - catch (e) { - var errorStr = cloudeebus.getError(e); - cloudeebus.log("Method callback exception: " + errorStr); - resolver.reject(errorStr, true); - } + cloudeebusService.isCreated = true; + resolver.fulfill(cloudeebusService, true); } function ServiceAddedErrorCB(error) { @@ -207,18 +196,30 @@ cloudeebus.BusConnection.prototype.addService = function(serviceName) { +/****************************************************************************** + * Copyright 2012 - 2013 Intel Corporation. + * + * Licensed 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. + *****************************************************************************/ + + + /*****************************************************************************/ -//Generic definition for an agent. An agent needs : -//srvDbusName : the DBus parent service -//objPath : a DBus path to access it -//jsHdl : a Javascript handler to process methods, -//xml : the xml which describe interface/methods/signals... -cloudeebus.Agent = function(srvDbusName, objPath, jsHdl, xml) { - this.srvName = srvDbusName; - this.registered = false; + +cloudeebus.Agent = function(objectPath, handler, xml) { this.xml = xml; - this.objectPath = objPath; - this.jsHdl = jsHdl; + this.objectPath = objectPath; + this.handler = handler; return this; }; @@ -238,26 +239,12 @@ cloudeebus.Service.prototype.remove = function() { var promise = new cloudeebus.Promise(function (resolver) { function ServiceRemovedSuccessCB(serviceName) { - try { - resolver.fulfill(serviceName, true); - } - catch (e) { - var errorStr = cloudeebus.getError(e); - cloudeebus.log("Method callback exception: " + errorStr); - resolver.reject(errorStr, true); - } + resolver.fulfill(serviceName, true); } function ServiceRemovedErrorCB(error) { var errorStr = cloudeebus.getError(error); - cloudeebus.log("Error removing service : " + self.name + ", error: " + errorStr); - self.promise.resolver.reject(errorStr, true); - } - - for (var idx in self.agents) { - if (self.agents[idx]) { - self.removeAgent(self.agents[idx]); - } + resolver.reject(errorStr, true); } var arglist = [ @@ -294,19 +281,19 @@ cloudeebus.Service.prototype._addMethod = function(ifName, method, agent) { var service = this; var methodId = this.name + "#" + agent.objectPath + "#" + ifName + "#" + method; - var funcToCall = this._searchMethod(ifName, method, agent.jsHdl); + var funcToCall = this._searchMethod(ifName, method, agent.handler); if (funcToCall == null) cloudeebus.log("Method " + method + " doesn't exist in Javascript object"); else { - agent.jsHdl.wrapperFunc[method] = function() { + agent.handler.wrapperFunc[method] = function() { var result; var methodId = arguments[0]; var callDict = {}; // affectation of callDict in eval, otherwise dictionary(='{}') interpreted as block of code by eval eval("callDict = " + arguments[1]); try { - result = funcToCall.apply(agent.jsHdl, callDict.args); + result = funcToCall.apply(agent.handler, callDict.args); service._returnMethod(methodId, callDict.callIndex, true, result); } catch (e) { @@ -315,32 +302,25 @@ cloudeebus.Service.prototype._addMethod = function(ifName, method, agent) { service._returnMethod(methodId, callDict.callIndex, false, errorStr); } }; - agent.jsHdl.methodId[agent.objectPath].push(methodId); - this.wampSession.subscribe(methodId, agent.jsHdl.wrapperFunc[method]); + agent.handler.methodId[agent.objectPath].push(methodId); + this.wampSession.subscribe(methodId, agent.handler.wrapperFunc[method]); } }; cloudeebus.Service.prototype._addSignal = function(ifName, signal, agent) { var service = this; - var methodExist = false; - if (agent.jsHdl.interfaceProxies && agent.jsHdl.interfaceProxies[ifName]) - if (agent.jsHdl.interfaceProxies[ifName][signal]) { - methodExist = true; - } else { - agent.jsHdl.interfaceProxies[ifName][signal] = function() { - service._emitSignal(agent.objectPath, signal, arguments[0]); - }; - return; - } - - if ((agent.jsHdl[signal] == undefined || agent.jsHdl[signal] == null) && !methodExist) - agent.jsHdl[signal] = function() { - service._emitSignal(agent.objectPath, signal, arguments[0]); + if (agent.handler[signal]) + cloudeebus.log("Signal '" + signal + "' emitter already implemented"); + else { + agent.handler[signal] = function() { + var args = []; + for (var i=0; i < arguments.length; i++ ) + args.push(arguments[i]); + service._emitSignal(agent.objectPath, signal, args); }; - else - cloudeebus.log("Can not create new method to emit signal '" + signal + "' in object JS this method already exist!"); + } }; @@ -349,9 +329,9 @@ cloudeebus.Service.prototype._createWrapper = function(agent) { var parser = new DOMParser(); var xmlDoc = parser.parseFromString(agent.xml, "text/xml"); var ifXml = xmlDoc.getElementsByTagName("interface"); - agent.jsHdl.wrapperFunc = []; - agent.jsHdl.methodId = []; - agent.jsHdl.methodId[agent.objectPath] = []; + agent.handler.wrapperFunc = {}; + agent.handler.methodId = {}; + agent.handler.methodId[agent.objectPath] = []; for (var i=0; i < ifXml.length; i++) { var ifName = ifXml[i].attributes.getNamedItem("name").value; var ifChild = ifXml[i].firstChild; @@ -375,35 +355,27 @@ cloudeebus.Service.prototype.addAgent = function(agent) { var promise = new cloudeebus.Promise(function (resolver) { function ServiceAddAgentSuccessCB(objPath) { - try { // calling dbus hook object function for un-translated types - self.agents.push(agent); - agent.registered = true; - resolver.fulfill(objPath, true); + self.agents.push(agent); + try { + self._createWrapper(agent); } catch (e) { var errorStr = cloudeebus.getError(e); - cloudeebus.log("Method callback exception: " + errorStr); + cloudeebus.log("Exception creating agent wrapper " + agent.objectPath + " : " + errorStr); resolver.reject(errorStr, true); + return; } + resolver.fulfill(objPath, true); } function ServiceAddAgenterrorCB(error) { var errorStr = cloudeebus.getError(error); cloudeebus.log("Error adding agent : " + agent.objectPath + ", error: " + errorStr); - self.promise.resolver.reject(errorStr, true); - } - - try { - self._createWrapper(agent); - } - catch (e) { - var errorStr = cloudeebus.getError(e); - cloudeebus.log("Exception creating agent wrapper " + agent.objectPath + " : " + errorStr); resolver.reject(errorStr, true); - return; } var arglist = [ + self.name, agent.objectPath, agent.xml ]; @@ -417,19 +389,17 @@ cloudeebus.Service.prototype.addAgent = function(agent) { cloudeebus.Service.prototype._deleteWrapper = function(agent) { - var objJs = agent.jsHdl; + var objJs = agent.handler; if (objJs.methodId[agent.objectPath]) { - for (var idx in objJs.methodId[agent.objectPath]) { + while (objJs.methodId[agent.objectPath].length) { try { - cloudeebus.log("unsubscribe " + objJs.methodId[agent.objectPath][idx]); - this.wampSession.unsubscribe(objJs.methodId[agent.objectPath][idx]); - objJs.methodId[agent.objectPath][idx] = null; + this.wampSession.unsubscribe( objJs.methodId[agent.objectPath].pop() ); } catch (e) { cloudeebus.log("Unsubscribe error: " + cloudeebus.getError(e)); } } - delete objJs.methodId[agent.objectPath]; + objJs.methodId[agent.objectPath] = null; } }; @@ -438,34 +408,25 @@ cloudeebus.Service.prototype.removeAgent = function(rmAgent) { var self = this; var promise = new cloudeebus.Promise(function (resolver) { - function ServiceRemoveAgentSuccessCB(agent) { - try { // calling dbus hook object function for un-translated types - self.agents.pop(agent); - agent.registered = false; - resolver.fulfill(agent, true); - } - catch (e) { - var errorStr = cloudeebus.getError(e); - cloudeebus.log("Method callback exception: " + errorStr); - resolver.reject(errorStr, true); - } + function ServiceRemoveAgentSuccessCB(objectPath) { + // Searching agent in list + for (var idx in self.agents) + if (self.agents[idx].objectPath == objectPath) { + agent = self.agents[idx]; + break; + } + + self.agents.splice(idx, 1); + self._deleteWrapper(agent); + resolver.fulfill(agent, true); } function ServiceRemoveAgentErrorCB(error) { var errorStr = cloudeebus.getError(error); cloudeebus.log("Error removing agent : " + rmAgent.objectPath + ", error: " + errorStr); - self.promise.resolver.reject(errorStr, true); + resolver.reject(errorStr, true); } - try { - self._deleteWrapper(rmAgent); - } - catch (e) { - var errorStr = cloudeebus.getError(e); - cloudeebus.log("Exception removing wrapper of agent " + rmAgent.objectPath + " : " + errorStr); - errorCB(errorStr); - } - var arglist = [ rmAgent.objectPath ]; @@ -490,11 +451,11 @@ cloudeebus.Service.prototype._returnMethod = function(methodId, callIndex, succe }; -cloudeebus.Service.prototype._emitSignal = function(objectPath, signalName, result, successCB, errorCB) { +cloudeebus.Service.prototype._emitSignal = function(objectPath, signalName, args, successCB, errorCB) { var arglist = [ objectPath, signalName, - result + JSON.stringify(args) ]; this.wampSession.call("emitSignal", arglist).then(successCB, errorCB); @@ -502,6 +463,24 @@ cloudeebus.Service.prototype._emitSignal = function(objectPath, signalName, resu +/****************************************************************************** + * Copyright 2012 - 2013 Intel Corporation. + * + * Licensed 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. + *****************************************************************************/ + + + /*****************************************************************************/ function _processWrappers(wrappers, value) { @@ -513,8 +492,10 @@ function _processWrappers(wrappers, value) { function _processWrappersAsync(wrappers, value) { var taskid = -1; function processAsyncOnce() { - _processWrappers(wrappers, value); + if (!wrappers.processed) + _processWrappers(wrappers, value); clearInterval(taskid); + wrappers.processed = true; } taskid = setInterval(processAsyncOnce, 200); } @@ -704,7 +685,7 @@ cloudeebus.Promise.any = function() { resolver.resolve(undefined, true); else for (i in arguments) - Promise.resolve(arguments[i]).appendWrappers(fulfillCallback,rejectCallback); + cloudeebus.Promise.resolve(arguments[i]).appendWrappers(fulfillCallback,rejectCallback); return promise; }; @@ -729,7 +710,7 @@ cloudeebus.Promise.every = function() { resolver.resolve(args, true); }; index++; - Promise.resolve(arguments[i]).appendWrappers(fulfillCallback,rejectCallback); + cloudeebus.Promise.resolve(arguments[i]).appendWrappers(fulfillCallback,rejectCallback); } return promise; @@ -756,7 +737,7 @@ cloudeebus.Promise.some = function() { resolver.reject(args, true); }; index++; - Promise.resolve(arguments[i]).appendWrappers(fulfillCallback,rejectCallback); + cloudeebus.Promise.resolve(arguments[i]).appendWrappers(fulfillCallback,rejectCallback); } return promise; @@ -764,6 +745,24 @@ cloudeebus.Promise.some = function() { +/****************************************************************************** + * Copyright 2012 - 2013 Intel Corporation. + * + * Licensed 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. + *****************************************************************************/ + + + /*****************************************************************************/ cloudeebus.ProxyObject = function(session, busConnection, busName, objectPath) { @@ -772,6 +771,7 @@ cloudeebus.ProxyObject = function(session, busConnection, busName, objectPath) { this.busName = busName; this.objectPath = objectPath; this.interfaceProxies = {}; + this.childNodeNames = []; return this; }; @@ -809,6 +809,10 @@ cloudeebus.ProxyObject.prototype._introspect = function(successCB, errorCB) { function introspectSuccessCB(str) { var parser = new DOMParser(); var xmlDoc = parser.parseFromString(str, "text/xml"); + var nodes = xmlDoc.getElementsByTagName("node"); + // first node is the parent/head node + for(var i=1; i < nodes.length; i++) + self.childNodeNames.push(nodes[i].getAttribute("name")); var interfaces = xmlDoc.getElementsByTagName("interface"); self.propInterfaces = []; var supportDBusProperties = false;