Implement ParseCompleted Step

Author: J12934

operator/apis/execution/v1/scan_types.go

@@ -64,7 +64,7 @@ const (
 type HookStatus struct {
 	HookName string    `json:"hookName"`
 	State    HookState `json:"state"`
-	JobName  string    `json:"jobName"`
+	JobName  string    `json:"jobName,omitempty"`
 }
 
 // FindingStats contains the general stats about the results of the scan

operator/apis/execution/v1/zz_generated.deepcopy.go

@@ -121,10 +121,10 @@ spec:
                   jobName:
                     type: string
                   state:
+                    description: HookState Describes the State of a Hook on a Scan
                     type: string
                 required:
                 - hookName
-                - jobName
                 - state
                 type: object
               type: array

operator/config/crd/bases/execution.experimental.securecodebox.io_scans.yaml

@@ -0,0 +1,8 @@
+apiVersion: execution.experimental.securecodebox.io/v1
+kind: ScanCompletionHook
+metadata:
+  name: "sleep-rw"
+spec:
+  image: "sleep"
+  type: "ReadAndWrite"
+  env: []

operator/config/samples/execution_v1_readandwritehook.yaml

@@ -114,8 +114,42 @@ func (r *ScanReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {
 		err = r.checkIfParsingIsCompleted(&scan)
 	case "ParseCompleted":
 		// Hook status erstellen
-		// List all ReadAndWrite Hook -> Hook Status an Scan hängen
-		// Scan State auf ReadAndWriteHookProcessing setzen
+
+		var scanCompletionHooks executionv1.ScanCompletionHookList
+
+		if err := r.List(ctx, &scanCompletionHooks, client.InNamespace(scan.Namespace)); err != nil {
+			r.Log.V(7).Info("Unable to fetch ScanCompletionHooks")
+			return ctrl.Result{}, err
+		}
+
+		r.Log.Info("Found ScanCompletionHooks", "ScanCompletionHooks", len(scanCompletionHooks.Items))
+
+		readAndWriteHooks := []executionv1.ScanCompletionHook{}
+		// filter all ReadAndWriteHooks in the scamCompletionHooks list
+		for _, hook := range scanCompletionHooks.Items {
+			if hook.Spec.Type == executionv1.ReadAndWrite {
+				readAndWriteHooks = append(readAndWriteHooks, hook)
+			}
+		}
+
+		r.Log.Info("Found ReadAndWriteHooks", "ReadAndWriteHooks", len(readAndWriteHooks))
+
+		hookStatus := []executionv1.HookStatus{}
+
+		for _, hook := range readAndWriteHooks {
+			hookStatus = append(hookStatus, executionv1.HookStatus{
+				HookName: hook.Name,
+				State:    executionv1.Pending,
+			})
+		}
+
+		scan.Status.State = "ReadAndWriteHookProcessing"
+		scan.Status.ReadAndWriteHookStatus = hookStatus
+
+		if err := r.Status().Update(ctx, &scan); err != nil {
+			r.Log.Error(err, "unable to update Scan status")
+			return ctrl.Result{}, err
+		}
 	case "ReadAndWriteHookProcessing":
 		// Hook Status Array durchgegen