Function writeTeamStorageAssets

src/shell/platform/teamStorageAssets.ts:55–109

(
  args: DownloadTeamStorageAssetsArgs,
  deps: DownloadTeamStorageAssetsDeps,
)

}

async function writeTeamStorageAssets(
  args: DownloadTeamStorageAssetsArgs,
  deps: DownloadTeamStorageAssetsDeps,
): Promise<SyncTeamStorageAssetsResult> {
  const fs = deps.fs ?? makeDefaultFs();
  const tmpAssets = mintAssetSnapshotPath(args.assetsAbs, "pull");
  const manifest = await readAssetManifest(args.assetsAbs, fs);
  const safeFiles: ReusableAssetFile[] = [];
  for (const file of args.files) {
    const relativePath = safeAssetPath(file.path);
    if (relativePath !== undefined) safeFiles.push({ file, relativePath });
  }
  const skippedCount = args.files.length - safeFiles.length;
  const reusable = await reusableAssetPaths(
    args.assetsAbs,
    safeFiles,
    manifest,
    fs,
  );
  const reusedCount = reusable.size;

  if (
    reusedCount === safeFiles.length &&
    (await hasExactAssetSnapshot(
      args.assetsAbs,
      safeFiles.map((file) => file.relativePath),
      fs,
    ))
  ) {
    return { downloadedCount: 0, reusedCount, skippedCount };
  }

  try {
    const downloadedCount = await writeAssetSnapshot({
      assetsAbs: args.assetsAbs,
      deps: { fetch: deps.fetch, fs },
      reusable,
      safeFiles,
      tmpAssets,
    });
    await replaceAssetsDir(args.assetsAbs, tmpAssets, fs);
    await writeAssetManifest(
      args.assetsAbs,
      safeFiles.map(({ file, relativePath }) => ({
        ...file,
        path: relativePath,
      })),
      fs,
    );
    return { downloadedCount, reusedCount, skippedCount };
  } catch (error: unknown) {
    await cleanupAssetSnapshot(tmpAssets, fs);
    throw error;
  }
}

type WriteAssetSnapshotArgs = {
  assetsAbs: string;