Sha256: c1db7d6e8c2433a88f27e4349dda1df578579e94c4b77e1c45e6e6f84e4b9e89
Contents?: true
Size: 1.96 KB
Versions: 6
Compression:
Stored size: 1.96 KB
Contents
# frozen_string_literal: true
require 'client/multipart_upload/chunks_client'
require_relative 'upload_client'
module Uploadcare
module Client
# Client for multipart uploads
#
# @see https://uploadcare.com/api-refs/upload-api/#tag/Upload
class MultipartUploaderClient < UploadClient
include MultipartUpload
# Upload a big file by splitting it into parts and sending those parts into assigned buckets
# object should be File
def upload(object, store: false, &block)
response = upload_start(object, store: store)
return response unless response.success[:parts] && response.success[:uuid]
links = response.success[:parts]
uuid = response.success[:uuid]
ChunksClient.upload_chunks(object, links, &block)
upload_complete(uuid)
end
# Asks Uploadcare server to create a number of storage bin for uploads
def upload_start(object, store: false)
body = HTTP::FormData::Multipart.new(
Param::Upload::UploadParamsGenerator.call(store).merge(form_data_for(object))
)
post(path: 'multipart/start/',
headers: { 'Content-Type': body.content_type },
body: body)
end
# When every chunk is uploaded, ask Uploadcare server to finish the upload
def upload_complete(uuid)
body = HTTP::FormData::Multipart.new(
{
UPLOADCARE_PUB_KEY: Uploadcare.config.public_key,
uuid: uuid
}
)
post(path: 'multipart/complete/', body: body, headers: { 'Content-Type': body.content_type })
end
private
def form_data_for(file)
form_data_file = super(file)
{
filename: form_data_file.filename,
size: form_data_file.size,
content_type: form_data_file.content_type
}
end
alias api_struct_post post
def post(**args)
handle_throttling { api_struct_post(**args) }
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems