42 lines
No EOL
1.3 KiB
Python
42 lines
No EOL
1.3 KiB
Python
import websockets
|
|
import asyncio
|
|
import json
|
|
|
|
from app.class_settings import Settings
|
|
|
|
class Server:
|
|
def __init__(self):
|
|
obj_settings = Settings()
|
|
obj_settings.set_logging()
|
|
|
|
self.yaml = obj_settings.yaml
|
|
|
|
try:
|
|
asyncio.run(self.start())
|
|
except KeyboardInterrupt:
|
|
print("Server sagt: Server wurde beendet.")
|
|
|
|
@staticmethod
|
|
async def handle_client(websocket):
|
|
print("Server sagt: Client verbunden")
|
|
try:
|
|
async for message in websocket:
|
|
print(f"Server hat Empfangen: {message}")
|
|
|
|
data = json.loads(message)
|
|
|
|
if data.get("data_path"):
|
|
pass
|
|
elif data.get("data_command"):
|
|
pass
|
|
|
|
#response = f"Server antwortet: {message.upper()}"
|
|
#await websocket.send(response)
|
|
|
|
except websockets.exceptions.ConnectionClosed:
|
|
print("Server sagt: Client getrennt")
|
|
|
|
async def start(self):
|
|
server = await websockets.serve(self.handle_client, self.yaml['server_ip'], self.yaml['server_port'])
|
|
print(f"Websocket Server läuft auf IP: {self.yaml['server_ip']} Port: {self.yaml['server_port']}")
|
|
await server.wait_closed() |