test: collapse duplicate trigger command coverage

This commit is contained in:
Peter Steinberger
2026-02-23 17:37:03 +00:00
parent 6a0fcf6518
commit ddc67aa4ef
2 changed files with 36 additions and 59 deletions

View File

@@ -85,6 +85,7 @@ async function expectStopAbortWithoutAgent(params: { home: string; body: string;
describe("trigger handling", () => { describe("trigger handling", () => {
it("filters usage summary to the current model provider", async () => { it("filters usage summary to the current model provider", async () => {
await withTempHome(async (home) => { await withTempHome(async (home) => {
const runEmbeddedPiAgentMock = getRunEmbeddedPiAgentMock();
usageMocks.loadProviderUsageSummary.mockClear(); usageMocks.loadProviderUsageSummary.mockClear();
usageMocks.loadProviderUsageSummary.mockResolvedValue({ usageMocks.loadProviderUsageSummary.mockResolvedValue({
updatedAt: 0, updatedAt: 0,
@@ -116,24 +117,12 @@ describe("trigger handling", () => {
); );
const text = Array.isArray(res) ? res[0]?.text : res?.text; const text = Array.isArray(res) ? res[0]?.text : res?.text;
expect(text).toContain("Model:");
expect(text).toContain("OpenClaw");
expect(normalizeTestText(text ?? "")).toContain("Usage: Claude 80% left"); expect(normalizeTestText(text ?? "")).toContain("Usage: Claude 80% left");
expect(usageMocks.loadProviderUsageSummary).toHaveBeenCalledWith( expect(usageMocks.loadProviderUsageSummary).toHaveBeenCalledWith(
expect.objectContaining({ providers: ["anthropic"] }), expect.objectContaining({ providers: ["anthropic"] }),
); );
});
});
it("reports /status once without invoking the agent", async () => {
await withTempHome(async (home) => {
const runEmbeddedPiAgentMock = getRunEmbeddedPiAgentMock();
const { blockReplies, replies } = await runCommandAndCollectReplies({
home,
body: "/status",
});
expect(blockReplies.length).toBe(0);
expect(replies.length).toBe(1);
const text = String(replies[0]?.text ?? "");
expect(text).toContain("Model:");
expect(text).toContain("OpenClaw");
expect(runEmbeddedPiAgentMock).not.toHaveBeenCalled(); expect(runEmbeddedPiAgentMock).not.toHaveBeenCalled();
}); });
}); });
@@ -150,10 +139,28 @@ describe("trigger handling", () => {
}); });
}); });
it("cycles /usage modes and persists to the session store", async () => { it("handles /usage back-compat and cycles modes, persisting to the session store", async () => {
await withTempHome(async (home) => { await withTempHome(async (home) => {
const cfg = makeCfg(home); const cfg = makeCfg(home);
const r0 = await getReplyFromConfig(
{
Body: "/usage on",
From: "+1000",
To: "+2000",
Provider: "whatsapp",
SenderE164: "+1000",
CommandAuthorized: true,
},
undefined,
cfg,
);
expect(String((Array.isArray(r0) ? r0[0]?.text : r0?.text) ?? "")).toContain(
"Usage footer: tokens",
);
const s0 = await readSessionStore(home);
expect(pickFirstStoreEntry<{ responseUsage?: string }>(s0)?.responseUsage).toBe("tokens");
const r1 = await getReplyFromConfig( const r1 = await getReplyFromConfig(
{ {
Body: "/usage", Body: "/usage",
@@ -167,10 +174,10 @@ describe("trigger handling", () => {
cfg, cfg,
); );
expect(String((Array.isArray(r1) ? r1[0]?.text : r1?.text) ?? "")).toContain( expect(String((Array.isArray(r1) ? r1[0]?.text : r1?.text) ?? "")).toContain(
"Usage footer: tokens", "Usage footer: full",
); );
const s1 = await readSessionStore(home); const s1 = await readSessionStore(home);
expect(pickFirstStoreEntry<{ responseUsage?: string }>(s1)?.responseUsage).toBe("tokens"); expect(pickFirstStoreEntry<{ responseUsage?: string }>(s1)?.responseUsage).toBe("full");
const r2 = await getReplyFromConfig( const r2 = await getReplyFromConfig(
{ {
@@ -185,10 +192,10 @@ describe("trigger handling", () => {
cfg, cfg,
); );
expect(String((Array.isArray(r2) ? r2[0]?.text : r2?.text) ?? "")).toContain( expect(String((Array.isArray(r2) ? r2[0]?.text : r2?.text) ?? "")).toContain(
"Usage footer: full", "Usage footer: off",
); );
const s2 = await readSessionStore(home); const s2 = await readSessionStore(home);
expect(pickFirstStoreEntry<{ responseUsage?: string }>(s2)?.responseUsage).toBe("full"); expect(pickFirstStoreEntry<{ responseUsage?: string }>(s2)?.responseUsage).toBeUndefined();
const r3 = await getReplyFromConfig( const r3 = await getReplyFromConfig(
{ {
@@ -203,36 +210,10 @@ describe("trigger handling", () => {
cfg, cfg,
); );
expect(String((Array.isArray(r3) ? r3[0]?.text : r3?.text) ?? "")).toContain( expect(String((Array.isArray(r3) ? r3[0]?.text : r3?.text) ?? "")).toContain(
"Usage footer: off", "Usage footer: tokens",
); );
const s3 = await readSessionStore(home); const s3 = await readSessionStore(home);
expect(pickFirstStoreEntry<{ responseUsage?: string }>(s3)?.responseUsage).toBeUndefined(); expect(pickFirstStoreEntry<{ responseUsage?: string }>(s3)?.responseUsage).toBe("tokens");
expect(getRunEmbeddedPiAgentMock()).not.toHaveBeenCalled();
});
});
it("treats /usage on as tokens (back-compat)", async () => {
await withTempHome(async (home) => {
const cfg = makeCfg(home);
const res = await getReplyFromConfig(
{
Body: "/usage on",
From: "+1000",
To: "+2000",
Provider: "whatsapp",
SenderE164: "+1000",
CommandAuthorized: true,
},
undefined,
cfg,
);
const replies = res ? (Array.isArray(res) ? res : [res]) : [];
expect(replies.length).toBe(1);
expect(String(replies[0]?.text ?? "")).toContain("Usage footer: tokens");
const store = await readSessionStore(home);
expect(pickFirstStoreEntry<{ responseUsage?: string }>(store)?.responseUsage).toBe("tokens");
expect(getRunEmbeddedPiAgentMock()).not.toHaveBeenCalled(); expect(getRunEmbeddedPiAgentMock()).not.toHaveBeenCalled();
}); });

View File

@@ -263,7 +263,7 @@ describe("trigger handling", () => {
}); });
}); });
it("enforces top-level command auth but keeps inline text for unauthorized senders", async () => { it("enforces top-level command auth, keeps inline text, and handles direct /help", async () => {
await withTempHome(async (home) => { await withTempHome(async (home) => {
for (const command of ["/status", "/whoami"] as const) { for (const command of ["/status", "/whoami"] as const) {
await expectUnauthorizedCommandDropped(home, command); await expectUnauthorizedCommandDropped(home, command);
@@ -280,13 +280,9 @@ describe("trigger handling", () => {
const prompt = runEmbeddedPiAgentMock.mock.calls.at(-1)?.[0]?.prompt ?? ""; const prompt = runEmbeddedPiAgentMock.mock.calls.at(-1)?.[0]?.prompt ?? "";
expect(prompt).toContain(command); expect(prompt).toContain(command);
} }
});
});
it("returns help without invoking the agent", async () => {
await withTempHome(async (home) => {
const runEmbeddedPiAgentMock = getRunEmbeddedPiAgentMock(); const runEmbeddedPiAgentMock = getRunEmbeddedPiAgentMock();
const res = await getReplyFromConfig( const callsBeforeHelp = runEmbeddedPiAgentMock.mock.calls.length;
const helpRes = await getReplyFromConfig(
{ {
Body: "/help", Body: "/help",
From: "+1002", From: "+1002",
@@ -296,11 +292,11 @@ describe("trigger handling", () => {
{}, {},
makeCfg(home), makeCfg(home),
); );
const text = Array.isArray(res) ? res[0]?.text : res?.text; const helpText = Array.isArray(helpRes) ? helpRes[0]?.text : helpRes?.text;
expect(text).toContain("Help"); expect(helpText).toContain("Help");
expect(text).toContain("Session"); expect(helpText).toContain("Session");
expect(text).toContain("More: /commands for full list"); expect(helpText).toContain("More: /commands for full list");
expect(runEmbeddedPiAgentMock).not.toHaveBeenCalled(); expect(runEmbeddedPiAgentMock.mock.calls.length).toBe(callsBeforeHelp);
}); });
}); });