Fix generation output configuration if used receiver input for ViaQ data model

Author: vparfonov

test/e2e/logforwarding/lokistack/forward_to_lokistack_test.go

@@ -17,8 +17,10 @@ import (
 
 var _ = Describe("[ClusterLogForwarder] Forward to Lokistack", func() {
 	const (
-		forwarderName = "my-forwarder"
-		logGenName    = "log-generator"
+		forwarderName    = "my-forwarder"
+		logGenName       = "log-generator"
+		httpReceiverPort = 8080
+		httpReceiver     = "http-audit"
 	)
 	var (
 		err               error
@@ -236,6 +238,50 @@ var _ = Describe("[ClusterLogForwarder] Forward to Lokistack", func() {
 		Expect(found).To(BeTrue())
 	})
 
+	It("should send logs to lokistack with HTTP receiver as audit logs", func() {
+		forwarder.Spec.Inputs = []obs.InputSpec{
+			{
+				Name: httpReceiver,
+				Type: obs.InputTypeReceiver,
+				Receiver: &obs.ReceiverSpec{
+					Type: obs.ReceiverTypeHTTP,
+					Port: httpReceiverPort,
+					HTTP: &obs.HTTPReceiver{
+						Format: obs.HTTPReceiverFormatKubeAPIAudit,
+					},
+				},
+			},
+		}
+
+		forwarder.Spec.Pipelines = []obs.PipelineSpec{
+			{
+				Name:       "input-receiver-logs",
+				OutputRefs: []string{"lokistack-otlp"},
+				InputRefs:  []string{httpReceiver},
+			},
+		}
+
+		forwarder.Spec.Outputs = append(forwarder.Spec.Outputs, *lokiStackOut)
+
+		if err := e2e.CreateObservabilityClusterLogForwarder(forwarder); err != nil {
+			Fail(fmt.Sprintf("Unable to create an instance of logforwarder: %v", err))
+		}
+		if err := e2e.WaitForDaemonSet(forwarder.Namespace, forwarder.Name); err != nil {
+			Fail(err.Error())
+		}
+
+		httpReceiverServiceName := fmt.Sprintf("%s-%s", forwarderName, httpReceiver)
+		httpReceiverEndpoint := fmt.Sprintf("https://%s.%s.svc.cluster.local:%d", httpReceiverServiceName, deployNS, httpReceiverPort)
+
+		if err = e2e.DeployCURLLogGeneratorWithNamespaceAndEndpoint(deployNS, httpReceiverEndpoint); err != nil {
+			Fail(fmt.Sprintf("unable to deploy log generator %v.", err))
+		}
+
+		found, err := lokistackReceiver.HasAuditLogs(serviceAccount.Name, framework.DefaultWaitForLogsTimeout)
+		Expect(err).To(BeNil())
+		Expect(found).To(BeTrue())
+	})
+
 	AfterEach(func() {
 		e2e.Cleanup()
 		e2e.WaitForCleanupCompletion(logGenNS, []string{"test"})