From: Erik Andresen <erik@vontaene.de>
Date: Sat, 3 Jan 2015 11:07:37 +0000 (+0100)
Subject: added json_server
X-Git-Url: https://defiant.homedns.org/gitweb/?a=commitdiff_plain;h=d73e753a4c2c8a9bb79ada177d1cb122a08cabeb;p=pyshared.git

added json_server
---

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..c9b568f
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,2 @@
+*.pyc
+*.swp
diff --git a/json_server.py b/json_server.py
new file mode 100755
index 0000000..081a499
--- /dev/null
+++ b/json_server.py
@@ -0,0 +1,72 @@
+#!/usr/bin/env python
+# -*- coding: iso-8859-15 -*-
+
+import SocketServer
+import json
+import threading
+import logging
+import control
+import threading
+
+SocketServer.TCPServer.allow_reuse_address = True
+
+logger = logging.getLogger(__name__)
+
+class TCPServer(threading.Thread):
+	def __init__(self):
+		threading.Thread.__init__(self)
+		self.setDaemon(True)
+		self.server = SocketServer.ThreadingTCPServer(('0.0.0.0', 10002), TCPHandler)
+		self.server.allow_reuse_address = True
+		self.server.daemon_threads = True
+		self.start()
+
+	def run(self):
+		self.server.serve_forever()
+
+	def stop(self):
+		self.server.shutdown()
+		self.server.socket.close()
+
+
+class TCPHandler(SocketServer.BaseRequestHandler):
+	def __init__(self, request, client_address, server):
+		self.__lock_send = threading.Lock()
+		SocketServer.BaseRequestHandler.__init__(self, request, client_address, server)
+
+	def finish(self):
+		return SocketServer.BaseRequestHandler.finish(self)
+
+	def send_log(self, s):
+		self.send({"log": s})
+
+	def send(self, d):
+		with self.__lock_send:
+			self.request.sendall(json.dumps(d))
+
+	def handle(self):
+		try:
+			while True:
+				s = self.request.recv(4096)
+				if not s:
+					return
+
+				data = json.loads(s)
+				if data.has_key("command"):
+					cmd = data["command"]
+					ret = control.handle(cmd)
+					self.send({"return": ret, "command_was": cmd})
+
+		except Exception, e:
+			logger.debug("Exception wile receiving message: \n%s", e)
+
+
+if __name__ == "__main__":
+	from time import sleep
+
+	logger.setLevel(logging.DEBUG)
+	logger.addHandler(logging.StreamHandler())
+
+	pServer = TCPServer()
+	while True:
+		sleep(1)