royalnet/royalnet_console/pda.py

"""
This module contains the :class:`.ConsolePDAImplementation`.
"""

from __future__ import annotations

import datetime
import logging
import math

import click
import royalnet.engineer as engi
import royalnet.royaltyping as t

from . import bullets

log = logging.getLogger(__name__)


class ConsolePDAImplementation(engi.ConversationListImplementation):
    """
    A :class:`~.engi.ConversationListImplementation` which **blockingly** runs a small interactive chat in the command
    line, and uses ``stdin`` e ``stdout`` to receive and send messages respectively.
    """

    @property
    def namespace(self):
        return "console"

    async def run(self, cycles: int = math.inf) -> t.NoReturn:
        """
        Run the main loop of the :class:`.ConsolePDA` for ``cycles`` cycles, or unlimited cycles if the parameter is
        :data:`True`.
        """

        while cycles > 0:
            message = click.prompt("", type=str, prompt_suffix=">>> ", show_default=False)
            log.debug(f"Received a new input: {message!r}")

            log.debug(f"Creating ConsoleMessageReceived from: {message!r}")
            projectile = bullets.ConsoleMessageReceived(_text=message, _timestamp=datetime.datetime.now())

            log.debug(f"Putting projectile: {projectile!r}")
            await self.put(key="TERMINAL", projectile=projectile)

            if isinstance(cycles, int):
                cycles -= 1


__all__ = (
    "ConsolePDAImplementation",
)