Fix wrong opensearch usage

Update wrong usage of opensearch and remove versions.

Signed-off-by: Vijayan Balasubramanian <[email protected]>

Author: VijayanB

lib/logstash/outputs/opensearch.rb

@@ -137,7 +137,7 @@ class LogStash::Outputs::OpenSearch < LogStash::Outputs::Base
 
   config :document_type,
     :validate => :string,
-    :deprecated => "Document types are being deprecated in OpenSearch 6.0, and removed entirely in 7.0. You should avoid this feature"
+    :deprecated => "Document types are removed entirely. You should avoid this feature"
 
   # From Logstash 1.3 onwards, a template is applied to Elasticsearch during
   # Logstash's startup if one with the name `template_name` does not already exist.

lib/logstash/plugin_mixins/opensearch/api_configs.rb

@@ -10,7 +10,7 @@
 module LogStash; module PluginMixins; module OpenSearch
   module APIConfigs
 
-    # This module defines common options that can be reused by alternate OpenSearch output plugins such as the OpenSearch_data_streams output.
+    # This module defines common options that can be reused by alternate OpenSearch output plugins.
 
     DEFAULT_HOST = ::LogStash::Util::SafeURI.new("//127.0.0.1")
 
@@ -129,7 +129,7 @@ module APIConfigs
         # See https://hc.apache.org/httpcomponents-client-ga/httpclient/apidocs/org/apache/http/impl/conn/PoolingHttpClientConnectionManager.html#setValidateAfterInactivity(int)[these docs for more info]
         :validate_after_inactivity => { :validate => :number, :default => 10000 },
 
-        # Enable gzip compression on requests. Note that response compression is on by default for OpenSearch v5.0 and beyond
+        # Enable gzip compression on requests.
         :http_compression => { :validate => :boolean, :default => false },
 
         # Custom Headers to send on each request to OpenSearch nodes

lib/logstash/plugin_mixins/opensearch/common.rb

@@ -12,7 +12,7 @@
 module LogStash; module PluginMixins; module OpenSearch
   module Common
 
-    # This module defines common methods that can be reused by alternate elasticsearch output plugins such as the OpenSearch_data_streams output.
+    # This module defines common methods that can be reused by alternate opensearch output plugins.
 
     attr_reader :hosts
 

scripts/logstash-run.sh

@@ -18,8 +18,8 @@ wait_for_es() {
 if [[ "$INTEGRATION" != "true" ]]; then
   bundle exec rspec -fd spec/unit -t ~integration
 else
-  echo "Waiting for elasticsearch to respond..."
-  ES_VERSION=$(wait_for_es)
-  echo "Elasticsearch $VERSION is Up!"
+  echo "Waiting for cluster to respond..."
+  VERSION=$(wait_for_es)
+  echo "Integration test cluster $VERSION is Up!"
   bundle exec rspec -fd --tag integration --tag update_tests:painless --tag version:$VERSION spec/integration
 fi

spec/fixtures/_nodes/7x.json

@@ -49,8 +49,8 @@
 
   describe("Complex sniff parsing") do
     before(:each) do
-      response_double = double("_nodes/http", body: File.read("spec/fixtures/_nodes/7x.json"))
-      allow(subject).to receive(:perform_request).and_return([nil, { version: "7.0" }, response_double])
+      response_double = double("_nodes/http", body: File.read("spec/fixtures/_nodes/nodes.json"))
+      allow(subject).to receive(:perform_request).and_return([nil, { version: "any" }, response_double])
       subject.start
     end