Function makeTestThread

packages/bot/src/thread.test.ts:9–31

(overrides: {
  state: MemoryStore;
  conversationKey?: string;
})

import { InMemoryActionStore } from "./action-store.js";

function makeTestThread(overrides: {
  state: MemoryStore;
  conversationKey?: string;
}): Thread {
  const adapter = new FakeAdapter();
  const registry = new ActionRegistry({ store: new InMemoryActionStore() });
  const deps: ThreadDeps = {
    adapter,
    replyTarget: {},
    conversationKey: overrides.conversationKey ?? "c1",
    registry,
    agentFactory: (id) => {
      throw new Error(`agentFactory not needed in this test: ${id}`);
    },
    tools: new Map(),
    toolDescriptors: [],
    context: [],
    registerWaiter: () => {},
    interruptHandlers: new Map(),
    state: overrides.state,
  };
  return new Thread(deps);
}

describe("Thread.subscribe / unsubscribe / isSubscribed", () => {
  it("subscribe marks the conversation as subscribed", async () => {