Add e2e test for unframed requests

Signed-off-by: Tomas Longo <tlongo@sternad.de>

Author: TomasLongo

e2e-test/log/build.gradle

@@ -84,6 +84,14 @@ List<LogTestConfiguration> logTestConfigurations = [
                 'otel-logs-source-pipeline.yml',
                 'data_prepper.yml'
         ),
+        new LogTestConfiguration(
+                'basicLogOtelLogsSourceGrpcUnframedRequestsEndToEndTest',
+                'Runs the basic end-to-end test using the otel logs source grpc service with unframed requests enabled.',
+                'org.opensearch.dataprepper.integration.log.EndToEndOtelLogsSourceTest.testOtelLogsSourceWithUnframedRequestsPipelineEndToEnd*',
+                'data-prepper-otel-logs-source',
+                'otel-logs-source-unframed-requests-pipeline.yml',
+                'data_prepper.yml'
+        ),
 ]
 
 

e2e-test/log/src/integrationTest/java/org/opensearch/dataprepper/integration/log/EndToEndOtelLogsSourceTest.java

@@ -56,11 +56,19 @@ public class EndToEndOtelLogsSourceTest {
 
     @Test
     public void testOtelLogsSourcePipelineEndToEnd() throws InvalidProtocolBufferException {
-        ingestLogs();
+        ingestLogs("/otel-logs-pipeline/logs");
 
         searchForLogsAndAssert();
     }
 
+    @Test
+    public void testOtelLogsSourceWithUnframedRequestsPipelineEndToEnd() throws InvalidProtocolBufferException {
+        ingestLogs("/opentelemetry.proto.collector.logs.v1.LogsService/Export");
+
+        searchForLogsAndAssert();
+    }
+
+
     private HttpData createOtelLogsHttpRequest() throws InvalidProtocolBufferException {
         ExportLogsServiceRequest exportLogsServiceRequest = ExportLogsServiceRequest.newBuilder().addResourceLogs(
                 ResourceLogs.newBuilder()
@@ -101,12 +109,12 @@ private RestHighLevelClient createOpenSearchClient() {
                 .createClient(null);
     }
 
-    private void ingestLogs() throws InvalidProtocolBufferException {
+    private void ingestLogs(String path) throws InvalidProtocolBufferException {
         RequestHeaders headers = RequestHeaders.builder()
                 .scheme(SessionProtocol.HTTP)
                 .authority(String.format("127.0.0.1:%d", SOURCE_PORT))
                 .method(HttpMethod.POST)
-                .path("/otel-logs-pipeline/logs")
+                .path(path)
                 .contentType(MediaType.JSON_UTF_8)
                 .build();
 

e2e-test/log/src/integrationTest/resources/otel-logs-source-unframed-requests-pipeline.yml

@@ -0,0 +1,16 @@
+otel-logs-pipeline:
+  workers: 2
+  source:
+    otel_logs_source:
+      http_path: "/${pipelineName}/logs"
+      port: 2021
+      ssl: false
+      unframed_requests: true
+  sink:
+    - opensearch:
+        hosts: [ "https://node-0.example.com:9200" ]
+        username: "admin"
+        password: "admin"
+        insecure: true
+        index: "otel-logs-index"
+        flush_timeout: 5000