vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-03-12 07:20:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: Fix types in tests 40/N.

Browse Source
This commit is contained in:
cpojer
2026-02-17 15:48:06 +09:00
parent c4bd82d81d
commit 3dc8d5656d
13 changed files with 23 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/cron/isolated-agent.delivers-response-has-heartbeat-ok-but-includes.test.ts
View File

@@ -25,6 +25,7 @@ describe("runCronIsolatedAgentTurn", () => {
lastTo: "123",
});
const deps: CliDeps = {
sendMessageSlack: vi.fn(),
sendMessageWhatsApp: vi.fn(),
sendMessageTelegram: vi.fn().mockResolvedValue({
messageId: "t1",

1
src/cron/isolated-agent.skips-delivery-without-whatsapp-recipient-besteffortdeliver-true.e2e.test.ts
View File

@@ -15,6 +15,7 @@ import { setupIsolatedAgentTurnMocks } from "./isolated-agent.test-setup.js";
function createCliDeps(overrides: Partial<CliDeps> = {}): CliDeps {
return {
sendMessageSlack: vi.fn(),
sendMessageWhatsApp: vi.fn(),
sendMessageTelegram: vi.fn(),
sendMessageDiscord: vi.fn(),

1
src/cron/isolated-agent.uses-last-non-empty-agent-text-as.e2e.test.ts
View File

@@ -21,6 +21,7 @@ const withTempHome = withTempCronHome;
function makeDeps(): CliDeps {
return {
sendMessageSlack: vi.fn(),
sendMessageWhatsApp: vi.fn(),
sendMessageTelegram: vi.fn(),
sendMessageDiscord: vi.fn(),

14
src/cron/service.delivery-plan.test.ts
View File

@@ -2,7 +2,8 @@ import fs from "node:fs/promises";
import os from "node:os";
import path from "node:path";
import { describe, expect, it, vi } from "vitest";
import { CronService } from "./service.js";
import type { ChannelId } from "../channels/plugins/types.js";
import { CronService, type CronServiceDeps } from "./service.js";
const noopLogger = {
debug: vi.fn(),
@@ -25,13 +26,13 @@ type DeliveryMode = "none" | "announce";
type DeliveryOverride = {
mode: DeliveryMode;
channel?: string;
channel?: ChannelId | "last";
to?: string;
};
async function withCronService(
params: {
runIsolatedAgentJob?: () => Promise<{ status: "ok"; summary: string; delivered?: boolean }>;
runIsolatedAgentJob?: CronServiceDeps["runIsolatedAgentJob"];
},
run: (context: {
cron: CronService;
@@ -50,7 +51,7 @@ async function withCronService(
requestHeartbeatNow,
runIsolatedAgentJob:
params.runIsolatedAgentJob ??
(vi.fn(async () => ({ status: "ok", summary: "done" })) as never),
(vi.fn(async () => ({ status: "ok" as const, summary: "done" })) as never),
});
await cron.start();
@@ -73,6 +74,7 @@ async function addIsolatedAgentTurnJob(
) {
return cron.add({
name: params.name,
enabled: true,
schedule: { kind: "every", everyMs: 60_000, anchorMs: Date.now() },
sessionTarget: "isolated",
wakeMode: params.wakeMode,
@@ -80,7 +82,7 @@ async function addIsolatedAgentTurnJob(
kind: "agentTurn",
message: "hello",
...params.payload,
},
} as unknown as { kind: "agentTurn"; message: string },
...(params.delivery
? {
delivery: params.delivery as unknown as {
@@ -129,7 +131,7 @@ describe("CronService delivery plan consistency", () => {
await withCronService(
{
runIsolatedAgentJob: vi.fn(async () => ({
status: "ok",
status: "ok" as const,
summary: "done",
delivered: true,
})),

2
src/cron/service.every-jobs-fire.test.ts
View File

@@ -147,7 +147,7 @@ describe("CronService interval/cron jobs fire on time", () => {
log: noopLogger,
enqueueSystemEvent,
requestHeartbeatNow,
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" })),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" as const })),
});
await cron.start();

2
src/cron/service.get-job.test.ts
View File

@@ -17,7 +17,7 @@ function createCronService(storePath: string) {
log: logger,
enqueueSystemEvent: vi.fn(),
requestHeartbeatNow: vi.fn(),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" })),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" as const })),
});
}

2
src/cron/service.issue-16156-list-skips-cron.test.ts
View File

@@ -34,7 +34,7 @@ function createCronFromStorePath(storePath: string) {
log: noopLogger,
enqueueSystemEvent: vi.fn(),
requestHeartbeatNow: vi.fn(),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" })),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" as const })),
});
}

2
src/cron/service.prevents-duplicate-timers.test.ts
View File

@@ -18,7 +18,7 @@ describe("CronService", () => {
const store = await makeStorePath();
const enqueueSystemEvent = vi.fn();
const requestHeartbeatNow = vi.fn();
const runIsolatedAgentJob = vi.fn(async () => ({ status: "ok" }));
const runIsolatedAgentJob = vi.fn(async () => ({ status: "ok" as const }));
const cronA = new CronService({
storePath: store.storePath,

6
src/cron/service.restart-catchup.test.ts
View File

@@ -30,9 +30,9 @@ describe("CronService restart catch-up", () => {
storePath: params.storePath,
cronEnabled: true,
log: noopLogger,
enqueueSystemEvent: params.enqueueSystemEvent,
requestHeartbeatNow: params.requestHeartbeatNow,
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" })),
enqueueSystemEvent: params.enqueueSystemEvent as never,
requestHeartbeatNow: params.requestHeartbeatNow as never,
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" as const })) as never,
});
}

4
src/cron/service.runs-one-shot-main-job-disables-it.test.ts
View File

@@ -394,7 +394,7 @@ async function loadLegacyDeliveryMigration(rawJob: Record<string, unknown>) {
log: noopLogger,
enqueueSystemEvent: vi.fn(),
requestHeartbeatNow: vi.fn(),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" })),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" as const })),
});
await cron.start();
const jobs = await cron.list({ includeDisabled: true });
@@ -506,7 +506,7 @@ describe("CronService", () => {
expect(job.state.runningAtMs).toBeTypeOf("number");
if (typeof resolveHeartbeat === "function") {
resolveHeartbeat({ status: "ran", durationMs: 123 });
(resolveHeartbeat as (res: HeartbeatRunResult) => void)({ status: "ran", durationMs: 123 });
}
await runPromise;

2
src/cron/service.skips-main-jobs-empty-systemevent-text.test.ts
View File

@@ -39,7 +39,7 @@ async function withCronService(
log: noopLogger,
enqueueSystemEvent,
requestHeartbeatNow,
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" })),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" as const })),
});
await cron.start();

2
src/cron/service.store-migration.test.ts
View File

@@ -58,7 +58,7 @@ describe("CronService store migrations", () => {
log: noopLogger,
enqueueSystemEvent: vi.fn(),
requestHeartbeatNow: vi.fn(),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok", summary: "ok" })),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" as const, summary: "ok" })),
});
await cron.start();

2
src/cron/service.store.migration.test.ts
View File

@@ -30,7 +30,7 @@ async function migrateAndLoadFirstJob(storePath: string): Promise<Record<string,
log: noopLogger,
enqueueSystemEvent: vi.fn(),
requestHeartbeatNow: vi.fn(),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" })),
runIsolatedAgentJob: vi.fn(async () => ({ status: "ok" as const })),
});
await cron.start();