Contents

module AssetCloud

  class FileSystemBucket < Bucket

    def ls(key = nil)
      objects = []
      base_path = File.join(path_for(key), '*')

      Dir.glob(base_path).each do |f|
        next unless File.file?(f)
        objects.push cloud[relative_path_for(f)]
      end
      objects
    end

    def read(key)
      File.read(path_for(key))
    rescue Errno::ENOENT => e
      raise AssetCloud::AssetNotFoundError, key
    end

    def delete(key)
      File.delete(path_for(key))
    rescue Errno::ENOENT
    end

    def write(key, data)
      full_path = path_for(key)

      retried = false

      begin
        File.open(full_path, "wb+") { |fp| fp << data }
        true
      rescue Errno::ENOENT => e
        if retried == false
          directory = File.dirname(full_path)
          FileUtils.mkdir_p(File.dirname(full_path))
          retried = true
          retry
        else
          raise
        end
        false
      end
    end

    def stat(key)
      begin
        stat = File.stat(path_for(key))
        Metadata.new(true, stat.size, stat.ctime, stat.mtime)
      rescue Errno::ENOENT => e
        Metadata.new(false)
      end
    end

    protected

    def path_for(key)
      cloud.path_for(key)
    end

    def path
      cloud.path
    end

    private

    def remove_full_path_regexp
      @regexp ||= /^#{path}\//
    end

    def relative_path_for(f)
      f.sub(remove_full_path_regexp, '')
    end
  end


end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
asset_cloud-2.0.0	lib/asset_cloud/buckets/file_system_bucket.rb
asset_cloud-1.1.1	lib/asset_cloud/buckets/file_system_bucket.rb
asset_cloud-1.1.0	lib/asset_cloud/buckets/file_system_bucket.rb
asset_cloud-1.0.2	lib/asset_cloud/buckets/file_system_bucket.rb