Added sessionmanager

src/pyscripts/xsbs/http/__init__.py

@@ -4,6 +4,8 @@
 from xsbs.settings import PluginConfig
 from xsbs.events import eventHandler
 
+from sessionmanager import SessionManager
+
 config = PluginConfig('httpserver')
 port = config.getOption('Config', 'port', '8081')
 enable = config.getOption('Config', 'enable', 'yes') == 'yes'
@@ -19,6 +21,7 @@ def __init__(self, address, port):
 		self.port = port
 		self.root_site = RootSite()
 		self.server_site = server.Site(self.root_site)
+		self.sessionManager = SessionManager()
 	def start(self):
 		self.connection = reactor.listenTCP(port, self.server_site)
 	def stop(self):

src/pyscripts/xsbs/http/jsonapi.py

@@ -48,6 +48,15 @@ def __call__(self, *args, **kwargs):
 class JsonSite(resource.Resource):
 	def render_GET(self, request):
 		setJsonHeaders(request)
+		try:
+			sesskey = request.args['sessionkey'][0]
+		except KeyError:
+			pass
+		else:
+			try:
+				request.session = httpServer.sessionManager.sessions[sesskey]
+			except KeyError:
+				pass
 		return self.render_JSON(request)
 	def render_OPTIONS(self, request):
 		setJsonHeaders(request)

src/pyscripts/xsbs/http/sessionmanager.py

@@ -0,0 +1,20 @@
+import time
+
+class Session(dict):
+	def __init__(self, key):
+		self.key = key
+		self.create_time = time.time()
+		self.touch_time = self.create_time
+	def touch(self):
+		self.touch_time = time.time()
+
+class SessionManager(object):
+	def __init__(self, stale_secs=3600):
+		self.sessions = {}
+		self.stale_secs = stale_secs
+	def removeStales(self):
+		cur_time = time.time()
+		for session in self.sessions.values():
+			if (session.touch_time + self.stale_secs) < cur_time:
+				del self.sessions[session.key]
+