Function createS3Backend

apps/sim/lib/uploads/core/storage-service.ts:208–236

(
  key: string,
  config: S3Config,
  contentType: string,
  purpose: string
)

}

async function createS3Backend(
  key: string,
  config: S3Config,
  contentType: string,
  purpose: string
): Promise<MultipartBackend> {
  const {
    initiateS3MultipartUpload,
    uploadS3Part,
    completeS3MultipartUpload,
    abortS3MultipartUpload,
  } = await import('@/lib/uploads/providers/s3/client')
  const { uploadId } = await initiateS3MultipartUpload({
    fileName: key,
    contentType,
    fileSize: 0,
    customConfig: config,
    customKey: key,
    purpose,
  })
  const parts: S3MultipartPart[] = []
  return {
    async uploadPart(partNumber, body) {
      parts.push(await uploadS3Part(key, uploadId, partNumber, body, config))
    },
    finish: () => completeS3MultipartUpload(key, uploadId, parts, config).then(() => undefined),
    abort: () => abortS3MultipartUpload(key, uploadId, config),
  }
}

async function createBlobBackend(
  key: string,