Hooks
Hooks let plugins observe, enrich, and transform messages as they flow through MindRoom.
A single @hook("event") decorator turns any async function into a typed event handler that runs with per-hook timeouts, per-event fault isolation, and zero risk of crashing the bot.
Hooks integrate with the existing plugin system and are configured through config.yaml.
Quick start
Create a plugin directory with a manifest and a hook:
# plugin.py
from mindroom.hooks import hook
@hook("message:enrich", priority=20)
async def enrich_with_location(ctx):
location = await fetch_location(ctx.settings["dawarich_url"])
if location:
ctx.add_metadata("location", f"User is at {location}", persist=False)
# config.yaml
plugins:
- path: ./plugins/location-context
settings:
dawarich_url: http://dawarich.local
When any agent receives a message, this hook runs concurrently with other enrichment hooks and injects the user's location into non-persisted current-turn context.
The persist=False option keeps it out of session history.
Hook types
The hook system has four execution modes, determined by the event, not by individual hooks.
Observer (emit)
Hooks run serially.
Each hook sees the context as read-only (except designated mutable fields like suppress).
Failures lose only that hook's side effects; the next hook still runs.
from mindroom.hooks import hook
@hook("message:received")
async def log_inbound(ctx):
ctx.logger.info("Message received", body=ctx.envelope.body)
@hook("message:after_response")
async def track_response(ctx):
save_metric(ctx.result.response_event_id, ctx.result.delivery_kind)
Collector (emit_collect)
Hooks run concurrently with isolated per-hook state.
Each hook contributes structured EnrichmentItem entries.
A failing hook loses only its items; other hooks' items are preserved.
Results merge in hook-order after all hooks complete.
from mindroom.hooks import hook
@hook("message:enrich", priority=10)
async def enrich_with_weather(ctx):
weather = await fetch_weather(ctx.settings["api_key"])
if weather:
ctx.add_metadata("weather", f"Current weather: {weather}")
@hook("message:enrich", priority=20)
async def enrich_with_calendar(ctx):
events = await fetch_calendar(ctx.settings["calendar_url"])
if events:
ctx.add_metadata("calendar", f"Upcoming: {events}")
Transformer (emit_transform)
Hooks run serially.
message:before_response receives a mutable ResponseDraft.
message:final_response_transform receives a mutable FinalResponseDraft.
Both hooks may replace draft.response_text.
Only message:before_response may suppress the reply.
For message:final_response_transform, failures skip that hook's changes and keep the previous draft for the next hook.
from mindroom.hooks import hook
@hook("message:before_response", priority=10)
async def add_disclaimer(ctx):
ctx.draft.response_text += "\n\n*Generated automatically.*"
@hook("message:before_response", priority=20)
async def redact_secrets(ctx):
ctx.draft.response_text = scrub_api_keys(ctx.draft.response_text)
@hook("message:final_response_transform", priority=10)
async def add_links(ctx):
ctx.draft.response_text = linkify_references(ctx.draft.response_text)
Gate (emit_gate)
Hooks run serially.
Each hook receives a mutable ToolBeforeCallContext.
Failures fail open, so a broken or timed-out gate hook does not block the real tool call.
The first hook that calls ctx.decline(reason) stops the chain and replaces the real tool call with a declined result.
from mindroom.hooks import hook
@hook("tool:before_call", priority=10)
async def block_secret_reads(ctx):
if ctx.tool_name == "read_file" and "secret" in str(ctx.arguments.get("path", "")):
ctx.decline("Sensitive files must stay unread.")
Built-in events
| Event | Mode | Context type | When it fires | Key mutable fields |
|---|---|---|---|---|
message:received |
Observer | MessageReceivedContext |
After authorization, dedup, and voice normalization; before command parsing, routing, and image/file/video attachment registration | suppress |
message:enrich |
Collector | MessageEnrichContext |
After routing resolves target agent/team; before AI generation | add_metadata() |
system:enrich |
Collector | SystemEnrichContext |
After message enrichment; before AI generation | add_instruction() |
message:before_response |
Transformer | BeforeResponseContext |
After AI generation; before the first visible Matrix send or edit | draft.response_text, draft.suppress |
message:final_response_transform |
Transformer | FinalResponseTransformContext |
On clean streamed success after real visible assistant text has already landed, before one best-effort final edit | draft.response_text |
message:after_response |
Observer | AfterResponseContext |
After final Matrix send or edit | None (frozen) |
message:cancelled |
Observer | CancelledResponseContext |
After any terminal outcome other than clean success, including explicit cancellation, interruption, suppression, and delivery-failure recovery | None (frozen) |
agent:started |
Observer | AgentLifecycleContext |
After bot starts (Matrix login, presence, callbacks registered) | None (frozen) |
agent:stopped |
Observer | AgentLifecycleContext |
During orderly shutdown | None (frozen) |
bot:ready |
Observer | AgentLifecycleContext |
After bot completes room joins and initial sync | None (frozen) |
session:started |
Observer | SessionHookContext |
Once per persisted session, after the response path confirms a new backing session was created for that history scope, during response finalization and before later cleanup such as persisted response-event IDs or transient-enrichment stripping | None (frozen) |
compaction:before |
Observer | CompactionHookContext |
After the compacted message set is prepared and before the compacted session is persisted | None (frozen) |
compaction:after |
Observer | CompactionHookContext |
After compaction is persisted, with before/after token counts and the generated summary | None (frozen) |
schedule:fired |
Observer | ScheduleFiredContext |
Before scheduled task posts its synthetic message | message_text, suppress |
reaction:received |
Observer | ReactionReceivedContext |
After built-in reaction handlers (stop, config, interactive) | None (frozen) |
room:member_joined |
Observer | RoomMemberJoinedContext |
On the router bot after a live human m.room.member join, excluding initial sync history, configured agents, the internal mindroom_user, and bot_accounts |
None (frozen) |
room:member_left |
Observer | RoomMemberLeftContext |
On the router bot after a human's self-authored m.room.member transition from join to leave, excluding configured agents, the internal mindroom_user, and bot_accounts |
None (frozen) |
config:reloaded |
Observer | ConfigReloadedContext |
After orchestrator applies new config and restarts affected entities | None (frozen) |
tool:before_call |
Gate | ToolBeforeCallContext |
Immediately before each tool call runs | decline() |
tool:after_call |
Observer | ToolAfterCallContext |
After each tool call returns, raises, or is declined | None (observer result snapshot) |
message:before_response only runs for AI-generated replies before the first real visible assistant text is sent.
For streaming replies, once real visible assistant text has landed, message:before_response does not receive a post-visible finalize pass.
Use message:final_response_transform for one text-only best-effort replacement on clean streamed success.
message:final_response_transform may not suppress, redact, delete, or mutate response metadata.
For compaction:before and compaction:after, ctx.messages contains raw agno.models.message.Message objects from the compacted session payload.
MindRoom does not sanitize attachments, media, tool calls, tool args, provider metadata, citations, reasoning fields, metrics, references, or extra Pydantic fields before these hooks run.
For message:cancelled, inspect ctx.info.failure_reason to distinguish explicit cancellation, interruption, suppression, and delivery failure recovery.
room:member_joined uses at-least-once delivery because MindRoom records the durable room/user marker only after the hook completes.
A process interruption or marker-write failure after a handler side effect can replay the same room/user pair, so handlers that create or invite resources must be idempotent.
room:member_left reads display_name and avatar_url from the joined membership state that the leave replaces.
Actionable room-lifecycle events remain pending until their callback completes, so an interruption can replay a leave before journal settlement and handlers must be idempotent.
Default timeouts
| Event | Default timeout (ms) |
|---|---|
message:received |
15000 |
message:enrich |
2000 |
system:enrich |
2000 |
message:before_response |
200 |
message:final_response_transform |
200 |
message:after_response |
3000 |
message:cancelled |
3000 |
reaction:received |
500 |
room:member_joined |
3000 |
room:member_left |
3000 |
schedule:fired |
1000 |
agent:started |
5000 |
agent:stopped |
5000 |
bot:ready |
5000 |
session:started |
5000 |
compaction:before |
15000 |
compaction:after |
5000 |
config:reloaded |
5000 |
tool:before_call |
200 |
tool:after_call |
300 |
| Custom events | 1000 |
For session:started, compaction:before, and compaction:after, ctx.scope.key identifies the persisted history scope rather than one unique session row.
Use ctx.session_id as the unique persisted session identifier within that scope.
The @hook decorator
from mindroom.hooks import hook
@hook(
"message:enrich",
name="enrich_weather", # Hook name (defaults to function name)
priority=20, # Lower runs first (default: 100)
timeout_ms=500, # Override default timeout for this event
agents=["code", "research"], # Only run for these agents
rooms=["!room:localhost"], # Only run in these rooms
)
async def enrich_weather(ctx):
...
| Parameter | Type | Default | Description |
|---|---|---|---|
event |
str |
required | Event name to listen for |
name |
str |
function name | Hook identifier (unique within a plugin) |
priority |
int |
100 |
Execution order; lower values run first |
timeout_ms |
int \| None |
per-event default | Override the event's default timeout |
agents |
Iterable[str] \| None |
None (all) |
Only fire for these agent names |
rooms |
Iterable[str] \| None |
None (all) |
Only fire for these room IDs |
The decorator is annotation-only.
It stores metadata on the function and has no side effects on import.
Hook callbacks must be async.
Plugin manifest
Add hooks_module to mindroom.plugin.json to point to a dedicated hooks file:
{
"name": "my-plugin",
"tools_module": "tools.py",
"hooks_module": "hooks.py",
"skills": ["skills"]
}
If hooks_module is omitted, MindRoom auto-scans tools_module for @hook-decorated functions.
If both fields point at the same file, MindRoom imports it once and reuses it for tool registration and hook discovery.
Config
String form (unchanged)
Object form (settings and hook overrides)
plugins:
- path: ./plugins/personal-context
settings:
dawarich_url: http://dawarich.local
weather_api_key: ${OPENWEATHER_API_KEY}
hooks:
enrich_with_weather:
enabled: false
enrich_with_location:
priority: 10
timeout_ms: 500
Both forms can be mixed in the same plugins list.
Environment variable substitution works through MindRoom's existing config loading.
Hook override fields
| Field | Type | Default | Description |
|---|---|---|---|
enabled |
bool |
true |
Disable a hook without removing code |
priority |
int \| null |
null (use decorator value) |
Override the decorator priority |
timeout_ms |
int \| null |
null (use decorator value) |
Override the decorator timeout |
Override precedence
- Decorator defaults in code
- Plugin-level
settings(available to all hooks asctx.settings) - Per-hook overrides:
enabled,priority,timeout_ms
If a hook name appears in hooks: but the plugin has no hook with that name, MindRoom logs a startup warning and ignores the override.
Enrichment pipeline
The message:enrich event injects structured context into the current turn and lets each item choose whether it belongs in persisted history.
How it works
- Collect: After routing decides the target agent, MindRoom runs
emit_collect("message:enrich")which executes all matching enrichment hooks concurrently. -
Render: Persisted
EnrichmentItementries are rendered into an XML block appended to the user turn: -
AI sees it: The model receives persisted items in the current user message and all
persist=Falseitems in one separate non-persisted current-turn context message. For Claude requests, MindRoom places that transient block after the cacheable user content so the growing conversation prefix remains reusable. - Replay sees persisted items: MindRoom keeps only persisted enrichment in session history.
Enrichment policy
Each enrichment item has a cache_policy:
"volatile"(default): The item may change on every message (e.g., weather, time)."stable": The item changes rarely (e.g., user profile, timezone).
MindRoom preserves persisted enrichment exactly as rendered for the live request. Use stable keys and deterministic hook output when you want later replays and cache keys to line up cleanly.
Message enrichment is persisted by default.
Set persist=False for live context that should be visible only during the current turn, such as location, weather, or other frequently changing external state.
Transient items stay out of the system prompt and replayable history so provider prompt caches can reuse their stable prefixes.
Adding enrichment items
Use ctx.add_metadata() in any message:enrich hook:
@hook("message:enrich")
async def enrich_with_profile(ctx):
profile = load_profile(ctx.envelope.requester_id)
ctx.add_metadata(
"user_profile",
f"Name: {profile.name}, Timezone: {profile.tz}",
cache_policy="stable",
)
Hooks can also return EnrichmentItem objects directly:
from mindroom.hooks import EnrichmentItem, hook
@hook("message:enrich")
async def enrich_with_time(ctx):
return EnrichmentItem(key="time", text=f"Current time: {now()}", persist=False)
The persist option only affects message:enrich items because system:enrich items are already current-turn context.
Performance
Enrichment hooks run concurrently with per-hook timeouts. A slow weather API does not block a fast calendar lookup. Total enrichment latency equals max(individual hook latencies), not the sum. A bounded semaphore (default 10) prevents one plugin from flooding the event loop.
System enrichment pipeline
The system:enrich event powers a parallel enrichment pipeline for the system prompt.
Use it when room-scoped or turn-scoped instructions should live in agent.additional_context instead of the current user message.
How it works
- Collect: After
message:enrichfinishes, MindRoom runsemit_collect("system:enrich")with aSystemEnrichContext, which executes all matching system-enrichment hooks concurrently. -
Render: Collected
EnrichmentItementries are rendered into an XML block for the system prompt: -
Apply: For agent runs, MindRoom renders the block into
agent.additional_contextbefore AI generation. - Apply to teams: For team runs, MindRoom assigns the same rendered block to both
team.additional_contextand each member agent'sadditional_context.
Adding system enrichment items
Use ctx.add_instruction() in any system:enrich hook:
from mindroom.hooks import SystemEnrichContext, hook
@hook("system:enrich", priority=40)
async def inject_room_tags(ctx: SystemEnrichContext) -> None:
"""Inject existing room thread tags into system prompt."""
tags = await get_room_tags(ctx.envelope.room_id)
if tags:
tag_list = ", ".join(sorted(tags))
ctx.add_instruction(
"room_tags",
f"Existing thread tags in this room: {tag_list}",
cache_policy="stable",
)
Hooks can also return EnrichmentItem objects directly, the same way message:enrich hooks can.
System cache policy
Each item still carries a cache_policy, but system enrichment uses it to control deterministic ordering for prompt caching:
"stable": Sorted first by key so long-lived instructions stay grouped at the front of the block."volatile"(default): Sorted last by key so frequently changing instructions stay grouped at the end of the block.
System enrichment changes the system prompt, so use it only when context needs system-level priority.
Use message:enrich with persist=False for live data so the stable system and history prefixes remain reusable.
The matrix_message_target key is runtime-owned and travels with non-persisted current-turn context for agents that can use matrix_message.
Hook-provided items with that key are replaced by the runtime value.
Key differences from message:enrich
system:enrichinjects into the system prompt viaagent.additional_context, whilemessage:enrichinjects into the current user turn.system:enrichrenders<mindroom_system_context>blocks, whilemessage:enrichrenders<mindroom_message_context>blocks.system:enrichusesctx.add_instruction(), whilemessage:enrichusesctx.add_metadata().system:enrichis intended for room- or turn-scoped instructions, whilemessage:enrichis intended for user-prompt conversational context.
Custom events
Plugins can define and emit namespaced custom events.
Built-in namespaces (message:*, system:*, agent:*, bot:*, compaction:*, schedule:*, reaction:*, room:*, config:*, session:*, tool:*) are reserved.
Defining a custom event hook
from mindroom.hooks import hook
@hook("todo:item_completed")
async def audit_completion(ctx):
append_jsonl(ctx.state_root / "events.jsonl", {"item_id": ctx.payload["item_id"]})
Emitting from tool code
Tools emit custom events through the runtime context:
from mindroom.tool_system.runtime_context import emit_custom_event
# Inside a tool method:
await emit_custom_event("my-plugin", "todo:item_completed", {"item_id": "123"})
Hook contexts do not expose a hook_registry, so hook callbacks cannot emit custom events directly through ctx.
If you are writing internal code or tests and already have an explicit HookRegistry, you can still call emit(registry, event_name, context) manually.
Event name rules
- Pattern:
^[a-z0-9_.-]+(:[a-z0-9_.-]+)+$ - Must contain at least one colon separator
- Reserved namespaces:
message,system,agent,bot,compaction,schedule,reaction,room,config,session,tool - Custom events run in observer mode (
emit()) - Recursion guard: nested emissions stop at depth 3
Error handling
Fault isolation
Every hook invocation runs inside an asyncio.timeout() with structured error logging.
Ordinary Exception and SystemExit failures are logged and isolated so later hooks can continue.
Cancellation follows the caller and event policy, and external side effects completed before a failure cannot be rolled back.
Failure semantics are mode-aware:
- Observer failures stop that callback; completed external side effects remain, and the next hook still runs
- Collector failures lose only that hook's contributed items
message:before_responsetransformer failures preserve mutations already made to the shared draft before the failuremessage:final_response_transformtransformer failures discard the failed hook's copy and continue with the previous draft
No quarantine, no cooldown
A hook that raises is logged and skipped for that one event. The next event invokes it again. If it keeps raising, you keep getting logs — fix it (combined with plugin hot reload, the next save is live within ~1s) and the next invocation just works. There is no failure threshold, no muting, no cooldown to wait out.
No automatic retries
The hook runtime does not retry failed hooks. If a hook needs retry logic, implement it inside the hook where the author understands idempotency.
Plugin state
Every hook has access to persistent storage via ctx.state_root, which maps to mindroom_data/plugins/<plugin_name>/.
The directory is created on first access.
import json
from mindroom.hooks import hook
@hook("reaction:received")
async def pin_message(ctx):
if ctx.reaction_key != "\U0001f4cc":
return
pins_file = ctx.state_root / "pins.json"
pins = json.loads(pins_file.read_text()) if pins_file.exists() else []
pins.append({"room": ctx.room_id, "event": ctx.target_event_id})
pins_file.write_text(json.dumps(pins))
Scoped sub-paths (per-room, per-user) are the plugin author's responsibility.
Context reference
Base fields (non-tool hooks)
Contexts derived from HookContext include these fields:
| Field | Type | Description |
|---|---|---|
event_name |
str |
The event that triggered this hook |
plugin_name |
str |
Name of the plugin owning this hook |
settings |
dict[str, Any] |
Plugin settings from config.yaml |
config |
Config |
Current MindRoom config (read-only) |
runtime_paths |
RuntimePaths |
Storage paths and environment values |
logger |
BoundLogger |
Plugin-scoped structured logger |
correlation_id |
str |
Unique ID per inbound event |
runtime_started_at |
float \| None |
Unix timestamp of the latest bot start, useful when plugin state must ignore anything recorded before it |
state_root |
Path |
Plugin state directory (property) |
Those non-tool contexts also expose the following helpers:
ToolBeforeCallContext and ToolAfterCallContext use a separate tool-hook surface.
Their config and runtime_paths values may be absent, and they do not expose runtime_started_at or get_latest_agent_message_snapshot().
await ctx.send_message(room_id, text, *, thread_id=None, extra_content=None, trigger_dispatch=False)
Sends a hook-originated Matrix message and returns the event ID on success, or None when no sender is bound.
For message-derived contexts, MindRoom automatically preserves the original requester in com.mindroom.original_sender so downstream routing, permissions, and memory attribution continue to use the human sender instead of the router relay.
For ScheduleFiredContext, omitting thread_id inherits ctx.thread_id, while passing thread_id=None explicitly posts at room level.
Plain hook sends can still dispatch when they satisfy the usual routing rules, for example if the message explicitly mentions an agent or otherwise qualifies as a normal addressed message.
Hook-originated sends always carry an internal synthetic-chain depth.
The first hook-originated hop uses depth 1, and each later synthetic hop increments it.
When trigger_dispatch=True, MindRoom sends the message as source kind hook_dispatch.
The first synthetic hook hop still re-enters the normal ingress pipeline, including message:received.
For hook_dispatch, that first synthetic hop also bypasses the usual "ignore other agent unless mentioned" ingress gate before continuing through normal permissions, routing, and should-respond checks.
If that first synthetic hop originated from message:received, MindRoom skips the origin plugin on the message:received re-entry.
Deeper synthetic hook hops still arrive as messages, but they do not re-enter message:received and they stop before further command handling or agent/model dispatch to avoid feedback loops.
await ctx.query_room_state(room_id, event_type, state_key=None)
Queries Matrix room state events.
When state_key is provided, returns the content dict for that single state event, or None on Matrix error response/not-found.
When state_key is None, returns a {state_key: content} dict of all state events matching event_type, or None on Matrix error response.
Returns None when no room state querier is available (e.g. no Matrix client bound).
When both the current bot and the router can query room state, MindRoom tries the current bot first and falls back to the router on Matrix error responses.
Transport exceptions from the underlying Matrix client propagate to the hook.
await ctx.get_latest_agent_message_snapshot(room_id, sender, *, thread_id=None)
Returns the latest visible m.room.message from sender in the given room or thread scope, read from the conversation projection.
thread_id=None means the unthreaded room conversation, so a threaded reply never answers a room-scope question.
The read never blocks on the homeserver and is bounded to the 50 most recent messages in that scope.
It returns None when no reader is bound, when the sender has no visible message inside that window, or when the sender's newest message is awaiting a server refetch because its visible revision was redacted.
await ctx.put_room_state(room_id, event_type, state_key, content)
Writes a single Matrix room state event and returns True on success, False on Matrix error response.
Returns False when no room state putter is available.
When both the current bot and the router can write room state, MindRoom tries the current bot first and falls back to the router on Matrix error responses.
Transport exceptions from the underlying Matrix client propagate to the hook.
ctx.matrix_admin
Provides a narrow Matrix admin facade when MindRoom has a router-backed admin client available for the current hook context.
This facade is part of the supported hook contract and is intentionally not the raw Matrix client.
It is None when no admin-capable client is bound.
The available methods are resolve_alias(alias), create_room(name=..., alias_localpart=..., topic=..., power_user_ids=...), invite_user(room_id, user_id), force_join_user(room_id, user_id), kick_user(room_id, user_id, reason=None), get_room_members(room_id), add_room_to_space(space_room_id, room_id), and put_room_state(room_id, event_type, state_key, content).
Membership mutation methods return a boolean success result and surface transport exceptions consistently with the other admin operations.
get_room_members returns None when the membership fetch fails, so callers can distinguish an unreadable room from a genuinely empty one.
Rooms created via create_room are retained for the creating bot across room cleanup and restarts, the same way rooms it is invited to are kept.
Transport objects
MessageEnvelope(
source_event_id: str,
target: MessageTarget,
body: str,
attachment_ids: tuple[str, ...],
mentioned_agents: tuple[str, ...],
agent_name: str,
origin: TurnOrigin,
hook_source: str | None = None,
message_received_depth: int = 0, # internal synthetic-chain depth for hook-originated relays
dispatch_policy_source_kind: str | None = None,
)
# envelope.room_id is derived from target.room_id.
# envelope.requester_id, envelope.sender_id, and envelope.source_kind are derived from origin.
# target.source_thread_id preserves the raw inbound thread ID.
# target.resolved_thread_id is the delivery thread after safe-root and room-mode resolution.
# target.session_id is the canonical persistence key for the conversation.
# origin is keyword-only in the dataclass constructor and is required.
# Hook handlers normally inspect ctx.envelope.origin rather than constructing MessageEnvelope themselves.
# Internal code and tests that construct MessageEnvelope must pass a TurnOrigin built by MindRoom's origin classifier.
# dispatch_policy_source_kind is usually None.
# When it is "active_thread_follow_up", source_kind still preserves the original modality such as "message" or "voice".
# ACTIVE_THREAD_FOLLOW_UP_SOURCE_KIND and TRUSTED_INTERNAL_RELAY_SOURCE_KIND are exported from mindroom.hooks for comparisons.
TurnOrigin(
transport_sender_id: str,
requester_id: str,
sender_entity_name: str | None,
requester_entity_name: str | None,
sender_kind: SenderKind,
requester_kind: SenderKind,
intent: TurnIntent,
source_kind: str,
trust: TurnTrust,
)
# TurnOrigin, TurnIntent, SenderKind, and TurnTrust are exported from mindroom.hooks for type comparisons.
# sender_kind and requester_kind are "user" or "managed_entity".
# intent is "user_message", "managed_message", "router_handoff", "router_notice", "scheduled_fire", "hook_message", "hook_dispatch", or "trusted_internal_relay".
# trust is "external", "trusted_internal", or "trusted_user_relay".
# origin.may_answer_interactive_prompt is true only for human-requested user messages and trusted human relays.
# origin.may_dispatch_without_mention is true only for the synthetic turns that explicitly bypass the managed-sender mention gate.
ResponseDraft(
response_text: str,
response_kind: str, # "ai", "team", "router", "system"
tool_trace: list[ToolTraceEntry] | None,
extra_content: dict[str, Any] | None,
envelope: MessageEnvelope,
suppress: bool = False,
)
FinalResponseDraft(
response_text: str,
response_kind: str, # "ai", "team", "router", "system"
envelope: MessageEnvelope,
)
ResponseResult(
response_text: str,
response_event_id: str,
delivery_kind: str, # "sent" or "edited"
response_kind: str,
envelope: MessageEnvelope,
)
RoomMemberJoinedContext(
agent_name: str,
room_id: str,
event_id: str,
user_id: str,
sender_id: str,
display_name: str | None,
avatar_url: str | None,
membership: str,
prev_membership: str | None,
)
RoomMemberLeftContext(
agent_name: str,
room_id: str,
event_id: str,
user_id: str,
sender_id: str,
display_name: str | None,
avatar_url: str | None,
membership: str,
prev_membership: str | None,
)
ToolBeforeCallContext(
tool_name: str,
arguments: dict[str, Any],
agent_name: str,
room_id: str | None,
thread_id: str | None,
requester_id: str | None,
session_id: str | None,
declined: bool = False,
decline_reason: str = "",
)
ToolAfterCallContext(
tool_name: str,
arguments: dict[str, Any],
agent_name: str,
room_id: str | None,
thread_id: str | None,
requester_id: str | None,
session_id: str | None,
result: object | None,
error: BaseException | None,
blocked: bool,
duration_ms: float,
)
For schedule:fired, ScheduleFiredContext.thread_id is the resolved delivery thread.
This may differ from workflow.thread_id when the workflow starts a new thread or resolves to room mode.
Testing
Hook tests follow standard pytest patterns. Build a registry from stub plugins and invoke the execution helpers directly.
Testing an observer hook
import pytest
from mindroom.hooks import EVENT_MESSAGE_RECEIVED, HookRegistry, MessageReceivedContext, hook
from mindroom.hooks.execution import emit
@hook(EVENT_MESSAGE_RECEIVED)
async def suppress_spam(ctx):
if "spam" in ctx.envelope.body:
ctx.suppress = True
@pytest.mark.asyncio
async def test_suppress_spam(hook_context_factory):
registry = HookRegistry.from_plugins([stub_plugin("demo", [suppress_spam])])
ctx = hook_context_factory(MessageReceivedContext, body="buy spam now")
await emit(registry, EVENT_MESSAGE_RECEIVED, ctx)
assert ctx.suppress is True
Testing an enrichment hook
import pytest
from mindroom.hooks import EVENT_MESSAGE_ENRICH, HookRegistry, hook
from mindroom.hooks.execution import emit_collect
@hook(EVENT_MESSAGE_ENRICH)
async def enrich_with_time(ctx):
ctx.add_metadata("time", "2026-03-23T10:00:00Z")
@pytest.mark.asyncio
async def test_enrichment(hook_context_factory):
registry = HookRegistry.from_plugins([stub_plugin("demo", [enrich_with_time])])
ctx = hook_context_factory("MessageEnrichContext")
items = await emit_collect(registry, EVENT_MESSAGE_ENRICH, ctx)
assert len(items) == 1
assert items[0].key == "time"
Testing a transformer hook
import pytest
from mindroom.hooks import EVENT_MESSAGE_BEFORE_RESPONSE, HookRegistry, hook
from mindroom.hooks.execution import emit_transform
@hook(EVENT_MESSAGE_BEFORE_RESPONSE)
async def append_footer(ctx):
ctx.draft.response_text += "\n-- Footer"
@pytest.mark.asyncio
async def test_append_footer(hook_context_factory):
registry = HookRegistry.from_plugins([stub_plugin("demo", [append_footer])])
ctx = hook_context_factory("BeforeResponseContext", response_text="Hello")
result = await emit_transform(registry, EVENT_MESSAGE_BEFORE_RESPONSE, ctx)
assert result.response_text == "Hello\n-- Footer"
Creating stub plugins for tests
from mindroom.config.plugin import PluginEntryConfig
def stub_plugin(name, callbacks, *, plugin_order=0, settings=None, hooks=None):
return type(
"PluginStub",
(),
{
"name": name,
"discovered_hooks": tuple(callbacks),
"entry_config": PluginEntryConfig(
path=f"./plugins/{name}",
settings=settings or {},
hooks=hooks or {},
),
"plugin_order": plugin_order,
},
)()
Migration
Existing plugins work with zero changes.
A manifest with only name, tools_module, and skills behaves exactly as before.
To adopt hooks:
- Add
@hook(...)decorators to the existingtools_module. MindRoom auto-scans and discovers them. - Switch the plugin config entry from string to object form only when you need
settingsor per-hook overrides. - Add
hooks_moduleto the manifest later if you want to separate hook code from tool code.
What stays the same
plugins: list[str]config works unchanged- Tool names remain globally unique
- Per-agent tool filtering (
tools: [file, shell]) is unchanged - Skill allowlists are unchanged
- Hot reload rebuilds the hook registry from scratch and swaps atomically
What is out of scope
- Hooks cannot replace core routing, authorization, or deduplication
- No hook context exposes the Matrix client directly
- No automatic retries in the hook runtime
- No cross-worker custom event IPC (primary process only)