class ActiveStorage::Service::DiskService
Wraps a local disk path as an Active Storage service. See ActiveStorage::Service
for the generic API documentation that applies to all services.
Attributes
root[R]
Public Class Methods
new(root:)
click to toggle source
# File activestorage/lib/active_storage/service/disk_service.rb, line 14 def initialize(root:) @root = root end
Public Instance Methods
delete(key)
click to toggle source
# File activestorage/lib/active_storage/service/disk_service.rb, line 41 def delete(key) instrument :delete, key do begin File.delete path_for(key) rescue Errno::ENOENT # Ignore files already deleted end end end
download(key) { |data| ... }
click to toggle source
# File activestorage/lib/active_storage/service/disk_service.rb, line 25 def download(key) if block_given? instrument :streaming_download, key do File.open(path_for(key), "rb") do |file| while data = file.read(64.kilobytes) yield data end end end else instrument :download, key do File.binread path_for(key) end end end
exist?(key)
click to toggle source
# File activestorage/lib/active_storage/service/disk_service.rb, line 51 def exist?(key) instrument :exist, key do |payload| answer = File.exist? path_for(key) payload[:exist] = answer answer end end
headers_for_direct_upload(key, content_type:, **)
click to toggle source
# File activestorage/lib/active_storage/service/disk_service.rb, line 104 def headers_for_direct_upload(key, content_type:, **) { "Content-Type" => content_type } end
upload(key, io, checksum: nil)
click to toggle source
# File activestorage/lib/active_storage/service/disk_service.rb, line 18 def upload(key, io, checksum: nil) instrument :upload, key, checksum: checksum do IO.copy_stream(io, make_path_for(key)) ensure_integrity_of(key, checksum) if checksum end end
url(key, expires_in:, filename:, disposition:, content_type:)
click to toggle source
# File activestorage/lib/active_storage/service/disk_service.rb, line 59 def url(key, expires_in:, filename:, disposition:, content_type:) instrument :url, key do |payload| verified_key_with_expiration = ActiveStorage.verifier.generate(key, expires_in: expires_in, purpose: :blob_key) generated_url = if defined?(Quails.application) Quails.application.routes.url_helpers.quails_disk_service_path \ verified_key_with_expiration, filename: filename, disposition: disposition, content_type: content_type else "/quails/active_storage/disk/#{verified_key_with_expiration}/#{filename}?content_type=#{content_type}&disposition=#{disposition}" 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
# File activestorage/lib/active_storage/service/disk_service.rb, line 78 def url_for_direct_upload(key, expires_in:, content_type:, content_length:, checksum:) instrument :url, key do |payload| verified_token_with_expiration = ActiveStorage.verifier.generate( { key: key, content_type: content_type, content_length: content_length, checksum: checksum }, { expires_in: expires_in, purpose: :blob_token } ) generated_url = if defined?(Quails.application) Quails.application.routes.url_helpers.update_quails_disk_service_path verified_token_with_expiration else "/quails/active_storage/disk/#{verified_token_with_expiration}" end payload[:url] = generated_url generated_url end end
Private Instance Methods
ensure_integrity_of(key, checksum)
click to toggle source
# File activestorage/lib/active_storage/service/disk_service.rb, line 121 def ensure_integrity_of(key, checksum) unless Digest::MD5.file(path_for(key)).base64digest == checksum delete key raise ActiveStorage::IntegrityError end end
folder_for(key)
click to toggle source
# File activestorage/lib/active_storage/service/disk_service.rb, line 113 def folder_for(key) [ key[0..1], key[2..3] ].join("/") end
make_path_for(key)
click to toggle source
# File activestorage/lib/active_storage/service/disk_service.rb, line 117 def make_path_for(key) path_for(key).tap { |path| FileUtils.mkdir_p File.dirname(path) } end
path_for(key)
click to toggle source
# File activestorage/lib/active_storage/service/disk_service.rb, line 109 def path_for(key) File.join root, folder_for(key), key end