From bab08e91a8f3a513b949cfb6a755e33e97fd2672 Mon Sep 17 00:00:00 2001
From: mcmlxxix <>
Date: Fri, 20 May 2011 21:52:37 +0000
Subject: [PATCH] new JSON socket service
---
exec/json-service.js | 130 +++++++++++++++++++++++++++++++++++++++++++
1 file changed, 130 insertions(+)
create mode 100644 exec/json-service.js
diff --git a/exec/json-service.js b/exec/json-service.js
new file mode 100644
index 0000000000..a1256d8663
--- /dev/null
+++ b/exec/json-service.js
@@ -0,0 +1,130 @@
+load("event-timer.js");
+load("json-sock.js");
+load("json-db.js");
+
+var timer = new Timer();
+var maindb = new JSONdb(system.data_dir+"db.json");
+
+/* server object */
+service = new (function() {
+
+ this.VERSION = "$Revision$".split(' ')[1];
+ this.sockets = [];
+ this.timeout = 1;
+
+ this.init = function() {
+
+ /* method called when socket is selected for reading */
+ Socket.prototype.cycle = function() {
+ var packet=this.recvJSON();
+ if(!packet)
+ return false;
+ switch(packet.func.toUpperCase()) {
+ /* main database queries */
+ case "QUERY":
+ maindb.query(this,packet.data);
+ break;
+ /* unknown queries (usually a specific module) */
+ default:
+ engine.query(this,packet);
+ break;
+ }
+ }
+
+ server.socket.nonblocking = true;
+ server.socket.cycle = function() {
+ var client=this.accept();
+ client.nonblocking = true;
+ client.id = client.descriptor;
+ service.sockets.push(client);
+ log(LOG_INFO,"connected: " + client.remote_ip_address);
+ }
+
+ this.sockets.push(server.socket);
+ log(LOG_INFO,"JSON server initialized (v" + this.VERSION + ")");
+ }
+
+ this.cycle = function() {
+ var active=socket_select(this.sockets,this.timeout);
+ for each(var s in active) {
+ this.sockets[s].cycle();
+ }
+ for(var s=1;s<this.sockets.length;s++) {
+ if(!this.sockets[s].is_connected) {
+ log(LOG_INFO,"disconnected: " + this.sockets[s].remote_ip_address);
+ database.release(this.sockets[s].descriptor);
+ this.sockets.splice(s--,1);
+ }
+ }
+ }
+
+ this.init();
+})();
+
+/* module handler */
+engine = new (function() {
+
+ this.modules = [];
+
+ this.file = new File(system.ctrl_dir + "json-service.ini");
+
+ this.init = function() {
+ /* if there is no module initialization file, fuck it */
+ if(!file_exists(this.file.name))
+ return;
+
+ this.file.open('r');
+ var modules=this.file.iniGetObject();
+ this.file.close();
+
+ for(var l in modules) {
+ this.modules[l.toUpperCase()]=new Module(modules[l],l);
+ }
+ }
+
+ this.cycle = function() {
+ for each(var m in this.modules) {
+ m.cycle();
+ }
+ }
+
+ this.query = function(client,query) {
+ if(this.modules[query.func.toUpperCase()]) {
+ this.modules[module.toUpperCase()].query(client,query.data);
+ }
+ else {
+ var error={
+ func:"ERROR",
+ data:{
+ operation:"ERROR",
+ error_num:0,
+ error_desc:"module not found"
+ }
+ };
+ client.sendJSON(error);
+ }
+ }
+
+ function Module(dir,name) {
+ this.dir=dir;
+ this.name=name;
+ this.init=function() {
+ log(LOG_DEBUG,"initializing module: " + l);
+ if(file_exists(this.dir + "service.js")) {
+ load(this,this.dir + "service.js");
+ }
+ }
+
+ this.init();
+ }
+
+ this.init();
+})();
+
+/* main service loop */
+while(!js.terminated) {
+ service.cycle();
+ engine.cycle();
+ timer.cycle();
+ maindb.cycle();
+}
--
GitLab