From 9fd1b9baedcde1ef195e2fb73d2ab9121e017e51 Mon Sep 17 00:00:00 2001 From: transcental Date: Sun, 29 Jun 2025 03:13:50 +0100 Subject: [PATCH] don't delete support team broadcasts --- nephthys/events/message.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/nephthys/events/message.py b/nephthys/events/message.py index 090aa5b..d65995d 100644 --- a/nephthys/events/message.py +++ b/nephthys/events/message.py @@ -17,7 +17,12 @@ async def on_message(event: Dict[str, Any], client: AsyncWebClient): if "subtype" in event and event["subtype"] not in ALLOWED_SUBTYPES: return - if event.get("subtype") == "thread_broadcast": + user = event.get("user", "unknown") + text = event.get("text", "") + + db_user = await env.db.user.find_first(where={"slackId": user}) + + if event.get("subtype") == "thread_broadcast" and not (db_user and db_user.helper): await client.chat_delete( channel=event["channel"], ts=event["ts"], @@ -32,11 +37,6 @@ async def on_message(event: Dict[str, Any], client: AsyncWebClient): thread_ts=event["thread_ts"] if "thread_ts" in event else event["ts"], ) - user = event.get("user", "unknown") - text = event.get("text", "") - - db_user = await env.db.user.find_first(where={"slackId": user}) - if event.get("thread_ts"): if db_user and db_user.helper: ticket = await env.db.ticket.find_first(