.gitignore

@@ -1 +1,2 @@
-/.venv
+/node_modules
+

README.md

@@ -2,12 +2,12 @@
 
 ```text
 GET  /api/ws
-GET  /api/cc/{uuid}/keypad/code
+GET  /api/{uuid}/keypad/code
-GET  /api/cc/{uuid}/keypad/get_user_info/{uid}
+GET  /api/{uuid}/keypad/get_user_info/{uid}
-POST /api/cc/{uuid}/keypad/log/door_open/{uid}
+POST /api/{uuid}/keypad/log/door_open/{uid}
-POST /api/cc/{uuid}/keypad/set_code
+POST /api/{uuid}/keypad/set_code
-POST /api/cc/{uuid}/core/reboot
+POST /api/{uuid}/core/reboot
-POST /api/cc/{uuid}/core/update
+POST /api/{uuid}/core/update
 ```
 
 ## websocket 

package.json

@@ -0,0 +1,24 @@
+{
+  "name": "rtmc-be",
+  "version": "1.0.0",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "ISC",
+  "description": "",
+  "devDependencies": {
+    "@types/express": "^4.17.21",
+    "@types/knex": "^0.15.2",
+    "@types/node": "^22.5.0",
+    "@types/ws": "^8.5.12",
+    "typescript": "^5.5.4"
+  },
+  "dependencies": {
+    "express": "^4.19.2",
+    "knex": "^3.1.0",
+    "pug": "^3.0.3",
+    "ws": "^8.18.0"
+  }
+}

pyproject.toml

@@ -1,8 +0,0 @@
-[tool.pylint.'MESSAGES CONTROL']
-disable = [
-    "line-too-long",
-    "unnecessary-semicolon",
-    "trailing-newlines",
-    "missing-docstring"
-]
-

server.py

@@ -1,98 +1,47 @@
 import asyncio
-import string
-import secrets
 import json
-import websockets
+from websockets import serve
 
 clients = {
-    "FD3ZJFHQ7r": {
+    "FD3ZJFHQ7r" : {
-        "doorOpen": False,
+        "doorOpen" : False,
-        "lockdown": False,
+        "lockdown" : False,
-        "lastOpened": 1, #unix timestamp
+        "lastOpened" : 1, #unix timestamp
-        "secLevel": 1,
+        "secLevel" : 1,
-        "openedBy": "user"
+        "openedBy" : "user"
     }
 }
 
-def rand_id():
+async def echo(websocket):
-    return ''.join(secrets.choice(string.ascii_letters + string.digits) for _ in range(16))
+    print("Connection established")
-
+    authenticated = False
-class WsClient:
+    await websocket.send(json.dumps({
-    def __init__(self, ws):
-        self.ws = ws
-        self.module_info = {}
-        self.pcid = None
-    
-    def send(self, message):
-        self.ws.send(json.dumps(message))
-
-
-
-class WebSocketHandler:
-    def __init__(self):
-        self.clients = {}
-
-    def on_message(self, client, message):
-        message_type = message.get('type')
-
-        # Route messages based on type using match-case
-        match message_type:
-            case "CAuth":
-                client.pcid = message["pcid"]
-            case "CLog":
-                print(f"[CC] [{message["level"]}] {message["msg"]}")
-            case "CModule":
-                match message["module"]:
-                    case "keypad":
-                        self.handle_keypad_msg(client, message["message"]);
-
-    def handle_keypad_msg(self, client: WsClient, message):
-        match message["type"]:
-            case "CDoorOpened":
-                print(f"[CC][KEYPAD] Door was opened on {message["time"]} {"manually" if message["manual"] else ""}")
-            case "CGetUserStat":
-                client.send({
-                    "type": "SUserStat",
-                    # user info
-                })
-            case "CGetDoorStat":
-                stats = {}
-
-                for pc in self.clients:
-                    i = pc.module_info["keypad"]
-                    stats[pc.uid] = i if i else {}
-
-                client.send({
-                    "type": "CDoorStat",
-                    "stats": stats
-                })
-
-
-
-    async def new_client(self, ws):
-        uid = rand_id()
-        self.clients[uid] = WsClient(ws)
-
-        self.clients[uid].send({
         "type" : "SAuthReq"
-        })
+    }))
 
-        async for msg_t in ws:
+    async for msg in websocket:
-            msg = json.loads(msg_t)
+        msg_json = json.loads(msg)
-            self.on_message(self.clients[uid], msg) 
+        if authenticated == False:
-            
+            if msg_json["type"] == "CAuth":
-
+                if msg_json["token"] in clients:
-    def stop(self):
+                    await websocket.send(json.dumps({
-        for c in self.clients:
+                        "type" : "SAuthStatus",
-            c.ws.close()
+                        "failed" : False,
+                        "reason" : "Authentication Successful"
+                    }))
+                    authenticated = True
+                else:
+                    await websocket.send(json.dumps({
+                        "type" : "SAuthStatus",
+                        "failed" : True,
+                        "reason" : "Invalid token"
+                    }))
 
 
   
 
 async def main():
-    wsh = WebSocketHandler()
+    async with serve(echo, "localhost", 8765):
-
-    async with websockets.serve(wsh.new_client, "localhost", 8765):
         await asyncio.get_running_loop().create_future()
 
 asyncio.run(main())

tsconfig.json

@@ -0,0 +1,21 @@
+{
+    "$schema": "http://json.schemastore.org/tsconfig",
+    "compilerOptions": {
+        "typeRoots": ["./node_modules/@types", "./src/types"],
+        "strict": true,
+        "target": "ESNext",
+        "module": "ESNext",
+        "moduleResolution": "NodeNext",
+        "allowSyntheticDefaultImports": true,
+        "esModuleInterop": true,
+        "types": [""],
+        "noEmit": true,
+        "isolatedModules": true,
+        "noImplicitAny": true,
+        "alwaysStrict": true,
+        "outDir": "build",
+    },
+    "include": [
+        "src/**/*.ts",
+    ]
+}