File size: 5,372 Bytes
9646e24 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 | import { test, before, after } from "node:test";
import assert from "node:assert";
import fs from "node:fs";
import path from "node:path";
import { detectCommitments } from "../commitment/detector";
import {
upsertCommitmentByEmailId,
listCommitments,
loadMetrics,
recordAcceptanceOutcome,
} from "../commitment/store";
import { executeCommitment } from "../commitment/executor";
import { CommitmentContract, ProcessedEmailRecord } from "@/types";
const dataDir = path.join(process.cwd(), "data");
const commitmentsFile = path.join(dataDir, "commitments.json");
const metricsFile = path.join(dataDir, "commitment-metrics.json");
let commitmentsBackup: string | null = null;
let metricsBackup: string | null = null;
let commitmentsExisted = false;
let metricsExisted = false;
before(() => {
commitmentsExisted = fs.existsSync(commitmentsFile);
metricsExisted = fs.existsSync(metricsFile);
if (commitmentsExisted) {
commitmentsBackup = fs.readFileSync(commitmentsFile, "utf-8");
}
if (metricsExisted) {
metricsBackup = fs.readFileSync(metricsFile, "utf-8");
}
});
after(() => {
try {
if (commitmentsExisted) {
fs.mkdirSync(dataDir, { recursive: true });
fs.writeFileSync(commitmentsFile, commitmentsBackup ?? "", "utf-8");
} else if (fs.existsSync(commitmentsFile)) {
fs.unlinkSync(commitmentsFile);
}
} catch {
// ignore
}
try {
if (metricsExisted) {
fs.mkdirSync(dataDir, { recursive: true });
fs.writeFileSync(metricsFile, metricsBackup ?? "", "utf-8");
} else if (fs.existsSync(metricsFile)) {
fs.unlinkSync(metricsFile);
}
} catch {
// ignore
}
});
test("detectCommitments extracts a commitment contract", () => {
const emailId = `test-email-${Date.now()}`;
const record: ProcessedEmailRecord = {
id: "rec-1",
emailId,
subject: "Need territory report by Friday",
sender: "Sarah Martinez, Regional Manager",
senderEmail: "sarah.martinez@example.com",
receivedDate: new Date().toISOString(),
processedAt: new Date().toISOString(),
category: "report",
confidence: 0.9,
fieldCount: 0,
tableCount: 0,
extractedData: {
emailId,
extractedAt: new Date().toISOString(),
fields: [],
tables: [],
summary: "Please prepare the territory analysis report by Friday.",
category: "report",
confidence: 0.9,
source: "email_body",
},
};
const commitments = detectCommitments([record]);
assert.equal(commitments.length, 1);
assert.equal(commitments[0].emailId, emailId);
assert.equal(commitments[0].requesterEmail, "sarah.martinez@example.com");
});
test("upsertCommitmentByEmailId is idempotent", () => {
const emailId = `test-email-${Date.now()}-idempotent`;
const contract: CommitmentContract = {
id: "",
emailId,
emailSubject: "Test subject",
requester: "Requester",
requesterEmail: "req@example.com",
recipientRole: "field_representative",
authorityVerified: true,
requestedOutcome: "Prepare territory report",
deadline: new Date().toISOString(),
mandatoryOutputs: ["Written report"],
inferredOutputs: [],
permittedTools: ["internal_report_writer"],
externalSendAllowed: false,
autonomyClass: 1,
completionProbability: 0.9,
dependencies: [],
assumptions: [],
status: "detected",
auditEvents: [],
detectedAt: new Date().toISOString(),
};
const first = upsertCommitmentByEmailId(contract);
const second = upsertCommitmentByEmailId(contract);
assert.equal(first.id, second.id);
const all = listCommitments().filter((c) => c.emailId === emailId);
assert.equal(all.length, 1);
});
test("executeCommitment completes class-1 work and stages class-2 work", () => {
const emailId = `test-email-${Date.now()}-exec`;
const metrics = loadMetrics();
const base: CommitmentContract = {
id: "",
emailId,
emailSubject: "Execution request",
requester: "Requester",
requesterEmail: "req@example.com",
recipientRole: "field_representative",
authorityVerified: true,
requestedOutcome: "Prepare territory report",
deadline: new Date().toISOString(),
mandatoryOutputs: ["Written report"],
inferredOutputs: ["Executive summary"],
permittedTools: ["internal_report_writer"],
externalSendAllowed: false,
autonomyClass: 1,
completionProbability: 0.9,
dependencies: [],
assumptions: [],
status: "detected",
auditEvents: [],
detectedAt: new Date().toISOString(),
};
const done = executeCommitment(base, metrics);
assert.equal(done.contract.status, "completed");
assert.ok((done.contract.deliverables?.length ?? 0) >= 2);
assert.ok(done.contract.confidenceBreakdown);
assert.ok(done.contract.completionProbability >= 0 && done.contract.completionProbability <= 1);
const staged = executeCommitment({ ...base, autonomyClass: 2 }, metrics);
assert.equal(staged.contract.status, "awaiting_approval");
});
test("recordAcceptanceOutcome updates acceptance metric", () => {
const before = loadMetrics();
const after = recordAcceptanceOutcome({ acceptedWithoutRevision: true });
assert.equal(after.acceptedWithoutRevision.total, before.acceptedWithoutRevision.total + 1);
assert.equal(after.acceptedWithoutRevision.success, before.acceptedWithoutRevision.success + 1);
});
|