require "fileutils" require "pathname" require "active_support/core_ext/numeric/bytes" class ActiveStorage::Service::DiskService < ActiveStorage::Service attr_reader :root def initialize(root:) @root = root end def upload(key, io) File.open(make_path_for(key), "wb") do |file| while chunk = io.read(64.kilobytes) file.write(chunk) end end end def download(key) if block_given? File.open(path_for(key)) do |file| while data = file.read(64.kilobytes) yield data end end else File.open path_for(key), &:read end end def delete(key) File.delete path_for(key) rescue Errno::ENOENT # Ignore files already deleted end def exist?(key) File.exist? path_for(key) end def url(key, expires_in:, disposition:, filename:) verified_key_with_expiration = ActiveStorage::VerifiedKeyWithExpiration.encode(key, expires_in: expires_in) if defined?(Rails) && defined?(Rails.application) Rails.application.routes.url_helpers.rails_disk_blob_path(verified_key_with_expiration, disposition: disposition) else "/rails/blobs/#{verified_key_with_expiration}?disposition=#{disposition}" end end private def path_for(key) File.join root, folder_for(key), key end def folder_for(key) [ key[0..1], key[2..3] ].join("/") end def make_path_for(key) path_for(key).tap { |path| FileUtils.mkdir_p File.dirname(path) } end end