refactor(slack): remove hardcoded messages and implement direct notifications for guideline upload

Details:
- Moved success/failure texts to lexicon.py.
- Added notify_slack_upload_success and notify_slack_upload_failure callbacks.
- Passed user_id from API to task to enable Direct Messages via Slack.

Author: PyDevDeep

backend/api/routes/feedback.py

@@ -261,7 +261,6 @@ async def slack_interactions(request: Request):
             )
         # --- СЦЕНАРІЙ 3: Завантаження гайдлайну ---
         elif callback_id == "modal_upload_guideline":
-            # Slack повертає масив об'єктів файлів
             files = (
                 state_values.get("block_file_upload", {})
                 .get("input_file", {})
@@ -271,23 +270,7 @@ async def slack_interactions(request: Request):
                 return Response(status_code=400)
 
             file_info = files[0]
-            # file_url = file_info.get("url_private_download")
-            file_name = file_info.get("name")
-
-            logger.info("slack_file_uploaded", user_id=user_id, file_name=file_name)
-
-            # --- СЦЕНАРІЙ 3: Завантаження гайдлайну ---
-        elif callback_id == "modal_upload_guideline":
-            files = (
-                state_values.get("block_file_upload", {})
-                .get("input_file", {})
-                .get("files", [])
-            )
-            if not files:
-                return Response(status_code=400)
-
-            file_info = files[0]
-            file_url = file_info.get("url_private_download")  # РОЗКОМЕНТОВАНО
+            file_url = file_info.get("url_private_download")
             file_name = file_info.get("name")
 
             logger.info("slack_file_uploaded", user_id=user_id, file_name=file_name)
@@ -300,12 +283,6 @@ async def slack_interactions(request: Request):
                 status_code=200,
             )
 
-            # Закриваємо модалку
-            return Response(
-                content=json.dumps({"response_action": "clear"}),
-                media_type="application/json",
-                status_code=200,
-            )
     return Response(status_code=200)
 
 

backend/config/lexicon.py

@@ -47,4 +47,7 @@
     "upload_modal_title": "База знань",
     "upload_modal_submit": "Завантажити",
     "upload_modal_input_label": "Оберіть файл (PDF/TXT)",
+    # --- Upload Notifications ---
+    "upload_success": "✅ Гайдлайн *{file_name}* успішно завантажено та векторизовано у базу знань!",
+    "upload_failure": "❌ *Помилка* обробки гайдлайну *{file_name}*.\n\nДеталі:\n```{error_msg}```",
 }

backend/workers/callbacks.py

@@ -94,3 +94,43 @@ async def notify_slack_on_failure(
         ],
     }
     await _send_slack_message(payload)
+
+
+async def notify_slack_upload_success(user_id: str, file_name: str) -> None:
+    """Відправляє повідомлення про успішну векторизацію гайдлайну."""
+    slack_token = (
+        settings.SLACK_BOT_TOKEN.get_secret_value()
+        if hasattr(settings.SLACK_BOT_TOKEN, "get_secret_value")
+        else settings.SLACK_BOT_TOKEN
+    )
+    async with httpx.AsyncClient() as client:
+        await client.post(
+            "https://slack.com/api/chat.postMessage",
+            headers={"Authorization": f"Bearer {slack_token}"},
+            json={
+                "channel": user_id,
+                "text": SLACK_UI["upload_success"].format(file_name=file_name),
+            },
+        )
+
+
+async def notify_slack_upload_failure(
+    user_id: str, file_name: str, error_msg: str
+) -> None:
+    """Відправляє повідомлення про провал завантаження/векторизації."""
+    slack_token = (
+        settings.SLACK_BOT_TOKEN.get_secret_value()
+        if hasattr(settings.SLACK_BOT_TOKEN, "get_secret_value")
+        else settings.SLACK_BOT_TOKEN
+    )
+    async with httpx.AsyncClient() as client:
+        await client.post(
+            "https://slack.com/api/chat.postMessage",
+            headers={"Authorization": f"Bearer {slack_token}"},
+            json={
+                "channel": user_id,
+                "text": SLACK_UI["upload_failure"].format(
+                    file_name=file_name, error_msg=error_msg
+                ),
+            },
+        )

backend/workers/tasks/ingest_guideline.py

@@ -14,6 +14,10 @@
 
 from backend.config.settings import settings
 from backend.workers.broker import broker
+from backend.workers.callbacks import (
+    notify_slack_upload_failure,
+    notify_slack_upload_success,
+)
 
 logger = structlog.get_logger()
 
@@ -30,7 +34,9 @@
 
 
 @broker.task(task_name="ingest_guideline_task", timeout=300)
-async def ingest_guideline_task(file_url: str, file_name: str) -> None:
+async def ingest_guideline_task(
+    file_url: str, file_name: str, user_id: str | None = None
+) -> None:  # Додано user_id
     logger.info("ingest_guideline_started", file_name=file_name)
 
     try:
@@ -79,8 +85,20 @@ async def ingest_guideline_task(file_url: str, file_name: str) -> None:
             "guideline_ingestion_success", file_name=file_name, chunks=len(documents)
         )
 
-        # TODO: Додати notify_slack_on_complete для сповіщення користувача про успіх (опціонально)
+        logger.info(
+            "guideline_ingestion_success", file_name=file_name, chunks=len(documents)
+        )
+
+        # ДОДАНО: Сповіщення про успіх
+        if user_id:
+            await notify_slack_upload_success(user_id=user_id, file_name=file_name)
 
     except Exception as e:
         logger.error("guideline_ingestion_failed", file_name=file_name, error=str(e))
+
+        # ДОДАНО: Сповіщення про помилку
+        if user_id:
+            await notify_slack_upload_failure(
+                user_id=user_id, file_name=file_name, error_msg=str(e)
+            )
         raise