iopsys-feed/luciexpress/htdocs/js/rpc.js

//! Author: Martin K. Schröder <mkschreder.uk@gmail.com>

(function(scope){
	var RPC_HOST = ""; //(($config.rpc.host)?$config.rpc.host:"")
	var RPC_SESSION_ID = "00000000000000000000000000000000"; 
	var RPC_DEFAULT_SESSION_ID = "00000000000000000000000000000000"; 
	var gettext = function(text){ return text; }; 
	var default_calls = [
		"session.access", 
		"session.login", 
		"local.features", 
		"local.set_rpc_host"
	]; 
	
	function rpc_request(type, namespace, method, data){
		var sid = ""; 
		var deferred = $.Deferred(); 
		// setup default rpcs
		$.jsonRPC.withOptions({
			namespace: "", 
			endPoint: RPC_HOST+"/ubus"
		}, function(){	 
			//var sid = "00000000000000000000000000000000"; 
			//if($rootScope.sid) sid = $rootScope.sid; 
			//data.ubus_rpc_session = sid;  
			this.request(type, {
				params: [ RPC_SESSION_ID, namespace, method, data],
				success: function(result){
					//console.log("SID: "+sid + " :: "+ JSON.stringify(result)); 
					if(type == "call" && result && result.result) {
						// TODO: modify all rpc UCI services so that they ALWAYS return at least 
						// an empty json object. Otherwise we have no way to differentiate success 
						// from failure of a request. This has to be done on the host side. 
						if(result.result[0] != 0){ // || result.result[1] == undefined) {
							function _errstr(error){
								switch(error){
									case 0: return gettext("Parse error"); 
									case 1: return gettext("Invalid request"); 
									case 2: return gettext("Invalid parameters"); 
									case 3: return gettext("Internal error"); 
									case 4: return gettext("Object not found"); 
									case 5: return gettext("Session not found"); 
									case 6: return gettext("Access denied"); 
									case 7: return gettext("Timed out"); 
									default: return gettext("RPC error #")+result.result[0]+": "+result.result[1]; 
								}
							}
							console.log("RPC succeeded ("+namespace+"."+method+"), but returned error: "+JSON.stringify(result)+": "+_errstr(result.result[0]));
							deferred.reject(_errstr(result.result[0])); 
						} else {
							deferred.resolve(result.result[1]);
						}
					} else if(type == "list" && result && result.result){
						if((typeof result.result) == "object")
							deferred.resolve(result.result); 
						else 
							deferred.reject(result.result[1]); // for etimeout [1, "ETIMEOUT"]
					} else {
						deferred.reject(); 
					}
				}, 
				error: function(result){
					console.error("RPC error ("+namespace+"."+method+"): "+JSON.stringify(result));
					if(result && result.error){
						deferred.reject(result.error);  
						//$rootScope.$broadcast("error", result.error.message); 
					}
				}
			})
		});
		return deferred.promise(); 
	}
	var rpc = {
		$sid: function(sid){
			if(sid) RPC_SESSION_ID = sid; 
			else return RPC_SESSION_ID; 
		}, 
		$authenticate: function(){
			var self = this; 
			var deferred  = $.Deferred(); 
			
			self.session.access({
				"keys": ""
			}).done(function(result){
                if(!("username" in (result.data||{}))) {
					console.log("Session: Not authenticated!");
					RPC_SESSION_ID = RPC_DEFAULT_SESSION_ID; // reset sid to 000..
					deferred.reject(); 
				} else {
					self.$session = result; 
					if(!("data" in self.$session)) self.$session.data = {}; 
					console.log("Session: Loggedin! "); 
					deferred.resolve(result); 
				}  
			}).fail(function err(result){
				RPC_SESSION_ID = RPC_DEFAULT_SESSION_ID; 
				deferred.reject(); 
			}); 
			return deferred.promise(); 
		}, 
		$login: function(opts){
			var self = this; 
			var deferred  = $.Deferred(); 
			
			self.session.login({
				"username": opts.username, 
				"password": opts.password
			}).done(function(result){
				RPC_SESSION_ID = result.ubus_rpc_session;
				self.$session = result; 
				//JUCI.localStorage.setItem("sid", self.sid); 
				//if(result && result.acls && result.acls.ubus) setupUbusRPC(result.acls.ubus); 
				deferred.resolve(self.sid); 
			}).fail(function(result){
				deferred.reject(result); 
			}); 
			return deferred.promise(); 
		},
		$register: function(call){
			//console.log("registering: "+call); 
			if(!call) return; 
			var self = this; 
			function _find(path, obj){
				if(!obj.hasOwnProperty(path[0])){
					obj[path[0]] = {}; 
				}
				if(path.length == 1) {
					var namespace = call.split("."); 
					namespace.pop(); namespace = namespace.join("."); 
					(function(namespace, method){
						// create the rpc method
						obj[path[0]] = function(data){
							if(!data) data = { }; 
							return rpc_request("call", namespace, method, data); 
						}
					})(namespace, path[0]); 
				} else {
					var child = path[0]; 
					path.shift(); 
					_find(path, obj[child]); 
				}
			}
			_find(call.split("."), self); 
		}, 
		$init: function(host){
			var self = this; 
			if(host) {
				if(host.host) RPC_HOST = host.host;
			} 
			console.log("Init UBUS"); 
			var deferred = $.Deferred(); 
			default_calls.map(function(x){ self.$register(x); }); 
			// request list of all methods and construct rpc object containing all of the methods in javascript. 
			rpc_request("list", "*", "", {}).done(function(result){
				//console.log("RESULT: "+JSON.stringify(result)); 
				// TODO: make this less obscure of a method :)
				function _processNode(obj, cur_path){
					var is_leaf = true; 
					var leafs = {}; 
					Object.keys(obj).map(function(x){
						if((typeof obj[x]) == "object") {
							leafs[x] = obj[x]; 
							is_leaf = false; 
						} else {
							
						}
					}); 
					if(is_leaf && cur_path){
						// add a new rpc call 
						//console.log("Leaf: "+namespace+", "+method); 
						self.$register(cur_path); 
					} else { 
						//console.log("Processing node: "+cur_path); 
						Object.keys(leafs).map(function(x){
							var path = ((cur_path)?(cur_path+"."):"")+x; 
							_processNode(leafs[x], path); 
						}); 
					}
				}
				_processNode(result, null); 
				deferred.resolve(); 
			}).fail(function(){
				deferred.reject(); 
			}); 
			return deferred.promise(); 
		}
	}; 
	
	scope.UBUS = rpc; 
	/*if(exports.JUCI){
		var JUCI = exports.JUCI; 
		JUCI.ubus = rpc; 
		console.log(JSON.stringify(JUCI.app)); 
		// luci rpc module for communicating with the server
		if(JUCI.app) {
			JUCI.app.factory('$rpc', function($rootScope, $config, gettext){
				return window.rpc; 
			}); 
		}
	} else {
		console.log("RPC: Not registering as JUCI plugin!"); 
	}*/
	
})(typeof exports === 'undefined'? this : global);