From 5657300a32428620d5c1aabeb6d8d681d09e8d85 Mon Sep 17 00:00:00 2001 From: Peter Steinberger Date: Tue, 26 May 2026 00:27:16 +0100 Subject: [PATCH] fix: clean up embedded agent ci drift --- package.json | 44 +++++++++++++++++++ ...ent-subscribe.handlers.tools.media.test.ts | 2 +- ...sion.subscribeembeddedagentsession.test.ts | 2 +- src/agents/subagent-announce-delivery.test.ts | 24 +++++----- test/scripts/test-projects.test.ts | 4 +- 5 files changed, 60 insertions(+), 16 deletions(-) diff --git a/package.json b/package.json index 6c1e3692487..b5284c1da7b 100644 --- a/package.json +++ b/package.json @@ -1355,6 +1355,50 @@ "types": "./dist/plugin-sdk/zod.d.ts", "default": "./dist/plugin-sdk/zod.js" }, + "./plugin-sdk/agent-core": { + "types": "./dist/plugin-sdk/agent-core.d.ts", + "default": "./dist/plugin-sdk/agent-core.js" + }, + "./plugin-sdk/agent-sessions": { + "types": "./dist/plugin-sdk/agent-sessions.d.ts", + "default": "./dist/plugin-sdk/agent-sessions.js" + }, + "./plugin-sdk/llm": { + "types": "./dist/plugin-sdk/llm.d.ts", + "default": "./dist/plugin-sdk/llm.js" + }, + "./plugin-sdk/llm-anthropic": { + "types": "./dist/plugin-sdk/llm-anthropic.d.ts", + "default": "./dist/plugin-sdk/llm-anthropic.js" + }, + "./plugin-sdk/llm-bedrock": { + "types": "./dist/plugin-sdk/llm-bedrock.d.ts", + "default": "./dist/plugin-sdk/llm-bedrock.js" + }, + "./plugin-sdk/llm-google-shared": { + "types": "./dist/plugin-sdk/llm-google-shared.d.ts", + "default": "./dist/plugin-sdk/llm-google-shared.js" + }, + "./plugin-sdk/llm-provider-runtime": { + "types": "./dist/plugin-sdk/llm-provider-runtime.d.ts", + "default": "./dist/plugin-sdk/llm-provider-runtime.js" + }, + "./plugin-sdk/llm-oauth": { + "types": "./dist/plugin-sdk/llm-oauth.d.ts", + "default": "./dist/plugin-sdk/llm-oauth.js" + }, + "./plugin-sdk/llm-openai-codex-responses": { + "types": "./dist/plugin-sdk/llm-openai-codex-responses.d.ts", + "default": "./dist/plugin-sdk/llm-openai-codex-responses.js" + }, + "./plugin-sdk/llm-openai-completions": { + "types": "./dist/plugin-sdk/llm-openai-completions.d.ts", + "default": "./dist/plugin-sdk/llm-openai-completions.js" + }, + "./plugin-sdk/llm-openai-responses": { + "types": "./dist/plugin-sdk/llm-openai-responses.d.ts", + "default": "./dist/plugin-sdk/llm-openai-responses.js" + }, "./extension-api": "./dist/extensionAPI.js", "./cli-entry": "./openclaw.mjs" }, diff --git a/src/agents/embedded-agent-subscribe.handlers.tools.media.test.ts b/src/agents/embedded-agent-subscribe.handlers.tools.media.test.ts index 8e27f09b873..3b3cc7c182c 100644 --- a/src/agents/embedded-agent-subscribe.handlers.tools.media.test.ts +++ b/src/agents/embedded-agent-subscribe.handlers.tools.media.test.ts @@ -43,7 +43,7 @@ function createMockContext(overrides?: { }, log: { debug: vi.fn(), info: vi.fn(), warn: vi.fn() }, builtinToolNames: overrides?.builtinToolNames, - trustedLocalMediaToolNames: overrides?.trustedLocalMediaToolNames, + trustedLocalMediaToolNames: overrides?.trustedLocalMediaToolNames ?? overrides?.builtinToolNames, shouldEmitToolResult: vi.fn(() => false), shouldEmitToolOutput: vi.fn(() => overrides?.shouldEmitToolOutput ?? false), emitToolSummary: vi.fn(), diff --git a/src/agents/embedded-agent-subscribe.subscribe-embedded-agent-session.subscribeembeddedagentsession.test.ts b/src/agents/embedded-agent-subscribe.subscribe-embedded-agent-session.subscribeembeddedagentsession.test.ts index 8094bd276ea..fe8834667a5 100644 --- a/src/agents/embedded-agent-subscribe.subscribe-embedded-agent-session.subscribeembeddedagentsession.test.ts +++ b/src/agents/embedded-agent-subscribe.subscribe-embedded-agent-session.subscribeembeddedagentsession.test.ts @@ -1169,7 +1169,7 @@ describe("subscribeEmbeddedAgentSession", () => { it("notifies the runner once when a heartbeat response tool result is recorded", async () => { const { session, emit } = createStubSessionHarness(); const onHeartbeatToolResponse = vi.fn(); - const subscription = subscribeEmbeddedPiSession({ + const subscription = subscribeEmbeddedAgentSession({ session, runId: "run-heartbeat-terminal", sessionKey: "agent:main:main", diff --git a/src/agents/subagent-announce-delivery.test.ts b/src/agents/subagent-announce-delivery.test.ts index 5d870c55842..f11751baf90 100644 --- a/src/agents/subagent-announce-delivery.test.ts +++ b/src/agents/subagent-announce-delivery.test.ts @@ -2575,7 +2575,7 @@ describe("deliverSubagentAnnouncement completion delivery", () => { ], }, }); - const queueEmbeddedPiMessageWithOutcome = createQueueOutcomeSequenceMock([ + const queueEmbeddedAgentMessageWithOutcome = createQueueOutcomeSequenceMock([ "transcript_commit_wait_unsupported", "no_active_run", ]); @@ -2583,7 +2583,7 @@ describe("deliverSubagentAnnouncement completion delivery", () => { const result = await deliverSlackChannelAnnouncement({ callGateway, sendMessage, - queueEmbeddedPiMessageWithOutcome, + queueEmbeddedAgentMessageWithOutcome, sessionId: "requester-session-channel", isActive: true, expectsCompletionMessage: true, @@ -2612,7 +2612,7 @@ describe("deliverSubagentAnnouncement completion delivery", () => { delivered: true, path: "direct", }); - expect(queueEmbeddedPiMessageWithOutcome).toHaveBeenCalledTimes(2); + expect(queueEmbeddedAgentMessageWithOutcome).toHaveBeenCalledTimes(2); expect(callGateway).toHaveBeenCalledTimes(1); expect(sendMessage).toHaveBeenCalledWith( expect.objectContaining({ @@ -2629,11 +2629,11 @@ describe("deliverSubagentAnnouncement completion delivery", () => { it("directly delivers stale isolated cron run media completions", async () => { const callGateway = createGatewayMock(); const sendMessage = createSendMessageMock(); - const queueEmbeddedPiMessageWithOutcome = createQueueOutcomeMock(true); + const queueEmbeddedAgentMessageWithOutcome = createQueueOutcomeMock(true); const result = await deliverSlackChannelAnnouncement({ callGateway, sendMessage, - queueEmbeddedPiMessageWithOutcome, + queueEmbeddedAgentMessageWithOutcome, sessionId: "stale-cron-run-session", isActive: false, requesterSessionKey: "agent:main:cron:daily-media:run:run-123", @@ -2661,7 +2661,7 @@ describe("deliverSubagentAnnouncement completion delivery", () => { delivered: true, path: "direct", }); - expect(queueEmbeddedPiMessageWithOutcome).not.toHaveBeenCalled(); + expect(queueEmbeddedAgentMessageWithOutcome).not.toHaveBeenCalled(); expect(callGateway).not.toHaveBeenCalled(); expect(sendMessage).toHaveBeenCalledWith( expect.objectContaining({ @@ -2678,11 +2678,11 @@ describe("deliverSubagentAnnouncement completion delivery", () => { it("no-ops stale isolated cron run text completions", async () => { const callGateway = createGatewayMock(); const sendMessage = createSendMessageMock(); - const queueEmbeddedPiMessageWithOutcome = createQueueOutcomeMock(true); + const queueEmbeddedAgentMessageWithOutcome = createQueueOutcomeMock(true); const result = await deliverSlackChannelAnnouncement({ callGateway, sendMessage, - queueEmbeddedPiMessageWithOutcome, + queueEmbeddedAgentMessageWithOutcome, sessionId: "stale-cron-run-session", isActive: false, requesterSessionKey: "agent:main:cron:daily-text:run:run-123", @@ -2696,7 +2696,7 @@ describe("deliverSubagentAnnouncement completion delivery", () => { path: "none", phases: [{ phase: "direct-primary", delivered: true, path: "none", error: undefined }], }); - expect(queueEmbeddedPiMessageWithOutcome).not.toHaveBeenCalled(); + expect(queueEmbeddedAgentMessageWithOutcome).not.toHaveBeenCalled(); expect(callGateway).not.toHaveBeenCalled(); expect(sendMessage).not.toHaveBeenCalled(); }); @@ -2708,11 +2708,11 @@ describe("deliverSubagentAnnouncement completion delivery", () => { }, }); const sendMessage = createSendMessageMock(); - const queueEmbeddedPiMessageWithOutcome = createQueueOutcomeMock(true); + const queueEmbeddedAgentMessageWithOutcome = createQueueOutcomeMock(true); const result = await deliverSlackChannelAnnouncement({ callGateway, sendMessage, - queueEmbeddedPiMessageWithOutcome, + queueEmbeddedAgentMessageWithOutcome, sessionId: "stale-cron-run-session", isActive: false, requesterSessionKey: "agent:main:cron:daily-media:run:run-123", @@ -2739,7 +2739,7 @@ describe("deliverSubagentAnnouncement completion delivery", () => { delivered: true, path: "direct", }); - expect(queueEmbeddedPiMessageWithOutcome).not.toHaveBeenCalled(); + expect(queueEmbeddedAgentMessageWithOutcome).not.toHaveBeenCalled(); expectGatewayAgentParams(callGateway, { deliver: true, channel: "slack", diff --git a/test/scripts/test-projects.test.ts b/test/scripts/test-projects.test.ts index c89017ad354..8037219ff81 100644 --- a/test/scripts/test-projects.test.ts +++ b/test/scripts/test-projects.test.ts @@ -375,7 +375,7 @@ describe("scripts/test-projects changed-target routing", () => { findUnmatchedExplicitTestTargets( [ "test/vitest/vitest.agents-core.config.ts", - "test/vitest/vitest.agents-pi-embedded.config.ts", + "test/vitest/vitest.agents-embedded-agent.config.ts", "test/vitest/vitest.agents-support.config.ts", "test/vitest/vitest.agents-tools.config.ts", ], @@ -1051,7 +1051,7 @@ describe("scripts/test-projects changed-target routing", () => { it.each([ "test/vitest/vitest.agents-core.config.ts", - "test/vitest/vitest.agents-pi-embedded.config.ts", + "test/vitest/vitest.agents-embedded-agent.config.ts", "test/vitest/vitest.agents-support.config.ts", "test/vitest/vitest.agents-tools.config.ts", ])("routes split agents vitest config %s to itself", (target) => {