From 863e2551e604a6a2559da4cf4eae13f26bf77973 Mon Sep 17 00:00:00 2001
From: Ivan Malopinsky <imsky@users.noreply.github.com>
Date: Tue, 17 Apr 2018 16:10:04 -0400
Subject: [PATCH] implement "delete" action

---
 plan.go | 56 +++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 55 insertions(+), 1 deletion(-)

diff --git a/plan.go b/plan.go
index 9d44bc0..8287cdc 100644
--- a/plan.go
+++ b/plan.go
@@ -34,7 +34,24 @@ func pairObjectsByCriteria(srcObjects []runtime.Object, dstObjects []runtime.Obj
 		pairs = append(pairs, pair)
 	}
 
-	//todo: iterate over dstObjects
+	for i := range dstObjects {
+		dstMetadata, dstLabels := getObjectMetadata(dstObjects[i])
+		pair := ObjectPair{nil, &dstObjects[i]}
+
+		for j := range srcObjects {
+			srcMetadata, srcLabels := getObjectMetadata(srcObjects[j])
+
+			if criteria.label != "" &&
+				srcLabels.Get(criteria.label) == dstLabels.Get(criteria.label) &&
+				srcMetadata.GetNamespace() == dstMetadata.GetNamespace() {
+				pair.src = &srcObjects[j]
+			}
+		}
+
+		if pair.src == nil {
+			pairs = append(pairs, pair)
+		}
+	}
 
 	return pairs
 }
@@ -142,6 +159,43 @@ func executePlan(plan []Step, config PlanConfig) {
 			default:
 				_ = srcType
 			}
+		} else if step.action == "delete" {
+			dst := *step.pair.dst
+			dstMetadata, _ := getObjectMetadata(dst)
+			propagationPolicy := metav1.DeletePropagationForeground
+
+			switch dstType := dst.(type) {
+			case *batchv1.Job:
+				fmt.Println(`Deleting Job "` + dstMetadata.GetName() + `"`)
+
+				if !execute {
+					break
+				}
+
+				err := clientset.BatchV1().Jobs(dstMetadata.GetNamespace()).Delete(dstMetadata.GetName(), &metav1.DeleteOptions{PropagationPolicy: &propagationPolicy})
+
+				if err != nil {
+					panic(err)
+				}
+
+				waitForObjectDeletion(dst, clientset)
+			case *batchv2alpha1.CronJob:
+				fmt.Println(`Deleting CronJob "` + dstMetadata.GetName() + `"`)
+
+				if !execute {
+					break
+				}
+
+				err := clientset.BatchV2alpha1().CronJobs(dstMetadata.GetNamespace()).Delete(dstMetadata.GetName(), &metav1.DeleteOptions{PropagationPolicy: &propagationPolicy})
+
+				if err != nil {
+					panic(err)
+				}
+
+				waitForObjectDeletion(dst, clientset)
+			default:
+				_ = dstType
+			}
 		} else if step.action == "update" {
 			src := *step.pair.src
 			dst := *step.pair.dst