Function runCodexNativeApiServe

src/cli.ts:399–497

(args: string[])

}

async function runCodexNativeApiServe(args: string[]) {
  const i18n = createI18n();
  const options = parseCodexNativeApiServeArgs(args);
  const stateDir = path.resolve(options.stateDir ?? defaultCodexBridgeStateDir());
  const defaultCwd = path.resolve(options.cwd ?? process.env.CODEXBRIDGE_DEFAULT_CWD ?? process.cwd());
  const serveLock = await acquireServeLock(path.join(stateDir, 'runtime', 'codex-native-api-serve.lock'));
  const repositories = createFileJsonRepositories(path.join(stateDir, 'runtime'));
  const codexProfiles = loadCodexProfilesFromEnv();
  const codexAuthManager = createWeixinServeCodexAuthManager(stateDir);
  const runtime = createCodexBridgeRuntime({
    providerPlugins: [
      new OpenAINativeProviderPlugin(),
      new OpenAICompatibleProviderPlugin(),
    ],
    providerProfiles: codexProfiles.profiles,
    defaultProviderProfileId: codexProfiles.defaultProviderProfileId,
    defaultCwd,
    locale: i18n.locale,
    repositories,
    assistantAttachmentRoot: path.join(stateDir, 'assistant', 'attachments'),
    codexAuthManager,
    codexGoalManager: createWeixinServeCodexGoalManager(stateDir),
  });
  const host = options.host
    ?? normalizeCliString(process.env.CODEX_NATIVE_API_HOST)
    ?? DEFAULT_CODEX_NATIVE_API_HOST;
  const port = options.port
    ?? parseOptionalNonNegativeInt(process.env.CODEX_NATIVE_API_PORT)
    ?? DEFAULT_CODEX_NATIVE_API_PORT;
  const providerProfileId = options.providerProfileId
    ?? normalizeCliString(process.env.CODEX_NATIVE_API_PROVIDER_PROFILE_ID)
    ?? null;
  const authToken = normalizeCliString(process.env.CODEX_NATIVE_API_AUTH_TOKEN);
  const defaultModel = normalizeCliString(process.env.CODEX_NATIVE_API_DEFAULT_MODEL);
  const requestTitlePrefix = normalizeCliString(process.env.CODEX_NATIVE_API_TITLE_PREFIX);
  const nativeApi = new CodexNativeApiService({
    providerProfiles: runtime.repositories.providerProfiles,
    providerRegistry: runtime.registry,
    defaultProviderProfileId: runtime.config.defaultProviderProfileId,
    providerProfileId,
    authPath: codexAuthManager.authPath,
    env: process.env,
    host,
    port,
    authToken,
    defaultModel,
    defaultCwd,
    defaultLocale: i18n.locale,
    requestTitlePrefix,
  });

  process.once('exit', () => {
    serveLock.releaseSync();
  });

  let stopped = false;
  let resolveStopped: (() => void) | null = null;
  const stoppedPromise = new Promise<void>((resolve) => {