Compare commits
11 Commits
0a8790b088
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
| 6721c0a4ed | |||
| 3da37e1519 | |||
| 6294d94bed | |||
| d0669a0878 | |||
| b9906f6047 | |||
| 8d933386d3 | |||
| 0b6117cd7e | |||
| fc5d8725f1 | |||
| b9a5bb6e80 | |||
| 0bf2e46212 | |||
| aeffbe65ee |
16
package-lock.json
generated
16
package-lock.json
generated
@@ -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"
|
||||
|
||||
@@ -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": {
|
||||
|
||||
87
plugin.json
87
plugin.json
@@ -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 המקושר"
|
||||
}
|
||||
]
|
||||
}
|
||||
@@ -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[];
|
||||
}
|
||||
|
||||
@@ -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: [
|
||||
{
|
||||
@@ -178,6 +195,13 @@ export default {
|
||||
'מסכם פידבק יו"ר מהשבוע האחרון ומעדכן את decision-lessons.md',
|
||||
schedule: "0 19 * * 0",
|
||||
},
|
||||
{
|
||||
jobKey: "route-pending-comments",
|
||||
displayName: "ערובת מסירת-הערות (sweep)",
|
||||
description:
|
||||
"sweep פיוס: מנתב כל הערת-משתמש שטרם נותבה ל-CEO (at-least-once), כדי שהערה לא תיפול גם אם ה-wakeup התבטל/התלכד",
|
||||
schedule: "*/2 * * * *",
|
||||
},
|
||||
],
|
||||
webhooks: [
|
||||
{
|
||||
|
||||
365
src/worker.ts
365
src/worker.ts
@@ -16,16 +16,79 @@ const CEO_AGENT_IDS: Record<string, string> = {
|
||||
"cdbfa8bc-3d61-41a4-a2e7-677ec7d34562", // CMPA (היטלי השבחה)
|
||||
};
|
||||
|
||||
const DEFAULT_LEGAL_API_BASE = "http://localhost:8085";
|
||||
|
||||
/**
|
||||
* 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 +570,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) => {
|
||||
@@ -535,6 +632,83 @@ const plugin = definePlugin({
|
||||
|
||||
// Route user comments through CEO agent — per company
|
||||
|
||||
// Marker: the id of the last user comment already routed to the CEO for
|
||||
// an issue. BOTH the event-driven route below and the reconciliation
|
||||
// sweep (`route-pending-comments`) set it, so the sweep never re-routes a
|
||||
// comment the fast path already handled. This is what turns best-effort
|
||||
// event delivery into an at-least-once guarantee.
|
||||
const LAST_ROUTED_COMMENT_KEY = "last-routed-comment-id";
|
||||
|
||||
async function markCommentRouted(
|
||||
issueId: string,
|
||||
commentId: string | undefined,
|
||||
): Promise<void> {
|
||||
if (!commentId) return;
|
||||
try {
|
||||
await ctx.state.set(
|
||||
{
|
||||
scopeKind: "issue",
|
||||
scopeId: issueId,
|
||||
stateKey: LAST_ROUTED_COMMENT_KEY,
|
||||
},
|
||||
commentId,
|
||||
);
|
||||
} catch (err) {
|
||||
ctx.logger.warn("Failed to persist last-routed-comment marker", {
|
||||
issueId,
|
||||
commentId,
|
||||
error: String(err),
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
// Invoke the company CEO to handle a user comment on an issue. Shared by
|
||||
// the event-driven route and the reconciliation sweep. On success it
|
||||
// stamps the marker so the comment is not routed twice. Returns true when
|
||||
// the CEO was invoked.
|
||||
async function routeCommentToCeo(args: {
|
||||
issue: { id: string; title: string; identifier?: string | null };
|
||||
companyId: string;
|
||||
ceoAgentId: string;
|
||||
commentBody: string;
|
||||
commentId?: string;
|
||||
source: "event" | "sweep";
|
||||
}): Promise<boolean> {
|
||||
const { issue, companyId, ceoAgentId, commentBody, commentId, source } =
|
||||
args;
|
||||
const promptBody = commentBody
|
||||
? commentBody
|
||||
: "(לא ניתן לקרוא את תוכן התגובה — קרא את ה-comments האחרונים על ה-issue ישירות)";
|
||||
try {
|
||||
const { runId } = await ctx.agents.invoke(ceoAgentId, companyId, {
|
||||
prompt: [
|
||||
`תגובה חדשה מחיים על issue "${issue.title}" (${issue.identifier || issue.id}):`,
|
||||
"",
|
||||
promptBody,
|
||||
"",
|
||||
`קרא את ה-comments האחרונים על ה-issue, הבן מה חיים מבקש, והחלט מה לעשות.`,
|
||||
`אם ההוראה ברורה — נתב לסוכן המתאים. אם לא ברור — שאל את חיים.`,
|
||||
].join("\n"),
|
||||
reason: `user_commented_on_${issue.identifier || issue.id}`,
|
||||
});
|
||||
await markCommentRouted(issue.id, commentId);
|
||||
ctx.logger.info("Routed user comment to CEO agent", {
|
||||
issueId: issue.id,
|
||||
commentId: commentId || null,
|
||||
runId,
|
||||
source,
|
||||
});
|
||||
return true;
|
||||
} catch (err) {
|
||||
ctx.logger.error("Failed to invoke CEO agent for comment routing", {
|
||||
issueId: issue.id,
|
||||
source,
|
||||
error: String(err),
|
||||
});
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
ctx.events.on("issue.comment.created", async (event) => {
|
||||
// Only intercept human comments — not agent comments (prevents loops)
|
||||
if (event.actorType !== "user") return;
|
||||
@@ -601,6 +775,9 @@ const plugin = definePlugin({
|
||||
"Comment reopened CEO-owned issue; native wake handles it, skipping plugin route",
|
||||
{ issueId, ceoAgentId },
|
||||
);
|
||||
// The comment IS being handled (natively) — stamp the marker so the
|
||||
// reconciliation sweep does not re-route it a second time.
|
||||
await markCommentRouted(issueId, commentId);
|
||||
return;
|
||||
}
|
||||
|
||||
@@ -617,7 +794,16 @@ const plugin = definePlugin({
|
||||
const matched = commentId
|
||||
? comments.find((c) => c.id === commentId)
|
||||
: undefined;
|
||||
const latest = comments[comments.length - 1];
|
||||
// Newest by createdAt — do NOT rely on listComments array order.
|
||||
const latest = comments.reduce<(typeof comments)[number] | null>(
|
||||
(acc, c) =>
|
||||
!acc ||
|
||||
new Date(c.createdAt).getTime() >
|
||||
new Date(acc.createdAt).getTime()
|
||||
? c
|
||||
: acc,
|
||||
null,
|
||||
);
|
||||
commentBody =
|
||||
matched?.body ||
|
||||
latest?.body ||
|
||||
@@ -625,41 +811,25 @@ const plugin = definePlugin({
|
||||
"(לא ניתן לקרוא את התגובה)";
|
||||
} catch (err) {
|
||||
ctx.logger.warn("listComments failed, falling back to bodySnippet", {
|
||||
issueId, commentId, error: String(err),
|
||||
issueId,
|
||||
commentId,
|
||||
error: String(err),
|
||||
});
|
||||
commentBody = payload?.bodySnippet ?? "";
|
||||
}
|
||||
}
|
||||
|
||||
// If we still have no body, instruct CEO to read comments directly
|
||||
// rather than sending empty/error content as the instruction.
|
||||
const promptBody = commentBody
|
||||
? commentBody
|
||||
: "(לא ניתן לקרוא את תוכן התגובה — קרא את ה-comments האחרונים על ה-issue ישירות)";
|
||||
|
||||
try {
|
||||
const { runId } = await ctx.agents.invoke(ceoAgentId, event.companyId, {
|
||||
prompt: [
|
||||
`תגובה חדשה מחיים על issue "${issue.title}" (${issue.identifier || issueId}):`,
|
||||
"",
|
||||
promptBody,
|
||||
"",
|
||||
`קרא את ה-comments האחרונים על ה-issue, הבן מה חיים מבקש, והחלט מה לעשות.`,
|
||||
`אם ההוראה ברורה — נתב לסוכן המתאים. אם לא ברור — שאל את חיים.`,
|
||||
].join("\n"),
|
||||
reason: `user_commented_on_${issue.identifier || issueId}`,
|
||||
// Route through the shared helper (also used by the sweep). It stamps
|
||||
// the `last-routed-comment-id` marker on success so the reconciliation
|
||||
// sweep does not re-deliver this comment.
|
||||
await routeCommentToCeo({
|
||||
issue,
|
||||
companyId: event.companyId,
|
||||
ceoAgentId,
|
||||
commentBody: commentBody ?? "",
|
||||
commentId,
|
||||
source: "event",
|
||||
});
|
||||
ctx.logger.info("Routed user comment to CEO agent", {
|
||||
issueId,
|
||||
commentId: commentId || null,
|
||||
runId,
|
||||
});
|
||||
} catch (err) {
|
||||
ctx.logger.error("Failed to invoke CEO agent for comment routing", {
|
||||
issueId,
|
||||
error: String(err),
|
||||
});
|
||||
}
|
||||
});
|
||||
|
||||
// ── Jobs ───────────────────────────────────────────────────────
|
||||
@@ -752,9 +922,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 {
|
||||
@@ -826,9 +995,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`,
|
||||
@@ -885,6 +1053,107 @@ const plugin = definePlugin({
|
||||
}
|
||||
});
|
||||
|
||||
// Reconciliation sweep — the at-least-once guarantee for user comments.
|
||||
// The event-driven route above is best-effort: a failed/coalesced CEO
|
||||
// invoke, or a comment that lands while an agent is mid-run, can leave a
|
||||
// user comment unrouted with nothing to retry (this is exactly how a
|
||||
// chair comment was silently dropped — see legal-ai task #164). This sweep
|
||||
// re-routes any issue whose newest user comment id does not match the
|
||||
// `last-routed-comment-id` marker, so no comment falls through. Idempotent:
|
||||
// the fast path stamps the marker, so a healthy comment is never
|
||||
// double-routed. Runs every 2 minutes (manifest schedule).
|
||||
ctx.jobs.register("route-pending-comments", async (_job) => {
|
||||
let companies: Awaited<ReturnType<typeof ctx.companies.list>>;
|
||||
try {
|
||||
companies = await ctx.companies.list();
|
||||
} catch (err) {
|
||||
ctx.logger.warn("route-pending-comments: companies.list failed", {
|
||||
error: String(err),
|
||||
});
|
||||
return;
|
||||
}
|
||||
|
||||
for (const company of companies) {
|
||||
const ceoAgentId = CEO_AGENT_IDS[company.id];
|
||||
if (!ceoAgentId) continue;
|
||||
|
||||
let issues: Awaited<ReturnType<typeof ctx.issues.list>>;
|
||||
try {
|
||||
issues = await ctx.issues.list({ companyId: company.id, limit: 200 });
|
||||
} catch (err) {
|
||||
ctx.logger.warn("route-pending-comments: issues.list failed", {
|
||||
companyId: company.id,
|
||||
error: String(err),
|
||||
});
|
||||
continue;
|
||||
}
|
||||
|
||||
for (const issue of issues) {
|
||||
// Terminal issues need no routing. A fresh user comment on a
|
||||
// `done` issue reopens it natively → it becomes active and is
|
||||
// caught on the next sweep.
|
||||
if (issue.status === "done" || issue.status === "cancelled") continue;
|
||||
|
||||
try {
|
||||
const comments = await ctx.issues.listComments(
|
||||
issue.id,
|
||||
company.id,
|
||||
);
|
||||
if (comments.length === 0) continue;
|
||||
|
||||
// "Pending" = the chair spoke last among real participants: the
|
||||
// newest USER comment is newer than the newest AGENT comment (or
|
||||
// no agent has commented yet), so an agent never responded to it.
|
||||
// Order-independent (sort by createdAt, do NOT rely on the array
|
||||
// order of listComments) and system comments are ignored — an
|
||||
// automated "draft ready" line is not an agent response. This
|
||||
// targets the exact failure (chair commented, no agent reply) and
|
||||
// skips historically-answered comments.
|
||||
const ts = (c: { createdAt: string | Date }) =>
|
||||
new Date(c.createdAt).getTime();
|
||||
let newestUser: (typeof comments)[number] | null = null;
|
||||
let newestAgent: (typeof comments)[number] | null = null;
|
||||
for (const c of comments) {
|
||||
if (c.authorType === "user") {
|
||||
if (!newestUser || ts(c) > ts(newestUser)) newestUser = c;
|
||||
} else if (c.authorType === "agent") {
|
||||
if (!newestAgent || ts(c) > ts(newestAgent)) newestAgent = c;
|
||||
}
|
||||
}
|
||||
if (!newestUser) continue; // no chair comment
|
||||
// An agent has already responded after the chair — handled.
|
||||
if (newestAgent && ts(newestAgent) >= ts(newestUser)) continue;
|
||||
|
||||
const marker = await ctx.state.get({
|
||||
scopeKind: "issue",
|
||||
scopeId: issue.id,
|
||||
stateKey: LAST_ROUTED_COMMENT_KEY,
|
||||
});
|
||||
// Already routed (CEO may still be working) — don't re-fire.
|
||||
if (marker === newestUser.id) continue;
|
||||
|
||||
ctx.logger.info(
|
||||
"route-pending-comments: re-routing unrouted user comment",
|
||||
{ issueId: issue.id, commentId: newestUser.id },
|
||||
);
|
||||
await routeCommentToCeo({
|
||||
issue,
|
||||
companyId: company.id,
|
||||
ceoAgentId,
|
||||
commentBody: newestUser.body,
|
||||
commentId: newestUser.id,
|
||||
source: "sweep",
|
||||
});
|
||||
} catch (err) {
|
||||
ctx.logger.warn("route-pending-comments: failed for issue", {
|
||||
issueId: issue.id,
|
||||
error: String(err),
|
||||
});
|
||||
}
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
// ── Data handlers (UI bridge) ──────────────────────────────────
|
||||
// These back `usePluginData(key, params)` calls from the React UI bundle
|
||||
// in `dist/ui/index.js`. Errors are caught and rethrown with a clear
|
||||
@@ -921,9 +1190,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`,
|
||||
@@ -960,9 +1227,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`,
|
||||
@@ -998,9 +1263,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);
|
||||
|
||||
Reference in New Issue
Block a user