Sha256: c12a8141b7d4a4b55239042bbcfcc88f902baba15c66f4fa4623a956918b2612
Contents?: true
Size: 1.69 KB
Versions: 12
Compression:
Stored size: 1.69 KB
Contents
# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require "logstash/outputs/s3/write_bucket_permission_validator"
describe LogStash::Outputs::S3::WriteBucketPermissionValidator do
let(:logger) { spy(:logger ) }
let(:bucket_name) { "foobar" }
let(:obj) { double("s3_object") }
let(:client) { Aws::S3::Client.new(stub_responses: true) }
let(:bucket) { Aws::S3::Bucket.new(bucket_name, :client => client) }
let(:upload_options) { {} }
subject { described_class.new(logger) }
before do
expect(bucket).to receive(:object).with(any_args).and_return(obj)
end
context 'when using upload_options' do
let(:upload_options) {{ :server_side_encryption => true }}
it 'they are passed through to upload_file' do
expect(obj).to receive(:upload_file).with(anything, upload_options)
expect(obj).to receive(:delete).and_return(true)
expect(subject.valid?(bucket, upload_options)).to be_truthy
end
end
context "when permissions are sufficient" do
it "returns true" do
expect(obj).to receive(:upload_file).with(any_args).and_return(true)
expect(obj).to receive(:delete).and_return(true)
expect(subject.valid?(bucket, upload_options)).to be_truthy
end
it "hides delete errors" do
expect(obj).to receive(:upload_file).with(any_args).and_return(true)
expect(obj).to receive(:delete).and_raise(StandardError)
expect(subject.valid?(bucket, upload_options)).to be_truthy
end
end
context "when permission aren't sufficient" do
it "returns false" do
expect(obj).to receive(:upload_file).with(any_args).and_raise(StandardError)
expect(subject.valid?(bucket, upload_options)).to be_falsey
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems