8 Commits

Author SHA1 Message Date
378e5657b5 fix(sync): סנכרון-הסטטוס יכתוב רק על issue-שורש פתוח, לא על sub-task שנסגר (#446)
הג'וב sync-case-status כתב על כל issue מקושר-לתיק שסטטוסו שונה מהיעד — השומר
היחיד היה 'issue.status !== targetStatus'. לכן הוא החזיר sub-tasks שנסגרו
(done) ל-in_progress, כפי שתועד ב-CMPA-140 / תיק 8125-09-24.

בחירת-היעד חולצה ל-src/sync-target.ts: נבחר שורש יחיד (parentId === null)
שאינו done/cancelled ואינו in_review/blocked; אפס או יותר-מאחד → לא נכתב
דבר, ונרשם לוג עם הסיבה. שני הקבועים מובחנים בכוונה — CLOSED_ISSUE_STATUSES
הוא ההגדרה היחידה של 'סגור' (מראה של legal-ai/web/paperclip_client.py:561),
ו-NON_WRITABLE_STATUSES הוא 'מצב בבעלות Paperclip/בהמתנה-לאדם': כתיבת
in_progress על issue ב-in_review מזמינה auto-block תוך דקה
(legal-ai/docs/paperclip-quirks.md §3) וגונבת אותו מתור-הביקורת של היו"ר.

הלולאה הכפולה הוחלפה במעבר אחד + קיבוץ למפת case_number→מועמדים; הקיבוץ
נדרש כדי לבחור 'השורש היחיד', וכתוצר-לוואי O(NxM)→O(M) קריאות state.get.

מבחן-רגרסיה (node --test, ללא תלויות חדשות) משחזר את 11 ה-issues שנמדדו
לתיק 8125-09-24 ומוכיח את הדלתא: הכלל הישן היה כותב על CMPA-140, החדש לא.

בבעלות ריפו זה בהחלטת פאנל — העברת הלוגיקה ל-legal-ai נפסלה כי היא מוסיפה
UPDATE ישיר ל-DB של Paperclip, בהפרת INV-INT4 (GAP-24/25).
2026-08-24 07:41:32 +03:00
6721c0a4ed chore(manifest): מחיקת plugin.json — קובץ מת שמטעה
plugin.json הצהיר 16 כלים ולא נקרא ע"י אף אחד: המניפסט האמיתי הוא
src/manifest.ts → dist/manifest.js, שנפתר דרך package.json →
paperclipPlugin.manifest. הפער ניכר בכך שהקובץ חסר את
legal_predecessor_context, שנוסף למניפסט האמיתי ב-b9906f6.

ה-16 השגוי הזה הוא מקור ה-"16 tools" ב-~/CLAUDE.md, בעוד שה-loader
רושם 9 — המספר שבמניפסט האמיתי ובמאניפסט השמור ב-DB.

אומת לפני המחיקה: אין הפניה לקובץ בקוד, בבנייה, או בקוד השרת.

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
2026-07-25 17:17:06 +00:00
3da37e1519 Merge pull request 'fix(config): קריאת config מותאמת ל-scope של חברה (Paperclip 2026.722.0)' (#7) from fix/company-scoped-plugin-config into main 2026-07-25 16:42:19 +00:00
6294d94bed fix(config): קריאת config מותאמת ל-scope של חברה (Paperclip 2026.722.0)
מיגרציה 0164_plugin_config_company_scope הפכה את config של פלאגינים
ל-company-scoped, ו-`ctx.config.get()` בלי companyId זורק
"company context is required" כשה-host לא יכול לגזור חברה מההקשר.
ב-setup() אין חברה בהגדרה, ולכן הקריאה שם הפילה את הפעלת הפלאגין כולו
בשדרוג מ-2026.609.0 (status=error, 0 כלים רשומים).

- setup() כבר לא קורא config; LegalApi מקבל resolver עצל במקום URL קבוע
  (baseUrl שימש במקום אחד בלבד, ולכן 17 ה-tool handlers לא נגעו)
- resolveApiBase() פותר לפי הסדר: companyId מפורש → גזירת ה-host
  מההקשר → סריקת החברות ב-CEO_AGENT_IDS → ברירת מחדל
- data handlers מעבירים params.companyId; jobs מתוזמנים חסרי חברה
  (PluginJobContext לא כולל companyId) ולכן נשענים על הסריקה
- שדרוג @paperclipai/plugin-sdk ל-2026.722.0

מאומת: הפלאגין עולה עם אותה חתימת רישום כמו לפני השדרוג —
eventSubscriptions:2, jobs:4, webhooks:1, tools:9, בלי warnings.

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
2026-07-25 16:18:30 +00:00
d0669a0878 Merge pull request 'fix(manifest): הצהרת legal_predecessor_context ב-manifest (חשיפת הכלי)' (#6) from fix/predecessor-manifest into main 2026-07-07 05:16:43 +00:00
b9906f6047 fix(manifest): הצהרת legal_predecessor_context ב-manifest (חשיפת הכלי)
ה-manifest.tools הוא המקור-הקובע לרישום/חשיפת כלים ב-Paperclip — ctx.tools.register
ב-worker.ts נותן רק את ה-handler. בלי הצהרה ב-manifest, הכלי לא נחשף (הלוגים הראו
toolCount=8, בלי legal_predecessor_context). מוסיף את ההצהרה → toolCount=9, הכלי חשוף.

אומת חי: reinstall+restart → logs מראים toolCount:9 + legal_predecessor_context רשום.
(המשך #220; משלים את PR #5.)

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
2026-07-07 05:16:18 +00:00
8d933386d3 Merge pull request 'feat(tools): כלי legal_predecessor_context — הקשר מריצות-קודמות לסוכן (#220)' (#5) from feat/predecessor-context into main 2026-07-07 05:12:18 +00:00
0b6117cd7e feat(tools): כלי legal_predecessor_context — הקשר מריצות-קודמות לסוכן (#220)
מוסיף כלי-plugin שהסוכן קורא בעת continuation כדי לראות מה ריצות קודמות על התיק
הסיקו (ה-summary של כל heartbeat), במקום לגלות-מחדש הקשר מאפס (blind heartbeat).

- legal-api.ts: getPredecessorForCase(caseNumber) → GET
  /api/operations/cases/{case}/predecessor (endpoint שנוסף ב-legal-ai #410).
- worker.ts: רישום הכלי (case_number param) — מעצב digest קריא (agent·issue·when·
  status + summary חתוך ל-600 תווים, newest-first).

ארכיטקטורה (ההכרעה מהדיון): הכלי חי ב-plugin — המעטפת המוצהרת שמותר לה לדבר גם
Paperclip וגם legal-ai web — ולא ב-mcp-server (הליבה נשארת עיוורת-פלטפורמה, G12).
זו הסיבה שזה plugin-tool ולא mcp→web seam.

בנייה: tsc + biome נקיים. פריסה (ידנית, pm2): npm run build → plugin install →
pm2 restart paperclip. המשך: הוראת-HEARTBEAT לקרוא בעת continuation.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
2026-07-07 05:11:44 +00:00
9 changed files with 486 additions and 182 deletions

16
package-lock.json generated
View File

@@ -8,7 +8,7 @@
"name": "@marcusgroup/plugin-legal-ai",
"version": "0.1.0",
"dependencies": {
"@paperclipai/plugin-sdk": "^2026.525.0",
"@paperclipai/plugin-sdk": "^2026.722.0",
"react": "^19.0.0"
},
"devDependencies": {
@@ -625,12 +625,12 @@
}
},
"node_modules/@paperclipai/plugin-sdk": {
"version": "2026.525.0",
"resolved": "https://registry.npmjs.org/@paperclipai/plugin-sdk/-/plugin-sdk-2026.525.0.tgz",
"integrity": "sha512-7ivXbFSwH7cS+/2WNbPwQve5vVtLnqgxX5lmqTKn+i3fOY03d5KHaYF2bbI5zeTkAAwwEJ0Nz3rfBWNPguRRUw==",
"version": "2026.722.0",
"resolved": "https://registry.npmjs.org/@paperclipai/plugin-sdk/-/plugin-sdk-2026.722.0.tgz",
"integrity": "sha512-2rMJCBo8ZAouuMsapdaY4/l+oHmrXKHW/k/HfPOLCxFng7+g04c5JhoFq+/ptGfNcW3kXzs34y7brviDCml06Q==",
"license": "MIT",
"dependencies": {
"@paperclipai/shared": "2026.525.0",
"@paperclipai/shared": "2026.722.0",
"zod": "^3.24.2"
},
"bin": {
@@ -646,9 +646,9 @@
}
},
"node_modules/@paperclipai/shared": {
"version": "2026.525.0",
"resolved": "https://registry.npmjs.org/@paperclipai/shared/-/shared-2026.525.0.tgz",
"integrity": "sha512-fbVrEx96oxkxXbRBFDLAgW5Z0lRC7Ii+BeCNhKqKRCg9m2IwtP97CGoOeAROdRrvRpP8Neb3vgaaDbDjXT74lQ==",
"version": "2026.722.0",
"resolved": "https://registry.npmjs.org/@paperclipai/shared/-/shared-2026.722.0.tgz",
"integrity": "sha512-JciI6EbtNwHSeoyN5ZkshwqpyfIluyO46JHp8I7pPCvpJ7Uv7MSZEBs3lKXdXLadFEN6qzfwNmf39xjIFC8isA==",
"license": "MIT",
"dependencies": {
"zod": "^3.24.2"

View File

@@ -17,7 +17,7 @@
"biome:fix": "biome check --write src/"
},
"dependencies": {
"@paperclipai/plugin-sdk": "^2026.525.0",
"@paperclipai/plugin-sdk": "^2026.722.0",
"react": "^19.0.0"
},
"devDependencies": {

View File

@@ -1,87 +0,0 @@
{
"id": "marcusgroup.legal-ai",
"apiVersion": 1,
"version": "0.2.0",
"displayName": "Ezer Mishpati - Legal AI",
"description": "Integration with legal decision drafting system — case management, semantic search, workflow tracking, QA validation, and learning loop",
"author": "Marcus Group",
"categories": ["integration"],
"minimumHostVersion": "2026.325.0",
"capabilities": [
"events.subscribe",
"issues.read",
"issues.create",
"issues.update",
"issue.comments.create",
"issue.comments.read",
"agents.read",
"agents.invoke",
"agent.tools.register",
"http.outbound",
"plugin.state.read",
"plugin.state.write",
"jobs.schedule",
"activity.log.write",
"companies.read",
"projects.read",
"webhooks.receive"
],
"entrypoints": {
"worker": "dist/worker.js"
},
"instanceConfigSchema": {
"type": "object",
"properties": {
"legalApiBaseUrl": {
"type": "string",
"default": "http://localhost:8085",
"description": "Base URL for the Ezer Mishpati API"
}
}
},
"tools": [
{ "toolKey": "legal_case_list", "displayName": "רשימת תיקי ערר" },
{ "toolKey": "legal_case_get", "displayName": "פרטי תיק ערר" },
{ "toolKey": "legal_case_create", "displayName": "יצירת תיק ערר" },
{ "toolKey": "legal_case_update", "displayName": "עדכון תיק ערר" },
{ "toolKey": "legal_case_status", "displayName": "סטטוס תהליך עבודה" },
{ "toolKey": "legal_search", "displayName": "חיפוש תקדימים" },
{ "toolKey": "legal_case_template", "displayName": "תבנית החלטה" },
{ "toolKey": "legal_processing_status", "displayName": "סטטוס עיבוד כללי" },
{ "toolKey": "legal_document_list", "displayName": "רשימת מסמכים בתיק" },
{ "toolKey": "legal_set_outcome", "displayName": "הזנת תוצאת ערר" },
{ "toolKey": "legal_get_claims", "displayName": "טענות מחולצות" },
{ "toolKey": "legal_search_case", "displayName": "חיפוש בתוך תיק" },
{ "toolKey": "legal_find_similar", "displayName": "תקדימים דומים" },
{ "toolKey": "legal_run_qa", "displayName": "בדיקת איכות" },
{ "toolKey": "legal_trigger_learning", "displayName": "לולאת למידה" },
{ "toolKey": "legal_style_guide", "displayName": "מדריך סגנון" }
],
"jobs": [
{
"jobKey": "sync-case-status",
"displayName": "סנכרון סטטוס תיקים",
"description": "סנכרון סטטוס בין legal-ai ל-Paperclip כל 15 דקות",
"schedule": "*/15 * * * *"
},
{
"jobKey": "stale-case-reminder",
"displayName": "תזכורת תיקים תקועים",
"description": "מזהה תיקים שלא עודכנו 3+ ימים ומוסיף תגובה ל-issue",
"schedule": "0 8 * * *"
},
{
"jobKey": "weekly-feedback-analysis",
"displayName": "ניתוח פידבק שבועי",
"description": "מסכם פידבק יו\"ר מהשבוע האחרון ומעדכן את decision-lessons.md",
"schedule": "0 19 * * 0"
}
],
"webhooks": [
{
"endpointKey": "case-status",
"displayName": "עדכון סטטוס תיק",
"description": "מקבל עדכוני סטטוס מ-legal-ai ומפרסם תגובה על ה-issue המקושר"
}
]
}

View File

@@ -2,11 +2,23 @@
* HTTP client for Ezer Mishpati legal-ai REST API.
*/
/**
* Where the client gets its base URL. A plain string still works; a resolver is
* used when the URL comes from company-scoped plugin config, which cannot be
* read at worker startup (see worker.ts — `ctx.config.get` needs a company).
*/
export type BaseUrlSource = string | (() => string | Promise<string>);
export class LegalApi {
constructor(private baseUrl: string) {}
constructor(private baseUrl: BaseUrlSource) {}
private async resolveBaseUrl(): Promise<string> {
return typeof this.baseUrl === "string" ? this.baseUrl : this.baseUrl();
}
private async request<T>(path: string, init?: RequestInit): Promise<T> {
const res = await fetch(`${this.baseUrl}${path}`, {
const base = await this.resolveBaseUrl();
const res = await fetch(`${base}${path}`, {
...init,
headers: {
"Content-Type": "application/json",
@@ -148,6 +160,20 @@ export class LegalApi {
// Return static style guide reference
return "ראה skill-legal-decision/SKILL.md — מדריך סגנון מלא של דפנה תמיר";
}
/**
* Recent conclusions of prior heartbeat runs across a case's issues (#220,
* "seance"). Lets a resuming agent read what earlier sessions concluded
* instead of re-deriving context from scratch.
*/
async getPredecessorForCase(
caseNumber: string,
limit = 5,
): Promise<PredecessorResponse> {
return this.request(
`/api/operations/cases/${encodeURIComponent(caseNumber)}/predecessor?limit=${limit}`,
);
}
}
// Types
@@ -260,3 +286,21 @@ export interface QAResponse {
}>;
status: string;
}
export interface PredecessorRun {
run_id: string;
status: string;
started_at: string | null;
finished_at: string | null;
summary: string | null;
error_code: string | null;
session_id: string | null;
agent_name: string | null;
identifier: string | null;
}
export interface PredecessorResponse {
ok: boolean;
case_number: string;
runs: PredecessorRun[];
}

View File

@@ -156,6 +156,23 @@ export default {
description: "Get overall system processing status",
parametersSchema: { type: "object" as const, properties: {} },
},
{
toolKey: "legal_predecessor_context",
name: "legal_predecessor_context",
displayName: "הקשר מריצות קודמות",
description:
"Recent conclusions from prior heartbeat runs on this case (the 'summary' each run left). Call this when RESUMING work on a case to see what earlier sessions already did/decided — instead of re-deriving context from scratch.",
parametersSchema: {
type: "object" as const,
properties: {
case_number: {
type: "string" as const,
description: "Case number (e.g. 1043-02-26)",
},
},
required: ["case_number"],
},
},
],
jobs: [
{

134
src/sync-target.test.ts Normal file
View File

@@ -0,0 +1,134 @@
/// <reference types="node" />
import assert from "node:assert/strict";
import { test } from "node:test";
// Excluded from tsc (tsconfig.json) — never bundled/emitted, run natively via
// `node --test`, which requires the literal `.ts` extension (Node's ESM
// resolver does not remap `.js` specifiers to `.ts` files at runtime).
import { pickSyncTargetIssue, type SyncCandidate } from "./sync-target.ts";
/**
* הכלל הישן (worker.ts:894 לפני #446): כל issue מקושר שסטטוסו שונה מהיעד —
* נכתב, בלי סינון parentId ובלי סינון-סטטוס.
*/
function legacyTargets(
candidates: readonly SyncCandidate[],
targetStatus: string,
): string[] {
return candidates.filter((c) => c.status !== targetStatus).map((c) => c.id);
}
test("רגרסיית 8125-09-24 / CMPA-140: 11 ה-issues הממשיים של התיק, אף sub-task done לא נבחר", () => {
// נמדד ב-DB החי של Paperclip (2026-08-24) — כל ה-issues המקושרים לתיק
// 8125-09-24. CMPA-140 (זה שנדרס בפועל, done→in_progress) הוא **ילד** של
// CMPA-139, לא שורש. CMPA-139 עצמו אינו ברשימה בכוונה: נמדד שאין לו
// רשומת legal-case-number ב-plugin_state, ולכן הוא לא מגיע כמועמד כלל —
// לילד יש הורה שאינו מקושר.
const candidates: SyncCandidate[] = [
{ id: "CMPA-116", status: "cancelled", parentId: null },
{ id: "CMPA-84", status: "cancelled", parentId: null },
{ id: "CMPA-86", status: "cancelled", parentId: null },
{ id: "CMPA-140", status: "done", parentId: "CMPA-139" }, // זה שנדרס בפועל
{ id: "CMPA-141", status: "cancelled", parentId: "CMPA-139" },
{ id: "CMPA-85", status: "done", parentId: "CMPA-84" },
{ id: "CMPA-146", status: "done", parentId: "CMPA-84" },
{ id: "CMPA-147", status: "done", parentId: "CMPA-84" },
{ id: "CMPA-87", status: "done", parentId: "CMPA-86" },
{ id: "CMPA-88", status: "done", parentId: "CMPA-86" },
{ id: "CMPA-89", status: "cancelled", parentId: "CMPA-86" },
];
// סטטוס-התיק היה drafted → in_progress (CASE_STATUS_TO_ISSUE_STATUS ב-worker.ts).
const targetStatus = "in_progress";
// הכלל הישן היה כותב על CMPA-140 — זה הבאג שתועד.
assert.ok(legacyTargets(candidates, targetStatus).includes("CMPA-140"));
const result = pickSyncTargetIssue(candidates);
// הכלל החדש אינו כותב על דבר.
assert.equal(result.target, null);
assert.equal(result.reason, "no_writable_root");
});
test("sub-task יחיד ב-done ומקושר: sub-task לעולם לא נבחר", () => {
const candidates: SyncCandidate[] = [
{ id: "sub-1", status: "done", parentId: "some-root" },
];
const result = pickSyncTargetIssue(candidates);
assert.equal(result.target, null);
assert.equal(result.reason, "no_writable_root");
});
test("sub-task יחיד פתוח (in_progress) + שורש cancelled: פתוח אינו מספיק, חייב שורש", () => {
const candidates: SyncCandidate[] = [
{ id: "root-1", status: "cancelled", parentId: null },
{ id: "sub-1", status: "in_progress", parentId: "root-1" },
];
const result = pickSyncTargetIssue(candidates);
assert.equal(result.target, null);
assert.equal(result.reason, "no_writable_root");
});
test("שורש יחיד ב-todo: נבחר", () => {
const candidates: SyncCandidate[] = [
{ id: "root-1", status: "todo", parentId: null },
];
const result = pickSyncTargetIssue(candidates);
assert.equal(result.target?.id, "root-1");
assert.equal(result.reason, "ok");
assert.equal(result.writableRoots, 1);
});
test("שורש יחיד ב-in_review: לא נכתב (הגנת auto-block)", () => {
const candidates: SyncCandidate[] = [
{ id: "root-1", status: "in_review", parentId: null },
];
const result = pickSyncTargetIssue(candidates);
assert.equal(result.target, null);
assert.equal(result.reason, "no_writable_root");
});
test("שורש יחיד ב-blocked: לא נכתב", () => {
const candidates: SyncCandidate[] = [
{ id: "root-1", status: "blocked", parentId: null },
];
const result = pickSyncTargetIssue(candidates);
assert.equal(result.target, null);
assert.equal(result.reason, "no_writable_root");
});
test("שני שורשים ברי-כתיבה: ambiguous, לא נכתב", () => {
const candidates: SyncCandidate[] = [
{ id: "root-1", status: "todo", parentId: null },
{ id: "root-2", status: "in_progress", parentId: null },
];
const result = pickSyncTargetIssue(candidates);
assert.equal(result.target, null);
assert.equal(result.reason, "ambiguous_writable_roots");
assert.equal(result.writableRoots, 2);
});
test("שורש todo + ילד in_progress: השורש נבחר", () => {
const candidates: SyncCandidate[] = [
{ id: "root-1", status: "todo", parentId: null },
{ id: "child-1", status: "in_progress", parentId: "root-1" },
];
const result = pickSyncTargetIssue(candidates);
assert.equal(result.target?.id, "root-1");
assert.equal(result.reason, "ok");
});

79
src/sync-target.ts Normal file
View File

@@ -0,0 +1,79 @@
/**
* בחירת יעד-הסנכרון של הג'וב `sync-case-status` (issue #446).
*
* המקור לבאג: הג'וב הישן כתב על **כל** issue מקושר-לתיק, כולל sub-issues
* ו-issues בסטטוסים סגורים/בהמתנה-לאדם. זה החזיר CMPA-140 מ-`done` ל-`in_progress`
* (8125-09-24) — כי sub-task שהושלם עדיין נמנה כ"מקושר".
*
* המודול הזה טהור בכוונה — בלי import מה-SDK ובלי side effects — כדי שאפשר
* יהיה לייבא אותו ישירות בטסט בלי להריץ את `runWorker(plugin, import.meta.url)`
* שקורה בזמן import של worker.ts.
*/
/** "סגור" — ההגדרה היחידה. מראה של web/paperclip_client.py:561 ב-legal-ai. */
export const CLOSED_ISSUE_STATUSES: ReadonlySet<string> = new Set([
"done",
"cancelled",
]);
/**
* מצב בבעלות Paperclip / בהמתנה-לאדם — **לא** הגדרה שנייה של "סגור".
* `in_review` הוא מצב-ההמתנה-ליו"ר המכוון: CEO שמשאיר issue ב-`in_progress`
* מקבל auto-block מ-Paperclip תוך דקה, ולכן הוא מעביר ל-`in_review`
* (legal-ai/docs/paperclip-quirks.md §3). כתיבת-סטטוס אוטומטית עליו גונבת את
* ה-issue מתור-הביקורת של היו"ר ומזמינה קרב-סטטוסים.
* `blocked` — כתיבה עליו מסתירה חוסם קיים.
*/
export const NON_WRITABLE_STATUSES: ReadonlySet<string> = new Set([
"in_review",
"blocked",
]);
export interface SyncCandidate {
id: string;
status: string;
parentId: string | null;
}
export type SyncTargetReason =
| "ok"
| "no_linked_issues"
| "no_writable_root"
| "ambiguous_writable_roots";
export interface SyncTargetResult {
target: SyncCandidate | null;
reason: SyncTargetReason;
/** כמה שורשים ברי-כתיבה נמצאו — לצורך לוג. */
writableRoots: number;
}
export function isWritableStatus(status: string): boolean {
return (
!CLOSED_ISSUE_STATUSES.has(status) && !NON_WRITABLE_STATUSES.has(status)
);
}
export function pickSyncTargetIssue(
candidates: readonly SyncCandidate[],
): SyncTargetResult {
if (candidates.length === 0) {
return { target: null, reason: "no_linked_issues", writableRoots: 0 };
}
const roots = candidates.filter(
(c) => c.parentId === null && isWritableStatus(c.status),
);
if (roots.length === 1) {
return { target: roots[0], reason: "ok", writableRoots: 1 };
}
if (roots.length === 0) {
return { target: null, reason: "no_writable_root", writableRoots: 0 };
}
return {
target: null,
reason: "ambiguous_writable_roots",
writableRoots: roots.length,
};
}

View File

@@ -4,6 +4,7 @@ import type {
} from "@paperclipai/plugin-sdk";
import { definePlugin, runWorker } from "@paperclipai/plugin-sdk";
import { LegalApi } from "./legal-api.js";
import { pickSyncTargetIssue, type SyncCandidate } from "./sync-target.js";
// Hoisted so onWebhook can access the context after setup() completes.
let pluginCtx: PluginContext | null = null;
@@ -16,16 +17,116 @@ const CEO_AGENT_IDS: Record<string, string> = {
"cdbfa8bc-3d61-41a4-a2e7-677ec7d34562", // CMPA (היטלי השבחה)
};
const DEFAULT_LEGAL_API_BASE = "http://localhost:8085";
// Map 13 legal-ai case statuses to Paperclip issue status (used by the
// `sync-case-status` job).
const CASE_STATUS_TO_ISSUE_STATUS: Record<
string,
"todo" | "in_progress" | "done"
> = {
new: "todo",
uploading: "todo",
processing: "in_progress",
documents_ready: "in_progress",
outcome_set: "in_progress",
brainstorming: "in_progress",
direction_approved: "in_progress",
drafting: "in_progress",
qa_review: "in_progress",
drafted: "in_progress",
exported: "in_progress",
reviewed: "in_progress",
final: "done",
};
const CASE_STATUS_LABELS: Record<string, string> = {
new: "תיק חדש",
uploading: "העלאת מסמכים",
processing: "עיבוד מסמכים",
documents_ready: "מסמכים מוכנים — הזן תוצאה",
outcome_set: "תוצאה הוזנה — נדרש סיעור מוחות",
brainstorming: "גיבוש כיוון בתהליך",
direction_approved: "כיוון אושר — מוכן לכתיבה",
drafting: "כתיבת החלטה בתהליך",
qa_review: "בדיקת איכות",
drafted: "טיוטה מוכנה — בדוק ושלח לדפנה",
exported: "DOCX נוצר — ממתין לדפנה",
reviewed: "דפנה הגיהה — העלה גרסה סופית",
final: "גרסה סופית — לולאת למידה",
};
/**
* Resolve `legalApiBaseUrl` from company-scoped plugin config.
*
* ⚠️ Plugin config became company-scoped in @paperclipai/server 2026.722.0
* (migration `0164_plugin_config_company_scope`). A bare `ctx.config.get()` now
* throws `company context is required` unless the host can derive the company
* from the current invocation — which it CANNOT during `setup()`, because
* worker initialisation belongs to no company. Reading config at startup is what
* made the whole plugin fail to activate on the 722.0 upgrade.
*
* So: never call this from setup(); call it from a handler, passing the
* companyId that handler was given. Tool handlers get `runCtx.companyId`; data
* handlers get `params.companyId`. Scheduled jobs have no company at all, so
* they fall back to probing the companies we know about.
*/
/** Pull the companyId the host passes to `ctx.data` handlers, if present. */
function companyIdOf(params: unknown): string | undefined {
const id = (params as { companyId?: unknown } | null)?.companyId;
return typeof id === "string" && id.trim() ? id : undefined;
}
async function resolveApiBase(
ctx: PluginContext,
companyId?: string,
): Promise<string> {
const read = async (id?: string): Promise<string | null> => {
try {
const cfg = (await ctx.config.get(id)) as {
legalApiBaseUrl?: unknown;
} | null;
const url = cfg?.legalApiBaseUrl;
return typeof url === "string" && url.trim() ? url.trim() : null;
} catch {
return null;
}
};
if (companyId) {
const scoped = await read(companyId);
if (scoped) return scoped;
}
// No companyId passed in — but the host derives one itself when the call
// happens inside a host-scoped invocation (e.g. a tool handler). Ask before
// falling back to guesswork, so tools honour their own company's config.
const derived = await read(undefined);
if (derived) return derived;
// Genuinely no company (scheduled jobs): try each company we know of. All of
// them point at the same legal-ai instance in practice, so the first hit wins.
for (const knownCompanyId of Object.keys(CEO_AGENT_IDS)) {
const url = await read(knownCompanyId);
if (url) return url;
}
ctx.logger.warn("legalApiBaseUrl unresolved — using default", {
companyId: companyId ?? null,
fallback: DEFAULT_LEGAL_API_BASE,
});
return DEFAULT_LEGAL_API_BASE;
}
const plugin = definePlugin({
async setup(ctx) {
pluginCtx = ctx; // save for onWebhook
const config = (await ctx.config.get()) as {
legalApiBaseUrl?: string;
} | null;
const baseUrl = config?.legalApiBaseUrl || "http://localhost:8085";
const api = new LegalApi(baseUrl);
ctx.logger.info("Legal AI plugin starting", { url: baseUrl });
// Lazy: the URL is fetched on the first request, from inside a handler
// that has company context — not here. See resolveApiBase() above.
const api = new LegalApi(() => resolveApiBase(ctx));
ctx.logger.info("Legal AI plugin starting");
// ── Tools ──────────────────────────────────────────────────────
@@ -507,6 +608,40 @@ const plugin = definePlugin({
},
);
ctx.tools.register(
"legal_predecessor_context",
{
displayName: "הקשר מריצות קודמות",
description:
"Recent conclusions from prior heartbeat runs on this case (the 'summary' each run left). Call this when RESUMING work on a case to see what earlier sessions already did/decided — instead of re-deriving context from scratch. Provide the case number.",
parametersSchema: {
type: "object",
properties: {
case_number: {
type: "string",
description: "Case number (e.g. 1043-02-26)",
},
},
required: ["case_number"],
},
},
async (params) => {
const { case_number } = params as { case_number: string };
const result = await api.getPredecessorForCase(case_number);
// Readable digest for the agent — each prior run's conclusion,
// newest-first, summaries trimmed to keep the wake context lean.
const lines = result.runs.map((r) => {
const summary = (r.summary ?? "").trim().slice(0, 600);
const when = r.finished_at ?? r.started_at ?? "";
return `${r.agent_name ?? "?"} · ${r.identifier ?? ""} · ${when} · ${r.status}\n${summary}`;
});
const content = lines.length
? lines.join("\n\n")
: "אין ריצות קודמות עם מסקנות לתיק זה.";
return { content, data: result };
},
);
// ── Events ─────────────────────────────────────────────────────
ctx.events.on("issue.created", async (event) => {
@@ -748,71 +883,60 @@ const plugin = definePlugin({
const companyId = companies[0].id;
const issues = await ctx.issues.list({ companyId });
// מעבר אחד על ה-issues: state.get אחד ל-issue (לא לכל צירוף תיק×issue),
// וקיבוץ למפה case_number → מועמדים. הקיבוץ נדרש כדי לבחור "השורש היחיד".
const byCase = new Map<string, SyncCandidate[]>();
for (const issue of issues) {
const linkedCase = await ctx.state.get({
scopeKind: "issue",
scopeId: issue.id,
stateKey: "legal-case-number",
});
if (typeof linkedCase !== "string" || !linkedCase) continue;
const list = byCase.get(linkedCase) ?? [];
list.push({
id: issue.id,
status: issue.status,
parentId: issue.parentId,
});
byCase.set(linkedCase, list);
}
for (const legalCase of cases) {
for (const issue of issues) {
const linkedCase = await ctx.state.get({
scopeKind: "issue",
scopeId: issue.id,
stateKey: "legal-case-number",
const targetStatus = CASE_STATUS_TO_ISSUE_STATUS[legalCase.status];
if (!targetStatus) continue;
const candidates = byCase.get(legalCase.case_number) ?? [];
const { target, reason, writableRoots } =
pickSyncTargetIssue(candidates);
if (!target) {
// אין בליעה שקטה: מדווח למה לא נכתב כלום.
ctx.logger.info("sync-case-status: no sync target", {
caseNumber: legalCase.case_number,
reason,
linked: candidates.length,
writableRoots,
});
if (linkedCase === legalCase.case_number) {
// Map 13 legal-ai statuses to Paperclip issue status
const statusMap: Record<string, "todo" | "in_progress" | "done"> =
{
new: "todo",
uploading: "todo",
processing: "in_progress",
documents_ready: "in_progress",
outcome_set: "in_progress",
brainstorming: "in_progress",
direction_approved: "in_progress",
drafting: "in_progress",
qa_review: "in_progress",
drafted: "in_progress",
exported: "in_progress",
reviewed: "in_progress",
final: "done",
};
const statusLabels: Record<string, string> = {
new: "תיק חדש",
uploading: "העלאת מסמכים",
processing: "עיבוד מסמכים",
documents_ready: "מסמכים מוכנים — הזן תוצאה",
outcome_set: "תוצאה הוזנה — נדרש סיעור מוחות",
brainstorming: "גיבוש כיוון בתהליך",
direction_approved: "כיוון אושר — מוכן לכתיבה",
drafting: "כתיבת החלטה בתהליך",
qa_review: "בדיקת איכות",
drafted: "טיוטה מוכנה — בדוק ושלח לדפנה",
exported: "DOCX נוצר — ממתין לדפנה",
reviewed: "דפנה הגיהה — העלה גרסה סופית",
final: "גרסה סופית — לולאת למידה",
};
const targetStatus = statusMap[legalCase.status];
const label = statusLabels[legalCase.status] || legalCase.status;
if (targetStatus && issue.status !== targetStatus) {
await ctx.issues.update(
issue.id,
{ status: targetStatus },
companyId,
);
await ctx.issues.createComment(
issue.id,
`📋 ${label}`,
companyId,
);
ctx.logger.info("Synced issue status", {
issueId: issue.id,
caseNumber: legalCase.case_number,
newStatus: targetStatus,
});
}
}
continue;
}
if (target.status === targetStatus) continue;
const label =
CASE_STATUS_LABELS[legalCase.status] || legalCase.status;
await ctx.issues.update(
target.id,
{ status: targetStatus },
companyId,
);
await ctx.issues.createComment(target.id, `📋 ${label}`, companyId);
ctx.logger.info("Synced issue status", {
issueId: target.id,
caseNumber: legalCase.case_number,
newStatus: targetStatus,
});
}
ctx.logger.info("Case status sync completed", {
@@ -825,9 +949,8 @@ const plugin = definePlugin({
ctx.jobs.register("stale-case-reminder", async (_job) => {
ctx.logger.info("stale-case-reminder: starting");
const config = await ctx.config.get();
const apiBase =
(config.legalApiBaseUrl as string) ?? "http://localhost:8085";
// Scheduled job — no company context; resolveApiBase probes known companies.
const apiBase = await resolveApiBase(ctx);
let resp: Awaited<ReturnType<typeof ctx.http.fetch>>;
try {
@@ -899,9 +1022,8 @@ const plugin = definePlugin({
ctx.jobs.register("weekly-feedback-analysis", async (_job) => {
ctx.logger.info("weekly-feedback-analysis: starting");
const config = await ctx.config.get();
const apiBase =
(config.legalApiBaseUrl as string) ?? "http://localhost:8085";
// Scheduled job — no company context; resolveApiBase probes known companies.
const apiBase = await resolveApiBase(ctx);
const resp = await ctx.http.fetch(
`${apiBase}/api/chair-feedback/weekly-summary`,
@@ -1095,9 +1217,7 @@ const plugin = definePlugin({
if (!issueId) return null;
const caseNumber = await resolveCaseNumber(issueId);
if (!caseNumber) return null;
const config2 = await ctx.config.get();
const apiBase =
(config2.legalApiBaseUrl as string) ?? "http://localhost:8085";
const apiBase = await resolveApiBase(ctx, companyIdOf(params));
try {
const resp = await ctx.http.fetch(
`${apiBase}/api/cases/${encodeURIComponent(caseNumber)}/legal-arguments`,
@@ -1134,9 +1254,7 @@ const plugin = definePlugin({
if (!issueId) return [];
const caseNumber = await resolveCaseNumber(issueId);
if (!caseNumber) return [];
const config2 = await ctx.config.get();
const apiBase =
(config2.legalApiBaseUrl as string) ?? "http://localhost:8085";
const apiBase = await resolveApiBase(ctx, companyIdOf(params));
try {
const resp = await ctx.http.fetch(
`${apiBase}/api/cases/${encodeURIComponent(caseNumber)}/precedents`,
@@ -1172,9 +1290,7 @@ const plugin = definePlugin({
if (!issueId) return [];
const caseNumber = await resolveCaseNumber(issueId);
if (!caseNumber) return [];
const config2 = await ctx.config.get();
const apiBase =
(config2.legalApiBaseUrl as string) ?? "http://localhost:8085";
const apiBase = await resolveApiBase(ctx, companyIdOf(params));
try {
const url = new URL(`${apiBase}/api/missing-precedents`);
url.searchParams.set("case_number", caseNumber);

View File

@@ -12,5 +12,6 @@
"jsx": "react-jsx",
"lib": ["ES2022", "DOM", "DOM.Iterable"]
},
"include": ["src"]
"include": ["src"],
"exclude": ["src/**/*.test.ts"]
}