class ActiveStorage::Service::AliyunService
Constants
- CHUNK_SIZE
Attributes
config[R]
Public Class Methods
new(**config)
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 7 def initialize(**config) Aliyun::Common::Logging.set_log_file("/dev/null") @config = config @public = @config.fetch(:public, false) # Compatible with mode config if @config.fetch(:mode, nil) == "public" ActiveSupport::Deprecation.warn("mode has deprecated, and will remove in 1.1.0, use public: true instead.") @public = true end end
Public Instance Methods
delete(key)
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 58 def delete(key) instrument :delete, key: key do bucket.delete_object(path_for(key)) end end
delete_prefixed(prefix)
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 64 def delete_prefixed(prefix) instrument :delete_prefixed, prefix: prefix do files = bucket.list_objects(prefix: path_for(prefix)) return if files.blank? keys = files.map(&:key) return if keys.blank? bucket.batch_delete_objects(keys, quiet: true) end end
download(key, &block)
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 31 def download(key, &block) if block_given? instrument :streaming_download, key: key do bucket.get_object(path_for(key), &block) end else instrument :download, key: key do chunk_buff = [] bucket.get_object(path_for(key)) do |chunk| chunk_buff << chunk end chunk_buff.join("") end end end
download_chunk(key, range)
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 47 def download_chunk(key, range) instrument :download_chunk, key: key, range: range do chunk_buff = [] range_end = range.exclude_end? ? range.end : range.end + 1 bucket.get_object(path_for(key), range: [range.begin, range_end]) do |chunk| chunk_buff << chunk end chunk_buff.join("") end end
exist?(key)
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 74 def exist?(key) instrument :exist, key: key do |payload| bucket.object_exists?(path_for(key)) end end
headers_for_direct_upload(key, content_type:, checksum:, **)
click to toggle source
Headers for Direct Upload help.aliyun.com/document_detail/31951.html headers is required use x-oss-date instead
# File lib/active_storage/service/aliyun_service.rb, line 97 def headers_for_direct_upload(key, content_type:, checksum:, **) date = Time.now.httpdate { "Content-Type" => content_type, "Content-MD5" => checksum, "Authorization" => authorization(key, content_type, checksum, date), "x-oss-date" => date, } end
upload(key, io, checksum: nil, content_type: nil, disposition: nil, filename: nil)
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 22 def upload(key, io, checksum: nil, content_type: nil, disposition: nil, filename: nil) instrument :upload, key: key, checksum: checksum do content_type ||= Marcel::MimeType.for(io) bucket.put_object(path_for(key), content_type: content_type) do |stream| stream << io.read(CHUNK_SIZE) until io.eof? end end end
url(key, **options)
click to toggle source
Remove this in Rails 6.1, compatiable with Rails 6.0.0
# File lib/active_storage/service/aliyun_service.rb, line 108 def url(key, **options) instrument :url, key: key do |payload| generated_url = if public? public_url(key, **options) else private_url(key, **options) end payload[:url] = generated_url generated_url end end
url_for_direct_upload(key, expires_in:, content_type:, content_length:, checksum:)
click to toggle source
You must setup CORS on OSS control panel to allow JavaScript request from your site domain. www.alibabacloud.com/help/zh/doc-detail/31988.htm help.aliyun.com/document_detail/31925.html Source: *.your.host.com Allowed Methods: POST, PUT, HEAD Allowed Headers: *
# File lib/active_storage/service/aliyun_service.rb, line 86 def url_for_direct_upload(key, expires_in:, content_type:, content_length:, checksum:) instrument :url, key: key do |payload| generated_url = bucket.object_url(path_for(key), false) payload[:url] = generated_url generated_url end end
Private Instance Methods
bucket()
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 184 def bucket return @bucket if defined? @bucket @bucket = client.get_bucket(config.fetch(:bucket)) @bucket end
client()
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 202 def client @client ||= Aliyun::OSS::Client.new( endpoint: endpoint, access_key_id: config.fetch(:access_key_id), access_key_secret: config.fetch(:access_key_secret), cname: config.fetch(:cname, false) ) end
endpoint()
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 198 def endpoint config.fetch(:endpoint, "https://oss-cn-hangzhou.aliyuncs.com") end
object_url(key, sign: false, expires_in: 60, params: {})
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 159 def object_url(key, sign: false, expires_in: 60, params: {}) url = bucket.object_url(key, false) unless sign return url if params.blank? return url + "?" + params.to_query end resource = "/#{bucket.name}/#{key}" expires = Time.now.to_i + expires_in query = { "Expires" => expires, "OSSAccessKeyId" => config.fetch(:access_key_id) } query.merge!(params) if params.present? resource += "?" + params.map { |k, v| "#{k}=#{v}" }.sort.join("&") end string_to_sign = ["GET", "", "", expires, resource].join("\n") query["Signature"] = bucket.sign(string_to_sign) [url, query.to_query].join("?") end
path_for(key)
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 148 def path_for(key) root_path = config.fetch(:path, nil) if root_path.blank? || root_path == "/" full_path = key else full_path = File.join(root_path, key) end full_path.gsub(/^\//, "").gsub(/[\/]+/, "/") end
private_url(key, expires_in: 60, filename: nil, content_type: nil, disposition: nil, params: {}, **)
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 126 def private_url(key, expires_in: 60, filename: nil, content_type: nil, disposition: nil, params: {}, **) filekey = path_for(key) params["response-content-type"] = content_type unless content_type.blank? if filename filename = ActiveStorage::Filename.wrap(filename) params["response-content-disposition"] = content_disposition_with(type: disposition, filename: filename) end object_url(filekey, sign: true, expires_in: expires_in, params: params) end
public?()
click to toggle source
Remove this in Rails 6.1, compatiable with Rails 6.0.0
# File lib/active_storage/service/aliyun_service.rb, line 144 def public? @public == true end
public_url(key, params: {}, **)
click to toggle source
# File lib/active_storage/service/aliyun_service.rb, line 139 def public_url(key, params: {}, **) object_url(path_for(key), sign: false, params: params) end