"""APIs for working with Kubernetes deployments."""

from datetime import UTC, datetime

from kubernetes_asyncio import client
from kubernetes_asyncio.client.api_client import ApiClient
from kubernetes_asyncio.client.models import V1DeploymentList


async def restart_deployment(deployment: str, namespace: str) -> None:
    """Patch a deployment with a custom annotation to trigger redeployment."""
    async with ApiClient() as api_client:
        api = client.AppsV1Api(api_client)
        await api.patch_namespaced_deployment(
            name=deployment,
            namespace=namespace,
            body={
                "spec": {
                    "template": {
                        "metadata": {
                            "annotations": {
                                "king-arthur.pydis.com/restartedAt": datetime.now(UTC).isoformat()
                            }
                        }
                    }
                }
            },
            field_manager="King Arthur",
        )


async def list_deployments(namespace: str) -> V1DeploymentList:
    """Query the Kubernetes API for a list of deployments in the provided namespace."""
    async with ApiClient() as api_client:
        api = client.AppsV1Api(api_client)
        return await api.list_namespaced_deployment(namespace=namespace)