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

fix: dont ack failed signal sends

Browse Source
This commit is contained in:
Johnathen Sheppard
2024-02-15 16:28:29 +01:00
parent 5810e408c8
commit 2c202940d8
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
signal-query-dispatch.py
View File

@@ -14,6 +14,8 @@ def signal_send(phone, message):
'''Send message via signal''' '''Send message via signal'''
cmd = [signal_cli_bin, "send", "-m", "'{}'".format(message.replace("'","")), phone] cmd = [signal_cli_bin, "send", "-m", "'{}'".format(message.replace("'","")), phone]
p = subprocess.run(cmd) p = subprocess.run(cmd)
p.check_returncode()
def confirm_dispatch(target, uid): def confirm_dispatch(target, uid):
@@ -53,6 +55,8 @@ if __name__ == "__main__":
response.raise_for_status() response.raise_for_status()
dispatch_confirmed = [] dispatch_confirmed = []
dispatch_failed = []
for entry in response.json(): for entry in response.json():
user = entry["person"] user = entry["person"]
@@ -62,7 +66,10 @@ if __name__ == "__main__":
# send message # # send message #
if entry["method"] == "signal": if entry["method"] == "signal":
signal_send(phone, message) try:
signal_send(phone, message)
except subprocess.CalledProcessError as e:
print("Dispatch failed {}".format(e))
else: else:
print("Unsupported dispatch method {}".format(entry["method"]), sys=sys.stderr) print("Unsupported dispatch method {}".format(entry["method"]), sys=sys.stderr)