From d2c652513b823ca0105e9c47dba15a8c3eb1bd76 Mon Sep 17 00:00:00 2001
From: Athish Pranav D <athishanna@gmail.com>
Date: Tue, 10 Sep 2024 11:52:31 +0530
Subject: [PATCH] Added UTs

Signed-off-by: Athish Pranav D <athishanna@gmail.com>
---
 test/plugin/test_filter_parser.rb | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/test/plugin/test_filter_parser.rb b/test/plugin/test_filter_parser.rb
index 3b538798b6..d96e44a397 100644
--- a/test/plugin/test_filter_parser.rb
+++ b/test/plugin/test_filter_parser.rb
@@ -206,6 +206,23 @@ def test_filter
 
   end
 
+  def test_filter_with_multiple_records
+    d1 = create_driver(%[
+      key_name data
+      <parse>
+        @type json
+      </parse>
+    ])
+    time = Fluent::EventTime.from_time(@default_time)
+    d1.run(default_tag: @tag) do
+      d1.feed(time, {'data' => '[{"xxx_1":"first","yyy":"second"}, {"xxx_2":"first", "yyy_2":"second"}]'})
+    end
+    filtered = d1.filtered
+    assert_equal 2, filtered.length
+    assert_equal ({"xxx_1"=>"first", "yyy"=>"second"}), filtered[0][1]
+    assert_equal ({"xxx_2"=>"first", "yyy_2"=>"second"}), filtered[1][1]
+  end
+
   data(:keep_key_name => false,
        :remove_key_name => true)
   def test_filter_with_reserved_data(remove_key_name)