sheppy/atlantis-event-dispatcher
1
0
Fork 0
mirror of https://github.com/FAUSheppy/atlantis-event-dispatcher synced 2025-12-06 06:21:36 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: legacy signal dispatcher with new confirm

Browse Source
This commit is contained in:
Johnathen Sheppard
2024-02-18 17:32:10 +01:00
parent 1b3885850b
commit 00bb802327
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
signal-query-dispatch.py
View File

@@ -24,7 +24,7 @@ def report_dispatch_error(target, uid, error):
def confirm_dispatch(target, uid):
'''Confirm to server that message has been dispatched and can be removed'''
response = requests.post(target + "/confirm-dispatch", json=[{ "uid" : uid }],
response = requests.post(target + "/confirm-dispatch", json=[{ "uuid" : uid }],
auth=(args.user, args.password))
if response.status_code not in [200, 204]:
@@ -64,6 +64,7 @@ if __name__ == "__main__":
# track dispatches that were confirmed to avoid duplicate confirmation #
dispatch_confirmed = []
dispatch_failed = []
errors = {}
for entry in response.json():
@@ -82,6 +83,9 @@ if __name__ == "__main__":
try:
signal_send(phone, message)
except subprocess.CalledProcessError as e:
for uid in uid_list:
errors.update({uid:str(e)})
print("Dispatch failed {}".format(e))
continue
else:
@@ -94,7 +98,7 @@ if __name__ == "__main__":
if uid not in dispatch_confirmed:
# confirm or report fail #
if errors[uid]:
if errors.get(uid):
report_dispatch_error(args.target, uid, errors[uid])
else:
confirm_dispatch(args.target, uid)