mirror of
https://github.com/RYGhub/royalnet.git
synced 2024-11-23 11:34:18 +00:00
52 lines
1.4 KiB
Python
52 lines
1.4 KiB
Python
"""
|
|
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",
|
|
)
|