Returns problems from sbom processor

internal/handler/insightsParserFilter.go

@@ -14,23 +14,7 @@ func processSbomInsightsData(h *Messaging, insights InsightsData, v string, apiC
 	logger := slog.With("ProjectName", resource.Project, "EnvironmentName", resource.Environment, "Source", source)
 
 	// ret values
-	problemSlice := []lagoonclient.LagoonProblem{
-		{
-			Id:                0,
-			Environment:       0,
-			Identifier:        "test",
-			Version:           "",
-			FixedVersion:      "",
-			Source:            "",
-			Service:           "",
-			Data:              "",
-			Severity:          "",
-			SeverityScore:     0,
-			AssociatedPackage: "",
-			Description:       "",
-			Links:             "",
-		},
-	}
+	var problemSlice []lagoonclient.LagoonProblem
 
 	if insights.InsightsType != Sbom {
 		return []LagoonFact{}, problemSlice, "", nil
@@ -57,7 +41,7 @@ func processSbomInsightsData(h *Messaging, insights InsightsData, v string, apiC
 			logger.Debug("Trivy is reachable")
 		}
 		if isAlive {
-			err = SbomToProblems(apiClient, h.TrivyServerEndpoint, "/tmp/", environment.Id, resource.Service, *bom)
+			problemSlice, err = SbomToProblems(apiClient, h.TrivyServerEndpoint, "/tmp/", environment.Id, resource.Service, *bom)
 		}
 		if err != nil {
 			return nil, problemSlice, "", err

internal/handler/main.go

@@ -428,6 +428,11 @@ func (h *Messaging) deleteExistingFactsBySource(apiClient graphql.Client, enviro
 	return nil
 }
 
+func (h *Messaging) SendProblemSliceToLagoon(result []lagoonclient.LagoonProblem, resource ResourceDestination, source string) error {
+	slog.Info(fmt.Sprintf("Found the following problems for Project '%v', environment '%v', source '%v"), resource.Project, resource.Environment, source)
+	return nil
+}
+
 func (h *Messaging) getApiClient() graphql.Client {
 	apiClient := graphql.NewClient(h.LagoonAPI.Endpoint, &http.Client{Transport: &authedTransport{wrapped: http.DefaultTransport, h: h}})
 	return apiClient

internal/handler/messaging.go

@@ -156,7 +156,12 @@ func (h *Messaging) processMessageQueue(message mq.Message) {
 			}
 			for _, lspm := range lagoonSourceProblemMapCollection {
 				for sourceName, problems := range lspm {
-					fmt.Println("GOT PROBLEM COUNT FOR SOURCE '%v': %v", sourceName, len(problems))
+					err := h.SendProblemSliceToLagoon(problems, resource, sourceName)
+					if err != nil {
+						slog.Error("Unable to write problems to api", "Error", err.Error())
+						rejectMessage(false)
+						return
+					}
 				}
 			}
 		}

internal/handler/trivyProcessing.go

@@ -17,10 +17,10 @@ import (
 
 const problemSource = "insights-handler-trivy"
 
-func SbomToProblems(apiClient graphql.Client, trivyRemoteAddress string, bomWriteDirectory string, environmentId int, service string, sbom cdx.BOM) error {
+func SbomToProblems(apiClient graphql.Client, trivyRemoteAddress string, bomWriteDirectory string, environmentId int, service string, sbom cdx.BOM) ([]lagoonclient.LagoonProblem, error) {
 	problemsArray, err := executeProcessingTrivy(trivyRemoteAddress, bomWriteDirectory, sbom)
 	if err != nil {
-		return fmt.Errorf("unable to execute trivy processing: %v", err.Error())
+		return problemsArray, fmt.Errorf("unable to execute trivy processing: %v", err.Error())
 	}
 
 	for i := 0; i < len(problemsArray); i++ {
@@ -31,9 +31,9 @@ func SbomToProblems(apiClient graphql.Client, trivyRemoteAddress string, bomWrit
 
 	err = writeProblemsArrayToApi(apiClient, environmentId, problemSource, service, problemsArray)
 	if err != nil {
-		return fmt.Errorf("unable to execute trivy processing- writing problems to api: %v", err.Error())
+		return problemsArray, fmt.Errorf("unable to execute trivy processing- writing problems to api: %v", err.Error())
 	}
-	return nil
+	return problemsArray, nil
 }
 
 func convertBOMToProblemsArray(environment int, source string, service string, bom cdx.BOM) ([]lagoonclient.LagoonProblem, error) {