Function createBot

packages/bot/src/create-bot.ts:254–814

(opts: CreateBotOptions<TStateSchema>)

}

export function createBot<
  TStateSchema extends StandardSchemaV1 | undefined = undefined,
>(opts: CreateBotOptions<TStateSchema>): Bot<ThreadStateOf<TStateSchema>> {
  const cfg = opts.store ?? {};
  if (
    (cfg.identity && !cfg.transcripts) ||
    (!cfg.identity && cfg.transcripts)
  ) {
    throw new Error(
      "createBot: `identity` and `transcripts` must be configured together.",
    );
  }

  const backend: StateStore = cfg.adapter ?? new MemoryStore();
  const telemetry = new BotTelemetry({
    backend,
    packageName: pkg.name,
    packageVersion: pkg.version,
  });
  const transcripts = new Transcripts(backend, cfg.transcripts ?? {});
  const registry = new ActionRegistry({
    store: opts.actionStore ?? kvActionStore(backend),
  });

  for (const c of opts.components ?? []) {
    if (!c.name) {
      console.warn(
        "[bot] createBot: skipping anonymous component — give it a name to enable durable actions after restart.",
      );
      continue;
    }
    registry.registerComponent(c.name, c as unknown as ComponentFn);
  }

  const agentFactory: (threadId: string) => AbstractAgent = (() => {
    const a = opts.agent;
    if (typeof a === "function")
      return a as (threadId: string) => AbstractAgent;
    if (a) return () => a;
    return () => {
      throw new Error(
        "createBot: no agent configured (pass `agent` to use runAgent)",
      );
    };
  })();

  const toolMap = new Map<string, BotTool>();
  for (const t of opts.tools ?? []) toolMap.set(t.name, t);
  const context = opts.context ?? [];

  const mentionHandlers: BotHandler[] = [];
  const messageHandlers: BotHandler[] = [];
  const threadStartedHandlers: ThreadStartHandler[] = [];
  const interactionHandlers = new Map<
    string,
    (ctx: InteractionContext) => void | Promise<void>
  >();
  const interruptHandlers = new Map<