"""Simple Http client for Omada controller REST api."""

import os
from typing import NamedTuple
from aiohttp import MultipartWriter
from aiohttp.client import ClientSession
from awesomeversion import AwesomeVersion
from multidict import CIMultiDict

from .definitions import OmadaControllerUpdateInfo, OmadaHardwareUpgradeStatus
from .omadasiteclient import OmadaSiteClient
from .omadaapiconnection import OmadaApiConnection


from .exceptions import (
    SiteNotFound,
)
from .devices import (
    OmadaInterfaceDetails,
)


class OmadaSite(NamedTuple):
    """Identifies a site controlled by the controller."""

    name: str
    id: str


class OmadaClient:
    """
    Simple client for Omada controller API

    Provides a very limited subset of the API documented in the
    'Omada_SDN_Controller_V5.0.15 API Document'
    """

    def __init__(
        self,
        url: str,
        username: str,
        password: str,
        websession: ClientSession | None = None,
        verify_ssl=True,
    ):
        self._api = OmadaApiConnection(url, username, password, websession, verify_ssl)

    async def __aenter__(self):
        await self._api.__aenter__()
        return self

    async def __aexit__(self, *args) -> bool:
        """Call when the client is disposed."""
        # Close the web session, if we created it (i.e. it was not passed in)
        return await self._api.__aexit__(*args)

    async def login(self) -> str:
        """
        Log in to the controller and returns the controller's unique ID.

        Calls to login are optional, as the API will automatically authenticate as necessary.
        However, you may want to attempt a login to check connectivity.
        """
        return await self._api.login()

    async def get_controller_version(self) -> AwesomeVersion:
        """Get the controller version as an AwesomeVersion object."""
        return await self._api.get_controller_version()

    async def get_controller_name(self) -> str:
        """Get the display name of the Omada controller."""
        result = await self._api.request("get", self._api.format_url("maintenance/uiInterface"))

        return OmadaInterfaceDetails(result).controller_name

    async def get_sites(self) -> list[OmadaSite]:
        """Get basic list of sites the user can see"""
        response = await self._api.request("get", self._api.format_url("users/current"))

        sites = [OmadaSite(s["name"], s["key"]) for s in response["privilege"]["sites"]]
        return sites

    async def get_site_client(self, site: str | OmadaSite) -> OmadaSiteClient:
        """Get a client that can query the specified Omada site."""
        if isinstance(site, OmadaSite):
            site_id = site.id
        else:
            site_id = await self._get_site_id(site)
        return OmadaSiteClient(site_id, self._api)

    async def _get_site_id(self, site_name: str):
        """Get site id by (display) name"""

        # The current user object has a list of allowed sites to administer
        sites = await self.get_sites()

        site_id = next((s.id for s in sites if s.name == site_name), None)

        if site_id:
            return site_id

        raise SiteNotFound(f"Site '{site_name}' not found")

    async def reboot(self) -> int:
        """
        Reboot the Omada controller.

        Returns the estimated number of seconds until the reboot finishes.
        """
        url = self._api.format_url("cmd/reboot")
        result = await self._api.request("post", url)

        return result["rebootTime"]

    async def set_certificate(self, file: str, cert_password: str):
        """Upload a new PKCS12 PFX certificate to the controller."""

        base_name = os.path.basename(file)
        with open(file, "rb") as upload_file:
            cert_data = upload_file.read()

        with MultipartWriter("form-data") as mpwriter:
            file_part = mpwriter.append(cert_data, CIMultiDict({"Content-Type": "application/x-pkcs12"}))
            file_part.set_content_disposition("form-data", name="file", filename=base_name)

            data_part = mpwriter.append_json({"cerName": base_name})
            data_part.set_content_disposition("form-data", name="data")

            url = self._api.format_url("files/controller/certificate")
            upload_result = await self._api.request("post", url, data=mpwriter)
        cert_id = upload_result["cerId"]
        cert_name = upload_result["cerName"]

        payload = {
            "certificate": {
                "cerId": cert_id,
                "cerName": cert_name,
                "cerType": "PFX",
                "enable": True,
                "keyPassword": cert_password,
            }
        }
        url = self._api.format_url("controller/setting")
        await self._api.request("patch", url, json=payload)

    async def check_firmware_updates(self) -> OmadaControllerUpdateInfo:
        """Check if firmware updates are available for the Omada hardware controller

        Software Controller updates are probably not available via this API
        """
        result = await self._api.request("get", self._api.format_url("controller/notification/updateInfo"))

        return OmadaControllerUpdateInfo(result)

    async def upgrade_controller_firmware(self, target_version: str) -> bool:
        """Upgrade the Omada hardware controller firmware to the specified version."""
        url = self._api.format_url("cmd/upgradeFirmware")
        payload = {"targetVersion": target_version}
        await self._api.request("post", url, json=payload)
        return True

    async def get_controller_upgrade_status(self) -> OmadaHardwareUpgradeStatus:
        """Get the status of an ongoing hardware controller firmware upgrade."""
        url = self._api.format_url("maintenance/hardware/upgradeStatus")
        result = await self._api.request("get", url)
        return OmadaHardwareUpgradeStatus(result)