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 Asset.at(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

3 entries across 3 versions & 2 rubygems

Version	Path
Shopify-asset_cloud-0.5.1	lib/asset_cloud/file_system_bucket.rb
jamesmacaulay-asset_cloud-0.5.0	lib/asset_cloud/file_system_bucket.rb
jamesmacaulay-asset_cloud-0.5.1	lib/asset_cloud/file_system_bucket.rb