feat: let visitors re-list books mid-chat and switch selection

Expand catalog list phrases, clear session pin on catalog_response, always render book_selector in the widget, and clear Telegram durable pin when the picker is returned.

Co-authored-by: Cursor <cursoragent@cursor.com>

.agent/BDD_SPECS.md

@@ -197,6 +197,14 @@ Feature: Book Selector Intelligence
     Then the next visitor message should receive a graceful redirect
     And the redirect should offer the remaining active books
 
+  Scenario: Pinned visitor asks for books again
+    Given a visitor has selected book "Mindset Mastery" and is mid-conversation
+    When the visitor asks "what books do you have" or "show books" or "change book"
+    Then the book selector popup should appear with all active books
+    And the previous book pin should be cleared
+    When the visitor selects a different book
+    Then subsequent answers should use that newly selected book only
+
 
 Feature: Hallucination Guardrail
 

app/channels/services/bot_bridge.py

@@ -97,6 +97,7 @@ async def generate_channel_reply(
         import time
 
         from app.channels.services.telegram_book_select import (
+            clear_selected_book_on_conversation,
             expand_this_book_query,
             load_selected_book_from_conversation,
             pin_selected_book_on_conversation,
@@ -324,7 +325,14 @@ async def generate_channel_reply(
             user_message=text,
             assistant_message=reply,
         )
-        if session_ctx.selected_book_id:
+        if selector and not session_ctx.selected_book_id:
+            # Catalog re-list cleared the session pin — clear durable too.
+            await session_mgr.set_selected_book(
+                session_id, author_id, None, is_cross=False
+            )
+            await clear_selected_book_on_conversation(db, conversation_id)
+            await db.commit()
+        elif session_ctx.selected_book_id:
             await session_mgr.set_selected_book(
                 session_id, author_id, session_ctx.selected_book_id, is_cross=False
             )

app/channels/services/telegram_book_select.py

@@ -149,6 +149,24 @@ async def pin_selected_book_on_conversation(
     await db.flush()
 
 
+async def clear_selected_book_on_conversation(
+    db: AsyncSession,
+    conversation_id: str,
+) -> None:
+    """Remove durable selected-book pin so the visitor can re-pick from the list."""
+    from app.channels.models import ChannelConversation
+
+    conv = await db.get(ChannelConversation, conversation_id)
+    if not conv:
+        return
+    meta = _parse_conv_meta(conv.channel_metadata)
+    if _META_SELECTED not in meta:
+        return
+    meta.pop(_META_SELECTED, None)
+    conv.channel_metadata = json.dumps(meta)
+    await db.flush()
+
+
 async def load_selected_book_from_conversation(
     db: AsyncSession,
     conversation_id: str,

app/services/pipeline/guards.py

@@ -72,6 +72,10 @@ def should_short_circuit_to_catalog(
             "about the books", "tell me about your book", "tell me about the books",
             "in the catalog", "in your catalog", "show me your book",
             "uploaded book",
+            "show books", "show me books", "show the books",
+            "change book", "switch book", "another book", "other books",
+            "different book", "pick another", "choose another", "select another",
+            "book list", "list of books",
         )
         if any(p in q for p in list_phrases) or q in _CATALOG_EXACT:
             return True

app/services/pipeline/handlers.py

@@ -197,7 +197,9 @@ async def catalog_response(
     db: AsyncSession,
     start_ms: float,
 ) -> PipelineResult:
-    """Show the book catalog picker."""
+    """Show the book catalog picker and clear any prior book pin."""
+    session_context.selected_book_id = None
+    session_context.is_cross_book = False
     return books_list_response(CATALOG_RESPONSE, books, start_ms, intent="meta")
 
 

static/widget.js

@@ -740,7 +740,10 @@
         }, { 'X-Subscription-Token': CONFIG.token });
 
         typingEl.remove();
-        const bookSel = selectedBookId ? null : mapBooks(res.book_selector);
+        if (res.book_selector && res.book_selector.length) {
+          selectedBookId = null;
+        }
+        const bookSel = mapBooks(res.book_selector);
         addBotMessage(res.text, res.links || [], bookSel, res.follow_ups || [], res.platform_offers || null);
         if (res.links && res.links.length) {
           res.links.forEach(l => {

tests/unit/test_catalog_routing.py

@@ -29,6 +29,21 @@ def test_catalog_question_still_short_circuits_with_book_selected():
     ) is True
 
 
+def test_relisht_phrases_short_circuit_with_book_selected():
+    """Pinned visitor asking to see / change books must reopen the picker."""
+    for query in (
+        "show books",
+        "show me books",
+        "change book",
+        "switch book",
+        "other books",
+        "pick another",
+        "list of books",
+        "book list",
+    ):
+        assert should_short_circuit_to_catalog(query, "question", "book-123") is True, query
+
+
 def test_about_this_book_with_selection_reaches_rag():
     """Pinned book: 'tell me about the book' must not bounce to the picker."""
     assert should_short_circuit_to_catalog(
@@ -74,3 +89,39 @@ async def test_critique_debate_classified_as_question():
     )
     result = await classify_intent(query, history=[])
     assert result.intent == "question"
+
+
+@pytest.mark.asyncio
+async def test_catalog_response_clears_selected_book_pin():
+    """Re-listing books must unpin so the next pick becomes the active book."""
+    from types import SimpleNamespace
+    from unittest.mock import MagicMock
+
+    from app.services.pipeline.handlers import catalog_response
+    from app.services.session_core.manager import SessionContext
+
+    ctx = SessionContext(
+        session_id="s1",
+        author_id="a1",
+        selected_book_id="book-old",
+        is_cross_book=True,
+    )
+    books = [
+        SimpleNamespace(
+            id="b1",
+            title="One",
+            tagline="",
+            cover_path=None,
+            status="ready",
+        ),
+    ]
+    result = await catalog_response(
+        author=MagicMock(),
+        books=books,
+        session_context=ctx,
+        db=MagicMock(),
+        start_ms=0.0,
+    )
+    assert ctx.selected_book_id is None
+    assert ctx.is_cross_book is False
+    assert result.response.get("book_selector")