Contents

# frozen_string_literal: true

module CarrierWave
  module Storage
    class Aliyun < Abstract
      def store!(new_file)
        f = AliyunFile.new(uploader, self, uploader.store_path)
        headers = {
          content_type: new_file.content_type,
          content_disposition: uploader.try(:content_disposition)
        }

        f.store(new_file, headers)
        f
      end

      def retrieve!(identifier)
        AliyunFile.new(uploader, self, uploader.store_path(identifier))
      end

      def cache!(new_file)
        f = AliyunFile.new(uploader, self, uploader.cache_path)
        headers = {
          content_type: new_file.content_type,
          content_disposition: uploader.try(:content_disposition)
        }

        f.store(new_file, headers)
        f
      end

      def retrieve_from_cache!(identifier)
        AliyunFile.new(uploader, self, uploader.cache_path(identifier))
      end

      def delete_dir!(path)
        # do nothing, because there's no such things as 'empty directory'
      end

      def clean_cache!(_seconds)
        will_remove_keys = []
        bucket.list_objects(prefix: uploader.cache_path).each do |file|
          next unless file.is_a?(Object)
          time = file.key.scan(/(\d+)-\d+-\d+(?:-\d+)?/).first.map { |t| t.to_i }
          time = Time.at(*time)
          will_remove_keys << item.key if time < (Time.now.utc - seconds)
        end
        bucket.batch_delete_objects(will_remove_keys)
      end

      private

        def bucket
          @bucket ||= CarrierWave::Aliyun::Bucket.new(uploader)
        end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
carrierwave-aliyun-1.2.1	lib/carrierwave/storage/aliyun.rb
carrierwave-aliyun-1.2.0	lib/carrierwave/storage/aliyun.rb
carrierwave-aliyun-1.1.3	lib/carrierwave/storage/aliyun.rb
carrierwave-aliyun-1.1.2	lib/carrierwave/storage/aliyun.rb
carrierwave-aliyun-1.1.1	lib/carrierwave/storage/aliyun.rb