Sha256: 452a26fe7ef42dd3e039943efd9817285cf15337af312910db2d7447d0e0ccfd
Contents?: true
Size: 1.43 KB
Versions: 4
Compression:
Stored size: 1.43 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
)
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
f.close
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
FileUtils.rm_rf(f.path)
end
end
end
end
end
end
Version data entries
4 entries across 4 versions & 1 rubygems