Function detectMigration

packages/migration-legacy/src/detect.ts:27–102

(opts: { sourcePath: string })

}

export async function detectMigration(opts: { sourcePath: string }): Promise<MigrationPlan> {
  const src = opts.sourcePath;

  const hasConfig = existsSync(sourceConfigToml(src));
  const hasMcp = existsSync(sourceMcpJson(src));
  const hasUserHistory = existsSync(sourceUserHistoryDir(src));

  const oauthCredentials = await listDirSafe(sourceCredentialsDir(src), (n) =>
    n.endsWith('.json'),
  );
  const detectedPlugins = await listDirSafe(sourcePluginsDir(src), () => true);
  const detectedMcpOauthServers = await listDirSafe(sourceMcpOauthDir(src), () => true);

  // Reverse-lookup workdir from kimi.json
  const workdirMap = new Map<string, WorkdirMeta>();
  try {
    const text = await readFile(sourceKimiJson(src), 'utf-8');
    const parsed = OldKimiJsonSchema.parse(JSON.parse(text));
    for (const wd of parsed.work_dirs) {
      workdirMap.set(oldMd5BucketName(wd.path), { path: wd.path, kaos: wd.kaos });
    }
  } catch {
    // no kimi.json or unparseable — sessions list will be empty
  }

  const workdirs: WorkDirEntry[] = [];
  let totalSessions = 0;

  try {
    const sessionsRoot = sourceSessionsDir(src);
    const bucketNames = await readdir(sessionsRoot);
    for (const bucketName of bucketNames) {
      // Skip non-local-kaos buckets (`<kaos>_<md5>`) and unknown formats.
      if (!MD5_HEX_RE.test(bucketName)) continue;
      const wd = workdirMap.get(bucketName);
      if (wd === undefined) continue;
      if (wd.kaos !== 'local') continue;

      const bucketPath = join(sessionsRoot, bucketName);
      let uuids: string[];
      try {
        uuids = await readdir(bucketPath);
      } catch {
        continue;
      }

      const sessions: SessionEntry[] = [];
      for (const uuid of uuids) {
        const sessionDir = join(bucketPath, uuid);
        const cls = await classifySessionDir(sessionDir);
        if (cls !== 'real') continue;
        const wireMtime = await readWireMtime(sessionDir);
        sessions.push({ uuid, oldDir: sessionDir, wireMtime });
        totalSessions++;
      }

      if (sessions.length > 0) {
        workdirs.push({ oldHashDir: bucketPath, workdirPath: wd.path, sessions });