mirror of
https://github.com/System-End/nephthys.git
synced 2026-04-19 19:45:12 +00:00
don't delete support team broadcasts
This commit is contained in:
parent
fa27dd073d
commit
9fd1b9baed
1 changed files with 6 additions and 6 deletions
|
|
@ -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(
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue