"""The Nodes cog helps with managing Kubernetes nodes."""

from textwrap import dedent

from discord.ext import commands
from tabulate import tabulate

from arthur.apis.kubernetes import nodes
from arthur.bot import KingArthur


class Nodes(commands.Cog):
    """Commands for working with Kubernetes nodes."""

    def __init__(self, bot: KingArthur) -> None:
        self.bot = bot

    @commands.group(name="nodes", aliases=["node"], invoke_without_command=True)
    async def nodes(self, ctx: commands.Context) -> None:
        """Commands for working with Kubernetes nodes."""
        await ctx.send_help(ctx.command)

    @nodes.command(name="list", aliases=["ls"])
    async def nodes_list(self, ctx: commands.Context) -> None:
        """List Kubernetes nodes in the cluster."""
        cluster_nodes = await nodes.list_nodes()

        table_data = []

        for node in cluster_nodes.items:
            statuses = []

            for condition in node.status.conditions:
                if condition.type == "Ready" and condition.status == "True":
                    statuses.append("Ready")
                    break
            else:
                statuses.append("Unready")

            for condition in node.status.conditions:
                if condition.type == "Ready":
                    pass

                if condition.status is True:
                    statuses.append(condition.type)

            if node.spec.taints:
                for taint in node.spec.taints:
                    statuses.append(taint.effect)  # noqa: PERF401

            node_creation = node.metadata.creation_timestamp

            table_data.append(
                [
                    node.metadata.name,
                    ", ".join(statuses),
                    node.status.node_info.kubelet_version,
                    node_creation,
                ]
            )

        table = tabulate(
            table_data, headers=["Name", "Status", "Kubernetes Version", "Created"], tablefmt="psql"
        )

        return_message = dedent("""
            **Cluster nodes**
            ```
            {0}
            ```
            """)

        await ctx.send(return_message.format(table))

    @nodes.command(name="cordon")
    async def nodes_cordon(self, ctx: commands.Context, *, node: str) -> None:
        """
        Cordon a node in the cluster.

        Cordoning a node has the effect of preventing any new deployments from being scheduled.
        """
        await nodes.cordon_node(node)

        await ctx.send(
            f":construction: **Cordoned {node}** Node is now "
            "cordoned and no pods will be scheduled to it."
        )

    @nodes.command(name="uncordon")
    async def nodes_uncordon(self, ctx: commands.Context, *, node: str) -> None:
        """
        Uncordon a node in the cluster.

        Cordoning a node has the effect of preventing any new deployments from being scheduled.
        """
        await nodes.uncordon_node(node)

        await ctx.send(
            f":construction: **Uncordoned {node}** Node is now "
            "uncordoned, future pods may be scheduled to it."
        )


async def setup(bot: KingArthur) -> None:
    """Add the extension to the bot."""
    await bot.add_cog(Nodes(bot))