fix: add entity UID into event name to generate relation.

This fixes [bug]: Events are not correctly generated in relation with the source entity #681.

Author: buehler

src/KubeOps.Operator/Builder/OperatorBuilder.cs

@@ -128,7 +128,7 @@ private static Func<IServiceProvider, EventPublisher> CreateEventPublisher()
                     message,
                     type);
 
-                var eventName = $"{entity.Name()}.{@namespace}.{reason}.{message}.{type}";
+                var eventName = $"{entity.Uid()}.{entity.Name()}.{@namespace}.{reason}.{message}.{type}";
                 var encodedEventName =
                     Convert.ToHexString(
                         SHA512.HashData(

src/KubeOps.Transpiler/Crds.cs

@@ -330,7 +330,8 @@ private static V1JSONSchemaProps Map(this MetadataLoadContext context, Type type
             "System.ValueType" => context.MapValueType(type),
             "System.Enum" => new V1JSONSchemaProps
             {
-                Type = String, EnumProperty = Enum.GetNames(type).Cast<object>().ToList(),
+                Type = String,
+                EnumProperty = Enum.GetNames(type).Cast<object>().ToList(),
             },
             _ => throw InvalidType(type),
         };

test/KubeOps.Operator.Test/Events/EventPublisher.Integration.Test.cs

@@ -25,15 +25,16 @@ public class EventPublisherIntegrationTest : IntegrationTestBase
     [Fact]
     public async Task Should_Create_New_Event()
     {
-        var eventName = $"single-entity.{_ns.Namespace}.REASON.message.Normal";
+        var entity =
+            await _client.CreateAsync(new V1OperatorIntegrationTestEntity("single-entity", "username", _ns.Namespace));
+        await _mock.WaitForInvocations;
+
+        var eventName = $"{entity.Uid()}.single-entity.{_ns.Namespace}.REASON.message.Normal";
         var encodedEventName =
             Convert.ToHexString(
                 SHA512.HashData(
                     Encoding.UTF8.GetBytes(eventName)));
 
-        await _client.CreateAsync(new V1OperatorIntegrationTestEntity("single-entity", "username", _ns.Namespace));
-        await _mock.WaitForInvocations;
-
         var e = await _client.GetAsync<Corev1Event>(encodedEventName, _ns.Namespace);
         e!.Count.Should().Be(1);
         e.Metadata.Annotations.Should().Contain(a => a.Key == "originalName" && a.Value == eventName);
@@ -43,15 +44,16 @@ public async Task Should_Create_New_Event()
     public async Task Should_Increase_Count_On_Existing_Event()
     {
         _mock.TargetInvocationCount = 5;
-        var eventName = $"test-entity.{_ns.Namespace}.REASON.message.Normal";
+        var entity =
+            await _client.CreateAsync(new V1OperatorIntegrationTestEntity("test-entity", "username", _ns.Namespace));
+        await _mock.WaitForInvocations;
+
+        var eventName = $"{entity.Uid()}.test-entity.{_ns.Namespace}.REASON.message.Normal";
         var encodedEventName =
             Convert.ToHexString(
                 SHA512.HashData(
                     Encoding.UTF8.GetBytes(eventName)));
 
-        await _client.CreateAsync(new V1OperatorIntegrationTestEntity("test-entity", "username", _ns.Namespace));
-        await _mock.WaitForInvocations;
-
         var e = await _client.GetAsync<Corev1Event>(encodedEventName, _ns.Namespace);
         e!.Count.Should().Be(5);
         e.Metadata.Annotations.Should().Contain(a => a.Key == "originalName" && a.Value == eventName);
@@ -78,9 +80,10 @@ protected override void ConfigureHost(HostApplicationBuilder builder)
             .AddController<TestController, V1OperatorIntegrationTestEntity>();
     }
 
-    private class TestController(InvocationCounter<V1OperatorIntegrationTestEntity> svc,
-            EntityRequeue<V1OperatorIntegrationTestEntity> requeue,
-            EventPublisher eventPublisher)
+    private class TestController(
+        InvocationCounter<V1OperatorIntegrationTestEntity> svc,
+        EntityRequeue<V1OperatorIntegrationTestEntity> requeue,
+        EventPublisher eventPublisher)
         : IEntityController<V1OperatorIntegrationTestEntity>
     {
         public async Task ReconcileAsync(V1OperatorIntegrationTestEntity entity)