Chaim
034b609bd3
INV-TOOL3 (idempotency על מפתח דטרמיניסטי). כל שלושת הכלים מחזירים את הרשומה הקיימת במקום ליצור כפילות: - case_create — מפתח case_number (כבר UNIQUE ב-schema): מחזיר את התיק הקיים במקום unique-violation. - precedent_attach — מפתח (case_id, section_id, citation, quote): צירוף חוזר של אותו ציטוט לאותו סעיף מחזיר את הקיים. - document_upload — מפתח (case_id, SHA-256 של בייטי הקובץ): העלאה חוזרת של אותו קובץ מחזירה את המסמך הקיים ו**מדלגת על copy+OCR+embed** (החלק היקר). נוספה עמודת documents.content_hash (תוספתי, DEFAULT '') + get_document_by_hash. נבחרה בדיקת-מפתח ברמת-אפליקציה (SELECT-לפני-INSERT) ולא UNIQUE-constraint — כדי לא לשבור startup אם קיימים נתונים-כפולים legacy. אין מיגרציה הרסנית. עודכנו docs/spec/X9 (INV-TOOL3 ✅) ו-gap-audit (GAP-52 ✅, פרוסה 2). py_compile עבר על 4 קבצי הקוד. אימות runtime (restart MCP server) נדחה עד שהחילוץ הפעיל יסתיים. Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
104 lines
4.0 KiB
Python
104 lines
4.0 KiB
Python
"""MCP tools for attached legal precedents (user-supplied case-law quotes).
|
|
|
|
These complement the existing `case_law` table (which is populated from
|
|
structured sources and is what the block-writer RAG searches) by storing
|
|
free-text citations the chair attaches during the compose phase.
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
import json
|
|
from pathlib import Path
|
|
from uuid import UUID
|
|
|
|
from legal_mcp.services import db
|
|
|
|
|
|
async def precedent_attach(
|
|
case_number: str,
|
|
quote: str,
|
|
citation: str,
|
|
section_id: str = "",
|
|
chair_note: str = "",
|
|
pdf_document_id: str = "",
|
|
) -> str:
|
|
"""צירוף פסיקה תומכת לתיק ערר.
|
|
|
|
Args:
|
|
case_number: מספר תיק הערר
|
|
quote: הציטוט המדויק שיוכנס להחלטה
|
|
citation: מראה המקום (ערר 1126-08-25 ... נ' ... (נבו 9.3.2026))
|
|
section_id: מזהה הטענה/סוגיה (threshold_1, issue_3); ריק = כללי לתיק
|
|
chair_note: הערה אופציונלית — למה הציטוט תומך בעמדה
|
|
pdf_document_id: מזהה קובץ PDF מצורף (אופציונלי)
|
|
"""
|
|
case = await db.get_case_by_number(case_number)
|
|
if not case:
|
|
return json.dumps({"error": f"תיק {case_number} לא נמצא."}, ensure_ascii=False)
|
|
|
|
pdf_uuid: UUID | None = None
|
|
if pdf_document_id:
|
|
try:
|
|
pdf_uuid = UUID(pdf_document_id)
|
|
except ValueError:
|
|
return json.dumps({"error": "pdf_document_id לא תקין"}, ensure_ascii=False)
|
|
|
|
# INV-TOOL3 / GAP-52: idempotent on (case_id, section_id, citation, quote).
|
|
# Re-attaching the same quote to the same section returns the existing row.
|
|
for _p in await db.list_case_precedents(UUID(case["id"])):
|
|
if (_p.get("citation") == citation and _p.get("quote") == quote
|
|
and (_p.get("section_id") or None) == (section_id or None)):
|
|
_p["idempotent_existing"] = True
|
|
return json.dumps(_p, ensure_ascii=False, indent=2, default=str)
|
|
|
|
row = await db.create_case_precedent(
|
|
case_id=UUID(case["id"]),
|
|
quote=quote,
|
|
citation=citation,
|
|
section_id=section_id or None,
|
|
chair_note=chair_note,
|
|
pdf_document_id=pdf_uuid,
|
|
practice_area=case.get("practice_area"),
|
|
)
|
|
return json.dumps(row, ensure_ascii=False, indent=2, default=str)
|
|
|
|
|
|
async def precedent_list(case_number: str) -> str:
|
|
"""רשימת כל הפסיקות שצורפו לתיק, ממוינות לפי סעיף ואז לפי זמן יצירה."""
|
|
case = await db.get_case_by_number(case_number)
|
|
if not case:
|
|
return json.dumps({"error": f"תיק {case_number} לא נמצא."}, ensure_ascii=False)
|
|
|
|
rows = await db.list_case_precedents(UUID(case["id"]))
|
|
return json.dumps(rows, ensure_ascii=False, indent=2, default=str)
|
|
|
|
|
|
async def precedent_remove(precedent_id: str) -> str:
|
|
"""הסרת פסיקה מצורפת. קובץ ה-PDF (אם צורף) נשאר ב-documents לצורך audit."""
|
|
try:
|
|
pid = UUID(precedent_id)
|
|
except ValueError:
|
|
return json.dumps({"error": "precedent_id לא תקין"}, ensure_ascii=False)
|
|
|
|
ok = await db.delete_case_precedent(pid)
|
|
return json.dumps(
|
|
{"deleted": ok, "precedent_id": precedent_id}, ensure_ascii=False,
|
|
)
|
|
|
|
|
|
async def precedent_search_library(
|
|
query: str, practice_area: str = "", limit: int = 10,
|
|
) -> str:
|
|
"""חיפוש בספרייה הרוחבית — כל הפסיקות שצורפו אי-פעם בכל התיקים.
|
|
|
|
Args:
|
|
query: מחרוזת חיפוש (מתחרה מול citation ומול quote)
|
|
practice_area: אופציונלי — סינון לתחום משפטי מסוים
|
|
limit: מספר תוצאות מקסימלי
|
|
"""
|
|
if not query or len(query.strip()) < 2:
|
|
return json.dumps([], ensure_ascii=False)
|
|
|
|
rows = await db.search_precedent_library(query.strip(), practice_area, limit)
|
|
return json.dumps(rows, ensure_ascii=False, indent=2, default=str)
|