Add bowtie tui — minimal interactive schema evaluator

Author: codefromlani

bowtie/_cli.py

@@ -32,6 +32,7 @@
     TextColumn,
     TimeElapsedColumn,
 )
+from rich.prompt import Prompt
 from rich.table import Column, Table
 from rich.text import Text
 from rich_click.utils import CommandGroupDict, OptionGroupDict
@@ -52,6 +53,7 @@
     convert_table_to_markdown,
 )
 from bowtie._direct_connectable import Direct
+from bowtie._tui import TuiSession
 from bowtie.exceptions import (
     CannotConnect,
     DialectError,
@@ -125,7 +127,7 @@ def _progress(*columns: Any) -> Progress:
     "bowtie": [
         CommandGroupDict(
             name="Basic Commands",
-            commands=["validate", "suite", "summary", "info"],
+            commands=["tui", "validate", "suite", "summary", "info"],
         ),
         CommandGroupDict(
             name="Advanced Usage",
@@ -1378,6 +1380,47 @@ def run(
     )
 
 
+@subcommand
+@implementation_subcommand()
+@dialect_option()
+def tui(start: Any, dialect: Dialect, **kwargs: Any):
+    """
+    Interactively evaluate schemas against instances across implementations.
+
+    Starts a REPL that keeps implementations running between validations,
+    prompting for a JSON Schema and an instance on each iteration
+    """
+
+    async def _tui(start: Any, dialect: Dialect, **kwargs: Any):
+        runners = []
+        async for impl_id, implementation in start():
+            try:
+                runner = await implementation.start_speaking(dialect)
+            except UnsupportedDialect as error:
+                STDERR.print(error)
+                continue
+            runners.append((
+                impl_id,
+                implementation.info.version or "?",
+                runner,
+            ))
+
+        if not runners:
+            STDERR.print(
+                "[bold red]No implementation started successfully![/]",
+                )
+            return EX.CONFIG
+        session = TuiSession(
+            runners=runners,
+            dialect=dialect,
+            console=STDOUT,
+            prompt=lambda msg: Prompt.ask(msg),
+        )
+        await session.repl()
+
+    return asyncio.run(_tui(start=start, dialect=dialect, **kwargs))
+
+
 @subcommand
 @dialect_option(default=None, callback=_set_dialect_via_schema)
 @IMPLEMENTATION