Function runCodexCleanupInternalThreads

src/cli.ts:317–397

(args: string[])

}

async function runCodexCleanupInternalThreads(args: string[]) {
  const i18n = createI18n();
  const options = parseCodexCleanupInternalThreadsArgs(args);
  const stateDir = path.resolve(options.stateDir ?? defaultCodexBridgeStateDir());
  const defaultCwd = path.resolve(options.cwd ?? process.env.CODEXBRIDGE_DEFAULT_CWD ?? process.cwd());
  const repositories = createFileJsonRepositories(path.join(stateDir, 'runtime'));
  const codexProfiles = loadCodexProfilesFromEnv();
  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: createWeixinServeCodexAuthManager(stateDir),
    codexGoalManager: createWeixinServeCodexGoalManager(stateDir),
  });

  process.stdout.write(`${i18n.t('cli.cleanupInternalThreads.starting')}\n`);
  process.stdout.write(`mode: ${options.dryRun ? 'dry-run' : 'apply'}\n`);
  process.stdout.write(`state_dir: ${stateDir}\n`);
  process.stdout.write(`default_cwd: ${defaultCwd}\n`);
  process.stdout.write(`limit: ${options.limit}\n`);

  try {
    const reports = await runtime.services.bridgeCoordinator.cleanupInternalProviderThreads({
      dryRun: options.dryRun,
      limit: options.limit,
    });
    let totalScanned = 0;
    let totalMatched = 0;
    let totalArchived = 0;
    let totalFailed = 0;

    for (const report of reports) {
      const failed = Array.isArray(report.failed) ? report.failed : [];
      const matches = Array.isArray(report.matches) ? report.matches : [];
      totalScanned += Number(report.scanned ?? 0);
      totalMatched += Number(report.matched ?? 0);
      totalArchived += Number(report.archived ?? 0);
      totalFailed += failed.length;
      process.stdout.write(`\nprofile: ${report.providerProfileId}\n`);
      process.stdout.write(`scanned: ${Number(report.scanned ?? 0)}\n`);
      process.stdout.write(`matched: ${Number(report.matched ?? 0)}\n`);
      process.stdout.write(`archived: ${Number(report.archived ?? 0)}\n`);
      if (matches.length > 0) {
        process.stdout.write('matches:\n');
        for (const match of matches.slice(0, 20)) {
          process.stdout.write(`  - ${match.threadId} ${match.title ?? ''}\n`);
        }
        if (matches.length > 20) {
          process.stdout.write(`  ... ${matches.length - 20} more\n`);
        }
      }