Function createBlobBackend

apps/sim/lib/uploads/core/storage-service.ts:238–254

(
  key: string,
  config: BlobConfig,
  contentType: string
)

}

async function createBlobBackend(
  key: string,
  config: BlobConfig,
  contentType: string
): Promise<MultipartBackend> {
  const { stageBlobPart, commitBlobBlockList, abortMultipartUpload } = await import(
    '@/lib/uploads/providers/blob/client'
  )
  const parts: AzureMultipartPart[] = []
  return {
    async uploadPart(partNumber, body) {
      parts.push(await stageBlobPart(key, partNumber, body, config))
    },
    finish: () => commitBlobBlockList(key, parts, contentType, config),
    abort: () => abortMultipartUpload(key, config),
  }
}

/**
 * Open a streaming multipart upload to the configured provider. On the local