Merge pull request 'fix(learning): כרטיס-אוצֵר כן-3-ערוצים + לכידת ממצאי-אוצֵר (source='curator')' (#339) from worktree-curator-learning-surface into main

mcp-server/src/legal_mcp/services/db.py

@@ -2675,6 +2675,22 @@ async def add_decision_lesson(
     return dict(row) if row else {}
 
 
+async def get_style_corpus_id_by_decision(decision_number: str) -> UUID | None:
+    """Resolve the style_corpus row id for a final decision by its number.
+
+    The curator knows the case_number; lessons attach to the corpus row the
+    learning pipeline enrolled (enroll_style_corpus). Returns None if the final
+    has not been enrolled yet (caller surfaces it — no silent attach).
+    """
+    pool = await get_pool()
+    async with pool.acquire() as conn:
+        row = await conn.fetchrow(
+            "SELECT id FROM style_corpus WHERE decision_number = $1 LIMIT 1",
+            decision_number,
+        )
+    return row["id"] if row else None
+
+
 async def update_decision_lesson(
     lesson_id: UUID,
     *,
@@ -2950,6 +2966,12 @@ async def get_recent_decision_lessons(limit: int = 15, practice_area: str = "")
     Gate (INV-LRN1/G10): returns only CHAIR-APPROVED lessons (review_status='approved').
     Panel-written proposals stay out of the writer's context until the chair approves
     them in /training — the chair's review is the gate, not the panel's 2/2 vote.
+
+    No silent cap (חוקה §6): when more approved lessons match than `limit`, the
+    overflow is dropped by ORDER BY created_at DESC — log it so coverage loss is
+    observable, not invisible. The real fix is lesson synthesis (TaskMaster #158):
+    consolidate overlapping lessons into fewer, richer ones so the set fits without
+    truncation. Until then this WARN is the audit trail.
     """
     pool = await get_pool()
     async with pool.acquire() as conn:
@@ -2964,6 +2986,20 @@ async def get_recent_decision_lessons(limit: int = 15, practice_area: str = "")
                LIMIT $1""",
             limit, practice_area,
         )
+        if len(rows) >= limit:
+            total = await conn.fetchval(
+                """SELECT count(*) FROM decision_lessons dl
+                   JOIN style_corpus sc ON sc.id = dl.style_corpus_id
+                   WHERE dl.review_status = 'approved'
+                     AND ($1 = '' OR sc.practice_area = $1)""",
+                practice_area,
+            ) or 0
+            if total > limit:
+                logger.warning(
+                    "get_recent_decision_lessons: capped %d→%d approved lessons "
+                    "(practice_area=%r) — %d not reaching the writer. See TaskMaster #158 (synthesis).",
+                    total, limit, practice_area or "*", total - limit,
+                )
     return [dict(r) for r in rows]