Function readExisting

packages/core/src/sync/index.ts:400–440

(modelsDir: string)

}

async function readExisting(modelsDir: string) {
  const existing = new Map<string, {
    authored: ExistingModel;
    toml: ExistingModel;
    header: string;
    symlink: boolean;
  }>();
  const brokenSymlinks = new Set<string>();
  let modelMetadata: Record<string, Record<string, unknown>> | undefined;

  for (const { file, symlink } of await tomlFiles(modelsDir)) {
    const filePath = path.join(modelsDir, file);
    let text: string;
    try {
      text = await Bun.file(filePath).text();
    } catch (error) {
      if (symlink && error instanceof Error && "code" in error && error.code === "ENOENT") {
        brokenSymlinks.add(file);
        continue;
      }
      throw error;
    }
    const parsed = ExistingModel.safeParse(Bun.TOML.parse(text));
    if (!parsed.success) {
      parsed.error.cause = { path: filePath };
      throw parsed.error;
    }

    const authored = parsed.data as ExistingModel;
    if (authored.base_model !== undefined && modelMetadata === undefined) {
      modelMetadata = await readModelMetadata(modelsDir);
    }
    const toml = authored.base_model === undefined
      ? authored
      : resolveBaseModel(authored, modelMetadata ?? {}, filePath);

    existing.set(file, { authored, toml, header: leadingComments(text), symlink });
  }

  return { models: existing, brokenSymlinks, modelMetadata };
}

async function isSymlink(filePath: string) {
  try {