-
Notifications
You must be signed in to change notification settings - Fork 40
/
SioClientHandler.py
72 lines (59 loc) · 2.37 KB
/
SioClientHandler.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
import asyncio
import json
import logging
from Traductores.TraductoresHandler import TraductoresHandler, TraductorException
from Configberry import Configberry
import socketio
logger = logging.getLogger("SocketIOClient")
class SioClientHandler():
def __init__(self):
self.serverUrl = Configberry.config.get("SERVIDOR","sio_host")
self.serverPort = Configberry.config.get("SERVIDOR","sio_port")
self.password = Configberry.config.get("SERVIDOR","sio_password")
self.traductor = TraductoresHandler(self)
def startSioClient(self, uuid):
sio = socketio.Client(logger = logger)
def on_comando(comando):
traductor = self.traductor
response = {}
logger.info(f"Request \n -> {comando}")
try:
if isinstance(comando, str):
jsonMes = json.loads(comando, strict=False)
else:
jsonMes = comando
response = asyncio.run(traductor.json_to_comando(jsonMes))
except TypeError as e:
errtxt = "Error parseando el JSON %s" % e
logger.exception(errtxt)
response["err"] = errtxt
except TraductorException as e:
errtxt = "Traductor Comandos: %s" % str(e)
logger.exception(errtxt)
response["err"] = errtxt
except KeyError as e:
errtxt = "El comando no es valido para ese tipo de impresora: %s" % e
logger.exception(errtxt)
response["err"] = errtxt
except Exception as e:
errtxt = repr(e) + "- " + str(e)
logger.exception(errtxt)
response["err"] = errtxt
logger.info("Response \n <- %s" % response)
return response
@sio.event
def connect():
print(uuid)
@sio.event
def disconnect():
pass
@sio.event
def command(msg):
print(msg)
return on_comando(msg)
try:
url = f"http://{self.serverUrl}:{self.serverPort}"
sio.connect(url = url, socketio_path = "/socket.io/", headers = {"X_UUID":uuid, "X_PWD": self.password})
except Exception as e:
logging.getLogger("Client").error(f"Error {e}")
sio.wait()