Function createUploadProgressTransform

src/upload-progress.ts:32–59

(options: {
  stage: UploadProgressStage;
  fileName: string;
  startOffset: number;
  totalBytes: number;
  onProgress?: UploadProgressSink;
})

export type UploadProgressSink = (event: UploadProgressEvent) => void;

export function createUploadProgressTransform(options: {
  stage: UploadProgressStage;
  fileName: string;
  startOffset: number;
  totalBytes: number;
  onProgress?: UploadProgressSink;
}): Transform {
  const { stage, fileName, startOffset, totalBytes, onProgress } = options;
  let transferredBytes = startOffset;
  const stepBytes = uploadProgressStepBytes(totalBytes);
  let nextReportAt = Math.min(totalBytes, startOffset + stepBytes);
  return new Transform({
    transform(chunk: Buffer, _encoding, callback) {
      transferredBytes = Math.min(totalBytes, transferredBytes + chunk.byteLength);
      if (transferredBytes >= nextReportAt) {
        onProgress?.({
          type: 'progress',
          stage,
          fileName,
          transferredBytes,
          totalBytes,
        });
        nextReportAt = Math.min(totalBytes, transferredBytes + stepBytes);
      }
      callback(null, chunk);
    },
  });
}

export function createStderrUploadProgressReporter(): UploadProgressSink | undefined {
  if (process.stderr.isTTY !== true || process.env.CI) return undefined;