Moves problem write

internal/handler/insightsParserFilter.go

@@ -32,7 +32,6 @@ func processSbomInsightsData(h *Messaging, insights InsightsData, v string, apiC
 	}
 
 	// we process the SBOM here
-	// TODO: This should actually live in its own function somewhere else.
 	if h.ProblemsFromSBOM == true {
 		isAlive, err := IsTrivyServerIsAlive(h.TrivyServerEndpoint)
 		if err != nil {

internal/handler/main.go

@@ -400,7 +400,19 @@ func (h *Messaging) deleteExistingFactsBySource(apiClient graphql.Client, enviro
 }
 
 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)
+
+	apiClient := h.getApiClient()
+	_, environment, apiErr := determineResourceFromLagoonAPI(apiClient, resource)
+
+	if apiErr != nil {
+		return apiErr
+	}
+
+	slog.Info(fmt.Sprintf("Found the following problems for Project '%v', environment '%v', source '%v", resource.Project, resource.Environment, source))
+	err := writeProblemsArrayToApi(apiClient, environment.Id, problemSource, resource.Service, result)
+	if err != nil {
+		return fmt.Errorf("unable to write problems to api: %v", err.Error())
+	}
 	return nil
 }
 

internal/handler/trivyProcessing.go

@@ -29,10 +29,6 @@ func SbomToProblems(apiClient graphql.Client, trivyRemoteAddress string, bomWrit
 		problemsArray[i].Source = problemSource
 	}
 
-	err = writeProblemsArrayToApi(apiClient, environmentId, problemSource, service, problemsArray)
-	if err != nil {
-		return problemsArray, fmt.Errorf("unable to execute trivy processing- writing problems to api: %v", err.Error())
-	}
 	return problemsArray, nil
 }