Function uploadViaPresignedPut

apps/sim/lib/uploads/client/direct-upload.ts:223–303

(opts: UploadViaPutOptions)

}

const uploadViaPresignedPut = (opts: UploadViaPutOptions): Promise<void> => {
  const { file, presignedUrl, uploadHeaders, signal, onProgress } = opts

  return new Promise((resolve, reject) => {
    const xhr = new XMLHttpRequest()
    let isCompleted = false
    const timeoutMs = calculateUploadTimeoutMs(file.size)

    const timeoutId = setTimeout(() => {
      if (isCompleted) return
      isCompleted = true
      signal?.removeEventListener('abort', abortHandler)
      xhr.abort()
      reject(new DirectUploadError(`Upload timeout for ${file.name}`, 'DIRECT_UPLOAD_ERROR'))
    }, timeoutMs)

    const abortHandler = () => {
      if (isCompleted) return
      isCompleted = true
      clearTimeout(timeoutId)
      xhr.abort()
      reject(new DirectUploadError(`Upload aborted for ${file.name}`, 'ABORTED'))
    }

    if (signal) {
      if (signal.aborted) {
        abortHandler()
        return
      }
      signal.addEventListener('abort', abortHandler)
    }

    xhr.upload.addEventListener('progress', (event) => {
      if (event.lengthComputable && !isCompleted) {
        onProgress?.({
          loaded: event.loaded,
          total: event.total,
          percent: Math.round((event.loaded / event.total) * 100),
        })
      }
    })

    xhr.addEventListener('load', () => {
      if (isCompleted) return
      isCompleted = true
      clearTimeout(timeoutId)
      signal?.removeEventListener('abort', abortHandler)

      if (xhr.status >= 200 && xhr.status < 300) {
        onProgress?.({ loaded: file.size, total: file.size, percent: 100 })
        resolve()
      } else {
        reject(
          new DirectUploadError(
            `Direct upload failed for ${file.name}: ${xhr.status} ${xhr.statusText}`,
            'DIRECT_UPLOAD_ERROR',
            undefined,
            xhr.status