Fix the otel_logs_source server in how it configures authentication t…

…o also support the getHttpAuthenticationService() alternative approach. (opensearch-project#5212)

Signed-off-by: David Venable <dlv@amazon.com>
(cherry picked from commit 6c9cdeb)

data-prepper-plugins/otel-logs-source/src/main/java/org/opensearch/dataprepper/plugins/source/otellogs/OTelLogsSource.java

@@ -5,6 +5,7 @@
 
 package org.opensearch.dataprepper.plugins.source.otellogs;
 
+import com.linecorp.armeria.server.HttpService;
 import com.linecorp.armeria.server.encoding.DecodingService;
 import org.opensearch.dataprepper.GrpcRequestExceptionHandler;
 import org.opensearch.dataprepper.plugins.codec.CompressionOption;
@@ -45,8 +46,10 @@
 import java.nio.charset.StandardCharsets;
 import java.util.Collections;
 import java.util.List;
+import java.util.Optional;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Executors;
+import java.util.function.Function;
 
 @DataPrepperPlugin(name = "otel_logs_source", pluginType = Source.class, pluginConfigurationType = OTelLogsSourceConfig.class)
 public class OTelLogsSource implements Source<Record<Object>> {
@@ -141,6 +144,13 @@ public void start(Buffer<Record<Object>> buffer) {
             } else {
                 sb.service(grpcServiceBuilder.build(), DecodingService.newDecorator());
             }
+
+            if (oTelLogsSourceConfig.getAuthentication() != null) {
+                final Optional<Function<? super HttpService, ? extends HttpService>> optionalHttpAuthenticationService =
+                        authenticationProvider.getHttpAuthenticationService();
+                optionalHttpAuthenticationService.ifPresent(sb::decorator);
+            }
+
             sb.requestTimeoutMillis(oTelLogsSourceConfig.getRequestTimeoutInMillis());
             if(oTelLogsSourceConfig.getMaxRequestLength() != null) {
                 sb.maxRequestLength(oTelLogsSourceConfig.getMaxRequestLength().getBytes());