diff options
Diffstat (limited to 'module')
-rw-r--r-- | module/remote/RequestHandler.py | 29 | ||||
-rw-r--r-- | module/remote/SocketServer.py | 15 |
2 files changed, 38 insertions, 6 deletions
diff --git a/module/remote/RequestHandler.py b/module/remote/RequestHandler.py new file mode 100644 index 000000000..9964c90c0 --- /dev/null +++ b/module/remote/RequestHandler.py @@ -0,0 +1,29 @@ +#!/usr/bin/python +# -*- coding: utf-8 -*- +""" +authored by: RaNaN + +this module handels the incoming requests + +""" + +import base64 +from cPickle import Pickler +from cStringIO import StringIO +from Crypto.Cipher import AES + + +class RequestHandler(): + def __init__(self, core): + self.core = core + self.p = Pickler(string) + self.obj = AES.new('pw', AES.MODE_ECB) + + def proceed(self, data): + return "the answer." + + def decrypt(self, string): + string = string + buf = StringIO(string) + + diff --git a/module/remote/SocketServer.py b/module/remote/SocketServer.py index 4469f89ac..3635e16d8 100644 --- a/module/remote/SocketServer.py +++ b/module/remote/SocketServer.py @@ -10,6 +10,7 @@ import asynchat import asyncore import socket import threading +from RequestHandler import RequestHandler class ServerThread(threading.Thread): @@ -41,18 +42,20 @@ class MainServerSocket(asyncore.dispatcher): class SecondaryServerSocket(asynchat.async_chat): - def __init__(self, pycore, *args): + def __init__(self, socket, pycore): print 'initing SSS' - self.pycore = pycore - asynchat.async_chat.__init__(self, *args) - self.set_terminator('\n') + asynchat.async_chat.__init__(self, socket) + self.pycore = pycore + self.handler = RequestHandler(pycore) + self.set_terminator('\n') self.data = [] def collect_incoming_data(self, data): self.data.append(data) def found_terminator(self): - self.push("daten") + self.handler.proceed(self.data) + self.push(str(self.pycore.plugins_avaible)) self.data = [] #having fun with the data def handle_close(self): print "Disconnected from", self.getpeername() - self.close()
\ No newline at end of file + self.close() |