mirror of
https://github.com/moltbot/moltbot.git
synced 2026-04-20 21:23:23 +00:00
test: refresh plugin sdk baseline
This commit is contained in:
Peter Steinberger
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@@ -1,392 +0,0 @@
|
||||
import { beforeEach, describe, expect, it, vi } from "vitest";
|
||||
import { createCliRuntimeCapture } from "../cli/test-runtime-capture.js";
|
||||
import {
|
||||
tasksAuditCommand,
|
||||
tasksCancelCommand,
|
||||
tasksListCommand,
|
||||
tasksMaintenanceCommand,
|
||||
tasksNotifyCommand,
|
||||
tasksShowCommand,
|
||||
} from "./tasks.js";
|
||||
|
||||
const mocks = vi.hoisted(() => ({
|
||||
reconcileInspectableTasksMock: vi.fn(),
|
||||
reconcileTaskLookupTokenMock: vi.fn(),
|
||||
listTaskAuditFindingsMock: vi.fn(),
|
||||
summarizeTaskAuditFindingsMock: vi.fn(),
|
||||
previewTaskRegistryMaintenanceMock: vi.fn(),
|
||||
runTaskRegistryMaintenanceMock: vi.fn(),
|
||||
getInspectableTaskRegistrySummaryMock: vi.fn(),
|
||||
getInspectableTaskAuditSummaryMock: vi.fn(),
|
||||
updateTaskNotifyPolicyByIdMock: vi.fn(),
|
||||
cancelTaskByIdMock: vi.fn(),
|
||||
getTaskByIdMock: vi.fn(),
|
||||
loadConfigMock: vi.fn(() => ({ loaded: true })),
|
||||
}));
|
||||
|
||||
const reconcileInspectableTasksMock = mocks.reconcileInspectableTasksMock;
|
||||
const reconcileTaskLookupTokenMock = mocks.reconcileTaskLookupTokenMock;
|
||||
const listTaskAuditFindingsMock = mocks.listTaskAuditFindingsMock;
|
||||
const summarizeTaskAuditFindingsMock = mocks.summarizeTaskAuditFindingsMock;
|
||||
const previewTaskRegistryMaintenanceMock = mocks.previewTaskRegistryMaintenanceMock;
|
||||
const runTaskRegistryMaintenanceMock = mocks.runTaskRegistryMaintenanceMock;
|
||||
const getInspectableTaskRegistrySummaryMock = mocks.getInspectableTaskRegistrySummaryMock;
|
||||
const getInspectableTaskAuditSummaryMock = mocks.getInspectableTaskAuditSummaryMock;
|
||||
const updateTaskNotifyPolicyByIdMock = mocks.updateTaskNotifyPolicyByIdMock;
|
||||
const cancelTaskByIdMock = mocks.cancelTaskByIdMock;
|
||||
const getTaskByIdMock = mocks.getTaskByIdMock;
|
||||
const loadConfigMock = mocks.loadConfigMock;
|
||||
|
||||
vi.mock("../tasks/task-registry.reconcile.js", () => ({
|
||||
reconcileInspectableTasks: (...args: unknown[]) => reconcileInspectableTasksMock(...args),
|
||||
reconcileTaskLookupToken: (...args: unknown[]) => reconcileTaskLookupTokenMock(...args),
|
||||
}));
|
||||
|
||||
vi.mock("../tasks/task-registry.audit.js", () => ({
|
||||
listTaskAuditFindings: (...args: unknown[]) => listTaskAuditFindingsMock(...args),
|
||||
summarizeTaskAuditFindings: (...args: unknown[]) => summarizeTaskAuditFindingsMock(...args),
|
||||
}));
|
||||
|
||||
vi.mock("../tasks/task-registry.maintenance.js", () => ({
|
||||
previewTaskRegistryMaintenance: (...args: unknown[]) =>
|
||||
previewTaskRegistryMaintenanceMock(...args),
|
||||
runTaskRegistryMaintenance: (...args: unknown[]) => runTaskRegistryMaintenanceMock(...args),
|
||||
getInspectableTaskRegistrySummary: (...args: unknown[]) =>
|
||||
getInspectableTaskRegistrySummaryMock(...args),
|
||||
getInspectableTaskAuditSummary: (...args: unknown[]) =>
|
||||
getInspectableTaskAuditSummaryMock(...args),
|
||||
}));
|
||||
|
||||
vi.mock("../tasks/task-registry.js", () => ({
|
||||
updateTaskNotifyPolicyById: (...args: unknown[]) => updateTaskNotifyPolicyByIdMock(...args),
|
||||
cancelTaskById: (...args: unknown[]) => cancelTaskByIdMock(...args),
|
||||
getTaskById: (...args: unknown[]) => getTaskByIdMock(...args),
|
||||
}));
|
||||
|
||||
vi.mock("../config/config.js", () => ({
|
||||
loadConfig: () => loadConfigMock(),
|
||||
}));
|
||||
|
||||
const {
|
||||
defaultRuntime: runtime,
|
||||
runtimeLogs,
|
||||
runtimeErrors,
|
||||
resetRuntimeCapture,
|
||||
} = createCliRuntimeCapture();
|
||||
|
||||
const taskFixture = {
|
||||
taskId: "task-12345678",
|
||||
runtime: "acp",
|
||||
sourceId: "run-12345678",
|
||||
requesterSessionKey: "agent:main:main",
|
||||
childSessionKey: "agent:codex:acp:child",
|
||||
runId: "run-12345678",
|
||||
task: "Create a file",
|
||||
status: "running",
|
||||
deliveryStatus: "pending",
|
||||
notifyPolicy: "state_changes",
|
||||
createdAt: Date.parse("2026-03-29T10:00:00.000Z"),
|
||||
lastEventAt: Date.parse("2026-03-29T10:00:10.000Z"),
|
||||
progressSummary: "No output for 60s. It may be waiting for input.",
|
||||
} as const;
|
||||
|
||||
describe("tasks commands", () => {
|
||||
beforeEach(() => {
|
||||
vi.clearAllMocks();
|
||||
resetRuntimeCapture();
|
||||
reconcileInspectableTasksMock.mockReturnValue([]);
|
||||
reconcileTaskLookupTokenMock.mockReturnValue(undefined);
|
||||
listTaskAuditFindingsMock.mockReturnValue([]);
|
||||
summarizeTaskAuditFindingsMock.mockReturnValue({
|
||||
total: 0,
|
||||
warnings: 0,
|
||||
errors: 0,
|
||||
byCode: {
|
||||
stale_queued: 0,
|
||||
stale_running: 0,
|
||||
lost: 0,
|
||||
delivery_failed: 0,
|
||||
missing_cleanup: 0,
|
||||
inconsistent_timestamps: 0,
|
||||
},
|
||||
});
|
||||
previewTaskRegistryMaintenanceMock.mockReturnValue({
|
||||
reconciled: 0,
|
||||
cleanupStamped: 0,
|
||||
pruned: 0,
|
||||
});
|
||||
runTaskRegistryMaintenanceMock.mockReturnValue({
|
||||
reconciled: 0,
|
||||
cleanupStamped: 0,
|
||||
pruned: 0,
|
||||
});
|
||||
getInspectableTaskRegistrySummaryMock.mockReturnValue({
|
||||
total: 0,
|
||||
active: 0,
|
||||
terminal: 0,
|
||||
failures: 0,
|
||||
byStatus: {
|
||||
queued: 0,
|
||||
running: 0,
|
||||
succeeded: 0,
|
||||
failed: 0,
|
||||
timed_out: 0,
|
||||
cancelled: 0,
|
||||
lost: 0,
|
||||
},
|
||||
byRuntime: {
|
||||
subagent: 0,
|
||||
acp: 0,
|
||||
cli: 0,
|
||||
cron: 0,
|
||||
},
|
||||
});
|
||||
getInspectableTaskAuditSummaryMock.mockReturnValue({
|
||||
total: 0,
|
||||
warnings: 0,
|
||||
errors: 0,
|
||||
byCode: {
|
||||
stale_queued: 0,
|
||||
stale_running: 0,
|
||||
lost: 0,
|
||||
delivery_failed: 0,
|
||||
missing_cleanup: 0,
|
||||
inconsistent_timestamps: 0,
|
||||
},
|
||||
});
|
||||
updateTaskNotifyPolicyByIdMock.mockReturnValue(undefined);
|
||||
cancelTaskByIdMock.mockResolvedValue({ found: false, cancelled: false, reason: "missing" });
|
||||
getTaskByIdMock.mockReturnValue(undefined);
|
||||
});
|
||||
|
||||
it("lists task rows with progress summary fallback", async () => {
|
||||
reconcileInspectableTasksMock.mockReturnValue([taskFixture]);
|
||||
|
||||
await tasksListCommand({ runtime: "acp", status: "running" }, runtime);
|
||||
|
||||
expect(runtimeLogs[0]).toContain("Background tasks: 1");
|
||||
expect(runtimeLogs[1]).toContain("Task pressure: 0 queued · 1 running · 0 issues");
|
||||
expect(runtimeLogs.join("\n")).toContain("No output for 60s. It may be waiting for input.");
|
||||
});
|
||||
|
||||
it("shows detailed task fields including notify and recent events", async () => {
|
||||
reconcileTaskLookupTokenMock.mockReturnValue(taskFixture);
|
||||
|
||||
await tasksShowCommand({ lookup: "run-12345678" }, runtime);
|
||||
|
||||
expect(runtimeLogs.join("\n")).toContain("notify: state_changes");
|
||||
expect(runtimeLogs.join("\n")).toContain(
|
||||
"progressSummary: No output for 60s. It may be waiting for input.",
|
||||
);
|
||||
});
|
||||
|
||||
it("updates notify policy for an existing task", async () => {
|
||||
reconcileTaskLookupTokenMock.mockReturnValue(taskFixture);
|
||||
updateTaskNotifyPolicyByIdMock.mockReturnValue({
|
||||
...taskFixture,
|
||||
notifyPolicy: "silent",
|
||||
});
|
||||
|
||||
await tasksNotifyCommand({ lookup: "run-12345678", notify: "silent" }, runtime);
|
||||
|
||||
expect(updateTaskNotifyPolicyByIdMock).toHaveBeenCalledWith({
|
||||
taskId: "task-12345678",
|
||||
notifyPolicy: "silent",
|
||||
});
|
||||
expect(runtimeLogs[0]).toContain("Updated task-12345678 notify policy to silent.");
|
||||
});
|
||||
|
||||
it("cancels a running task and reports the updated runtime", async () => {
|
||||
reconcileTaskLookupTokenMock.mockReturnValue(taskFixture);
|
||||
cancelTaskByIdMock.mockResolvedValue({
|
||||
found: true,
|
||||
cancelled: true,
|
||||
task: {
|
||||
...taskFixture,
|
||||
status: "cancelled",
|
||||
},
|
||||
});
|
||||
getTaskByIdMock.mockReturnValue({
|
||||
...taskFixture,
|
||||
status: "cancelled",
|
||||
});
|
||||
|
||||
await tasksCancelCommand({ lookup: "run-12345678" }, runtime);
|
||||
|
||||
expect(loadConfigMock).toHaveBeenCalled();
|
||||
expect(cancelTaskByIdMock).toHaveBeenCalledWith({
|
||||
cfg: { loaded: true },
|
||||
taskId: "task-12345678",
|
||||
});
|
||||
expect(runtimeLogs[0]).toContain("Cancelled task-12345678 (acp) run run-12345678.");
|
||||
expect(runtimeErrors).toEqual([]);
|
||||
});
|
||||
|
||||
it("shows task audit findings with filters", async () => {
|
||||
const findings = [
|
||||
{
|
||||
severity: "error",
|
||||
code: "stale_running",
|
||||
task: taskFixture,
|
||||
ageMs: 45 * 60_000,
|
||||
detail: "running task appears stuck",
|
||||
},
|
||||
{
|
||||
severity: "warn",
|
||||
code: "delivery_failed",
|
||||
task: {
|
||||
...taskFixture,
|
||||
taskId: "task-87654321",
|
||||
status: "failed",
|
||||
},
|
||||
ageMs: 10 * 60_000,
|
||||
detail: "terminal update delivery failed",
|
||||
},
|
||||
];
|
||||
listTaskAuditFindingsMock.mockReturnValue(findings);
|
||||
summarizeTaskAuditFindingsMock.mockReturnValue({
|
||||
total: 2,
|
||||
warnings: 1,
|
||||
errors: 1,
|
||||
byCode: {
|
||||
stale_queued: 0,
|
||||
stale_running: 1,
|
||||
lost: 0,
|
||||
delivery_failed: 1,
|
||||
missing_cleanup: 0,
|
||||
inconsistent_timestamps: 0,
|
||||
},
|
||||
});
|
||||
|
||||
await tasksAuditCommand({ severity: "error", code: "stale_running", limit: 1 }, runtime);
|
||||
|
||||
expect(summarizeTaskAuditFindingsMock).toHaveBeenCalledWith(findings);
|
||||
expect(runtimeLogs[0]).toContain("Task audit: 2 findings · 1 errors · 1 warnings");
|
||||
expect(runtimeLogs[1]).toContain("Showing 1 matching findings.");
|
||||
expect(runtimeLogs.join("\n")).toContain("stale_running");
|
||||
expect(runtimeLogs.join("\n")).toContain("running task appears stuck");
|
||||
expect(runtimeLogs.join("\n")).not.toContain("delivery_failed");
|
||||
});
|
||||
|
||||
it("previews task maintenance without applying changes", async () => {
|
||||
previewTaskRegistryMaintenanceMock.mockReturnValue({
|
||||
reconciled: 2,
|
||||
cleanupStamped: 1,
|
||||
pruned: 3,
|
||||
});
|
||||
getInspectableTaskRegistrySummaryMock.mockReturnValue({
|
||||
total: 5,
|
||||
active: 2,
|
||||
terminal: 3,
|
||||
failures: 1,
|
||||
byStatus: {
|
||||
queued: 1,
|
||||
running: 1,
|
||||
succeeded: 1,
|
||||
failed: 1,
|
||||
timed_out: 0,
|
||||
cancelled: 0,
|
||||
lost: 1,
|
||||
},
|
||||
byRuntime: {
|
||||
subagent: 1,
|
||||
acp: 1,
|
||||
cli: 1,
|
||||
cron: 2,
|
||||
},
|
||||
});
|
||||
getInspectableTaskAuditSummaryMock.mockReturnValue({
|
||||
total: 2,
|
||||
warnings: 1,
|
||||
errors: 1,
|
||||
byCode: {
|
||||
stale_queued: 0,
|
||||
stale_running: 1,
|
||||
lost: 1,
|
||||
delivery_failed: 0,
|
||||
missing_cleanup: 0,
|
||||
inconsistent_timestamps: 0,
|
||||
},
|
||||
});
|
||||
|
||||
await tasksMaintenanceCommand({}, runtime);
|
||||
|
||||
expect(previewTaskRegistryMaintenanceMock).toHaveBeenCalled();
|
||||
expect(runTaskRegistryMaintenanceMock).not.toHaveBeenCalled();
|
||||
expect(runtimeLogs[0]).toContain(
|
||||
"Task maintenance (preview): 2 reconcile · 1 cleanup stamp · 3 prune",
|
||||
);
|
||||
expect(runtimeLogs[1]).toContain(
|
||||
"Task health: 1 queued · 1 running · 1 audit errors · 1 audit warnings",
|
||||
);
|
||||
expect(runtimeLogs[2]).toContain("Dry run only.");
|
||||
});
|
||||
|
||||
it("shows before and after audit health when applying maintenance", async () => {
|
||||
runTaskRegistryMaintenanceMock.mockReturnValue({
|
||||
reconciled: 2,
|
||||
cleanupStamped: 1,
|
||||
pruned: 3,
|
||||
});
|
||||
getInspectableTaskRegistrySummaryMock.mockReturnValue({
|
||||
total: 4,
|
||||
active: 2,
|
||||
terminal: 2,
|
||||
failures: 1,
|
||||
byStatus: {
|
||||
queued: 1,
|
||||
running: 1,
|
||||
succeeded: 1,
|
||||
failed: 0,
|
||||
timed_out: 0,
|
||||
cancelled: 0,
|
||||
lost: 1,
|
||||
},
|
||||
byRuntime: {
|
||||
subagent: 1,
|
||||
acp: 1,
|
||||
cli: 0,
|
||||
cron: 2,
|
||||
},
|
||||
});
|
||||
getInspectableTaskAuditSummaryMock
|
||||
.mockReturnValueOnce({
|
||||
total: 3,
|
||||
warnings: 2,
|
||||
errors: 1,
|
||||
byCode: {
|
||||
stale_queued: 0,
|
||||
stale_running: 1,
|
||||
lost: 1,
|
||||
delivery_failed: 0,
|
||||
missing_cleanup: 1,
|
||||
inconsistent_timestamps: 0,
|
||||
},
|
||||
})
|
||||
.mockReturnValueOnce({
|
||||
total: 1,
|
||||
warnings: 1,
|
||||
errors: 0,
|
||||
byCode: {
|
||||
stale_queued: 0,
|
||||
stale_running: 0,
|
||||
lost: 1,
|
||||
delivery_failed: 0,
|
||||
missing_cleanup: 0,
|
||||
inconsistent_timestamps: 0,
|
||||
},
|
||||
});
|
||||
|
||||
await tasksMaintenanceCommand({ apply: true }, runtime);
|
||||
|
||||
expect(previewTaskRegistryMaintenanceMock).not.toHaveBeenCalled();
|
||||
expect(runTaskRegistryMaintenanceMock).toHaveBeenCalled();
|
||||
expect(runtimeLogs[0]).toContain(
|
||||
"Task maintenance (applied): 2 reconcile · 1 cleanup stamp · 3 prune",
|
||||
);
|
||||
expect(runtimeLogs[1]).toContain(
|
||||
"Task health after apply: 1 queued · 1 running · 0 audit errors · 1 audit warnings",
|
||||
);
|
||||
expect(runtimeLogs[2]).toContain("Task health before apply: 1 audit errors · 2 audit warnings");
|
||||
});
|
||||
});
|
||||
Reference in New Issue
Block a user