Sha256: fdb662397f09349b0c9a955021b55283505260e6996d5b105462eb664205a0a8
Contents?: true
Size: 1.6 KB
Versions: 17
Compression:
Stored size: 1.6 KB
Contents
require 'thread'
module Aws
module S3
# @api private
class ObjectCopier
# @param [S3::Objecst] object
def initialize(object, options = {})
@object = object
@options = options.merge(client: @object.client)
end
def copy_from(source, options = {})
copy_object(source, @object, options)
end
def copy_to(target, options = {})
copy_object(@object, target, options)
end
private
def copy_object(source, target, options)
target_bucket, target_key = copy_target(target)
options[:bucket] = target_bucket
options[:key] = target_key
options[:copy_source] = copy_source(source)
if options.delete(:multipart_copy)
ObjectMultipartCopier.new(@options).copy(options)
else
@object.client.copy_object(options)
end
end
def copy_source(source)
case source
when String then source
when Hash then "#{source[:bucket]}/#{source[:key]}"
when S3::Object then "#{source.bucket_name}/#{source.key}"
else
msg = "expected source to be an Aws::S3::Object, Hash, or String"
raise ArgumentError, msg
end
end
def copy_target(target)
case target
when String then target.match(/([^\/]+?)\/(.+)/)[1,2]
when Hash then target.values_at(:bucket, :key)
when S3::Object then [target.bucket_name, target.key]
else
msg = "expected target to be an Aws::S3::Object, Hash, or String"
raise ArgumentError, msg
end
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems