Skip to content

Commit 43a4900

Browse files
alexmvtimabbott
authored andcommitted
zephyr: Delete DMs after they are received.
1 parent e9d8ef3 commit 43a4900

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

zulip/integrations/zephyr/check-mirroring

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -300,6 +300,11 @@ if "error" in res["result"]:
300300
logging.error(res["msg"])
301301
print_status_and_exit(1)
302302
messages = [event["message"] for event in res["events"]]
303+
for m in messages:
304+
if m.get("stream_id") is None:
305+
# Non-stream messages can't have a retention policy, so clean
306+
# them up so they don't pile up
307+
zulip_client.delete_message(m["id"])
303308
logger.info("Finished receiving Zulip messages!")
304309

305310
receive_zephyrs()

0 commit comments

Comments
 (0)