Function find

tests/agent.test.ts:36–59

(provider, modelId)

  assert.deepEqual(model.headers, { "X-Existing": "kept" });
});

test("handleMessage forwards the final agent_end after an automatic retry", async () => {
  const rootDir = fs.mkdtempSync(path.join(os.tmpdir(), "skillpack-agent-"));
  const listeners = new Set<(event: { type: string }) => void>();
  const session = {
    _agentEventQueue: Promise.resolve(),
    state: { messages: [] },
    systemPrompt: "",
    subscribe(listener: (event: { type: string }) => void) {
      listeners.add(listener);
      return () => listeners.delete(listener);
    },
    async prompt() {
      for (const type of [
        "agent_start",
        "agent_end",
        "agent_start",
        "agent_end",
      ]) {
        for (const listener of listeners) {
          listener({ type });
        }
      }
    },
  };
  const channelSession = {
    session,