import dataclasses
from time import monotonic
from typing import Any
from typing import Sequence


@dataclasses.dataclass(frozen=True)
class HttpEndPoint:
    method: str
    path: str
    resource_name: str = dataclasses.field(default="")
    operation_name: str = dataclasses.field(default="http.request")
    response_body_type: Sequence[str] = dataclasses.field(default_factory=tuple)
    response_code: Sequence[int] = dataclasses.field(default_factory=tuple)
    _hash: int = dataclasses.field(init=False, repr=False)

    def __post_init__(self) -> None:
        super().__setattr__("method", self.method.upper())
        if not self.resource_name:
            super().__setattr__("resource_name", f"{self.method} {self.path}")
        # cache hash result
        super().__setattr__("_hash", hash((self.method, self.path)))

    def __hash__(self) -> int:
        return self._hash


def _dict_factory(lst: list[tuple[str, Any]]) -> dict[str, Any]:
    return {k: v for k, v in lst if v not in ((), [], None)}


class Singleton(type):
    """Singleton Class."""

    _instances: dict[type, object] = {}

    def __call__(cls, *args, **kwargs):
        if cls not in cls._instances:
            cls._instances[cls] = super(Singleton, cls).__call__(*args, **kwargs)
        return cls._instances[cls]


@dataclasses.dataclass()
class HttpEndPointsCollection(metaclass=Singleton):
    """A collection of HTTP endpoints that can be modified and flushed to a telemetry payload.

    The collection collects HTTP endpoints at startup and can be flushed to a telemetry payload.
    It maintains a maximum size and drops endpoints after a certain time period in case of a hot reload of the server.
    """

    endpoints: set[HttpEndPoint] = dataclasses.field(default_factory=set, init=False)
    is_first: bool = dataclasses.field(default=True, init=False)
    drop_time_seconds: float = dataclasses.field(default=90.0, init=False)
    last_modification_time: float = dataclasses.field(default_factory=monotonic, init=False)
    max_size_length: int = dataclasses.field(default=900, init=False)

    def reset(self) -> None:
        """Reset the collection to its initial state."""
        self.endpoints.clear()
        self.is_first = True
        self.last_modification_time = monotonic()

    def add_endpoint(
        self,
        method: str,
        path: str,
        resource_name: str = "",
        operation_name: str = "http.request",
        response_body_type: Sequence[str] = (),
        response_code: Sequence[int] = (),
    ) -> None:
        """
        Add an endpoint to the collection.
        """
        current_time = monotonic()
        if current_time - self.last_modification_time > self.drop_time_seconds:
            self.reset()
            self.endpoints.add(
                HttpEndPoint(
                    method=method,
                    path=path,
                    resource_name=resource_name,
                    operation_name=operation_name,
                    response_body_type=response_body_type,
                    response_code=response_code,
                )
            )
        elif len(self.endpoints) < self.max_size_length:
            self.last_modification_time = current_time
            self.endpoints.add(
                HttpEndPoint(
                    method=method,
                    path=path,
                    resource_name=resource_name,
                    operation_name=operation_name,
                    response_body_type=response_body_type,
                    response_code=response_code,
                )
            )
            self.last_modification_time = current_time

    def flush(self, max_length: int) -> dict:
        """
        Flush the endpoints to a payload, returning the first `max` endpoints.
        """
        endpoints_res: list[dict] = []
        while self.endpoints and len(endpoints_res) < max_length:
            endpoints_res.append(dataclasses.asdict(self.endpoints.pop(), dict_factory=_dict_factory))
        res = {"is_first": self.is_first, "endpoints": endpoints_res}
        self.is_first = False
        return res


endpoint_collection = HttpEndPointsCollection()