Fix connection placeholder replacements errors (#92)

Fixed connection placeholder replacements errors when running Logstash 8.15.1 and 8.15.2 versions

Author: edmocosta

CHANGELOG.md

@@ -1,3 +1,6 @@
+## 1.4.8
+  - Fixed connection placeholder replacements errors with Logstash `8.15.1` and `8.15.2` [#92](https://github.com/logstash-plugins/logstash-input-azure_event_hubs/pull/92)
+
 ## 1.4.7
   - [DOCS] Clarify examples for single and multiple event hubs [#90](https://github.com/logstash-plugins/logstash-input-azure_event_hubs/pull/90)
 

VERSION

@@ -1 +1 @@
-1.4.7
+1.4.8

lib/logstash/inputs/azure_event_hubs.rb

@@ -332,8 +332,7 @@ def initialize(params)
         connections = *params['event_hub_connections'] # ensure array
         connections.each.with_index do |_connection, i|
           begin
-            connection = self.class.replace_placeholders(_connection) if self.class.respond_to? 'replace_placeholders' # 6.x
-            connection = self.class.replace_env_placeholders(_connection) if self.class.respond_to? 'replace_env_placeholders' # 5.x
+            connection = replace_connection_placeholders(_connection)
             event_hub_name = ConnectionStringBuilder.new(connection).getEventHubName
             redacted_connection = connection.gsub(/(SharedAccessKey=)([0-9a-zA-Z=+]*)([;]*)(.*)/, '\\1<redacted>\\3\\4')
             params['event_hub_connections'][i] = redacted_connection # protect from leaking logs
@@ -361,6 +360,25 @@ def initialize(params)
 
   attr_reader :event_hubs_exploded
 
+  def replace_connection_placeholders(value)
+    connection = value
+    if self.class.respond_to? :replace_placeholders
+      # Logstash 6.x
+      if self.class.method(:replace_placeholders).arity == 1
+        connection = self.class.replace_placeholders(connection)
+      else
+        # Logstash 8.15.1 and 8.15.2 changed the method arity including a new boolean parameter `refine`.
+        # This was fixed in 8.15.3. see https://github.com/elastic/logstash/pull/16485
+        connection = self.class.replace_placeholders(connection, false)
+      end
+    end
+
+    # Logstash 5.x
+    connection = self.class.replace_env_placeholders(connection) if self.class.respond_to? :replace_env_placeholders
+
+    connection
+  end
+
   def register
     # augment the exploded config with the defaults
     @event_hubs_exploded.each do |event_hub|