"""Channel for real-time events from the Tractive REST API."""

from __future__ import annotations

import asyncio
import time
from asyncio.exceptions import TimeoutError as AIOTimeoutError
from collections.abc import AsyncIterator
from http import HTTPStatus
from typing import TYPE_CHECKING, Any

import aiohttp
import orjson
from aiohttp.client_exceptions import ClientResponseError

from .api import API
from .exceptions import DisconnectedError, TractiveError, UnauthorizedError


class Channel:
    """Channel for real-time events from the Tractive REST API."""

    CHANNEL_URL = "https://channel.tractive.com/3/channel"
    IGNORE_MESSAGES = ("handshake", "keep-alive")

    KEEP_ALIVE_TIMEOUT = 60  # seconds
    CHECK_CONNECTION_TIME = 5  # seconds

    def __init__(self, api: API) -> None:
        """Initialize the channel."""
        self._api = api
        self._last_keep_alive: float | None = None
        self._listen_task: asyncio.Task[None] | None = None
        self._check_connection_task: asyncio.Task[None] | None = None
        self._queue: asyncio.Queue[dict[str, Any]] = asyncio.Queue()

        self._retry_count = api.retry_count
        self._retry_delay = api.retry_delay

    async def listen(self) -> AsyncIterator[dict[str, Any]]:
        """Listen for real-time events from the Tractive API."""
        self._check_connection_task = asyncio.create_task(self._check_connection())
        self._listen_task = asyncio.create_task(self._listen())
        while True:
            event = await self._queue.get()
            self._queue.task_done()

            if event["type"] == "event":
                yield event["event"]

            if event["type"] == "error":
                self._check_connection_task.cancel()
                await self._check_connection_task

                self._listen_task.cancel()
                await self._listen_task

                raise event["error"]

            if event["type"] == "cancelled":
                self._listen_task.cancel()

                await self._listen_task
                raise DisconnectedError from event["error"]

    async def _listen(self) -> None:
        if TYPE_CHECKING:
            assert self._api.session is not None

        exc: TractiveError

        attempt = 0
        while True:
            attempt += 1
            try:
                async with self._api.session.request(
                    "POST",
                    self.CHANNEL_URL,
                    headers=await self._api.auth_headers(),
                    timeout=aiohttp.ClientTimeout(
                        total=None,
                        connect=10,
                        sock_connect=10,
                        sock_read=None,
                        ceil_threshold=5,
                    ),
                ) as response:
                    response.raise_for_status()
                    async for data in response.content:
                        event = orjson.loads(data)
                        if event["message"] == "keep-alive":
                            self._last_keep_alive = time.time()
                            continue
                        if event["message"] in self.IGNORE_MESSAGES:
                            continue
                        await self._queue.put({"type": "event", "event": event})
            except AIOTimeoutError:
                continue
            except ClientResponseError as error:
                if error.status in (HTTPStatus.UNAUTHORIZED, HTTPStatus.FORBIDDEN):
                    # Non-recoverable failures
                    exc = UnauthorizedError(str(error))
                    exc.__cause__ = error
                    await self._queue.put({"type": "error", "error": exc})
                    return

                if (
                    error.status == HTTPStatus.TOO_MANY_REQUESTS
                    or error.status >= HTTPStatus.INTERNAL_SERVER_ERROR
                ):
                    # Recoverable failures
                    if attempt <= self._retry_count:
                        delay = self._retry_delay(attempt)
                        await asyncio.sleep(delay)
                        continue

                    exc = TractiveError(str(error))
                    exc.__cause__ = error
                    await self._queue.put({"type": "error", "error": exc})
                    return

                # Other client errors, treat as non-recoverable
                exc = TractiveError(str(error))
                exc.__cause__ = error
                await self._queue.put({"type": "error", "error": exc})
                return

            except asyncio.CancelledError as error:
                await self._queue.put({"type": "cancelled", "error": error})
                return

            except Exception as error:  # noqa: BLE001
                exc = TractiveError(str(error))
                exc.__cause__ = error
                await self._queue.put({"type": "error", "error": exc})
                return

    async def _check_connection(self) -> None:
        try:
            while True:
                if self._last_keep_alive is not None and (
                    time.time() - self._last_keep_alive > self.KEEP_ALIVE_TIMEOUT
                ):
                    if self._listen_task is not None:
                        self._listen_task.cancel()
                    return

                await asyncio.sleep(self.CHECK_CONNECTION_TIME)
        except asyncio.CancelledError:
            return