Function runFileTasks

packages/core/src/sync/sync-files.ts:225–309

(
  tasks: FileTask[],
  operation: "upload" | "download",
  concurrency: number,
  onProgress?: (progress: SyncProgress) => void,
)

}

async function runFileTasks(
  tasks: FileTask[],
  operation: "upload" | "download",
  concurrency: number,
  onProgress?: (progress: SyncProgress) => void,
): Promise<boolean[]> {
  let completed = 0;
  const total = tasks.length;
  const operationLabel = operation === "upload" ? "Uploading" : "Downloading";
  const taskLoadedBytes = new Map<number, number>();
  const taskTotalBytes = new Map<number, number>();
  for (let i = 0; i < tasks.length; i++) {
    const size = tasks[i].sizeBytes;
    if (isPositiveFiniteNumber(size)) {
      taskTotalBytes.set(i, size);
      taskLoadedBytes.set(i, 0);
    }
  }

  const getTotalTransferBytes = () => {
    if (taskTotalBytes.size !== tasks.length) return undefined;
    const totalBytes = Array.from(taskTotalBytes.values()).reduce((sum, bytes) => sum + bytes, 0);
    return totalBytes > 0 ? totalBytes : undefined;
  };

  const getTotalCurrentBytes = () =>
    Array.from(taskLoadedBytes.values()).reduce((sum, bytes) => sum + bytes, 0);

  const tasksWithProgress = tasks.map((task, index) => async () => {
    const fileNumber = index + 1;
    const emitProgress = (currentBytes?: number, totalBytes?: number) => {
      if (isPositiveFiniteNumber(totalBytes)) {
        taskTotalBytes.set(index, totalBytes);
      }
      if (currentBytes !== undefined) {
        const knownTotal = taskTotalBytes.get(index);
        const boundedBytes = knownTotal
          ? Math.max(0, Math.min(currentBytes, knownTotal))
          : Math.max(0, currentBytes);
        taskLoadedBytes.set(index, boundedBytes);
      }
      const totalTransferBytes = getTotalTransferBytes();
      onProgress?.({
        phase: "files",
        operation,
        currentFile: task.label,
        completedFiles: completed,
        totalFiles: total,
        ...(currentBytes !== undefined ? { currentBytes } : {}),
        ...(totalBytes !== undefined ? { totalBytes } : {}),
        ...(taskLoadedBytes.size > 0 ? { totalCurrentBytes: getTotalCurrentBytes() } : {}),
        ...(totalTransferBytes !== undefined ? { totalTransferBytes } : {}),
        message: `${operationLabel} file ${fileNumber}/${total}...`,
      });
    };

    emitProgress();
    const result = await task.run((loaded, taskTotal) => {