pluginName: "google-calendar",

});

expect(config.diagnostics).toEqual([]);

expect(request.mock.calls.filter(([method]) => method === "app/list")).toHaveLength(1);

expect(

request.mock.calls.reduce((count, [method]) => count + (method === "app/list" ? 1 : 0), 0),

).toBe(1);

});

it("does not expose plugin apps missing from the app inventory snapshot", async () => {

},

} as OpenClawConfig;

function countMatching<T>(items: readonly T[], predicate: (item: T) => boolean) {

let count = 0;

for (const item of items) {

if (predicate(item)) {

count += 1;

}

}

return count;

}

const resolveSessionConversationStub: NonNullable<

ChannelMessagingAdapter["resolveSessionConversation"]

> = ({ rawId }) => ({

sessionKey: targetKey,

});

await new Promise((resolve) => setTimeout(resolve, 0));

expect(calls.filter((call) => call.method === "agent")).toHaveLength(1);

expect(countMatching(calls, (call) => call.method === "agent")).toBe(1);

});

it("sessions_send skips duplicate A2A delivery for waited parent-owned native subagents", async () => {

reply: "child reply",

delivery: { status: "skipped", mode: "announce" },

});

expect(calls.filter((call) => call.method === "agent")).toHaveLength(1);

expect(countMatching(calls, (call) => call.method === "agent")).toBe(1);

const replyPromptAgentCalls = calls.filter(

(call) =>

call.method === "agent" &&

});

await vi.waitFor(

() => {

expect(calls.filter((call) => call.method === "send")).toHaveLength(1);

expect(countMatching(calls, (call) => call.method === "send")).toBe(1);

},

{ timeout: 2_000, interval: 5 },

);