s3_spec.rb in logstash-input-s3-3.6.0

- old
+ new

@@ -8,10 +8,11 @@
   before do
     Thread.abort_on_exception = true
 
     upload_file('../fixtures/uncompressed.log' , "#{prefix}uncompressed_1.log")
     upload_file('../fixtures/compressed.log.gz', "#{prefix}compressed_1.log.gz")
+    sleep(LogStash::Inputs::S3::CUTOFF_SECOND + 1)
   end
 
   after do
     delete_remote_files(prefix)
     FileUtils.rm_rf(temporary_directory)
@@ -26,10 +27,11 @@
                                "bucket" => ENV['AWS_LOGSTASH_TEST_BUCKET'],
                                "region" => ENV["AWS_REGION"] || "us-east-1",
                                "prefix" => prefix,
                                "temporary_directory" => temporary_directory } }
   let(:backup_prefix) { "backup/" }
+  let(:backup_bucket) { "logstash-s3-input-backup" }
 
   it "support prefix to scope the remote files" do
     events = fetch_events(minimal_settings)
     expect(events.size).to eq(4)
   end
@@ -47,15 +49,19 @@
       expect(Dir.glob(File.join(backup_dir, "*")).size).to eq(2)
     end
   end
 
   context "remote backup" do
+    before do
+      create_bucket(backup_bucket)
+    end
+
     it "another bucket" do
-      fetch_events(minimal_settings.merge({ "backup_to_bucket" => "logstash-s3-input-backup"}))
-      expect(list_remote_files("", "logstash-s3-input-backup").size).to eq(2)
+      fetch_events(minimal_settings.merge({ "backup_to_bucket" => backup_bucket}))
+      expect(list_remote_files("", backup_bucket).size).to eq(2)
     end
 
     after do
-      delete_bucket("logstash-s3-input-backup")
+      delete_bucket(backup_bucket)
     end
   end
 end