RHINENG-5011 playbook not getting dispatched with POST /profiles

infrastructure/persistence/inventory/inventory_repository.go

@@ -89,8 +89,17 @@ func (c *InventoryClient) GetInventoryClients(ctx context.Context, page int) (In
 	}
 	defer res.Body.Close()
 
-	err = json.NewDecoder(res.Body).Decode(&results)
-	if err != nil {
+	switch {
+	case res.StatusCode >= 400:
+		responseBody, err := io.ReadAll(res.Body)
+		if err != nil {
+			log.Error().Err(err).Msg("Error reading response body")
+			return results, fmt.Errorf("error reading response body: %w", err)
+		}
+		return results, fmt.Errorf("error response received: %v, response body: %v", res.StatusCode, string(responseBody))
+	}
+
+	if err := json.NewDecoder(res.Body).Decode(&results); err != nil {
 		body, _ := io.ReadAll(res.Body)
 		log.Error().Err(err).Msgf("error decoding inventory response: %v", string(body))
 	}

internal/dispatch/dispatch.go

@@ -7,31 +7,38 @@ import (
 	"config-manager/internal/db"
 	"context"
 
+	"github.com/redhatinsights/platform-go-middlewares/identity"
 	"github.com/rs/zerolog/log"
 )
 
-var profiles chan db.Profile
+type ProfileWithIdentity struct {
+	Profile  db.Profile
+	Identity identity.XRHID
+}
+
+var profileIdentityChan chan ProfileWithIdentity
 
 func init() {
-	profiles = make(chan db.Profile)
+	profileIdentityChan = make(chan ProfileWithIdentity)
 	go func() {
-		for p := range profiles {
-			hosts, err := inventory.NewInventoryClient().GetAllInventoryClients(context.Background())
+		for profileIdentity := range profileIdentityChan {
+			ctx := context.WithValue(context.Background(), identity.Key, profileIdentity.Identity)
+			hosts, err := inventory.NewInventoryClient().GetAllInventoryClients(ctx)
 			if err != nil {
 				log.Error().Err(err).Msg("cannot get hosts from inventory")
 				continue
 			}
 
-			internal.ApplyProfile(context.Background(), &p, hosts, func(resp []dispatcher.RunCreated) {
-				log.Info().Str("profile_id", p.ID.String()).Msg("applied profile")
+			internal.ApplyProfile(ctx, &profileIdentity.Profile, hosts, func(resp []dispatcher.RunCreated) {
+				log.Info().Str("profile_id", profileIdentity.Profile.ID.String()).Msg("applied profile")
 			})
 		}
 	}()
 }
 
-// Dispatch queues the profile on a channel to be dispatched to connected hosts.
-func Dispatch(p db.Profile) {
+// Dispatch queues the profile with identity on a channel to be dispatched to connected hosts.
+func Dispatch(profile db.Profile, identity identity.XRHID) {
 	go func() {
-		profiles <- p
+		profileIdentityChan <- ProfileWithIdentity{Profile: profile, Identity: identity}
 	}()
 }

internal/http/v2/handlers.go

@@ -182,8 +182,7 @@ func createProfile(w http.ResponseWriter, r *http.Request) {
 		render.RenderPlain(w, r, http.StatusInternalServerError, fmt.Sprintf("cannot insert new profile: %v", err), logger)
 		return
 	}
-
-	dispatch.Dispatch(newProfile)
+	dispatch.Dispatch(newProfile, identity.Get(r.Context()))
 
 	render.RenderJSON(w, r, http.StatusCreated, newProfile, logger)
 }