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

@@ -144,7 +144,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
@@ -312,7 +312,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

@@ -35,13 +35,19 @@ 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
+    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_pod(name: str, namespace: Optional[str] = None) -> V1Pod:
@@ -51,10 +57,10 @@ def get_pod(name: str, namespace: Optional[str] = None) -> V1Pod:
     return sclient.read_namespaced_pod(name=name, namespace=namespace)
 
 
-def get_mission(mission: str) -> list[V1PodList]:
+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