Service name config (#168)

Add a config for service_name for IAM authentication, deafult: 'es'.

Signed-off-by: Deep Datta <deedatta@amazon.com>

Author: deepdatta

lib/logstash/outputs/opensearch/http_client/manticore_adapter.rb

@@ -76,6 +76,7 @@ def aws_iam_auth_initialization(options)
       instance_cred_timeout = options[:auth_type]["instance_profile_credentials_timeout"] || AWS_DEFAULT_PROFILE_CREDENTIAL_TIMEOUT
       region = options[:auth_type]["region"] || AWS_DEFAULT_REGION
       set_aws_region(region)
+      set_service_name(options[:auth_type]["service_name"] || AWS_SERVICE)
 
       credential_config = AWSIAMCredential.new(aws_access_key_id, aws_secret_access_key, session_token, profile, instance_cred_retries, instance_cred_timeout, region)
       @credentials = Aws::CredentialProviderChain.new(credential_config).resolve
@@ -93,6 +94,14 @@ def get_aws_region()
       @region
     end
 
+    def set_service_name(service_name)
+      @service_name = service_name
+    end
+
+    def get_service_name()
+      @service_name
+    end
+
     def set_user_password(options)
       @user = options[:auth_type]["user"]
       @password = options[:auth_type]["password"]

spec/unit/outputs/opensearch/http_client/manticore_adapter_spec.rb

@@ -61,12 +61,25 @@
         "aws_access_key_id"=>"AAAAAAAAAAAAAAAAAAAA",
         "aws_secret_access_key"=>"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA"}
     } }
+    let(:options_svc) { {
+      :auth_type => {
+        "type"=>"aws_iam",
+        "aws_access_key_id"=>"AAAAAAAAAAAAAAAAAAAA",
+        "aws_secret_access_key"=>"AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA",
+        "service_name"=>"svc_test"}
+    } }
     subject { described_class.new(logger, options) }
     let(:uri) { ::LogStash::Util::SafeURI.new("http://localhost:9200") }
     let(:sign_aws_request) {  }
 
     it "should validate AWS IAM credentials initialization" do
       expect(subject.aws_iam_auth_initialization(options)).not_to be_nil
+      expect(subject.get_service_name).to eq("es") 
+    end
+
+    it "should validate AWS IAM service_name config" do
+      expect(subject.aws_iam_auth_initialization(options_svc)).not_to be_nil
+      expect(subject.get_service_name).to eq("svc_test") 
     end
 
     it "should validate signing aws request" do