Function uploadFile

packages/uploadthing/src/_internal/client-future.ts:393–504

(
  url: string,
  { file, files, XHRImpl, ...options }: UploadFileOptions<TRoute>,
)

 * @internal
 */
export function uploadFile<TRoute extends AnyFileRoute>(
  url: string,
  { file, files, XHRImpl, ...options }: UploadFileOptions<TRoute>,
): Micro.Micro<UploadedFile<TRoute> | FailedFile<TRoute>, never, FetchContext> {
  return fetchEff(url, { method: "HEAD", headers: options.traceHeaders }).pipe(
    Micro.map(({ headers }) =>
      Number.parseInt(headers.get("x-ut-range-start") ?? "0"),
    ),
    Micro.map((rangeStart) => transitionToUploading(file, rangeStart)),
    Micro.tap((uploadingFile) => {
      options.onEvent({
        type: "upload-started",
        file: uploadingFile,
        files,
      });
    }),
    Micro.flatMap((uploadingFile) =>
      Micro.async<UploadedFile<TRoute>, XHRError | UTStorageError>((resume) => {
        const xhr = new XHRImpl();
        xhr.open("PUT", url, true);

        const rangeStart = uploadingFile.sent;
        xhr.setRequestHeader("Range", `bytes=${rangeStart}-`);
        xhr.setRequestHeader("x-uploadthing-version", version);
        xhr.setRequestHeader("b3", options.traceHeaders.b3);
        xhr.setRequestHeader("traceparent", options.traceHeaders.traceparent);
        xhr.responseType = "json";

        xhr.upload.addEventListener("progress", (ev) => {
          uploadingFile.sent = rangeStart + ev.loaded;
          options.onEvent({
            type: "upload-progress",
            file: uploadingFile,
            files,
          });
        });
        xhr.addEventListener("load", () => {
          if (
            xhr.status > 299 ||
            Predicate.hasProperty(xhr.response, "error")
          ) {
            resume(
              new UTStorageError({
                // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
                message: String(xhr.response.error),
                response: xhr.response,
              }),
            );
          } else {
            const uploadedFile = transitionToUploaded<TRoute>(
              uploadingFile,
              xhr.response as UploadPutResult,
            );
            options.onEvent({
              type: "upload-completed",
              file: uploadedFile,
              files,
            });