From 17f6ba8376a357cf90891b7c5b4a51e3e90d69c2 Mon Sep 17 00:00:00 2001 From: sietse jonker Date: Tue, 26 Mar 2024 23:03:26 +0100 Subject: [PATCH] Add WebSocket data sender scripts --- server/bullshitSenderENQUETE.py | 31 +++++++++++++++++++ ...lshitSender.py => bullshitSenderSENSOR.py} | 0 2 files changed, 31 insertions(+) create mode 100644 server/bullshitSenderENQUETE.py rename server/{bullshitSender.py => bullshitSenderSENSOR.py} (100%) diff --git a/server/bullshitSenderENQUETE.py b/server/bullshitSenderENQUETE.py new file mode 100644 index 0000000..1c58863 --- /dev/null +++ b/server/bullshitSenderENQUETE.py @@ -0,0 +1,31 @@ +import asyncio +import websockets +import json +import random +import time + +async def send_data(uri): + async with websockets.connect(uri) as websocket: + print("Connected to WebSocket server") + + while True: + data = { + "node": "69:42:08:F5:00:00", + "Response": str(round(random.uniform(0, 2))), + "QuestionID": str(round(random.uniform(0, 90))), + } + await websocket.send(json.dumps(data)) + print("Data sent") + + response = await websocket.recv() + print("Received message:", response) + + await asyncio.sleep(2) # Wait a bit before sending the next message + +# Start the WebSocket connection +while True: + try: + asyncio.get_event_loop().run_until_complete(send_data("ws://145.92.8.114/ws")) + except Exception as e: + print("Exception:", e) + time.sleep(1) # Wait a bit before trying to reconnect \ No newline at end of file diff --git a/server/bullshitSender.py b/server/bullshitSenderSENSOR.py similarity index 100% rename from server/bullshitSender.py rename to server/bullshitSenderSENSOR.py