Function main

apps/web/server/create-codex-thread.ts:48–113

()

}

async function main() {
  const raw = await readStdin();
  const payload = JSON.parse(raw || '{}') as InputPayload;
  const cwd = normalizeText(payload.cwd);
  const model = normalizeText(payload.model);
  const permissionsMode = normalizePermissionsMode(payload.permissionsMode);
  const reasoningEffort = normalizeText(payload.reasoningEffort);
  const stateDir = normalizeText(payload.stateDir);
  const repoRoot = normalizeText(payload.repoRoot);

  if (!stateDir || !repoRoot) {
    throw new Error('invalid_request');
  }
  const targetCwd = cwd || repoRoot;

  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'),
    }),
  });

  const providerProfileId = resolveNativeProviderProfileId(runtime);
  const initialSettings = {
    ...(permissionsMode ? buildPermissionsSettingsUpdate(permissionsMode) : {}),
    ...(model ? { model } : {}),
    ...(reasoningEffort ? { reasoningEffort } : {}),
  };
  const session = await runtime.services.bridgeSessions.createDetachedSession({
    providerProfileId,
    cwd: targetCwd,
    initialSettings,
    title: null,
  });

  await Promise.allSettled(
    runtime.registry.listProviders<any>().map((plugin) => plugin?.stop?.()),
  );