re-added at revision 1.8

exec/json-svc-ctrl.js

+log = function() {
+
+}
+
+load("json-client.js");
+load("sbbsdefs.js");				// K_*
+load("uifcdefs.js");				// WIN_*
+
+if(uifc == undefined) {
+	writeln("UIFC interface not available!");
+	exit(1);
+}
+
+var db;
+
+/* verify db connection */
+function verifyConnection() {
+	if(!db.socket.is_connected) {
+		uifc.msg("Socket disconnected");
+		return false;
+	}
+	return true;
+}
+
+/* wait for confirmation or error from db */
+function wait(func) {
+	var start = Date.now();
+	do {
+		var packet = db.receive();
+		if(!packet)
+			continue;
+		else if(packet.func == func) 
+			return packet.data;
+		else 
+			db.updates.push(packet.data);
+	} while(Date.now() - start < db.settings.SOCK_TIMEOUT);
+	throw("timed out waiting for server response");
+}
+
+/* process a menu choice */
+function processSelection(object) {
+	var str;
+	try {
+		switch(object.type) {
+		case "string":
+			str=uifc.input(WIN_MID, object.name, object.val, 0, K_EDIT);
+			if(str!=undefined)
+				object.val=str;
+			break;
+		case "date":
+			str=uifc.input(WIN_MID, object.name, object.val, 8, K_EDIT);
+			if(str!=undefined)
+				object.val=str;
+			break;
+		case "number":
+			str=uifc.input(WIN_MID, object.name, object.val.toString(), 0, K_NUMBER|K_EDIT);
+			if(str!=undefined)
+				object.val=Number(str);
+			break;
+		case "boolean":
+			object.val=!object.val;
+			break;
+		case "password":
+			str=uifc.input(WIN_MID, object.name, object.val, 0, K_EDIT);
+			if(str!=undefined)
+				object.val=str;
+			break;
+		case "function":
+			object.func();
+			break;
+		}
+	} catch(e) {
+		uifc.msg(e);
+	}
+}
+
+/* initialize uifc list */
+function initList(object) {
+	var list=new Array();
+	for(i=0; i<object.length; i++) {
+		switch(object[i].type) {
+			case "string":
+			case "date":
+			case "number":
+			case "boolean":
+				list.push(format("%-35s %s",object[i].name,object[i].val));
+				break;
+			case "password":
+				list.push(format("%-35s %s",object[i].name,object[i].val?"********":""));
+				break;
+			case "function":
+				list.push(format("%-35s %s",object[i].name,""));
+				break;
+		}
+	}
+	return list;
+}
+
+/* server configuration menu */
+function configureServer() {
+	var last=0;
+	var serverProperties=[
+		{	
+			name:"Server hostname"
+			,type:"string"
+			,val:"localhost"
+		}
+		,{	
+			name:"Server port"
+			,type:"number"
+			,val:"10088"
+		}
+		,{	
+			name:"User Name"
+			,type:"string"
+			,val:"your name"
+		}
+		,{
+			name:"User Password"
+			,type:"password"
+			,val:"your password"
+		}
+		,{
+			name:"Connect to Server"
+			,type:"function"
+			,func:connect
+		}
+	];
+	
+	/* connect to server */
+	function connect() {
+		if(!db)
+			db = new JSONClient(serverProperties[0].val,serverProperties[1].val);
+		if(!db.socket.is_connected)
+			db.connect();
+		db.ident("ADMIN",serverProperties[2].val,serverProperties[3].val);
+		var trash = wait("OK");
+		serviceAdmin();
+	}
+
+	for(;;) {
+		var list=initList(serverProperties);
+		var i=uifc.list(WIN_MID|WIN_ORG|WIN_ACT|WIN_ESC, 0, 0, 0, last, last, "Server Configuration", list);
+		
+		/* close connection and exit */
+		if(i==-1) {
+			if(db && db.socket.is_connected) 
+				db.disconnect();
+			exit();
+		}
+		
+		/* process selection */
+		else if(serverProperties[i]) {
+			last=i;
+			processSelection(serverProperties[i]);
+		}
+	}
+}
+
+/* control service and modules */
+function serviceAdmin() {
+	var i;
+	var last=0;
+	var serviceMenu=[
+		{	
+			 prop:"Restart"
+			,name:"Restart Service"
+			,type:"function"
+			,func:function() {
+				db.send({scope:"ADMIN",func:"RESTART"});
+				uifc.msg(wait("OK"));
+			}
+		}
+		,{	
+			 prop:"Close"
+			,name:"Close Service"
+			,type:"function"
+			,func:function() {
+				db.send({scope:"ADMIN",func:"CLOSE"});
+				uifc.msg(wait("OK"));
+			}
+		}
+		,{	
+			 prop:"Open"
+			,name:"Open Service"
+			,type:"function"
+			,func:function() {
+				db.send({scope:"ADMIN",func:"OPEN"});
+				uifc.msg(wait("OK"));
+			}
+		}
+		,{	
+			 prop:"Modules"
+			,name:"Modules"
+			,type:"function"
+			,func:moduleList
+		}
+	];
+	var list=initList(serviceMenu);
+
+	for(;;) {
+		if(!verifyConnection())
+			return;
+		i=uifc.list(WIN_MID|WIN_ORG, 0, 0, 0, last, last, "Server Administration", list);
+		/* process selection */
+		if(i==-1) {
+			db.disconnect();
+			return;
+		}
+		else if(serviceMenu[i]) {
+			last=i;
+			processSelection(serviceMenu[i]);
+		}
+	}
+}
+
+/* list service modules */
+function moduleList() {
+	
+	var last=0;
+	var list;
+	var moduleMenu;
+	
+	function init() {
+		db.send({scope:"ADMIN",func:"MODULES"});
+		var modules = db.wait();
+		
+		list = [];
+		moduleMenu=[];
+		for each(var m in modules) {
+			moduleMenu.push(m);
+			m.type = "function";
+			m.func = function() {
+				moduleAdmin(this);
+			}
+			list.push(format("%-35s %s",m.name,m.status?"online":"offline"));
+		}
+	}
+	
+	for(;;) {
+		if(!verifyConnection())
+			return;
+
+		init();
+		i=uifc.list(WIN_MID|WIN_ACT|WIN_ESC, 0, 0, 0, last, last, "Service Modules", list);
+		
+		/* process selection */
+		if(i==-1)
+			return;
+		else if(moduleMenu[i]) {
+			last=i;
+			processSelection(moduleMenu[i]);
+		}
+
+	}
+}
+
+/* configure a module */
+function moduleAdmin(module) {
+	var i;
+	var last=0;
+	var list;
+	
+	var moduleOptions=[
+		{	
+			 prop:"Set Offline"
+			,name:"Set Offline"
+			,type:"function"
+			,func:function() {
+				db.send({scope:module.name,func:"CLOSE"});
+				uifc.msg(wait("OK"));
+			}
+		}
+		,{	
+			 prop:"Set Online"
+			,name:"Set Online"
+			,type:"function"
+			,func:function() {
+				db.send({scope:module.name,func:"OPEN"});
+				uifc.msg(wait("OK"));
+			}
+		}
+		,{	
+			 prop:"Reload"
+			,name:"Reload"
+			,type:"function"
+			,func:function() {
+				db.send({scope:module.name,func:"RELOAD"});
+				uifc.msg(wait("OK"));
+			}
+		}
+		,{	
+			 prop:"Browse"
+			,name:"Browse"
+			,type:"function"
+			,func:function() {
+				browseData(module);
+			}
+		}
+		,{	
+			 prop:"Users"
+			,name:"Users"
+			,type:"function"
+			,func:function() {
+				whoData(module);
+			}
+		}
+		,{	
+			 prop:"Save Data"
+			,name:"Save Data"
+			,type:"function"
+			,func:function() {
+				db.send({scope:module.name,func:"SAVE"});
+				uifc.msg(wait("OK"));
+			}
+		}
+	];
+	
+	for(;;) {
+		if(!verifyConnection())
+			return;
+
+		list=initList(moduleOptions);
+		i=uifc.list(WIN_MID|WIN_ORG, 0, 0, 0, last, last, "Module Administration", list);
+		/* process selection */
+		if(i==-1) 
+			return;
+		else if(moduleOptions[i]) {
+			last=i;
+			processSelection(moduleOptions[i]);
+		}
+	}
+	
+}
+
+/* browse a module's database (recursive) */
+function browseData(module,location,dataType) {
+		
+	var last=0;
+	var list;
+	var keys;
+	var dataMenu;
+	var path;
+	
+	if(dataType == undefined) {
+		dataType = "object";
+	}
+	if(location == undefined) {
+		path = "";
+	}
+	else {
+		path = location + ".";
+	}
+	
+	function init() {
+		/* load in object list */
+		if(location == undefined) {
+			keys = db.keyTypes(module.name,"",1);
+		}
+		else {
+			keys = db.keyTypes(module.name,location,1);
+		}
+
+		list = [];
+		dataMenu = [];
+		for(var k=0;k<keys.length;k++) {
+			var data = db.read(module.name,path+keys[k],1);
+			switch(typeof data) {
+			case "object":
+				var item = {
+					name:keys[k],
+					type:"function",
+					val:data
+				};
+				if(data instanceof Array) {
+					list.push(format("%-35s %s",keys[k],"[...]"));
+					item.func=function() {
+						browseData(module,path+this.name,"array");
+					}
+				}
+				else {
+					list.push(format("%-35s %s",keys[k],"{...}"));
+					item.func=function() {
+						browseData(module,path+this.name,"object");
+					}
+				}
+				dataMenu.push(item);
+				break;
+			case "string":
+			case "number":
+			case "boolean":
+			case "undefined":
+				var item = {
+					name:keys[k],
+					type:typeof data,
+					val:data
+				};
+				list.push(format("%-35s %s",keys[k],data));
+				dataMenu.push(item);
+				break;
+			default:
+				break;
+			}
+		}
+	}
+	
+	function process(object) {
+		
+		/* if we are an array or object, browse */
+		switch(object.type) {
+		case "function":
+			object.func();
+			return;
+		}
+		/* otherwise, edit value */
+		var new_val = object.val;
+		switch(object.type) {
+		case "string":
+			str=uifc.input(WIN_MID, object.name, object.val, 0, K_EDIT);
+			if(str != undefined) 
+				new_val=str;
+			break;
+		case "number":
+			str=uifc.input(WIN_MID, object.name, object.val.toString(), 0, K_NUMBER|K_EDIT);
+			if(str != undefined) 
+				new_val=parseInt(str);
+			break;
+		case "boolean":
+			new_val=!object.val;
+			break;
+		default:
+			// fall through?
+			return;
+		}
+		
+		/* if the value has changed, write it to the db */
+		if(new_val !== object.val) {
+			db.lock(module.name,path+object.name,2);
+			var cur_val = db.read(module.name,path+object.name);
+			if(cur_val !== object.val) {
+				object.val = cur_val;
+				uifc.msg("Value has been modified remotely, aborting change");
+			}
+			else {
+				object.val = new_val;
+				db.write(module.name,path+object.name,object.val);
+			}
+			db.unlock(module.name,path+object.name);
+		}
+	}
+	
+	for(;;) {
+		if(!verifyConnection())
+			return;
+
+		init();
+		i=uifc.list(WIN_MID|WIN_ORG|WIN_XTR|WIN_INS|WIN_DEL, 0, 0, 0, last, last, "Browse Data", list);
+		
+		/* process selection */
+		if(i == -1) {
+			return;
+		}
+		if(i-MSK_DEL>=0 && dataMenu[i-MSK_DEL]) {
+			var index = i-MSK_DEL;
+			delObject(module,path + dataMenu[index].name);
+		}
+		else if(i-MSK_INS>=0 && (dataMenu[i-MSK_INS] || i-MSK_INS == dataMenu.length)) {
+			var index = i-MSK_INS;
+			insObject(module,location,index,dataType);
+		}
+		else if(dataMenu[i]) {
+			last=i;
+			process(dataMenu[i]);
+		}
+	}
+}
+
+/* list module subscribers */
+function whoData(module) {
+	
+	var userList, userMenu, list;
+	
+	function init() {
+		userList = db.who(module.name,"");
+		list=[];
+		
+		for each(var u in userList) {
+			u.type = "string";
+			if(u.nick == "")
+				list.push("SERVICE");
+			else
+				list.push(u.nick);
+		}
+	}
+	
+	for(;;) {
+		if(!verifyConnection())
+			return;
+
+		init();
+		i=uifc.list(WIN_MID|WIN_ACT|WIN_ESC, 0, 0, 0, 0, 0, "Module Users", list);
+		/* process selection */
+		if(i == -1) {
+			return;
+		}
+	}
+}
+
+/* choose a data type */
+function getDataType() {
+	
+	var last=0;
+	var list;
+	var dataTypes=[
+		{	
+			name:"String"
+			,type:"function"
+			,val:"string"
+		},
+		{	
+			name:"Number"
+			,type:"function"
+			,val:"number"
+		},
+		{	
+			name:"Array"
+			,type:"function"
+			,val:"array"
+		},
+		{	
+			name:"Object"
+			,type:"function"
+			,val:"object"
+		},
+		{	
+			name:"Boolean"
+			,type:"function"
+			,val:"boolean"
+		}
+	];
+	
+	for(;;) {
+		if(!verifyConnection())
+			return;
+
+		list=initList(dataTypes);
+		i=uifc.list(WIN_MID|WIN_ACT|WIN_ESC, 0, 0, 0, last, last, "Data Types", list);
+		
+		/* process selection */
+		if(i==-1)
+			return;
+		else if(dataTypes[i]) {
+			last=i;
+			return dataTypes[i].val;
+		}
+
+	}
+}
+
+/* insert a new object */
+function insObject(module,location,index,dataType) {
+	
+	var key=undefined;
+	var val=undefined;
+	
+	if(dataType=="object") {
+		key=uifc.input(WIN_MID, "New object property name", "", 0, K_EDIT);
+		if(key == undefined)
+			return;
+	}
+
+	/* choose a data type for new element */
+	var type=getDataType();
+	
+	/* prompt for new value based on data type */
+	switch(type) {
+	case "string":
+		val=uifc.input(WIN_MID, "Enter String", "", 0, K_EDIT);
+		break;
+	case "number":
+		val=uifc.input(WIN_MID, "Enter Number", "", 0, K_NUMBER|K_EDIT);
+		if(val!=undefined)
+			val=Number(val);
+		break;
+	case "boolean":
+		var choice = uifc.list(WIN_MID, 0, 0, 0, 0, 0, "Choose", ["True","False"]);
+		if(choice == 0)
+			val = true;
+		else if(choice == 1)
+			val = false;
+		break;
+	case "array":
+		val = [];
+		break;
+	case "object":
+		val = {};
+		break;
+	}
+	
+	/* if we did not choose a value, abort insert */
+	if(val == undefined) {
+		return;
+	}
+	
+	/* if key is not specified, we are in an array */
+	if(key == undefined) {
+		db.splice(module.name,location,index,0,val,2);
+	}
+	
+	/*otherwise, we're setting a new object property */
+	else {
+		db.write(module.name,location+"."+key,val,2);
+	}
+}
+
+/* delete an object */
+function delObject(module,location) {
+	var choice=uifc.list(WIN_MID, 0, 0, 0, 0, 0, "Are you sure?", ["Yes","No"]);
+	if(choice == 1)
+		return;
+	db.remove(module.name,location,2);
+}
+
+/* configure server address/port and user name/password */
+uifc.init("JSON Service Control");
+configureServer();
+uifc.pop();
+uifc.bail();