mirror of
https://github.com/FAUSheppy/ths-speech
synced 2025-12-07 18:51:36 +01:00
Server functionality
This commit is contained in:
16
python-server/exec_server.py
Normal file → Executable file
16
python-server/exec_server.py
Normal file → Executable file
@@ -1,6 +1,7 @@
|
|||||||
#/usr/bin/python3
|
#/usr/bin/python3
|
||||||
|
|
||||||
import socketserver
|
import socketserver
|
||||||
import server interface
|
import server_interface
|
||||||
|
|
||||||
class AppRequestHandler(socketserver.BaseRequestHandler):
|
class AppRequestHandler(socketserver.BaseRequestHandler):
|
||||||
def __init__(self, request, client_address, server):
|
def __init__(self, request, client_address, server):
|
||||||
@@ -12,12 +13,19 @@ class AppRequestHandler(socketserver.BaseRequestHandler):
|
|||||||
|
|
||||||
def handle(self):
|
def handle(self):
|
||||||
data = self.request.recv(1024)
|
data = self.request.recv(1024)
|
||||||
retval = server_interface.parse_request(data)
|
retval = server_interface.parse_request(data)
|
||||||
self.request.send(retval)
|
print(retval)
|
||||||
|
self.request.send(retval)
|
||||||
return
|
return
|
||||||
|
|
||||||
def finish(self):
|
def finish(self):
|
||||||
return socketserver.BaseRequestHandler.finish(self)
|
return socketserver.BaseRequestHandler.finish(self)
|
||||||
|
|
||||||
def start_server():
|
def start_server():
|
||||||
server = socketserver.Server(("localhost",7100),AppRequestHandler)
|
socketserver.TCPServer.allow_reuse_address = True
|
||||||
|
server = socketserver.TCPServer(("localhost",7100),AppRequestHandler)
|
||||||
|
server.serve_forever()
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == "__main__":
|
||||||
|
start_server()
|
||||||
|
|||||||
@@ -1,3 +1,28 @@
|
|||||||
|
def parse_request(data):
|
||||||
|
''' parse request and call correct function '''
|
||||||
|
|
||||||
|
# echo/test connection
|
||||||
|
cleared_data = is_data_type(b"ECHOREQUEST,",data)
|
||||||
|
if cleared_data:
|
||||||
|
return cleared_data
|
||||||
|
|
||||||
|
# other shit
|
||||||
|
return b"UNRECOGNIZED_SERVER_OPTION\n"
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
def is_data_type(tag,data):
|
||||||
|
print(data)
|
||||||
|
print(tag)
|
||||||
|
data = data.strip(b"\n")
|
||||||
|
if data.startswith(tag):
|
||||||
|
ret = data.strip(tag)
|
||||||
|
if not ret:
|
||||||
|
ret = b"NULL\n"
|
||||||
|
return ret
|
||||||
|
return None
|
||||||
|
|
||||||
|
|
||||||
def reply_logs(loglevel=0,lines=100):
|
def reply_logs(loglevel=0,lines=100):
|
||||||
''' replies with recent logs '''
|
''' replies with recent logs '''
|
||||||
pass
|
pass
|
||||||
|
|||||||
Reference in New Issue
Block a user