TaurixIT/tellme
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: TaurixIT:4801b74405702a953cf546747037d777b0516854
Branches Tags
TaurixIT:master
...
compare: TaurixIT:38d9e87393283c6340e1856e2e6b11e823875ac5
Branches Tags
TaurixIT:master

2 Commits
4801b74405 ... 38d9e87393

Author SHA1 Message Date
Guy Van Sanden
38d9e87393 Test threading lock 2025-02-12 11:11:58 +01:00
Guy Van Sanden
48791ee1f1 add output 2025-02-12 11:11:29 +01:00
1 changed files with 19 additions and 18 deletions
Show Stats Expand all files Collapse all files

3
server/src/tellmesrv.py
View File

@ -18,7 +18,6 @@ with open(r'/etc/tellme/hooks.yml') as hooksfile:
def sendmessage(target, message): def sendmessage(target, message):
print("Sendmessage %s called to %s" % (message, target)) print("Sendmessage %s called to %s" % (message, target))
with lock:
msg = ("%s %s" % (target, message)) msg = ("%s %s" % (target, message))
# Create a unique correlation ID # Create a unique correlation ID
@ -33,6 +32,7 @@ def sendmessage(target, message):
ws = websocket.create_connection(uri) # Blocking WebSocket connection ws = websocket.create_connection(uri) # Blocking WebSocket connection
ws.send(json_command) # Send message to WebSocket ws.send(json_command) # Send message to WebSocket
response = ws.recv() # Receive response response = ws.recv() # Receive response
print("Message %s sent over websocket to %s" % (message, target))
# ws.close() # Close WebSocket connection # ws.close() # Close WebSocket connection
# print(response) # print(response)
ws.close() ws.close()
@ -52,6 +52,7 @@ def webhook_receiver(id):
if target is not None: if target is not None:
print(target) print(target)
with lock:
sendmessage(target, data.get('message')) sendmessage(target, data.get('message'))
else: else:
print("No target found, dropping message") print("No target found, dropping message")