Delete server/src/notifier.py

Removed since it integrated into the server
This commit is contained in:
2026-04-23 12:04:46 +02:00
parent 61fa1be9f2
commit 5bb32ae4ff

View File

@@ -1,80 +0,0 @@
#!/bin/env python3
import websocket
import json
import random
import zmq
from pprint import pprint
__version__ = "2.1.0"
ws = None
uri = "ws://localhost:5080"
ws = websocket.create_connection(uri)
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://*:5555")
def sendsmpmessage(target, message):
global ws
print("Sendmessage %s called to %s" % (message, target))
msg = ("%s %s" % (target, message))
# Create a unique correlation ID
command = {
"corrId": f"id{random.randint(0, 999999)}",
"cmd": msg,
}
json_command = json.dumps(command)
""" Connects to WebSocket server, sends a message, and returns the response """
if ws is None:
uri = "ws://localhost:5080"
ws = websocket.create_connection(uri) # Blocking WebSocket connection
ws.send(json_command) # Send message to WebSocket
responsejson = ws.recv() # Receive response
response = json.loads(responsejson)
# ws.close()
if response is not None:
return True
else:
return False
# for chatitem in response['resp']['chatItems']:
# statusdict = chatitem['chatItem']['meta']['itemStatus']
# try:
# status = statusdict['sndProgress']
# except KeyError:
# pprint(response['resp']['chatItems'])
# print('---')
# pprint(chatitem)
# print("FAILED")
# status = 'FAILED'
# else:
# smessage = chatitem['chatItem']['meta']['itemText']
# print("Message '%s' sent over websocket to %s, status was %s" % (smessage, target, status))
# if status == 'complete' or status == 'partial':
# return True
# else:
# return False
if __name__ == '__main__':
print("Tellme Notifier started...")
while True:
zmqmessage = socket.recv_string()
print(f"Received request: {zmqmessage}")
result = True
decoded = json.loads(zmqmessage)
pprint(decoded)
result = sendsmpmessage(decoded.get('target'), decoded.get('message'))
print(result)
if result is True:
socket.send_string("sent")
else:
socket.send_string("failed")