feat(slack): add manual post modal and draft pagination on Home

PyDevDeep · PyDevDeep · commit 1a9d416192b0 · 2026-04-05T04:45:01.000+03:00
- Add manual post modal (text, platform, optional schedule time)
- Add Schedule button to draft card opening dedicated schedule modal
- Filter Home drafts to pending/generating/generated/scheduled only
- Add offset-based pagination (10 per page) with prev/next buttons
- Add all new UI strings to lexicon
diff --git a/backend/api/routes/feedback.py b/backend/api/routes/feedback.py
@@ -22,6 +22,7 @@
     build_approval_modal,
     build_draft_card,
     build_generation_modal,
+    build_manual_post_modal,
     build_schedule_modal,
     build_upload_modal,
 )
@@ -100,6 +101,29 @@ async def slack_interactions(
                 )
             return Response(status_code=200)
 
+        if action_id == "action_open_manual_post_modal":
+            modal_view = build_manual_post_modal()
+            async with httpx.AsyncClient() as client:
+                await client.post(
+                    "https://slack.com/api/views.open",
+                    headers=headers,
+                    json={"trigger_id": trigger_id, "view": modal_view},
+                )
+            return Response(status_code=200)
+
+        if action_id == "action_home_drafts_page":
+            page_offset = int(action_value) if action_value.isdigit() else 0
+            repo = DraftRepository(session)
+            drafts = await repo.get_recent_drafts(limit=10, offset=page_offset)
+            home_view = build_app_home(drafts=drafts, offset=page_offset)
+            async with httpx.AsyncClient() as client:
+                await client.post(
+                    "https://slack.com/api/views.publish",
+                    headers=headers,
+                    json={"user_id": user_id, "view": home_view},
+                )
+            return Response(status_code=200)
+
         if action_id == "action_open_generation_modal":
             modal_view = build_generation_modal(channel_id=user_id)
             async with httpx.AsyncClient() as client:
@@ -243,7 +267,6 @@ async def slack_interactions(
         callback_id = view.get("callback_id")
         state_values = view.get("state", {}).get("values", {})
 
-        # --- СЦЕНАРІЙ 1: Генерація нового драфту ---
         # --- СЦЕНАРІЙ 1: Генерація нового драфту ---
         if callback_id == "modal_generate_draft":
             channel_id = view.get("private_metadata")
@@ -388,7 +411,81 @@ async def slack_interactions(
                 status_code=200,
             )
 
-        # --- СЦЕНАРІЙ 3: Планування публікації ---
+        # --- СЦЕНАРІЙ 3: Ручний пост ---
+        elif callback_id == "modal_manual_post":
+            content = (
+                state_values.get("block_manual_content", {})
+                .get("input_manual_content", {})
+                .get("value", "")
+                .strip()
+            )
+
+            block_state = state_values.get("block_platform_select", {}).get(
+                "input_platform_select", {}
+            )
+            selected_option = block_state.get("selected_option")
+            platform_raw = selected_option.get("value", "telegram") if selected_option else "telegram"
+            platform = Platform(platform_raw)
+
+            schedule_timestamp = (
+                state_values.get("block_schedule_time", {})
+                .get("input_schedule_time", {})
+                .get("selected_date_time")
+            )
+            scheduled_at = (
+                datetime.fromtimestamp(int(schedule_timestamp), tz=timezone.utc)
+                if schedule_timestamp
+                else None
+            )
+
+            # Знаходимо або створюємо користувача
+            user_query = await session.execute(select(User).where(User.username == user_id))
+            db_user = user_query.scalar_one_or_none()
+            if not db_user:
+                db_user = User(username=user_id)
+                session.add(db_user)
+                await session.flush()
+
+            repo = DraftRepository(session)
+
+            if scheduled_at:
+                new_draft = await repo.create(
+                    DraftCreate(topic=content[:80], platform=platform, user_id=db_user.id)
+                )
+                await repo.update(
+                    new_draft.id,
+                    DraftUpdate(
+                        content=content,
+                        status=DraftStatus.SCHEDULED,
+                        scheduled_at=scheduled_at,
+                    ),
+                )
+                logger.info(
+                    "manual_post_scheduled",
+                    user_id=user_id,
+                    platform=platform,
+                    scheduled_at=scheduled_at.isoformat(),
+                )
+            else:
+                new_draft = await repo.create(
+                    DraftCreate(topic=content[:80], platform=platform, user_id=db_user.id)
+                )
+                await repo.update(
+                    new_draft.id,
+                    DraftUpdate(content=content, status=DraftStatus.PUBLISHED),
+                )
+                await publish_post_task.kiq(
+                    post_id=str(new_draft.id), platform=platform.value, content=content
+                )
+                logger.info("manual_post_published", user_id=user_id, platform=platform)
+
+            return Response(
+                content=json.dumps({"response_action": "clear"}),
+                media_type="application/json",
+                status_code=200,
+            )
+
+        # --- СЦЕНАРІЙ 4: Планування публікації ---
         elif callback_id == "modal_schedule_draft":
             metadata_parts = view.get("private_metadata", "").split("|")
             draft_id = metadata_parts[0] if len(metadata_parts) > 0 else ""
@@ -432,7 +529,7 @@ async def slack_interactions(
                 status_code=200,
             )
 
-        # --- СЦЕНАРІЙ 4: Завантаження гайдлайну ---
+        # --- СЦЕНАРІЙ 5: Завантаження гайдлайну ---
         elif callback_id == "modal_upload_guideline":
             files = (
                 state_values.get("block_file_upload", {})
@@ -490,7 +587,7 @@ async def slack_events(
             if hasattr(settings.SLACK_BOT_TOKEN, "get_secret_value")
             else settings.SLACK_BOT_TOKEN
         )
-        home_view = build_app_home(drafts=recent_drafts)
+        home_view = build_app_home(drafts=recent_drafts, offset=0)
         async with httpx.AsyncClient() as client:
             res = await client.post(
                 "https://slack.com/api/views.publish",
diff --git a/backend/config/lexicon.py b/backend/config/lexicon.py
@@ -50,13 +50,24 @@
     "home_drafts_empty": "_Поки що немає жодного драфту._",
     "home_draft_card_text": "*{topic}*\nПлатформа: *{platform}* | Статус: {status_emoji} `{status}`",
     "home_draft_open_btn": "📝 Відкрити",
+    "home_btn_next_page": "Наступні →",
+    "home_btn_prev_page": "← Попередні",
     # --- Upload Modal ---
     "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}```",
+    # --- Manual Post Modal ---
+    "home_btn_manual_post": "✏️ Написати пост",
+    "manual_post_modal_title": "Новий пост вручну",
+    "manual_post_modal_submit": "Опублікувати / Запланувати",
+    "manual_post_modal_content_label": "Текст публікації",
+    "manual_post_modal_platform_label": "Платформа",
+    "manual_post_modal_schedule_label": "📅 Запланувати (UTC, необов'язково)",
+    "manual_post_published": "✅ Пост опубліковано!",
+    "manual_post_scheduled": "🕒 Пост заплановано на *{scheduled_at}* UTC!",
     # --- Schedule ---
     "btn_schedule": "🕒 Запланувати",
     "schedule_modal_title": "Планування публікації",
diff --git a/backend/repositories/draft_repository.py b/backend/repositories/draft_repository.py
@@ -43,13 +43,18 @@ async def update(self, draft_id: int, draft_update: DraftUpdate) -> Draft | None
         return result.scalar_one_or_none()
 
     async def get_recent_drafts(
-        self, limit: int = 10, platform: str | None = None
+        self, limit: int = 10, offset: int = 0, platform: str | None = None
     ) -> list[Draft]:
         """Витягує останні драфти (для Дашборду в Slack)"""
-        stmt = select(Draft).order_by(Draft.updated_at.desc())
+        active_statuses = ("pending", "generating", "generated", "scheduled")
+        stmt = (
+            select(Draft)
+            .where(Draft.status.in_(active_statuses))
+            .order_by(Draft.updated_at.desc())
+        )
         if platform:
             stmt = stmt.where(Draft.platform == platform)
-        stmt = stmt.limit(limit)
+        stmt = stmt.limit(limit).offset(offset)
 
         result = await self.session.execute(stmt)
         return list(result.scalars().all())
diff --git a/slack_app/utils/block_builder.py b/slack_app/utils/block_builder.py
@@ -313,7 +313,74 @@ def build_generation_modal(channel_id: str) -> dict[str, Any]:
     }
 
 
-def build_app_home(drafts: list[Draft] | None = None) -> dict[str, Any]:
+def build_manual_post_modal() -> dict[str, Any]:
+    """Генерує модалку для ручного написання і публікації/планування поста."""
+    return {
+        "type": "modal",
+        "callback_id": "modal_manual_post",
+        "title": {"type": "plain_text", "text": SLACK_UI["manual_post_modal_title"], "emoji": True},
+        "submit": {"type": "plain_text", "text": SLACK_UI["manual_post_modal_submit"], "emoji": True},
+        "close": {"type": "plain_text", "text": SLACK_UI["modal_cancel"], "emoji": True},
+        "blocks": [
+            {
+                "type": "input",
+                "block_id": "block_manual_content",
+                "element": {
+                    "type": "plain_text_input",
+                    "action_id": "input_manual_content",
+                    "multiline": True,
+                    "placeholder": {
+                        "type": "plain_text",
+                        "text": "Введіть текст вашої публікації...",
+                    },
+                },
+                "label": {
+                    "type": "plain_text",
+                    "text": SLACK_UI["manual_post_modal_content_label"],
+                    "emoji": True,
+                },
+            },
+            {
+                "type": "input",
+                "block_id": "block_platform_select",
+                "element": {
+                    "type": "static_select",
+                    "action_id": "input_platform_select",
+                    "initial_option": {
+                        "text": {"type": "plain_text", "text": "Telegram"},
+                        "value": "telegram",
+                    },
+                    "options": [
+                        {"text": {"type": "plain_text", "text": "Telegram"}, "value": "telegram"},
+                        {"text": {"type": "plain_text", "text": "Twitter"}, "value": "twitter"},
+                        {"text": {"type": "plain_text", "text": "Threads"}, "value": "threads"},
+                    ],
+                },
+                "label": {
+                    "type": "plain_text",
+                    "text": SLACK_UI["manual_post_modal_platform_label"],
+                    "emoji": True,
+                },
+            },
+            {
+                "type": "input",
+                "block_id": "block_schedule_time",
+                "optional": True,
+                "element": {
+                    "type": "datetimepicker",
+                    "action_id": "input_schedule_time",
+                },
+                "label": {
+                    "type": "plain_text",
+                    "text": SLACK_UI["manual_post_modal_schedule_label"],
+                    "emoji": True,
+                },
+            },
+        ],
+    }
+
+
+def build_app_home(drafts: list[Draft] | None = None, offset: int = 0, page_size: int = 10) -> dict[str, Any]:
     if drafts is None:
         drafts = []
 
@@ -353,6 +420,15 @@ def build_app_home(drafts: list[Draft] | None = None) -> dict[str, Any]:
                     },
                     "action_id": "action_open_upload_modal",
                 },
+                {
+                    "type": "button",
+                    "text": {
+                        "type": "plain_text",
+                        "text": SLACK_UI["home_btn_manual_post"],
+                        "emoji": True,
+                    },
+                    "action_id": "action_open_manual_post_modal",
+                },
             ],
         },
         {"type": "divider"},
@@ -404,6 +480,28 @@ def build_app_home(drafts: list[Draft] | None = None) -> dict[str, Any]:
                 }
             )
 
+        pagination_elements: list[dict[str, Any]] = []
+        if offset > 0:
+            pagination_elements.append(
+                {
+                    "type": "button",
+                    "text": {"type": "plain_text", "text": SLACK_UI["home_btn_prev_page"], "emoji": True},
+                    "value": str(offset - page_size),
+                    "action_id": "action_home_drafts_page",
+                }
+            )
+        if len(drafts) == page_size:
+            pagination_elements.append(
+                {
+                    "type": "button",
+                    "text": {"type": "plain_text", "text": SLACK_UI["home_btn_next_page"], "emoji": True},
+                    "value": str(offset + page_size),
+                    "action_id": "action_home_drafts_page",
+                }
+            )
+        if pagination_elements:
+            blocks.append({"type": "actions", "elements": pagination_elements})
+
     return {"type": "home", "blocks": blocks}
 
 
