Sha256: e96e0d8b437f21b3f478491e90af739653f40ca1780b7840300d8b25eb8d4c86
Contents?: true
Size: 1.02 KB
Versions: 17
Compression:
Stored size: 1.02 KB
Contents
module Hobo
module Lib
module S3
module Remote
class IoHandler
include Hobo::Logging
def initialize s3, bucket, prefix
@s3 = s3
@bucket = bucket
@prefix = prefix ? "#{prefix.gsub(/^\//, '').chomp('/')}/" : ""
end
def ls
out = {}
logger.debug("s3sync: Listing remote bucket: #{@bucket} w/ prefix #{@prefix}")
@s3.buckets[@bucket].objects.with_prefix(@prefix).each do |file|
filename = file.key.gsub(/^#{@prefix}/, '')
next if filename == ""
out[filename] = file.etag.gsub('"', '')
end
return out
end
def open file, mode
s3_key = ::File.join(@prefix, file)
File.new @s3.buckets[@bucket].objects[s3_key], @prefix
end
def rm file
s3_key = ::File.join(@prefix, file)
@s3.buckets[@bucket].objects[s3_key].delete
end
end
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems