copy events from tmp clone pvcs to their target pvc

Signed-off-by: dsanatar <[email protected]>

Author: Dsanatar

pkg/controller/clone/csi-clone.go

@@ -73,6 +73,12 @@ func (p *CSIClonePhase) Reconcile(ctx context.Context) (*reconcile.Result, error
 		}
 	}
 
+	targetPvc, err := cc.GetAnnotatedEventSource(ctx, p.Client, pvc)
+	if err != nil {
+		return nil, err
+	}
+	cc.CopyEvents(pvc, targetPvc, p.Client, p.Recorder)
+
 	done, err := isClaimBoundOrWFFC(ctx, p.Client, pvc)
 	if err != nil {
 		return nil, err

pkg/controller/clone/host-clone.go

@@ -165,6 +165,12 @@ func (p *HostClonePhase) Reconcile(ctx context.Context) (*reconcile.Result, erro
 		}
 	}
 
+	targetPvc, err := cc.GetAnnotatedEventSource(ctx, p.Client, actualClaim)
+	if err != nil {
+		return nil, err
+	}
+	cc.CopyEvents(actualClaim, targetPvc, p.Client, p.Recorder)
+
 	if !p.hostCloneComplete(actualClaim) {
 		// requeue to update status
 		return &reconcile.Result{RequeueAfter: 3 * time.Second}, nil

pkg/controller/clone/snap-clone.go

@@ -69,6 +69,12 @@ func (p *SnapshotClonePhase) Reconcile(ctx context.Context) (*reconcile.Result,
 		}
 	}
 
+	targetPvc, err := cc.GetAnnotatedEventSource(ctx, p.Client, pvc)
+	if err != nil {
+		return nil, err
+	}
+	cc.CopyEvents(pvc, targetPvc, p.Client, p.Recorder)
+
 	done, err := isClaimBoundOrWFFC(ctx, p.Client, pvc)
 	if err != nil {
 		return nil, err