refactor: Remove unnecessary whitespace

Remove redundant spaces to improve code readability and consistency

Co-authored-by: Daijiro Fukuda <[email protected]>
Signed-off-by: ddukbg <[email protected]>

refactor: Simplify data compression logic

refactor: Simplify data compression logic

Remove duplicate file reading and streamline compression process

Co-authored-by: Daijiro Fukuda <[email protected]>
Signed-off-by: ddukbg <[email protected]>

Author: ddukbg

lib/fluent/plugin/out_s3.rb

@@ -641,11 +641,7 @@ def content_type
       end
 
       def compress(chunk, tmp)
-        uncompressed_data = ''
-        chunk.open do |io|
-          uncompressed_data = io.read
-        end
-        compressed_data = Zstd.compress(uncompressed_data, level: @level)
+        compressed_data = Zstd.compress(chunk.read, level: @level)
         tmp.write(compressed_data)
       rescue => e
         log.warn "zstd compression failed: #{e.message}"

test/test_out_s3.rb

@@ -467,20 +467,20 @@ def test_write_with_custom_s3_object_key_format_containing_hex_random_placeholde
   def test_write_with_zstd
     setup_mocks(true)
     s3_local_file_path = "/tmp/s3-test.zst"
-  
+
     expected_s3path = "log/events/ts=20110102-13/events_0-#{Socket.gethostname}.zst"
-  
+
     setup_s3_object_mocks(s3_local_file_path: s3_local_file_path, s3path: expected_s3path)
-  
+
     config = CONFIG_TIME_SLICE + "\nstore_as zstd\n"
     d = create_time_sliced_driver(config)
-  
+
     time = event_time("2011-01-02 13:14:15 UTC")
     d.run(default_tag: "test") do
       d.feed(time, { "a" => 1 })
       d.feed(time, { "a" => 2 })
     end
-  
+
     File.open(s3_local_file_path, 'rb') do |file|
       compressed_data = file.read
       uncompressed_data = Zstd.decompress(compressed_data)