Contents

module Attachs
  module Storages
    class S3
      
      cattr_accessor :config

      def initialize(default, private)
        if (Rails.env.test? and !default)
          env = 'test'
        elsif default
          env = 'production'
        else
          env = Rails.env
        end
        AWS.config access_key_id: config[env]['access_key_id'], secret_access_key: config[env]['secret_access_key']
        @bucket = AWS::S3.new.buckets[config[env]['bucket']]
        @private = private
      end

      def exists?(path)
        object(path).exists?
      end

      def size(path)
        object(path).content_length
      end

      def url(path)
        base_url.present? ? ::File.join(base_url, path) : object(path).public_url(secure: false)
      end

      def store(upload, path)
        bucket.objects.create(path, Pathname.new(upload.path)).acl = private? ? :private : :public_read
      end
      
      def delete(path)
        object(path).delete
      end

      def magick(source, output, upload)
        if cache[source].blank?
          if upload.present?
            cache[source] = upload.path
          else
            remote = create_tmp
            remote.binmode
            object(source).read { |chunk| remote.write(chunk) }
            remote.close
            remote.open
            cache[source] = remote.path
          end
        end
        tmp = create_tmp
        yield Attachs::Magick::Image.new(cache[source], tmp.path)
        store tmp, output
      end

      protected

      attr_reader :bucket

      def config
        self.class.config
      end

      def base_url
        Rails.application.config.attachs.base_url
      end

      def private?
        @private
      end
      
      def create_tmp
        Tempfile.new 's3'
      end

      def cache
        @cache ||= {}
      end

      def object(path)
        bucket.objects[path]
      end

    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
attachs-0.3.5	lib/attachs/storages/s3.rb