Merge pull request #46 from jepler/behavioral-fixes-new-textual
This commit is contained in:
commit
cf7ed2f66a
3 changed files with 35 additions and 8 deletions
|
|
@ -8,6 +8,6 @@ lorem-text
|
||||||
platformdirs
|
platformdirs
|
||||||
pyperclip
|
pyperclip
|
||||||
simple_parsing
|
simple_parsing
|
||||||
textual[syntax]
|
textual[syntax] >= 4
|
||||||
tiktoken
|
tiktoken
|
||||||
websockets
|
websockets
|
||||||
|
|
|
||||||
|
|
@ -145,7 +145,6 @@ class Tui(App[None]):
|
||||||
await self.container.mount_all(
|
await self.container.mount_all(
|
||||||
[markdown_for_step(User(query)), output], before="#pad"
|
[markdown_for_step(User(query)), output], before="#pad"
|
||||||
)
|
)
|
||||||
tokens: list[str] = []
|
|
||||||
update: asyncio.Queue[bool] = asyncio.Queue(1)
|
update: asyncio.Queue[bool] = asyncio.Queue(1)
|
||||||
|
|
||||||
for markdown in self.container.children:
|
for markdown in self.container.children:
|
||||||
|
|
@ -166,15 +165,22 @@ class Tui(App[None]):
|
||||||
)
|
)
|
||||||
|
|
||||||
async def render_fun() -> None:
|
async def render_fun() -> None:
|
||||||
|
old_len = 0
|
||||||
while await update.get():
|
while await update.get():
|
||||||
if tokens:
|
content = message.content
|
||||||
output.update("".join(tokens).strip())
|
new_len = len(content)
|
||||||
|
new_content = content[old_len:new_len]
|
||||||
|
if new_content:
|
||||||
|
if old_len:
|
||||||
|
await output.append(new_content)
|
||||||
|
else:
|
||||||
|
output.update(content)
|
||||||
self.container.scroll_end()
|
self.container.scroll_end()
|
||||||
await asyncio.sleep(0.1)
|
old_len = new_len
|
||||||
|
await asyncio.sleep(0.01)
|
||||||
|
|
||||||
async def get_token_fun() -> None:
|
async def get_token_fun() -> None:
|
||||||
async for token in self.api.aask(session, query):
|
async for token in self.api.aask(session, query):
|
||||||
tokens.append(token)
|
|
||||||
message.content += token
|
message.content += token
|
||||||
try:
|
try:
|
||||||
update.put_nowait(True)
|
update.put_nowait(True)
|
||||||
|
|
|
||||||
|
|
@ -44,6 +44,7 @@ else:
|
||||||
conversations_path = platformdirs.user_state_path("chap") / "conversations"
|
conversations_path = platformdirs.user_state_path("chap") / "conversations"
|
||||||
conversations_path.mkdir(parents=True, exist_ok=True)
|
conversations_path.mkdir(parents=True, exist_ok=True)
|
||||||
configuration_path = platformdirs.user_config_path("chap")
|
configuration_path = platformdirs.user_config_path("chap")
|
||||||
|
preset_path = configuration_path / "preset"
|
||||||
|
|
||||||
|
|
||||||
class ABackend(Protocol):
|
class ABackend(Protocol):
|
||||||
|
|
@ -363,7 +364,7 @@ def expand_splats(args: list[str]) -> list[str]:
|
||||||
result.append(a)
|
result.append(a)
|
||||||
continue
|
continue
|
||||||
if a.startswith("@:"):
|
if a.startswith("@:"):
|
||||||
fn: pathlib.Path = configuration_path / "preset" / a[2:]
|
fn: pathlib.Path = preset_path / a[2:]
|
||||||
else:
|
else:
|
||||||
fn = pathlib.Path(a[1:])
|
fn = pathlib.Path(a[1:])
|
||||||
fn = maybe_add_txt_extension(fn)
|
fn = maybe_add_txt_extension(fn)
|
||||||
|
|
@ -403,6 +404,19 @@ class MyCLI(click.Group):
|
||||||
except ModuleNotFoundError as exc:
|
except ModuleNotFoundError as exc:
|
||||||
raise click.UsageError(f"Invalid subcommand {cmd_name!r}", ctx) from exc
|
raise click.UsageError(f"Invalid subcommand {cmd_name!r}", ctx) from exc
|
||||||
|
|
||||||
|
def gather_preset_info(self) -> list[tuple[str, str]]:
|
||||||
|
result = []
|
||||||
|
for p in preset_path.glob("*"):
|
||||||
|
if p.is_file():
|
||||||
|
with p.open() as f:
|
||||||
|
first_line = f.readline()
|
||||||
|
if first_line.startswith("#"):
|
||||||
|
help_str = first_line[1:].strip()
|
||||||
|
else:
|
||||||
|
help_str = "(A comment on the first line would be shown here)"
|
||||||
|
result.append((f"@:{p.name}", help_str))
|
||||||
|
return result
|
||||||
|
|
||||||
def format_splat_options(
|
def format_splat_options(
|
||||||
self, ctx: click.Context, formatter: click.HelpFormatter
|
self, ctx: click.Context, formatter: click.HelpFormatter
|
||||||
) -> None:
|
) -> None:
|
||||||
|
|
@ -436,6 +450,13 @@ class MyCLI(click.Group):
|
||||||
the extension may be omitted."""
|
the extension may be omitted."""
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
formatter.write_paragraph()
|
||||||
|
if preset_info := self.gather_preset_info():
|
||||||
|
formatter.write_text("Presets found:")
|
||||||
|
formatter.write_paragraph()
|
||||||
|
formatter.indent()
|
||||||
|
formatter.write_dl(preset_info)
|
||||||
|
formatter.dedent()
|
||||||
|
|
||||||
def format_options(
|
def format_options(
|
||||||
self, ctx: click.Context, formatter: click.HelpFormatter
|
self, ctx: click.Context, formatter: click.HelpFormatter
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue