feat(workers): implement slack block kit callbacks and isolate ui text to lexicon

Author: PyDevDeep

backend/config/lexicon.py

@@ -0,0 +1,12 @@
+SLACK_UI = {
+    # Success Notifications
+    "draft_ready_fallback": "✅ Драфт готовий: {topic}",
+    "draft_ready_header": "📝 Новий драфт: {topic}",
+    "ordered_by": "👤 Замовлено: <@{user_id}>",
+    "btn_publish": "Опублікувати",
+    "btn_reject": "Відхилити",
+    # Error Notifications
+    "error_fallback": "❌ Помилка задачі: {topic}",
+    "error_header": "🚨 Сталася помилка",
+    "error_details": "*Тема/Задача:* {topic}\n*Замовник:* <@{user_id}>\n\n*Деталі помилки:*\n```{error_msg}```",
+}

backend/config/settings.py

@@ -47,6 +47,7 @@ class Settings(BaseSettings):
     QDRANT_PORT: int = 6333
     EXTERNAL_QDRANT_PORT: int = 6333
 
+    SLACK_BOT_TOKEN: SecretStr = Field(default=...)
     # Конфігурація Pydantic
     model_config = SettingsConfigDict(
         env_file=".env", env_file_encoding="utf-8", extra="ignore"

backend/workers/callbacks.py

@@ -1 +1,135 @@
-# backend/workers/callbacks.py
+from typing import Any
+
+import httpx
+import structlog
+
+from backend.config.lexicon import SLACK_UI
+from backend.config.settings import settings
+
+logger = structlog.get_logger()
+
+SLACK_API_URL = "https://slack.com/api/chat.postMessage"
+
+
+async def _send_slack_message(payload: dict[str, Any]) -> None:
+    token = (
+        settings.SLACK_BOT_TOKEN.get_secret_value()
+        if settings.SLACK_BOT_TOKEN
+        else None
+    )
+    if not token:
+        logger.error("slack_token_missing", action="aborting_notification")
+        return
+
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/json; charset=utf-8",
+    }
+
+    async with httpx.AsyncClient(timeout=10.0) as client:
+        try:
+            response = await client.post(SLACK_API_URL, headers=headers, json=payload)
+            response.raise_for_status()
+            data = response.json()
+            if not data.get("ok"):
+                logger.error(
+                    "slack_api_error", error=data.get("error"), payload=payload
+                )
+        except Exception as e:
+            logger.error(
+                "slack_network_error", error=str(e), error_type=type(e).__name__
+            )
+
+
+async def notify_slack_on_complete(
+    user_id: str, channel_id: str, draft: str, topic: str
+) -> None:
+    logger.info(
+        "sending_slack_completion_notification", user_id=user_id, channel_id=channel_id
+    )
+
+    payload = {
+        "channel": channel_id,
+        "text": SLACK_UI["draft_ready_fallback"].format(topic=topic),
+        "blocks": [
+            {
+                "type": "header",
+                "text": {
+                    "type": "plain_text",
+                    "text": SLACK_UI["draft_ready_header"].format(topic=topic),
+                    "emoji": True,
+                },
+            },
+            {"type": "section", "text": {"type": "mrkdwn", "text": f"```{draft}```"}},
+            {
+                "type": "context",
+                "elements": [
+                    {
+                        "type": "mrkdwn",
+                        "text": SLACK_UI["ordered_by"].format(user_id=user_id),
+                    }
+                ],
+            },
+            {
+                "type": "actions",
+                "elements": [
+                    {
+                        "type": "button",
+                        "text": {
+                            "type": "plain_text",
+                            "text": SLACK_UI["btn_publish"],
+                            "emoji": True,
+                        },
+                        "style": "primary",
+                        "value": "publish",
+                        "action_id": "action_publish_draft",
+                    },
+                    {
+                        "type": "button",
+                        "text": {
+                            "type": "plain_text",
+                            "text": SLACK_UI["btn_reject"],
+                            "emoji": True,
+                        },
+                        "style": "danger",
+                        "value": "reject",
+                        "action_id": "action_reject_draft",
+                    },
+                ],
+            },
+        ],
+    }
+    await _send_slack_message(payload)
+
+
+async def notify_slack_on_failure(
+    user_id: str, channel_id: str, error_msg: str, topic: str
+) -> None:
+    logger.info(
+        "sending_slack_failure_notification", user_id=user_id, channel_id=channel_id
+    )
+
+    payload = {
+        "channel": channel_id,
+        "text": SLACK_UI["error_fallback"].format(topic=topic),
+        "blocks": [
+            {
+                "type": "header",
+                "text": {
+                    "type": "plain_text",
+                    "text": SLACK_UI["error_header"],
+                    "emoji": True,
+                },
+            },
+            {
+                "type": "section",
+                "text": {
+                    "type": "mrkdwn",
+                    "text": SLACK_UI["error_details"].format(
+                        topic=topic, user_id=user_id, error_msg=error_msg
+                    ),
+                },
+            },
+        ],
+    }
+    await _send_slack_message(payload)

backend/workers/tasks/publish_post.py

@@ -1 +1,51 @@
-# backend/workers/tasks/publish_post.py
+import structlog
+from taskiq import TaskiqDepends  # type: ignore
+
+from backend.workers.broker import broker
+
+# TODO: Розкоментувати та реалізувати після створення PublisherService та DB сесій
+# from backend.workers.dependencies import get_publisher_service, get_db_session
+# from backend.services.publisher import PublisherService, PlatformAPIError
+
+logger = structlog.get_logger()
+
+
+@broker.task(task_name="publish_post", timeout=30, labels={"priority": "medium"})
+async def publish_post_task(
+    post_id: str,
+    platform: str,
+    content: str,
+    # publisher: PublisherService = TaskiqDepends(get_publisher_service),
+    # db_session = TaskiqDepends(get_db_session)
+) -> dict[str, str]:
+    """
+    Фонова задача для публікації контенту в цільову соцмережу.
+    """
+    logger.info("publish_task_started", post_id=post_id, platform=platform)
+
+    try:
+        # TODO: Реальна логіка виклику API платформи
+        # publish_result = await publisher.publish(platform=platform, content=content)
+
+        # TODO: Оновлення статусу в БД
+        # await db_session.execute(
+        #     update(Post).where(Post.id == post_id).values(status="PUBLISHED", url=publish_result.url)
+        # )
+        # await db_session.commit()
+
+        logger.info("publish_task_success", post_id=post_id, platform=platform)
+        return {"status": "success", "post_id": post_id, "platform": platform}
+
+    except Exception as e:  # Замінити на PlatformAPIError при реалізації
+        logger.error(
+            "publish_task_platform_error",
+            post_id=post_id,
+            platform=platform,
+            error=str(e),
+        )
+        # TODO: Оновлення статусу в БД на "FAILED"
+        # await db_session.execute(
+        #     update(Post).where(Post.id == post_id).values(status="FAILED", error_log=str(e))
+        # )
+        # await db_session.commit()
+        raise