Update object upon deletion

If an object is deleted and the API responds with a resource, update the
deleted object.

This causes the object to be updated with the deletion timestamp.

Signed-off-by: Kevin McDermott <[email protected]>

Author: bigkevmcd

pkg/client/client_test.go

@@ -50,6 +50,7 @@ import (
 	"sigs.k8s.io/controller-runtime/examples/crd/pkg"
 	"sigs.k8s.io/controller-runtime/pkg/cache"
 	"sigs.k8s.io/controller-runtime/pkg/client"
+	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 )
 
 func deleteDeployment(ctx context.Context, dep *appsv1.Deployment, ns string) {
@@ -1638,6 +1639,7 @@ U5wwSivyi7vmegHKmblOzNVKA5qPO8zWzqBC
 				nodeName := node.Name
 				err = cl.Delete(context.TODO(), node)
 				Expect(err).NotTo(HaveOccurred())
+				Expect(node.ObjectMeta.DeletionTimestamp).To(BeNil())
 
 				By("validating the Node no longer exists")
 				_, err = clientset.CoreV1().Nodes().Get(ctx, nodeName, metav1.GetOptions{})
@@ -1654,6 +1656,36 @@ U5wwSivyi7vmegHKmblOzNVKA5qPO8zWzqBC
 				Expect(err).To(HaveOccurred())
 			})
 
+			It("should update the resource when deleting if it receives a response", func() {
+				cl, err := client.New(cfg, client.Options{})
+				Expect(err).NotTo(HaveOccurred())
+				Expect(cl).NotTo(BeNil())
+
+				By("initially creating a Node")
+				node, err := clientset.CoreV1().Nodes().Create(ctx, node, metav1.CreateOptions{})
+				Expect(err).NotTo(HaveOccurred())
+
+				By("adding a finalizer we prevent the node from being deleted immediately")
+				controllerutil.AddFinalizer(node, "example.com/test")
+				node, err = clientset.CoreV1().Nodes().Update(ctx, node, metav1.UpdateOptions{})
+				Expect(err).NotTo(HaveOccurred())
+
+				By("deleting the Node")
+				nodeName := node.Name
+				err = cl.Delete(context.TODO(), node)
+				Expect(err).NotTo(HaveOccurred())
+				Expect(node.ObjectMeta.DeletionTimestamp).NotTo(BeNil())
+
+				By("removing the finalizer")
+				controllerutil.RemoveFinalizer(node, "example.com/test")
+				_, err = clientset.CoreV1().Nodes().Update(ctx, node, metav1.UpdateOptions{})
+				Expect(err).NotTo(HaveOccurred())
+
+				By("validating the Node no longer exists")
+				_, err = clientset.CoreV1().Nodes().Get(ctx, nodeName, metav1.GetOptions{})
+				Expect(err).To(HaveOccurred())
+			})
+
 			PIt("should fail if the object doesn't have meta", func() {
 
 			})

pkg/client/dryrun_test.go

@@ -182,7 +182,8 @@ var _ = Describe("DryRunClient", func() {
 	})
 
 	It("should not delete objects", func() {
-		Expect(getClient().Delete(ctx, dep)).NotTo(HaveOccurred())
+		changedDep := dep.DeepCopy()
+		Expect(getClient().Delete(ctx, changedDep)).NotTo(HaveOccurred())
 
 		actual, err := clientset.AppsV1().Deployments(ns).Get(ctx, dep.Name, metav1.GetOptions{})
 		Expect(err).NotTo(HaveOccurred())
@@ -193,7 +194,8 @@ var _ = Describe("DryRunClient", func() {
 	It("should not delete objects with opts", func() {
 		opts := &client.DeleteOptions{DryRun: []string{"Bye", "Pippa"}}
 
-		Expect(getClient().Delete(ctx, dep, opts)).NotTo(HaveOccurred())
+		changedDep := dep.DeepCopy()
+		Expect(getClient().Delete(ctx, changedDep, opts)).NotTo(HaveOccurred())
 
 		actual, err := clientset.AppsV1().Deployments(ns).Get(ctx, dep.Name, metav1.GetOptions{})
 		Expect(err).NotTo(HaveOccurred())

pkg/client/typed_client.go

@@ -85,7 +85,7 @@ func (c *typedClient) Delete(ctx context.Context, obj Object, opts ...DeleteOpti
 		Name(o.GetName()).
 		Body(deleteOpts.AsDeleteOptions()).
 		Do(ctx).
-		Error()
+		Into(obj)
 }
 
 // DeleteAllOf implements client.Client.