diff --git a/src/api/endpoints.py b/src/api/endpoints.py index b0f0421..5a613c7 100644 --- a/src/api/endpoints.py +++ b/src/api/endpoints.py @@ -128,7 +128,7 @@ async def message_actions(payload: str = Form(...)) -> JSONResponse: ).get("text", None) user_id = form_json.get("user", {}).get("id") - slack.add_announcement(message_object, user_id) + await slack.add_announcement(message_object, user_id) if response_url: async with httpx.AsyncClient() as client: diff --git a/src/core/slack.py b/src/core/slack.py index e85070e..c2a7c23 100644 --- a/src/core/slack.py +++ b/src/core/slack.py @@ -164,7 +164,7 @@ def get_announcement() -> dict[str, str] | None: return announcements.pop(0) -def add_announcement(announcement_text: str, user_id: str) -> None: +async def add_announcement(announcement_text: str, user_id: str) -> None: """ Adds an announcement to the queue. @@ -177,7 +177,7 @@ def add_announcement(announcement_text: str, user_id: str) -> None: logger.warning("Attempted to add empty announcement, skipping!") return - username: str = get_username(user_id=user_id) + username: str = await get_username(user_id=user_id) new_addition: dict[str, str] = {"content": announcement_text, "user": username}