Function executeWebThreadReply

apps/web/server/reply-executor.ts:96–244

({
  onApprovalRequest = null,
  onAssistantText = null,
  onCommentaryText = null,
  onTurnStarted = null,
  repoRoot,
  stateDir,
  text,
  threadId,
}: {
  onApprovalRequest?: ((request: { requestId?: string | null }) => Promise<void> | void) | null;
  onAssistantText?: ((text: string) => Promise<void> | void) | null;
  onCommentaryText?: ((text: string) => Promise<void> | void) | null;
  onTurnStarted?: ((meta: {
    bridgeSessionId: string;
    providerProfileId: string;
    threadId: string | null;
    turnId: string | null;
  }) => Promise<void> | void) | null;
  repoRoot: string;
  stateDir: string;
  text: string;
  threadId: string;
})

}

export async function executeWebThreadReply({
  onApprovalRequest = null,
  onAssistantText = null,
  onCommentaryText = null,
  onTurnStarted = null,
  repoRoot,
  stateDir,
  text,
  threadId,
}: {
  onApprovalRequest?: ((request: { requestId?: string | null }) => Promise<void> | void) | null;
  onAssistantText?: ((text: string) => Promise<void> | void) | null;
  onCommentaryText?: ((text: string) => Promise<void> | void) | null;
  onTurnStarted?: ((meta: {
    bridgeSessionId: string;
    providerProfileId: string;
    threadId: string | null;
    turnId: string | null;
  }) => Promise<void> | void) | null;
  repoRoot: string;
  stateDir: string;
  text: string;
  threadId: string;
}): Promise<WebReplyExecutionResult> {
  const runtimeDir = path.join(stateDir, 'runtime');
  const repositories = createFileJsonRepositories(runtimeDir);
  const providerProfiles = repositories.providerProfiles.list();
  const defaultProviderProfileId = providerProfiles.some((profile) => profile.id === 'openai-default')
    ? 'openai-default'
    : (providerProfiles[0]?.id ?? null);

  const runtime = createCodexBridgeRuntime({
    providerPlugins: [
      new OpenAINativeProviderPlugin(),
      new OpenAICompatibleProviderPlugin(),
    ],
    providerProfiles,
    defaultProviderProfileId,
    defaultCwd: process.env.CODEXBRIDGE_DEFAULT_CWD ?? repoRoot,
    locale: 'zh-CN',
    repositories,
    assistantAttachmentRoot: path.join(stateDir, 'assistant', 'attachments'),
    codexAuthManager: new CodexAccountManager({
      rootDir: path.join(stateDir, 'runtime', 'codex-login'),
    }),
    codexGoalManager: new CodexGoalManager({
      filePath: path.join(stateDir, 'runtime', 'codex-goal.txt'),
    }),
  });

  try {
    const providerProfileId = inferNativeProviderProfileId(runtime, threadId);
    const scopeRef = {
      platform: 'web',
      externalScopeId: `codex-thread:${threadId}`,
    };
    const session = await runtime.services.bridgeSessions.bindScopeToProviderThread(
      scopeRef,