Function runUploadStrategy

apps/sim/lib/uploads/client/direct-upload.ts:561–632

(
  opts: RunUploadStrategyOptions
)

 *   with code `FALLBACK_REQUIRED` is thrown so callers can fall back to a server-proxied path.
 */
export const runUploadStrategy = async (
  opts: RunUploadStrategyOptions
): Promise<UploadStrategyResult> => {
  const {
    file,
    presignedEndpoint,
    presignedOverride,
    presignedBody,
    workspaceId,
    context,
    workflowId,
    executionId,
    signal,
    onProgress,
  } = opts
  const contentType = getFileContentType(file)

  if (presignedOverride && !presignedOverride.directUploadSupported) {
    throw new DirectUploadError('Server signaled fallback to API upload', 'FALLBACK_REQUIRED')
  }

  if (file.size > LARGE_FILE_THRESHOLD) {
    const { key, path } = await uploadViaMultipart({
      file,
      workspaceId,
      context,
      workflowId,
      executionId,
      signal,
      onProgress,
    })
    return { key, path, name: file.name, size: file.size, contentType }
  }

  let presigned: PresignedUploadInfo
  if (presignedOverride) {
    presigned = presignedOverride
  } else {
    if (!presignedEndpoint) {
      throw new DirectUploadError(
        'runUploadStrategy requires either presignedEndpoint or presignedOverride',
        'PRESIGNED_URL_ERROR'
      )
    }
    presigned = await getPresignedUploadInfo({
      endpoint: presignedEndpoint,
      file,
      body: presignedBody,
      signal,
    })
  }

  if (!presigned.directUploadSupported) {
    throw new DirectUploadError('Server signaled fallback to API upload', 'FALLBACK_REQUIRED')
  }

  await uploadViaPresignedPut({
    file,