Replace Resource AfterAddOrModified (#17)

Author: pmdevers

examples/SimpleOperator/Projects/Project.cs

@@ -3,7 +3,7 @@
 
 namespace SimpleOperator.Projects;
 
-[KubernetesEntity(Group = "sonarcloud.io", ApiVersion = "v1alpha1", Kind = "Project", PluralName = "projects")]
+[KubernetesEntity(Group = "operator.io", ApiVersion = "v1alpha1", Kind = "Project", PluralName = "projects")]
 public class Project : CustomResource<Project.Specs, Project.ProjectStatus>
 {
     public class Specs

examples/SimpleOperator/Projects/ProjectController.cs

@@ -10,6 +10,14 @@ public class ProjectController(ILoggerFactory logger) : Controller<Project>
     public override Task AddOrModifyAsync(Project resource, CancellationToken cancellationToken)
     {
         _logger.LogDebug("Controller AddOrModify received.");
+
+        resource.Metadata.Labels = new Dictionary<string, string>
+        {
+            { "created", "created" }
+        };
+
+        resource.Status.Result = "HEHE";
+
         return base.AddOrModifyAsync(resource, cancellationToken);
     }
 

examples/SimpleOperator/Projects/TestItem.cs

@@ -5,7 +5,7 @@
 
 namespace SimpleOperator.Projects;
 
-[KubernetesEntity(Group = "sonarcloud.io", ApiVersion = "v1alpha1", Kind = "TestItem", PluralName = "testitems")]
+[KubernetesEntity(Group = "operator.io", ApiVersion = "v1alpha1", Kind = "TestItem", PluralName = "testitems")]
 public class TestItem : CustomResource<TestItemSpec, TestItemStatus>
 {
     public class TestItemSpec

examples/SimpleOperator/Properties/launchSettings.json

@@ -10,7 +10,7 @@
         },
         "Install": {
             "commandName": "Project",
-            "commandLineArgs": "install",
+            "commandLineArgs": "install > ./install.yaml",
             "environmentVariables": {
                 "ASPNETCORE_ENVIRONMENT": "Development"
             },

examples/SimpleOperator/install.yaml

@@ -0,0 +1,182 @@
+apiVersion: apiextensions.k8s.io/v1
+kind: CustomResourceDefinition
+metadata:
+  name: testitems.operator.io
+spec:
+  group: operator.io
+  names:
+    kind: TestItem
+    listKind: TestItemList
+    plural: testitems
+    singular: testitem
+  scope: Namespaced
+  versions:
+  - name: v1alpha1
+    schema:
+      openAPIV3Schema:
+        properties:
+          status:
+            nullable: false
+            type: object
+          spec:
+            nullable: false
+            properties:
+              scope:
+                enum:
+                - Namespaced
+                - Cluster
+                type: string
+              string:
+                nullable: false
+                type: string
+            required:
+            - scope
+            type: object
+        type: object
+    served: true
+    storage: true
+---
+apiVersion: apiextensions.k8s.io/v1
+kind: CustomResourceDefinition
+metadata:
+  name: projects.operator.io
+spec:
+  group: operator.io
+  names:
+    kind: Project
+    listKind: ProjectList
+    plural: projects
+    singular: project
+  scope: Namespaced
+  versions:
+  - name: v1alpha1
+    schema:
+      openAPIV3Schema:
+        properties:
+          status:
+            nullable: false
+            properties:
+              result:
+                nullable: false
+                type: string
+            required:
+            - result
+            type: object
+          spec:
+            nullable: false
+            properties:
+              name:
+                nullable: false
+                type: string
+              organization:
+                nullable: false
+                type: string
+              project:
+                nullable: false
+                type: string
+            required:
+            - name
+            - organization
+            - project
+            type: object
+        type: object
+    served: true
+    storage: true
+---
+apiVersion: rbac.authorization.k8s.io/v1
+kind: ClusterRole
+metadata:
+  name: simple-operator-role
+rules:
+- apiGroups:
+  - ""
+  resources:
+  - events
+  verbs:
+  - get
+  - list
+  - create
+  - update
+- apiGroups:
+  - coordination.k8s.io
+  resources:
+  - leases
+  verbs:
+  - '*'
+- apiGroups:
+  - operator.io
+  resources:
+  - testitems
+  - projects
+  verbs:
+  - '*'
+- apiGroups:
+  - operator.io
+  resources:
+  - testitems/status
+  - projects/status
+  verbs:
+  - get
+  - update
+  - patch
+---
+apiVersion: rbac.authorization.k8s.io/v1
+kind: ClusterRoleBinding
+metadata:
+  name: simple-operator-role-binding
+roleRef:
+  apiGroup: rbac.authorization.k8s.io
+  kind: ClusterRole
+  name: simple-operator-role
+subjects:
+- kind: ServiceAccount
+  name: default
+  namespace: system
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  labels:
+    operator-deployment: simple-operator
+  name: simple-operator-deployment
+spec:
+  replicas: 1
+  revisionHistoryLimit: 0
+  selector:
+    matchLabels:
+      operator-deployment: simple-operator
+  template:
+    metadata:
+      labels:
+        operator-deployment: simple-operator
+    spec:
+      containers:
+      - env:
+        - name: test
+          valueFrom:
+            fieldRef:
+              fieldPath: metadata.namespace
+        image: ghcr.io/operator/operator:latest
+        name: simple-operator
+        resources:
+          limits:
+            cpu: 100m
+            memory: 128Mi
+          requests:
+            cpu: 100m
+            memory: 64Mi
+        securityContext:
+          allowPrivilegeEscalation: false
+          capabilities:
+            drop:
+            - ALL
+          runAsGroup: 2024
+          runAsNonRoot: true
+          runAsUser: 2024
+      securityContext:
+        runAsNonRoot: true
+        seccompProfile:
+          type: RuntimeDefault
+      terminationGracePeriodSeconds: 10
+---
+

src/K8sOperator.NET/EventWatcher.cs

@@ -240,6 +240,9 @@ private async Task HandleAddOrModifyAsync(T resource, CancellationToken cancella
         }
 
         await _controller.AddOrModifyAsync(resource, cancellationToken);
+        
+        resource = await ReplaceAsync(resource, _cancellationToken);
+        
         _changeTracker.TrackResourceGenerationAsHandled(resource);
 
         Logger.EndAddOrModify(resource);