'''Timers to manage lease rebinding, renewal & expiration.'''

import asyncio
import dataclasses
from logging import getLogger
from typing import Optional

from pyroute2.dhcp.fsm import AsyncCallback
from pyroute2.dhcp.leases import Lease

LOG = getLogger(__name__)


@dataclasses.dataclass
class LeaseTimers:
    '''Manage callbacks associated with DHCP leases.'''

    renewal: Optional[asyncio.TimerHandle] = None
    rebinding: Optional[asyncio.TimerHandle] = None
    expiration: Optional[asyncio.TimerHandle] = None

    def cancel(self) -> None:
        '''Cancel all current timers.'''
        for timer_name in ('renewal', 'rebinding', 'expiration'):
            self._reset_timer(timer_name)

    def _reset_timer(self, timer_name: str) -> None:
        '''Cancel a timer and set it to None.'''
        if timer_name not in ('renewal', 'rebinding', 'expiration'):
            raise ValueError(f'Unknown timer {timer_name!r}')
        if timer := getattr(self, timer_name):
            assert isinstance(timer, asyncio.TimerHandle)
            if not timer.cancelled():
                # FIXME: how do we know a timer wasn't cancelled ?
                # this causes spurious logs
                LOG.debug('Canceling %s timer', timer_name)
                timer.cancel()
            setattr(self, timer_name, None)

    def arm(self, lease: Lease, **callbacks: AsyncCallback) -> None:
        '''Reset & arm timers from a `Lease`.

        `callbacks` must be async callables with no arguments
        that will be called when the associated timer expires.
        '''
        self.cancel()
        loop = asyncio.get_running_loop()

        for timer_name, async_callback in callbacks.items():
            self._reset_timer(timer_name)
            lease_time = getattr(lease, f'{timer_name}_in')
            if not lease_time:
                LOG.debug('%s time is infinite', timer_name)
                continue
            if lease_time < 0.0:
                LOG.debug('%s is in the past', timer_name)
                continue
            LOG.info('Scheduling %s in %.2fs', timer_name, lease_time)
            timer = loop.call_later(
                lease_time, self._create_timer_task, timer_name, async_callback
            )
            setattr(self, timer_name, timer)

    def _create_timer_task(
        self, timer_name: str, async_callback: AsyncCallback
    ) -> None:
        ''' 'Internal callback for loop.call_later.

        Creates a Task that runs the async_callback.
        '''
        asyncio.create_task(
            async_callback(), name=f"{timer_name} timer callback"
        )