k8s & control: query all namespaces

This expands `get_pods` view to query all namespaces.

It also flattens out list[V1PodList] into just list[V1Pod]. This affected two downstream functions:
`down` and `_logs`. I updated them accordingly.

Author: mplsgrant

src/warnet/control.py

@@ -138,7 +138,7 @@ def delete_pod(pod_name, namespace):
 
         # Delete remaining pods
         pods = get_pods()
-        for pod in pods.items:
+        for pod in pods:
             futures.append(executor.submit(delete_pod, pod.metadata.name, pod.metadata.namespace))
 
         # Wait for all tasks to complete and print results
@@ -306,7 +306,7 @@ def _logs(pod_name: str, follow: bool):
     if pod_name == "":
         try:
             pods = get_pods()
-            pod_list = [item.metadata.name for item in pods.items]
+            pod_list = [item.metadata.name for item in pods]
         except Exception as e:
             print(f"Could not fetch any pods in namespace {namespace}: {e}")
             return

src/warnet/k8s.py

@@ -9,7 +9,7 @@
 from kubernetes import client, config, watch
 from kubernetes.client import CoreV1Api
 from kubernetes.client.exceptions import ApiException
-from kubernetes.client.models import V1Namespace, V1PodList
+from kubernetes.client.models import V1Namespace, V1Pod, V1PodList
 from kubernetes.dynamic import DynamicClient
 from kubernetes.stream import stream
 
@@ -34,19 +34,25 @@ def get_dynamic_client() -> DynamicClient:
     return DynamicClient(client.ApiClient())
 
 
-def get_pods() -> V1PodList:
+def get_pods() -> list[V1Pod]:
     sclient = get_static_client()
-    try:
-        pod_list: V1PodList = sclient.list_namespaced_pod(get_default_namespace())
-    except Exception as e:
-        raise e
-    return pod_list
-
-
-def get_mission(mission: str) -> list[V1PodList]:
+    pods: list[V1Pod] = []
+    namespaces = get_namespaces()
+    for ns in namespaces:
+        namespace = ns.metadata.name
+        try:
+            pod_list: V1PodList = sclient.list_namespaced_pod(namespace)
+            for pod in pod_list.items:
+                pods.append(pod)
+        except Exception as e:
+            raise e
+    return pods
+
+
+def get_mission(mission: str) -> list[V1Pod]:
     pods = get_pods()
-    crew = []
-    for pod in pods.items:
+    crew: list[V1Pod] = []
+    for pod in pods:
         if "mission" in pod.metadata.labels and pod.metadata.labels["mission"] == mission:
             crew.append(pod)
     return crew