remove client, msg class

client/manager_client.py

@@ -1,11 +0,0 @@
-import socket
-s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-s.connect(("192.168.1.2", 1337))
-while True:
-    data = s.recv(1024)
-    if not data:
-        continue
-    msg = data.decode("ASCII")
-    if msg == "STA":
-        print("[SOUND THE ALARM]")
-s.close()

server/msg.py

@@ -0,0 +1,12 @@
+import json
+class msg:
+    def __init__(self, t, b):
+        self.type = t
+        self.body = b
+    def unpack_data(self, data):
+        as_str = data.decode("ASCII")
+        as_json = json.loads(as_str)
+        self.type = as_json["type"]
+        self.body = as_json["body"]
+    def pack(self):
+        return json.dumps(self.__dict__).encode("ASCII")

server/server.py

@@ -6,6 +6,8 @@ import alarm
 import http_server
 import asyncio
 from aiohttp import web
+import msg
+import json
 
 class server:
     def __init__(self, address, port):
@@ -27,14 +29,14 @@ class server:
         het = threading.Thread(target=self.launch_http_server, args=(runner,))
         het.start()
 
-        self.tasks.append(alarm.alarm(time.time() + 30))
+        # self.tasks.append(alarm.alarm(time.time() + 30))
 
         while True:
             time.sleep(10)
             for task in self.tasks:
                 if task.check():
                     for c in self.clients:
-                        c.sock.sendall("STA".encode("ASCII"))
+                        c.sock.sendall(msg.msg("task", json.dumps(task.__dict__)))
     def handle_connections(self):
         while True:
             (client_sock, address) = self.sock.accept()