Contents

require 'basiccache'

module S3Repo
  ##
  # Repo object, represents an Arch repo inside an S3 bucket
  class Repo < Base
    def initialize(params = {})
      super
    end

    def add_package(file)
      upload!(file)
    end

    def packages
      meta_cache.cache { parse_packages }
    end

    def include?(key)
      !packages.find { |x| x.key == key }.nil?
    end

    def serve(key)
      refresh = !key.match(/\.pkg\.tar\.xz$/)
      file_cache.serve(key, refresh)
    end

    private

    def file_cache
      @file_cache ||= Cache.new(client: client, tmpdir: @options[:tmpdir])
    end

    def meta_cache
      @meta_cache ||= BasicCache::TimeCache.new lifetime: 600
    end

    def upload!(file)
      client.put_object(
        bucket: bucket,
        key: file,
        body: File.open(file) { |fh| fh.read }
      )
    end

    def parse_packages
      client.list_objects(bucket: bucket).contents.select do |x|
        x.key.match(/.*\.pkg\.tar\.xz$/)
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
s3repo-0.0.3	lib/s3repo/repo.rb