import time

from engine.events.agents import TurnStopped
from features.parts import AgentContext, Handler
from features.update_reports.gather import UPDATE
from resources.base import USER
from controllers.types import Reports

COMMITS = "close_from_commits"
OFFERED = "update-offered"
OFFER_EVERY = 3600
OFFER = "offer"


class OfferAnUpdate(Handler):
    def handle(self, context: AgentContext, event: TurnStopped) -> None:
        commit = context.record.event_log.cursor_text(COMMITS)
        seen, _, at = context.record.event_log.cursor_text(OFFERED).partition(" ")
        if not commit or commit == seen:
            return
        if not seen:
            context.record.event_log.set_cursor_text(OFFERED, f"{commit} {time.time()}")
            return
        if time.time() - float(at) < OFFER_EVERY or self._unread(context):
            context.record.event_log.set_cursor_text(OFFERED, f"{commit} {at}")
            return
        context.record.event_log.set_cursor_text(OFFERED, f"{commit} {time.time()}")
        context.agent.say(OFFER)

    @staticmethod
    def _unread(context: AgentContext) -> bool:
        return any(r.data.get("kind") == UPDATE and not r.data.get("dismissed") and USER not in r.seen
                   for r in context.journal.get(Reports).rows.standing())