"""Metadata capability providing RSSI and last_seen timestamp."""

from datetime import datetime
from time import time

from ..eep.message import EEPMessage
from .capability import Capability
from .state_change import StateChange, StateChangeSource


class MetaDataCapability(Capability):
    """Capability providing metadata about received messages (RSSI and last seen timestamp).

    This capability can be attached to any device type to track:
    - RSSI (signal strength) when available
    - Last seen timestamp for every received message
    - Telegram count (number of messages received)
    """

    def __init__(self, device_address, on_state_change):
        """Initialize the metadata capability."""
        super().__init__(device_address, on_state_change)
        self._telegram_count = 0

    def _decode_impl(self, message: EEPMessage) -> None:
        """Decode metadata from the message."""
        self._telegram_count += 1
        timestamp = time()

        # Emit RSSI if available
        if message.rssi is not None:
            self._emit(
                StateChange(
                    device_address=self.device_address,
                    observable_uid="rssi",
                    value=message.rssi,
                    timestamp=timestamp,
                    source=StateChangeSource.TELEGRAM,
                )
            )

        # Always emit last_seen timestamp
        self._emit(
            StateChange(
                device_address=self.device_address,
                observable_uid="last_seen",
                value=timestamp,
                timestamp=timestamp,
                source=StateChangeSource.TELEGRAM,
            )
        )

        # Always emit telegram count
        self._emit(
            StateChange(
                device_address=self.device_address,
                observable_uid="telegram_count",
                value=self._telegram_count,
                timestamp=timestamp,
                source=StateChangeSource.TELEGRAM,
            )
        )