mirror of
https://github.com/NousResearch/hermes-agent.git
synced 2026-11-06 05:17:15 +00:00
unsupportedpastels
0ca88e6771
The Ink TUI sends every request on its canonical connection, and AuthorityConnection had no complete.path handler, so every path and @ completion answered -32601. Sending the session's cwd (TUI-2) could not fix that on its own. The sidecar's listing body moves into _path_completion_items in tui_gateway/methods_complete.py; the sidecar handler calls it unchanged. A new canonical handler (gateway/session_complete_path.py) authorizes session:read on the named session, as the sibling read-only session verbs do, and lists that session's frozen policy cwd. A client-sent cwd is ignored. A remote or sandboxed backend, or a request without a session, lists nothing: completion is advisory, and the host tree would be the wrong one. The TUI now names its session on complete.path. The method was already declared in tui_gateway/contracts, so the generated contracts do not change. Refs NousResearch#134889
40 lines
1.8 KiB
Python
40 lines
1.8 KiB
Python
"""``complete.path`` on the shared gateway: the sidecar's path / ``@`` listing, rooted in one session's folder.
|
|
|
|
The Ink TUI asks its canonical connection for composer completions. The listing is the sidecar's own
|
|
(``tui_gateway/methods_complete.py``); its root is the session's frozen policy cwd, never a cwd the
|
|
client sends or the daemon's own folder.
|
|
"""
|
|
import asyncio
|
|
import json
|
|
from pathlib import Path
|
|
|
|
from gateway.session_busy_controls import authorize
|
|
from hermes_state_runtime import RuntimeStoreError
|
|
|
|
|
|
async def complete_path(connection, ref, params):
|
|
if (set(params) - {'session_id', 'profile', 'word', 'cwd'}
|
|
or any(not isinstance(value, str) for value in params.values())):
|
|
raise RuntimeStoreError('invalid_params')
|
|
word = params.get('word', '')
|
|
if not word or not ref.session_id:
|
|
return {'items': []}
|
|
authority = connection.authority
|
|
if ref.session_id not in authority.sessions:
|
|
raise RuntimeStoreError('not_found')
|
|
authorize(connection, ref, params, 'session:read')
|
|
from gateway.session_policy import policy_for_source, terminal_uses_host_cwd
|
|
policy = policy_for_source(authority.runner, authority.sessions[ref.session_id].source)
|
|
if policy is None or not terminal_uses_host_cwd(json.loads(policy.terminal_json)):
|
|
# A remote or sandboxed backend's tree is not this host's; completion is advisory, so nothing.
|
|
return {'items': []}
|
|
# The listing helpers are bound onto the sidecar module's globals (method_ctx.bind_module).
|
|
from tui_gateway import server
|
|
|
|
def listing():
|
|
from gateway.run import _profile_runtime_scope
|
|
with _profile_runtime_scope(Path(authority.profile_id)):
|
|
return server._path_completion_items(word, policy.cwd, None, True)
|
|
|
|
return {'items': await asyncio.to_thread(listing)}
|