feat(kubernetes): pods_delete deletes managed resources

Author: manusa

pkg/kubernetes/pods.go

@@ -6,10 +6,12 @@ import (
 	v1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
+	labelutil "k8s.io/apimachinery/pkg/labels"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/apimachinery/pkg/util/intstr"
 	"k8s.io/apimachinery/pkg/util/rand"
+	"k8s.io/client-go/dynamic"
 	"k8s.io/client-go/kubernetes"
 )
 
@@ -32,8 +34,53 @@ func (k *Kubernetes) PodsGet(ctx context.Context, namespace, name string) (strin
 }
 
 func (k *Kubernetes) PodsDelete(ctx context.Context, namespace, name string) (string, error) {
-	// TODO
-	return "", nil
+	cs, err := kubernetes.NewForConfig(k.cfg)
+	if err != nil {
+		return "", err
+	}
+
+	namespace = namespaceOrDefault(namespace)
+	pod, err := cs.CoreV1().Pods(namespace).Get(ctx, name, metav1.GetOptions{})
+	if err != nil {
+		return "", err
+	}
+
+	isManaged := pod.GetLabels()[AppKubernetesManagedBy] == version.BinaryName
+	managedLabelSelector := labelutil.Set{
+		AppKubernetesManagedBy: version.BinaryName,
+		AppKubernetesName:      pod.GetLabels()[AppKubernetesName],
+	}.AsSelector()
+
+	// Delete managed service
+	if isManaged {
+		if sl, _ := cs.CoreV1().Services(namespace).List(ctx, metav1.ListOptions{
+			LabelSelector: managedLabelSelector.String(),
+		}); sl != nil {
+			for _, svc := range sl.Items {
+				_ = cs.CoreV1().Services(namespace).Delete(ctx, svc.Name, metav1.DeleteOptions{})
+			}
+		}
+	}
+
+	// Delete managed Route
+	if isManaged && k.supportsGroupVersion("route.openshift.io/v1") {
+		dynamicClient, dErr := dynamic.NewForConfig(k.cfg)
+		if dErr != nil {
+			return "", dErr
+		}
+		routeResources := dynamicClient.
+			Resource(schema.GroupVersionResource{Group: "route.openshift.io", Version: "v1", Resource: "routes"}).
+			Namespace(namespace)
+		if rl, _ := routeResources.List(ctx, metav1.ListOptions{
+			LabelSelector: managedLabelSelector.String(),
+		}); rl != nil {
+			for _, route := range rl.Items {
+				_ = routeResources.Delete(ctx, route.GetName(), metav1.DeleteOptions{})
+			}
+		}
+
+	}
+	return "Pod deleted successfully", cs.CoreV1().Pods(namespace).Delete(ctx, name, metav1.DeleteOptions{})
 }
 
 func (k *Kubernetes) PodsLog(ctx context.Context, namespace, name string) (string, error) {

pkg/mcp/common_test.go

@@ -231,33 +231,18 @@ func createTestData(ctx context.Context, kc *kubernetes.Clientset) {
 		Create(ctx, &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "ns-2"}}, metav1.CreateOptions{})
 	_, _ = kc.CoreV1().Namespaces().
 		Create(ctx, &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "ns-to-delete"}}, metav1.CreateOptions{})
-	_, _ = kc.CoreV1().Pods("default").
-		Create(ctx, &corev1.Pod{
-			ObjectMeta: metav1.ObjectMeta{Name: "a-pod-in-default"},
-			Spec: corev1.PodSpec{
-				Containers: []corev1.Container{
-					{Name: "nginx", Image: "nginx"},
-				},
-			},
-		}, metav1.CreateOptions{})
-	_, _ = kc.CoreV1().Pods("ns-1").
-		Create(ctx, &corev1.Pod{
-			ObjectMeta: metav1.ObjectMeta{Name: "a-pod-in-ns-1"},
-			Spec: corev1.PodSpec{
-				Containers: []corev1.Container{
-					{Name: "nginx", Image: "nginx"},
-				},
-			},
-		}, metav1.CreateOptions{})
-	_, _ = kc.CoreV1().Pods("ns-2").
-		Create(ctx, &corev1.Pod{
-			ObjectMeta: metav1.ObjectMeta{Name: "a-pod-in-ns-2"},
-			Spec: corev1.PodSpec{
-				Containers: []corev1.Container{
-					{Name: "nginx", Image: "nginx"},
-				},
-			},
-		}, metav1.CreateOptions{})
+	_, _ = kc.CoreV1().Pods("default").Create(ctx, &corev1.Pod{
+		ObjectMeta: metav1.ObjectMeta{Name: "a-pod-in-default"},
+		Spec:       corev1.PodSpec{Containers: []corev1.Container{{Name: "nginx", Image: "nginx"}}},
+	}, metav1.CreateOptions{})
+	_, _ = kc.CoreV1().Pods("ns-1").Create(ctx, &corev1.Pod{
+		ObjectMeta: metav1.ObjectMeta{Name: "a-pod-in-ns-1"},
+		Spec:       corev1.PodSpec{Containers: []corev1.Container{{Name: "nginx", Image: "nginx"}}},
+	}, metav1.CreateOptions{})
+	_, _ = kc.CoreV1().Pods("ns-2").Create(ctx, &corev1.Pod{
+		ObjectMeta: metav1.ObjectMeta{Name: "a-pod-in-ns-2"},
+		Spec:       corev1.PodSpec{Containers: []corev1.Container{{Name: "nginx", Image: "nginx"}}},
+	}, metav1.CreateOptions{})
 	_, _ = kc.CoreV1().ConfigMaps("default").
 		Create(ctx, &corev1.ConfigMap{ObjectMeta: metav1.ObjectMeta{Name: "a-configmap-to-delete"}}, metav1.CreateOptions{})
 }

pkg/mcp/mcp_test.go

@@ -11,6 +11,7 @@ func TestTools(t *testing.T) {
 		"pods_list",
 		"pods_list_in_namespace",
 		"pods_get",
+		"pods_delete",
 		"pods_log",
 		"pods_run",
 		"resources_list",

pkg/mcp/pods.go

@@ -32,14 +32,25 @@ func (s *Sever) initPods() {
 			mcp.Required(),
 		),
 	), podsGet)
+	s.server.AddTool(mcp.NewTool(
+		"pods_delete",
+		mcp.WithDescription("Delete a Kubernetes Pod in the current or provided namespace with the provided name"),
+		mcp.WithString("namespace",
+			mcp.Description("Namespace to delete the Pod from"),
+		),
+		mcp.WithString("name",
+			mcp.Description("Name of the Pod to delete"),
+			mcp.Required(),
+		),
+	), podsDelete)
 	s.server.AddTool(mcp.NewTool(
 		"pods_log",
 		mcp.WithDescription("Get the logs of a Kubernetes Pod in the current or provided namespace with the provided name"),
 		mcp.WithString("namespace",
 			mcp.Description("Namespace to get the Pod logs from"),
 		),
 		mcp.WithString("name",
-			mcp.Description("Name of the Pod"),
+			mcp.Description("Name of the Pod to get the logs from"),
 			mcp.Required(),
 		),
 	), podsLog)
@@ -110,6 +121,26 @@ func podsGet(ctx context.Context, ctr mcp.CallToolRequest) (*mcp.CallToolResult,
 	return NewTextResult(ret, err), nil
 }
 
+func podsDelete(ctx context.Context, ctr mcp.CallToolRequest) (*mcp.CallToolResult, error) {
+	k, err := kubernetes.NewKubernetes()
+	if err != nil {
+		return NewTextResult("", fmt.Errorf("failed to delete pod: %v", err)), nil
+	}
+	ns := ctr.Params.Arguments["namespace"]
+	if ns == nil {
+		ns = ""
+	}
+	name := ctr.Params.Arguments["name"]
+	if name == nil {
+		return NewTextResult("", errors.New("failed to delete pod, missing argument name")), nil
+	}
+	ret, err := k.PodsDelete(ctx, ns.(string), name.(string))
+	if err != nil {
+		return NewTextResult("", fmt.Errorf("failed to delete pod %s in namespace %s: %v", name, ns, err)), nil
+	}
+	return NewTextResult(ret, err), nil
+}
+
 func podsLog(ctx context.Context, ctr mcp.CallToolRequest) (*mcp.CallToolResult, error) {
 	k, err := kubernetes.NewKubernetes()
 	if err != nil {