Function emitProgress

packages/core/src/sync/sync-files.ts:255–279

(currentBytes?: number, totalBytes?: number)

  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) => {