fix notification cr kind

Author: williamlardier

tests/@setup/src/notifications.ts

@@ -160,13 +160,6 @@ async function getUUIDFromBackbeat(k8sClient: KubernetesClient, namespace: strin
         `app.kubernetes.io/name=backbeat-config,app.kubernetes.io/instance=${zenkoName}`
     );
 
-    logger.info('Found secrets for UUID extraction', {
-        count: secrets.length,
-        namespace,
-        instanceId,
-        zenkoName
-    });
-
     if (!secrets.length) {
         throw new Error(`No backbeat config secret found with Zenko name ${zenkoName} (instanceId: ${instanceId}) in namespace ${namespace}`);
     }
@@ -175,13 +168,6 @@ async function getUUIDFromBackbeat(k8sClient: KubernetesClient, namespace: strin
     const configJson = k8sClient.getSecretData(secrets[0], 'config.json');
     const config: BackbeatConfig = JSON.parse(configJson);
 
-    logger.info('Backbeat config structure', {
-        hasKafka: !!config.kafka,
-        hasExtensions: !!config.extensions,
-        hasReplication: !!config.extensions?.replication,
-        replicationTopic: config.extensions?.replication?.topic
-    });
-
     // Extract UUID from replication topic
     let uuid = config.extensions.replication.topic.replace(/"/g, ''); // Remove quotes
     logger.debug('UUID before processing', { rawUuid: uuid });
@@ -208,57 +194,48 @@ async function applyNotificationDestinations(k8sClient: KubernetesClient, namesp
     const notifDestTopic = process.env[kafkaTopicsConfig.notificationTopics[0].envVar] || kafkaTopicsConfig.notificationTopics[0].default;
     const notifAltDestTopic = process.env[kafkaTopicsConfig.notificationTopics[1].envVar] || kafkaTopicsConfig.notificationTopics[1].default;
 
-    // Create notification config ConfigMap
-    const notificationConfigMap = {
-        apiVersion: 'v1',
-        kind: 'ConfigMap',
+    // Create ZenkoNotificationTarget resources (the correct CRD that actually exists)
+    const zenkoName = process.env.ZENKO_NAME || 'end2end';
+    const [kafkaHostOnly, kafkaPortOnly] = kafkaHost.split(':');
+    
+    const primaryNotificationTarget = {
+        apiVersion: 'zenko.io/v1alpha2',
+        kind: 'ZenkoNotificationTarget',
         metadata: {
-            name: 'notification-config',
-            namespace
+            name: 'kafka-destination',
+            namespace,
+            labels: {
+                'app.kubernetes.io/instance': zenkoName
+            }
         },
-        data: {
-            'destinations.yaml': `destinations:
-  - name: kafka-destination
-    type: kafka
-    config:
-      bootstrapServers: "${kafkaHost.split(':')[0]}:${kafkaPort}"
-      topic: "${notifDestTopic}"
-      securityProtocol: PLAINTEXT
-  - name: kafka-alt-destination
-    type: kafka
-    config:
-      bootstrapServers: "${kafkaHost.split(':')[0]}:${kafkaPort}"
-      topic: "${notifAltDestTopic}"
-      securityProtocol: PLAINTEXT`
+        spec: {
+            type: 'kafka',
+            host: kafkaHostOnly,
+            port: parseInt(kafkaPortOnly || kafkaPort, 10),
+            destinationTopic: notifDestTopic
         }
     };
 
-    // Create BucketNotificationConfiguration custom resource
-    const bucketNotificationConfig = {
-        apiVersion: 'zenko.io/v1alpha1',
-        kind: 'BucketNotificationConfiguration',
+    const altNotificationTarget = {
+        apiVersion: 'zenko.io/v1alpha2',
+        kind: 'ZenkoNotificationTarget',
         metadata: {
-            name: 'notification-destinations',
-            namespace
+            name: 'kafka-alt-destination',
+            namespace,
+            labels: {
+                'app.kubernetes.io/instance': zenkoName
+            }
         },
         spec: {
-            configurations: [
-                {
-                    name: 'primary',
-                    destination: 'kafka-destination',
-                    events: ['s3:ObjectCreated:*', 's3:ObjectRemoved:*']
-                },
-                {
-                    name: 'alternative',
-                    destination: 'kafka-alt-destination',
-                    events: ['s3:ObjectCreated:Put', 's3:ObjectCreated:Post']
-                }
-            ]
+            type: 'kafka',
+            host: kafkaHostOnly,
+            port: parseInt(kafkaPortOnly || kafkaPort, 10),
+            destinationTopic: notifAltDestTopic
         }
     };
 
     try {
-        await k8sClient.applyManifests([notificationConfigMap, bucketNotificationConfig], namespace);
+        await k8sClient.applyManifests([primaryNotificationTarget, altNotificationTarget], namespace);
 
         logger.info('Notification destinations applied successfully');
     } catch (error) {