Sha256: 9db200c64beb5b54b94b011cbf46ede83e22596c3a499ba9748c89b34cdcf2fa
Contents?: true
Size: 1.47 KB
Versions: 3
Compression:
Stored size: 1.47 KB
Contents
# encoding: utf-8
require "stud/temporary"
require "socket"
require "fileutils"
module LogStash
module Outputs
class S3
class WriteBucketPermissionValidator
attr_reader :logger
def initialize(logger)
@logger = logger
end
def valid?(bucket_resource)
begin
upload_test_file(bucket_resource)
true
rescue StandardError => e
logger.error("Error validating bucket write permissions!",
:message => e.message,
:class => e.class.name,
:backtrace => e.backtrace
)
false
end
end
private
def upload_test_file(bucket_resource)
generated_at = Time.now
key = "logstash-programmatic-access-test-object-#{generated_at}"
content = "Logstash permission check on #{generated_at}, by #{Socket.gethostname}"
begin
f = Stud::Temporary.file
f.write(content)
f.fsync
obj = bucket_resource.object(key)
obj.upload_file(f)
begin
obj.delete
rescue
# Try to remove the files on the remote bucket,
# but don't raise any errors if that doesn't work.
# since we only really need `putobject`.
end
ensure
f.close
FileUtils.rm_rf(f.path)
end
end
end
end
end
end
Version data entries
3 entries across 3 versions & 1 rubygems