Compare commits
9 Commits
0bf2e46212
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
| 6721c0a4ed | |||
| 3da37e1519 | |||
| 6294d94bed | |||
| d0669a0878 | |||
| b9906f6047 | |||
| 8d933386d3 | |||
| 0b6117cd7e | |||
| fc5d8725f1 | |||
| b9a5bb6e80 |
16
package-lock.json
generated
16
package-lock.json
generated
@@ -8,7 +8,7 @@
|
|||||||
"name": "@marcusgroup/plugin-legal-ai",
|
"name": "@marcusgroup/plugin-legal-ai",
|
||||||
"version": "0.1.0",
|
"version": "0.1.0",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@paperclipai/plugin-sdk": "^2026.525.0",
|
"@paperclipai/plugin-sdk": "^2026.722.0",
|
||||||
"react": "^19.0.0"
|
"react": "^19.0.0"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
@@ -625,12 +625,12 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/@paperclipai/plugin-sdk": {
|
"node_modules/@paperclipai/plugin-sdk": {
|
||||||
"version": "2026.525.0",
|
"version": "2026.722.0",
|
||||||
"resolved": "https://registry.npmjs.org/@paperclipai/plugin-sdk/-/plugin-sdk-2026.525.0.tgz",
|
"resolved": "https://registry.npmjs.org/@paperclipai/plugin-sdk/-/plugin-sdk-2026.722.0.tgz",
|
||||||
"integrity": "sha512-7ivXbFSwH7cS+/2WNbPwQve5vVtLnqgxX5lmqTKn+i3fOY03d5KHaYF2bbI5zeTkAAwwEJ0Nz3rfBWNPguRRUw==",
|
"integrity": "sha512-2rMJCBo8ZAouuMsapdaY4/l+oHmrXKHW/k/HfPOLCxFng7+g04c5JhoFq+/ptGfNcW3kXzs34y7brviDCml06Q==",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@paperclipai/shared": "2026.525.0",
|
"@paperclipai/shared": "2026.722.0",
|
||||||
"zod": "^3.24.2"
|
"zod": "^3.24.2"
|
||||||
},
|
},
|
||||||
"bin": {
|
"bin": {
|
||||||
@@ -646,9 +646,9 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/@paperclipai/shared": {
|
"node_modules/@paperclipai/shared": {
|
||||||
"version": "2026.525.0",
|
"version": "2026.722.0",
|
||||||
"resolved": "https://registry.npmjs.org/@paperclipai/shared/-/shared-2026.525.0.tgz",
|
"resolved": "https://registry.npmjs.org/@paperclipai/shared/-/shared-2026.722.0.tgz",
|
||||||
"integrity": "sha512-fbVrEx96oxkxXbRBFDLAgW5Z0lRC7Ii+BeCNhKqKRCg9m2IwtP97CGoOeAROdRrvRpP8Neb3vgaaDbDjXT74lQ==",
|
"integrity": "sha512-JciI6EbtNwHSeoyN5ZkshwqpyfIluyO46JHp8I7pPCvpJ7Uv7MSZEBs3lKXdXLadFEN6qzfwNmf39xjIFC8isA==",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"zod": "^3.24.2"
|
"zod": "^3.24.2"
|
||||||
|
|||||||
@@ -17,7 +17,7 @@
|
|||||||
"biome:fix": "biome check --write src/"
|
"biome:fix": "biome check --write src/"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@paperclipai/plugin-sdk": "^2026.525.0",
|
"@paperclipai/plugin-sdk": "^2026.722.0",
|
||||||
"react": "^19.0.0"
|
"react": "^19.0.0"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"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.
|
* 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 {
|
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> {
|
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,
|
...init,
|
||||||
headers: {
|
headers: {
|
||||||
"Content-Type": "application/json",
|
"Content-Type": "application/json",
|
||||||
@@ -148,6 +160,20 @@ export class LegalApi {
|
|||||||
// Return static style guide reference
|
// Return static style guide reference
|
||||||
return "ראה skill-legal-decision/SKILL.md — מדריך סגנון מלא של דפנה תמיר";
|
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
|
// Types
|
||||||
@@ -260,3 +286,21 @@ export interface QAResponse {
|
|||||||
}>;
|
}>;
|
||||||
status: string;
|
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",
|
description: "Get overall system processing status",
|
||||||
parametersSchema: { type: "object" as const, properties: {} },
|
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: [
|
jobs: [
|
||||||
{
|
{
|
||||||
|
|||||||
180
src/worker.ts
180
src/worker.ts
@@ -16,16 +16,79 @@ const CEO_AGENT_IDS: Record<string, string> = {
|
|||||||
"cdbfa8bc-3d61-41a4-a2e7-677ec7d34562", // CMPA (היטלי השבחה)
|
"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({
|
const plugin = definePlugin({
|
||||||
async setup(ctx) {
|
async setup(ctx) {
|
||||||
pluginCtx = ctx; // save for onWebhook
|
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 ──────────────────────────────────────────────────────
|
// ── 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 ─────────────────────────────────────────────────────
|
// ── Events ─────────────────────────────────────────────────────
|
||||||
|
|
||||||
ctx.events.on("issue.created", async (event) => {
|
ctx.events.on("issue.created", async (event) => {
|
||||||
@@ -697,7 +794,16 @@ const plugin = definePlugin({
|
|||||||
const matched = commentId
|
const matched = commentId
|
||||||
? comments.find((c) => c.id === commentId)
|
? comments.find((c) => c.id === commentId)
|
||||||
: undefined;
|
: 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 =
|
commentBody =
|
||||||
matched?.body ||
|
matched?.body ||
|
||||||
latest?.body ||
|
latest?.body ||
|
||||||
@@ -816,9 +922,8 @@ const plugin = definePlugin({
|
|||||||
|
|
||||||
ctx.jobs.register("stale-case-reminder", async (_job) => {
|
ctx.jobs.register("stale-case-reminder", async (_job) => {
|
||||||
ctx.logger.info("stale-case-reminder: starting");
|
ctx.logger.info("stale-case-reminder: starting");
|
||||||
const config = await ctx.config.get();
|
// Scheduled job — no company context; resolveApiBase probes known companies.
|
||||||
const apiBase =
|
const apiBase = await resolveApiBase(ctx);
|
||||||
(config.legalApiBaseUrl as string) ?? "http://localhost:8085";
|
|
||||||
|
|
||||||
let resp: Awaited<ReturnType<typeof ctx.http.fetch>>;
|
let resp: Awaited<ReturnType<typeof ctx.http.fetch>>;
|
||||||
try {
|
try {
|
||||||
@@ -890,9 +995,8 @@ const plugin = definePlugin({
|
|||||||
|
|
||||||
ctx.jobs.register("weekly-feedback-analysis", async (_job) => {
|
ctx.jobs.register("weekly-feedback-analysis", async (_job) => {
|
||||||
ctx.logger.info("weekly-feedback-analysis: starting");
|
ctx.logger.info("weekly-feedback-analysis: starting");
|
||||||
const config = await ctx.config.get();
|
// Scheduled job — no company context; resolveApiBase probes known companies.
|
||||||
const apiBase =
|
const apiBase = await resolveApiBase(ctx);
|
||||||
(config.legalApiBaseUrl as string) ?? "http://localhost:8085";
|
|
||||||
|
|
||||||
const resp = await ctx.http.fetch(
|
const resp = await ctx.http.fetch(
|
||||||
`${apiBase}/api/chair-feedback/weekly-summary`,
|
`${apiBase}/api/chair-feedback/weekly-summary`,
|
||||||
@@ -997,14 +1101,28 @@ const plugin = definePlugin({
|
|||||||
);
|
);
|
||||||
if (comments.length === 0) continue;
|
if (comments.length === 0) continue;
|
||||||
|
|
||||||
// "Pending" = the conversation's last word is the chair's, with
|
// "Pending" = the chair spoke last among real participants: the
|
||||||
// no agent reply after it. listComments is chronological (newest
|
// newest USER comment is newer than the newest AGENT comment (or
|
||||||
// last). If an agent already responded, the comment was handled —
|
// no agent has commented yet), so an agent never responded to it.
|
||||||
// skip. This both targets the exact failure (chair commented, no
|
// Order-independent (sort by createdAt, do NOT rely on the array
|
||||||
// agent response) and avoids re-routing historically-answered
|
// order of listComments) and system comments are ignored — an
|
||||||
// comments on first run after deploy.
|
// automated "draft ready" line is not an agent response. This
|
||||||
const last = comments[comments.length - 1];
|
// targets the exact failure (chair commented, no agent reply) and
|
||||||
if (last.authorType !== "user") continue;
|
// 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({
|
const marker = await ctx.state.get({
|
||||||
scopeKind: "issue",
|
scopeKind: "issue",
|
||||||
@@ -1012,18 +1130,18 @@ const plugin = definePlugin({
|
|||||||
stateKey: LAST_ROUTED_COMMENT_KEY,
|
stateKey: LAST_ROUTED_COMMENT_KEY,
|
||||||
});
|
});
|
||||||
// Already routed (CEO may still be working) — don't re-fire.
|
// Already routed (CEO may still be working) — don't re-fire.
|
||||||
if (marker === last.id) continue;
|
if (marker === newestUser.id) continue;
|
||||||
|
|
||||||
ctx.logger.info(
|
ctx.logger.info(
|
||||||
"route-pending-comments: re-routing unrouted user comment",
|
"route-pending-comments: re-routing unrouted user comment",
|
||||||
{ issueId: issue.id, commentId: last.id },
|
{ issueId: issue.id, commentId: newestUser.id },
|
||||||
);
|
);
|
||||||
await routeCommentToCeo({
|
await routeCommentToCeo({
|
||||||
issue,
|
issue,
|
||||||
companyId: company.id,
|
companyId: company.id,
|
||||||
ceoAgentId,
|
ceoAgentId,
|
||||||
commentBody: last.body,
|
commentBody: newestUser.body,
|
||||||
commentId: last.id,
|
commentId: newestUser.id,
|
||||||
source: "sweep",
|
source: "sweep",
|
||||||
});
|
});
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
@@ -1072,9 +1190,7 @@ const plugin = definePlugin({
|
|||||||
if (!issueId) return null;
|
if (!issueId) return null;
|
||||||
const caseNumber = await resolveCaseNumber(issueId);
|
const caseNumber = await resolveCaseNumber(issueId);
|
||||||
if (!caseNumber) return null;
|
if (!caseNumber) return null;
|
||||||
const config2 = await ctx.config.get();
|
const apiBase = await resolveApiBase(ctx, companyIdOf(params));
|
||||||
const apiBase =
|
|
||||||
(config2.legalApiBaseUrl as string) ?? "http://localhost:8085";
|
|
||||||
try {
|
try {
|
||||||
const resp = await ctx.http.fetch(
|
const resp = await ctx.http.fetch(
|
||||||
`${apiBase}/api/cases/${encodeURIComponent(caseNumber)}/legal-arguments`,
|
`${apiBase}/api/cases/${encodeURIComponent(caseNumber)}/legal-arguments`,
|
||||||
@@ -1111,9 +1227,7 @@ const plugin = definePlugin({
|
|||||||
if (!issueId) return [];
|
if (!issueId) return [];
|
||||||
const caseNumber = await resolveCaseNumber(issueId);
|
const caseNumber = await resolveCaseNumber(issueId);
|
||||||
if (!caseNumber) return [];
|
if (!caseNumber) return [];
|
||||||
const config2 = await ctx.config.get();
|
const apiBase = await resolveApiBase(ctx, companyIdOf(params));
|
||||||
const apiBase =
|
|
||||||
(config2.legalApiBaseUrl as string) ?? "http://localhost:8085";
|
|
||||||
try {
|
try {
|
||||||
const resp = await ctx.http.fetch(
|
const resp = await ctx.http.fetch(
|
||||||
`${apiBase}/api/cases/${encodeURIComponent(caseNumber)}/precedents`,
|
`${apiBase}/api/cases/${encodeURIComponent(caseNumber)}/precedents`,
|
||||||
@@ -1149,9 +1263,7 @@ const plugin = definePlugin({
|
|||||||
if (!issueId) return [];
|
if (!issueId) return [];
|
||||||
const caseNumber = await resolveCaseNumber(issueId);
|
const caseNumber = await resolveCaseNumber(issueId);
|
||||||
if (!caseNumber) return [];
|
if (!caseNumber) return [];
|
||||||
const config2 = await ctx.config.get();
|
const apiBase = await resolveApiBase(ctx, companyIdOf(params));
|
||||||
const apiBase =
|
|
||||||
(config2.legalApiBaseUrl as string) ?? "http://localhost:8085";
|
|
||||||
try {
|
try {
|
||||||
const url = new URL(`${apiBase}/api/missing-precedents`);
|
const url = new URL(`${apiBase}/api/missing-precedents`);
|
||||||
url.searchParams.set("case_number", caseNumber);
|
url.searchParams.set("case_number", caseNumber);
|
||||||
|
|||||||
Reference in New Issue
Block a user