diff --git a/internal/sentinel/sentinel.go b/internal/sentinel/sentinel.go index 3c15368..c81690f 100644 --- a/internal/sentinel/sentinel.go +++ b/internal/sentinel/sentinel.go @@ -3,6 +3,7 @@ package sentinel import ( "context" "fmt" + "strings" "sync" "time" @@ -165,7 +166,7 @@ func (s *Sentinel) trigger(ctx context.Context) error { // Create CloudEvent event := cloudevents.NewEvent() event.SetSpecVersion(cloudevents.VersionV1) - event.SetType(fmt.Sprintf("com.redhat.hyperfleet.%s.reconcile", resource.Kind)) + event.SetType(fmt.Sprintf("com.redhat.hyperfleet.%s.reconcile", strings.ToLower(resource.Kind))) event.SetSource("hyperfleet-sentinel") event.SetID(uuid.New().String()) if err := event.SetData(cloudevents.ApplicationJSON, eventData); err != nil { diff --git a/internal/sentinel/sentinel_test.go b/internal/sentinel/sentinel_test.go index 45ddfaf..494f2c5 100644 --- a/internal/sentinel/sentinel_test.go +++ b/internal/sentinel/sentinel_test.go @@ -188,8 +188,8 @@ func TestTrigger_Success(t *testing.T) { } event := mockPublisher.publishedEvents[0] - if event.Type() != "com.redhat.hyperfleet.Cluster.reconcile" { - t.Errorf("Expected event type 'com.redhat.hyperfleet.Cluster.reconcile', got '%s'", event.Type()) + if event.Type() != "com.redhat.hyperfleet.cluster.reconcile" { + t.Errorf("Expected event type 'com.redhat.hyperfleet.cluster.reconcile', got '%s'", event.Type()) } if event.Source() != "hyperfleet-sentinel" { t.Errorf("Expected source 'hyperfleet-sentinel', got '%s'", event.Source())