Class: ActiveStorage::Service::DiskService
Relationships & Source Files | |
Super Chains via Extension / Inclusion / Inheritance | |
Class Chain:
|
|
Instance Chain:
self,
::ActiveStorage::Service
|
|
Inherits: |
ActiveStorage::Service
|
Defined in: | activestorage/lib/active_storage/service/disk_service.rb |
Overview
Active Storage Disk Service
Wraps a local disk path as an Active Storage service. See ::ActiveStorage::Service
for the generic API documentation that applies to all services.
Class Method Summary
::ActiveStorage::Service
- Inherited
.configure | Configure an Active Storage service by name from a set of configurations, typically loaded from a YAML file. |
::ActiveSupport::Autoload
- Extended
Instance Attribute Summary
Instance Method Summary
- #compose(source_keys, destination_key)
- #delete(key)
- #delete_prefixed(prefix)
- #download(key, &block)
- #download_chunk(key, range)
- #exist?(key) ⇒ Boolean
- #headers_for_direct_upload(key, content_type:)
- #upload(key, io, checksum: nil)
- #url_for_direct_upload(key, expires_in:, content_type:, content_length:, checksum:, custom_metadata: {})
::ActiveStorage::Service
- Inherited
#compose | Concatenate multiple files into a single “composed” file. |
#delete | Delete the file at the |
#delete_prefixed | Delete files at keys starting with the |
#download | Return the content of the file at the |
#download_chunk | Return the partial content in the byte |
#exist? | Return |
#headers_for_direct_upload | Returns a |
#open, | |
#update_metadata | Update metadata for the file identified by |
#upload | Upload the |
#url | Returns the URL for the file at the |
#url_for_direct_upload | Returns a signed, temporary URL that a direct upload file can be PUT to on the |
Constructor Details
.new(root:, public: false, **options) ⇒ DiskService
# File 'activestorage/lib/active_storage/service/disk_service.rb', line 16
def initialize(root:, public: false, ** ) @root = root @public = public end
Instance Attribute Details
#root (rw)
[ GitHub ]# File 'activestorage/lib/active_storage/service/disk_service.rb', line 14
attr_accessor :root
Instance Method Details
#compose(source_keys, destination_key)
[ GitHub ]# File 'activestorage/lib/active_storage/service/disk_service.rb', line 105
def compose(source_keys, destination_key, **) File.open(make_path_for(destination_key), "w") do |destination_file| source_keys.each do |source_key| File.open(path_for(source_key), "rb") do |source_file| IO.copy_stream(source_file, destination_file) end end end end
#delete(key)
[ GitHub ]#delete_prefixed(prefix)
[ GitHub ]# File 'activestorage/lib/active_storage/service/disk_service.rb', line 61
def delete_prefixed(prefix) instrument :delete_prefixed, prefix: prefix do Dir.glob(path_for("#{prefix}*")).each do |path| FileUtils.rm_rf(path) end end end
#download(key, &block)
[ GitHub ]# File 'activestorage/lib/active_storage/service/disk_service.rb', line 28
def download(key, &block) if block_given? instrument :streaming_download, key: key do stream key, &block end else instrument :download, key: key do File.binread path_for(key) rescue Errno::ENOENT raise ActiveStorage::FileNotFoundError end end end
#download_chunk(key, range)
[ GitHub ]# File 'activestorage/lib/active_storage/service/disk_service.rb', line 42
def download_chunk(key, range) instrument :download_chunk, key: key, range: range do File.open(path_for(key), "rb") do |file| file.seek range.begin file.read range.size end rescue Errno::ENOENT raise ActiveStorage::FileNotFoundError end end
#exist?(key) ⇒ Boolean
#headers_for_direct_upload(key, content_type:)
[ GitHub ]# File 'activestorage/lib/active_storage/service/disk_service.rb', line 97
def headers_for_direct_upload(key, content_type:, **) { "Content-Type" => content_type } end
#upload(key, io, checksum: nil)
[ GitHub ]# File 'activestorage/lib/active_storage/service/disk_service.rb', line 21
def upload(key, io, checksum: nil, **) instrument :upload, key: key, checksum: checksum do IO.copy_stream(io, make_path_for(key)) ensure_integrity_of(key, checksum) if checksum end end
#url_for_direct_upload(key, expires_in:, content_type:, content_length:, checksum:, custom_metadata: {})
[ GitHub ]# File 'activestorage/lib/active_storage/service/disk_service.rb', line 77
def url_for_direct_upload(key, expires_in:, content_type:, content_length:, checksum:, custom_metadata: {}) instrument :url, key: key do |payload| verified_token_with_expiration = ActiveStorage.verifier.generate( { key: key, content_type: content_type, content_length: content_length, checksum: checksum, service_name: name }, expires_in: expires_in, purpose: :blob_token ) url_helpers.update_rails_disk_service_url(verified_token_with_expiration, ).tap do |generated_url| payload[:url] = generated_url end end end