Add changelog, remove total value extraction logic of 7.x

Author: mashhurs

CHANGELOG.md

@@ -1,3 +1,6 @@
+## 4.3.2
+  - End of 7.x stack version support. Allow to update elasticsearch-ruby client to 9.x version [#213](https://github.com/logstash-plugins/logstash-filter-elasticsearch/pull/213)
+
 ## 4.3.1
   - Added support for encoded and non encoded api-key formats on plugin configuration [#203](https://github.com/logstash-plugins/logstash-filter-elasticsearch/pull/203)
 

lib/logstash/filters/elasticsearch/dsl_executor.rb

@@ -45,7 +45,7 @@ def process(client, event)
             results = client.search(params)
             raise "Elasticsearch query error: #{results["_shards"]["failures"]}" if results["_shards"].include? "failures"
 
-            event.set("[@metadata][total_hits]", extract_total_from_hits(results['hits']))
+            event.set("[@metadata][total_hits]", results['hits']['total'])
 
             result_hits = results["hits"]["hits"]
             if !result_hits.nil? && !result_hits.empty?
@@ -91,21 +91,6 @@ def process(client, event)
         end
 
         private
-
-        # Given a "hits" object from an Elasticsearch response, return the total number of hits in
-        # the result set.
-        # @param hits [Hash{String=>Object}]
-        # @return [Integer]
-        def extract_total_from_hits(hits)
-          total = hits['total']
-
-          # Elasticsearch 7.x produces an object containing `value` and `relation` in order
-          # to enable unambiguous reporting when the total is only a lower bound; if we get
-          # an object back, return its `value`.
-          return total['value'] if total.kind_of?(Hash)
-          total
-        end
-
         # get an array of path elements from a path reference
         def extract_path(path_reference)
           return [path_reference] unless path_reference.start_with?('[') && path_reference.end_with?(']')