Mikhail Putilovskij
b1aaa210a1
Agent routing: - Remove !agent command and manual agent selection flow - Registry auto-assigns agent from user_agents mapping (fallback: agents[0]) - provision_workspace_chat and !new both write agent_id to room_meta - Reconciliation backfills agent_id from registry on cold start - Fix duplicate agent_id block in auth.py Deployment stability: - Add bot-state named volume to persist lambda_matrix.db and matrix_store - Fix docker-compose.prod.yml duplicate environment: key (was silently losing all Matrix credentials) - Fix MATRIX_AGENT_REGISTRY_PATH to use absolute container path /app/config/... - Add bot-state volume declaration to docker-compose.fullstack.yml Docs and config: - Rewrite README.md for platform handoff (deploy table, working commands only) - Rewrite docs/matrix-prototype.md (remove stale commands and mock descriptions) - Remove !save/!load/!context/!agent from help text and welcome message - Add !clear, !list, !remove, !yes/!no to help text - Clean up .env.example (remove Telegram token, internal vars, real URLs) - Update config/matrix-agents.example.yaml with user_agents section and comments - Add explanatory comment to Dockerfile for --ignore-requires-python - Remove silent uv sync fallbacks in Dockerfile
73 lines
3.1 KiB
Python
73 lines
3.1 KiB
Python
from __future__ import annotations
|
|
|
|
from adapter.matrix.handlers.chat import (
|
|
handle_list_chats,
|
|
make_handle_archive,
|
|
make_handle_new_chat,
|
|
make_handle_rename,
|
|
)
|
|
from adapter.matrix.handlers.confirm import make_handle_cancel, make_handle_confirm
|
|
from adapter.matrix.handlers.context_commands import (
|
|
make_handle_context,
|
|
make_handle_load,
|
|
make_handle_reset,
|
|
make_handle_save,
|
|
)
|
|
from adapter.matrix.handlers.settings import (
|
|
handle_help,
|
|
handle_settings,
|
|
handle_settings_connectors,
|
|
handle_settings_plan,
|
|
handle_settings_safety,
|
|
handle_settings_skills,
|
|
handle_settings_soul,
|
|
handle_settings_status,
|
|
handle_settings_whoami,
|
|
handle_toggle_skill,
|
|
handle_unknown_command,
|
|
)
|
|
from core.handler import EventDispatcher
|
|
from core.protocol import IncomingCallback, IncomingCommand
|
|
|
|
|
|
def register_matrix_handlers(
|
|
dispatcher: EventDispatcher,
|
|
client=None,
|
|
store=None,
|
|
registry=None,
|
|
prototype_state=None,
|
|
agent_base_url: str = "http://127.0.0.1:8000",
|
|
) -> None:
|
|
dispatcher.register(IncomingCommand, "new", make_handle_new_chat(client, store, registry))
|
|
dispatcher.register(IncomingCommand, "chats", handle_list_chats)
|
|
dispatcher.register(IncomingCommand, "rename", make_handle_rename(client, store))
|
|
dispatcher.register(IncomingCommand, "archive", make_handle_archive(client, store))
|
|
dispatcher.register(IncomingCommand, "help", handle_help)
|
|
dispatcher.register(IncomingCommand, "settings", handle_settings)
|
|
if prototype_state is not None:
|
|
clear_handler = make_handle_reset(store, prototype_state)
|
|
dispatcher.register(IncomingCommand, "clear", clear_handler)
|
|
dispatcher.register(IncomingCommand, "reset", clear_handler)
|
|
else:
|
|
dispatcher.register(IncomingCommand, "reset", handle_settings)
|
|
dispatcher.register(IncomingCommand, "settings_skills", handle_settings_skills)
|
|
dispatcher.register(IncomingCommand, "settings_connectors", handle_settings_connectors)
|
|
dispatcher.register(IncomingCommand, "settings_soul", handle_settings_soul)
|
|
dispatcher.register(IncomingCommand, "settings_safety", handle_settings_safety)
|
|
dispatcher.register(IncomingCommand, "settings_plan", handle_settings_plan)
|
|
dispatcher.register(IncomingCommand, "settings_status", handle_settings_status)
|
|
dispatcher.register(IncomingCommand, "settings_whoami", handle_settings_whoami)
|
|
|
|
dispatcher.register(IncomingCallback, "confirm", make_handle_confirm(store))
|
|
dispatcher.register(IncomingCallback, "cancel", make_handle_cancel(store))
|
|
dispatcher.register(IncomingCallback, "toggle_skill", handle_toggle_skill)
|
|
dispatcher.register(IncomingCommand, "*", handle_unknown_command)
|
|
|
|
if prototype_state is not None:
|
|
dispatcher.register(
|
|
IncomingCommand,
|
|
"save",
|
|
make_handle_save(None, store, prototype_state),
|
|
)
|
|
dispatcher.register(IncomingCommand, "load", make_handle_load(store, prototype_state))
|
|
dispatcher.register(IncomingCommand, "context", make_handle_context(store, prototype_state))
|