- Add comment_type column (note/blocker) with migration 000028 - Blocker comments auto-fail task, cancel member session via EventTeamTaskFailed broadcast, and escalate to leader via InboundMessage (system:escalation bypasses debounce) - Enrich audit events: fix tenant scope bug (context.Background → WithTenantID), add 4 missing types (commented/progress/updated/stale), populate data field (reason, comment_text, progress_percent) - Add blocker escalation config toggle in team settings UI - Add audit logs modal with paginated team events (Clock icon) - Update features modal: all features now available (no coming soon) - Update code comments: reviewer role not yet active, all flows via leader - Update docs: remove v1/v2 versioning, add blocker escalation and review workflow sections, document enriched audit events
31 KiB
03 - Tools System
The tools system is the bridge between the agent loop and the external environment. When the LLM emits a tool call, the agent loop delegates execution to the tool registry, which handles rate limiting, credential scrubbing, policy enforcement, and virtual filesystem routing before returning results for the next LLM iteration.
1. Tool Execution Flow
sequenceDiagram
participant AL as Agent Loop
participant R as Registry
participant RL as Rate Limiter
participant T as Tool
participant SC as Scrubber
AL->>R: ExecuteWithContext(name, args, channel, chatID, ...)
R->>R: Inject context values into ctx
R->>RL: Allow(sessionKey)?
alt Rate limited
RL-->>R: Error: rate limit exceeded
else Allowed
RL-->>R: OK
R->>T: Execute(ctx, args)
T-->>R: Result
R->>SC: ScrubCredentials(result.ForLLM)
R->>SC: ScrubCredentials(result.ForUser)
SC-->>R: Cleaned result
end
R-->>AL: Result
ExecuteWithContext performs 8 steps:
- Lock registry, find tool by name, unlock
- Inject
WithToolChannel(ctx, channel) - Inject
WithToolChatID(ctx, chatID) - Inject
WithToolPeerKind(ctx, peerKind) - Inject
WithToolSandboxKey(ctx, sessionKey) - Rate limit check via
rateLimiter.Allow(sessionKey) - Execute
tool.Execute(ctx, args) - Scrub credentials from both
ForLLMandForUseroutput, log duration
Context keys ensure each tool call receives the correct per-call values without mutable fields, allowing tool instances to be shared safely across concurrent goroutines.
2. Complete Tool Inventory
Filesystem (group: fs)
| Tool | Description |
|---|---|
read_file |
Read file contents with optional line range |
write_file |
Write or create a file |
edit |
Apply targeted edits to a file |
list_files |
List directory contents |
search |
Search file contents with regex |
glob |
Find files matching a glob pattern |
Runtime (group: runtime)
| Tool | Description |
|---|---|
exec |
Execute a shell command |
credentialed_exec |
Execute CLI with injected credentials (direct exec mode, no shell) |
Web (group: web)
| Tool | Description |
|---|---|
web_search |
Search the web (Brave, DuckDuckGo) |
web_fetch |
Fetch and parse a URL |
Memory (group: memory)
| Tool | Description |
|---|---|
memory_search |
Search memory documents (BM25 + vector) |
memory_get |
Retrieve a specific memory document |
Sessions (group: sessions)
| Tool | Description |
|---|---|
sessions_list |
List active sessions |
sessions_history |
View session message history |
sessions_send |
Send a message to a session |
spawn |
Spawn subagent or delegate to another agent |
session_status |
Get current session status |
Knowledge & Search (group: knowledge)
| Tool | Description |
|---|---|
knowledge_graph_search |
Search knowledge graph for entities and relationships |
skill_search |
Search available skills (BM25) |
Automation (group: automation)
| Tool | Description |
|---|---|
cron |
Manage scheduled tasks |
datetime |
Get current date/time with timezone support |
Messaging (group: messaging)
| Tool | Description |
|---|---|
message |
Send a message to a channel |
create_forum_topic |
Create a Telegram forum topic |
Delegation (group: delegation)
The
delegatetool has been removed. Delegation is now handled via agent teams usingteam_tasksandteam_message.
Teams (group: teams)
| Tool | Description |
|---|---|
team_tasks |
Task board: create, list, get, claim, complete, cancel, assign, review, approve, reject, comment (with type: note/blocker), progress, attach, ask_user, search, update |
team_message |
Mailbox: send direct message to teammate, broadcast to all, read unread messages |
Media Generation
Images
| Tool | Description |
|---|---|
create_image |
Generate images from text description (OpenAI, Gemini, MiniMax, DashScope) |
Audio & Music
| Tool | Description |
|---|---|
create_audio |
Generate audio/music/sound effects (MiniMax music, ElevenLabs effects) |
tts |
Text-to-speech synthesis (OpenAI, ElevenLabs, Edge, MiniMax) |
Video
| Tool | Description |
|---|---|
create_video |
Generate video from text/image (MiniMax) |
Media Reading
Images
| Tool | Description |
|---|---|
read_image |
Analyze/describe images using vision AI (Gemini, Anthropic, OpenRouter, DashScope) |
Audio & Speech
| Tool | Description |
|---|---|
read_audio |
Transcribe audio to text (Resolve transcription service) |
Documents
| Tool | Description |
|---|---|
read_document |
Extract and analyze documents (PDF, images, etc) via Gemini or Resolve service |
Video
| Tool | Description |
|---|---|
read_video |
Analyze/transcribe video content via Resolve service |
Skills & Content
| Tool | Description |
|---|---|
use_skill |
Activate a skill (marker tool for observability) |
publish_skill |
Register a skill directory in the database |
AI & LLM
| Tool | Description |
|---|---|
openai_compat_call |
Call OpenAI-compatible endpoints with custom request formats |
Workspace & Administration
| Tool | Description |
|---|---|
workspace_dir |
Resolve workspace directory for team/user context |
3. Filesystem Tools and Virtual FS Routing
Filesystem operations are intercepted before hitting the host disk. Two interceptor layers route specific paths to the database instead.
flowchart TD
CALL["read_file / write_file"] --> INT1{"ContextFile<br/>Interceptor?"}
INT1 -->|Handled| DB1[("DB: agent_context_files<br/>/ user_context_files")]
INT1 -->|Not handled| INT2{"Memory<br/>Interceptor?"}
INT2 -->|Handled| DB2[("DB: memory_documents")]
INT2 -->|Not handled| SBX{"Sandbox enabled?"}
SBX -->|Yes| DOCKER["Docker container"]
SBX -->|No| HOST["Host filesystem<br/>resolvePath -> os.ReadFile / WriteFile"]
ContextFileInterceptor -- 7 Routed Files
| File | Description |
|---|---|
SOUL.md |
Agent personality and behavior |
IDENTITY.md |
Agent identity information |
AGENTS.md |
Sub-agent definitions |
TOOLS.md |
Tool usage guidance |
USER.md |
Per-user preferences and context |
BOOTSTRAP.md |
First-run instructions (write empty = delete row) |
Routing by Agent Type
flowchart TD
FILE{"Path is one of<br/>7 context files?"} -->|No| PASS["Pass through to disk"]
FILE -->|Yes| TYPE{"Agent type?"}
TYPE -->|open| USER_CF["user_context_files<br/>fallback: agent_context_files"]
TYPE -->|predefined| PRED{"File = USER.md?"}
PRED -->|Yes| USER_CF2["user_context_files"]
PRED -->|No| AGENT_CF["agent_context_files"]
- Open agents: All 7 files are per-user. If a user file does not exist, the agent-level template is returned as fallback.
- Predefined agents: Only
USER.mdis per-user. All other files come from the agent-level store.
MemoryInterceptor
Routes MEMORY.md, memory.md, and memory/* paths. Per-user results take priority with a fallback to global scope. Writing a .md file automatically triggers IndexDocument() (chunking + embedding).
PathDenyable Interface
Tools that access the filesystem implement the PathDenyable interface, allowing specific path prefixes to be denied at runtime:
type PathDenyable interface {
DenyPaths(...string)
}
All four filesystem tools (read_file, write_file, list_files, edit_file) implement it. list_files additionally filters denied directories from its output entirely -- the agent doesn't even know the directory exists. Used to prevent agents from accessing .goclaw directories within workspaces.
Workspace Context Injection
Filesystem and shell tools read their workspace from ToolWorkspaceFromCtx(ctx), which is injected by the agent loop based on the current user and agent. This enables per-user workspace isolation without changing any tool code. Falls back to the struct field for backward compatibility.
Path Security
resolvePath() joins relative paths with the workspace root, applies filepath.Clean(), and verifies the result with HasPrefix(). This prevents path traversal attacks (e.g., ../../../etc/passwd). The extended resolvePathWithAllowed() permits additional prefixes for skills directories.
4. Shell Execution
The exec tool allows the LLM to run shell commands, with multiple defense layers.
Credentialed CLI Tools
Direct Exec Mode allows secure credential injection for CLI tools without exposing credentials via shell. Credentials are auto-injected as environment variables directly into the child process (no shell involved).
How it works:
- Credential lookup — Administrator configures binary → encrypted env vars in
secure_cli_binariestable - Shell operator detection — Blocks unsafe command chaining (
;,|,&&,||,>,<,$(), backticks) - Path verification — Binary is resolved to absolute path and matched against configured path
- Per-binary deny check — Optional regex patterns block specific arguments (e.g.,
auth\s+,ssh-key) - Direct exec — Command runs as
exec.CommandContext(binary, args...)with credentials in env
Available presets: gh, gcloud, aws, kubectl, terraform
Security layers:
- No shell — Direct exec prevents shell command injection
- Path verification — Binary spoofing (e.g.,
./ghin workspace) is blocked - Per-binary deny — Admins can block sensitive operations per CLI
- Output scrubbing — Credential values registered for automatic redaction
Configuration (JSON in secure_cli_binaries table):
{
"binary_name": "gh",
"encrypted_env": {"GH_TOKEN": "ghp_..."},
"deny_args": ["auth\\s+", "ssh-key"],
"deny_verbose": ["--verbose", "-v"],
"timeout_seconds": 30,
"tips": "GitHub CLI. Available: gh api, gh repo, gh issue, etc."
}
Deny Patterns
| Category | Blocked Patterns |
|---|---|
| Destructive file ops | rm -rf, del /f, rmdir /s |
| Disk destruction | mkfs, dd if=, > /dev/sd* |
| System control | shutdown, reboot, poweroff |
| Fork bombs | :(){ ... };: |
| Remote code exec | curl | sh, wget -O - | sh |
| Reverse shells | /dev/tcp/, nc -e |
| Eval injection | eval $(), base64 -d | sh |
Approval Workflow
flowchart TD
CMD["Shell Command"] --> DENY{"Matches deny<br/>pattern?"}
DENY -->|Yes| BLOCK["Blocked by safety policy"]
DENY -->|No| APPROVAL{"Approval manager<br/>configured?"}
APPROVAL -->|No| EXEC["Execute on host"]
APPROVAL -->|Yes| CHECK{"CheckCommand()"}
CHECK -->|deny| BLOCK2["Command denied"]
CHECK -->|allow| EXEC
CHECK -->|ask| REQUEST["Request approval<br/>(2-minute timeout)"]
REQUEST -->|allow-once| EXEC
REQUEST -->|allow-always| ADD["Add to dynamic allowlist"] --> EXEC
REQUEST -->|deny / timeout| BLOCK3["Command denied"]
Sandbox Routing
When a sandbox manager is configured and a sandboxKey exists in context, commands execute inside a Docker container. The host working directory maps to /workspace in the container. Host timeout is 60 seconds; sandbox timeout is 300 seconds. If sandbox returns ErrSandboxDisabled, execution falls back to the host.
5. Policy Engine
The policy engine determines which tools the LLM can use through a 7-step allow pipeline followed by deny subtraction and additive alsoAllow.
flowchart TD
ALL["All registered tools"] --> S1
S1["Step 1: Global Profile<br/>full / minimal / coding / messaging"] --> S2
S2["Step 2: Provider Profile Override<br/>byProvider.{name}.profile"] --> S3
S3["Step 3: Global Allow List<br/>Intersection with allow list"] --> S4
S4["Step 4: Provider Allow Override<br/>byProvider.{name}.allow"] --> S5
S5["Step 5: Agent Allow<br/>Per-agent allow list"] --> S6
S6["Step 6: Agent + Provider Allow<br/>Per-agent per-provider allow"] --> S7
S7["Step 7: Group Allow<br/>Group-level allow list"]
S7 --> DENY["Apply Deny Lists<br/>Global deny, then Agent deny"]
DENY --> ALSO["Apply AlsoAllow<br/>Global alsoAllow, Agent alsoAllow<br/>(additive union)"]
ALSO --> SUB{"Subagent?"}
SUB -->|Yes| SUBDENY["Apply subagent deny list<br/>+ leaf deny list if at max depth"]
SUB -->|No| FINAL["Final tool list sent to LLM"]
SUBDENY --> FINAL
Profiles
| Profile | Tools Included |
|---|---|
full |
All registered tools (no restriction) |
coding |
group:fs, group:runtime, group:sessions, group:memory, group:web, group:knowledge, group:media_gen, group:media_read, group:skills |
messaging |
group:messaging, group:web, group:sessions, group:media_read, skill_search |
minimal |
session_status only |
Tool Groups
| Group | Members |
|---|---|
fs |
read_file, write_file, list_files, edit, search, glob |
runtime |
exec, credentialed_exec |
web |
web_search, web_fetch |
memory |
memory_search, memory_get |
sessions |
sessions_list, sessions_history, sessions_send, spawn, session_status |
knowledge |
knowledge_graph_search, skill_search |
automation |
cron, datetime |
messaging |
message, create_forum_topic |
delegation |
delegate |
teams |
team_tasks, team_message |
media_gen |
create_image, create_audio, create_video, tts |
media_read |
read_image, read_audio, read_document, read_video |
skills |
use_skill, publish_skill |
goclaw |
All native tools (composite group) |
Groups can be referenced in allow/deny lists with the group: prefix (e.g., group:fs). The MCP manager dynamically registers mcp and mcp:{serverName} groups at runtime.
Per-Request Tool Allow List
In addition to the static policy pipeline, channels can inject a per-request tool allow list via message metadata. For example, Telegram forum topics can restrict tools per-topic (see 05-channels-messaging.md Section 5). The allow list is applied as a final intersection step after the policy pipeline completes.
6. Subagent System
Subagents are child agent instances spawned to handle parallel or complex tasks. They run in background goroutines with restricted tool access.
Lifecycle
stateDiagram-v2
[*] --> Spawning: spawn(task, label)
Spawning --> Running: Limits pass<br/>(depth, concurrent, children)
Spawning --> Rejected: Limit exceeded
Running --> Completed: Task finished
Running --> Failed: LLM error
Running --> Cancelled: cancel / steer / parent abort
Completed --> Archived: After 60 min
Failed --> Archived: After 60 min
Cancelled --> Archived: After 60 min
Limits
| Constraint | Default | Description |
|---|---|---|
| MaxConcurrent | 8 | Total running subagents across all parents |
| MaxSpawnDepth | 1 | Maximum nesting depth |
| MaxChildrenPerAgent | 5 | Maximum children per parent agent |
| ArchiveAfterMinutes | 60 | Auto-archive completed tasks |
| Max iterations | 20 | LLM loop iterations per subagent |
Subagent Actions
| Action | Behavior |
|---|---|
spawn (async) |
Launch in goroutine, return immediately with acceptance message |
run (sync) |
Block until subagent completes, return result directly |
list |
List all subagent tasks with status |
cancel |
Cancel by specific ID, "all", or "last" |
steer |
Cancel + settle 500ms + respawn with new message |
Tool Deny Lists
| List | Denied Tools |
|---|---|
| Always denied (all depths) | gateway, agents_list, whatsapp_login, session_status, cron, memory_search, memory_get, sessions_send |
| Leaf denied (max depth) | sessions_list, sessions_history, sessions_spawn, spawn, subagent |
Results are announced back to the parent agent via the message bus, optionally batched through an AnnounceQueue with debouncing.
7. Delegation System
Note: The
delegatetool has been removed. TheDelegateManagerdescribed below is deprecated/removed. Delegation is now handled via agent teams: leads create tasks on the shared board (team_tasks) and spawn member agents explicitly. See 11-agent-teams.md for the current model.
Delegation allows named agents to delegate tasks to other fully independent agents (each with its own identity, tools, provider, model, and context files). Unlike subagents (anonymous clones), delegation crosses agent boundaries via explicit permission links.
DelegateManager (Removed)
The delegate tool and its DelegateManager in internal/tools/subagent_spawn_tool.go have been removed. Previously supported actions:
| Action | Mode | Behavior |
|---|---|---|
delegate |
sync |
Caller waits for result (quick lookups, fact checks) |
delegate |
async |
Caller moves on; result announced later via message bus (delegate:{id}) |
cancel |
-- | Cancel a running async delegation by ID |
list |
-- | List active delegations |
history |
-- | Query past delegations from delegation_history table |
Callback Pattern
The tools package cannot import agent (import cycle). A callback function bridges the gap:
type AgentRunFunc func(ctx context.Context, agentKey string, req DelegateRunRequest) (*DelegateRunResult, error)
The cmd layer provides the implementation at wiring time. The tools package never knows agent exists.
Concurrency Control
Delegation concurrency is controlled at the agent level to prevent overload:
| Layer | Config | Scope |
|---|---|---|
| Per-agent | other_config.max_delegation_load |
B from all sources |
When limits hit, the error message is written for LLM reasoning: "Agent at capacity (5/5). Try a different agent or handle it yourself."
DELEGATION.md Auto-Injection
During agent resolution, DELEGATION.md is auto-generated and injected into the system prompt:
- ≤15 targets: Full inline list with agent keys, names, and frontmatter
- >15 targets: Brief description-only list (LLM reads available delegation targets via resolver)
Context File Merging (Open Agents)
For open agents, per-user context files merge with resolver-injected base files. Per-user files override same-name base files, but base-only files like DELEGATION.md are preserved:
Base files (resolver): DELEGATION.md
Per-user files (DB): AGENTS.md, SOUL.md, TOOLS.md, USER.md, ...
Merged result: AGENTS.md, SOUL.md, TOOLS.md, USER.md, ..., DELEGATION.md ✓
8. Agent Teams
Teams add a shared coordination layer on top of delegation: a task board for parallel work and a mailbox for peer-to-peer communication.
Architecture
An admin creates a team via the dashboard, assigns a lead and members. When a user messages the lead:
- The lead sees
TEAM.mdin its system prompt (teammate list + role) - The lead posts tasks to the board
- Teammates are activated, claim tasks, and work in parallel
- Teammates message each other for coordination
- The lead synthesizes results and replies to the user
Task Board (team_tasks tool)
| Action | Description |
|---|---|
list |
List tasks (filter: active/completed/all, order: priority/newest) |
create |
Create task with subject, description, priority, blocked_by |
claim |
Atomically claim a pending task (race-safe via row-level lock) |
complete |
Mark task done with result; auto-unblocks dependent tasks |
search |
FTS search over task subject + description |
Mailbox (team_message tool)
| Action | Description |
|---|---|
send |
Send direct message to a specific teammate |
broadcast |
Send message to all teammates |
read |
Read unread messages |
Lead-Centric Design
Only the lead gets TEAM.md in its system prompt. Teammates discover context on demand through tools -- no wasted tokens on idle agents. When a teammate message arrives, the message itself carries context (e.g., "[Team message from lead]: please claim a task from the board.").
Message Routing
Teammate results route through the message bus with a "teammate:" prefix. The consumer publishes the outbound response so the lead (and ultimately the user) sees the result.
10. MCP Bridge Tools
GoClaw integrates with Model Context Protocol (MCP) servers via internal/mcp/. The MCP Manager connects to external tool servers and registers their tools in the tool registry with a configurable prefix.
Transports
| Transport | Description |
|---|---|
stdio |
Launch process with command + args, communicate via stdin/stdout |
sse |
Connect to SSE endpoint via URL |
streamable-http |
Connect to HTTP streaming endpoint |
Behavior
- Health checks run every 30 seconds per server
- Reconnection uses exponential backoff (2s initial, 60s max, 10 attempts)
- Tools are registered with a prefix (e.g.,
mcp_servername_toolname) - Dynamic tool group registration:
mcpandmcp:{serverName}groups
Access Control
MCP server access is controlled through per-agent and per-user grants stored in PostgreSQL.
flowchart TD
REQ["LoadForAgent(agentID, userID)"] --> QUERY["ListAccessible()<br/>JOIN mcp_servers + agent_grants + user_grants"]
QUERY --> SERVERS["Accessible servers list<br/>(with ToolAllow/ToolDeny per grant)"]
SERVERS --> CONNECT["Connect each server<br/>(stdio/sse/streamable-http)"]
CONNECT --> DISCOVER["ListTools() from server"]
DISCOVER --> FILTER["filterTools()<br/>1. Remove tools in deny list<br/>2. Keep only tools in allow list (if set)<br/>3. Deny takes priority over allow"]
FILTER --> REGISTER["Register filtered tools<br/>in tool registry"]
Grant types:
| Grant | Table | Scope | Fields |
|---|---|---|---|
| Agent grant | mcp_agent_grants |
Per server + agent | tool_allow, tool_deny (JSONB arrays), config_overrides, enabled |
| User grant | mcp_user_grants |
Per server + user | tool_allow, tool_deny (JSONB arrays), enabled |
Access request workflow: Users can request access to MCP servers. Admins review and approve or reject. On approval, a corresponding grant is created transactionally.
flowchart LR
USER["CreateRequest()<br/>scope: agent/user<br/>status: pending"] --> ADMIN["ReviewRequest()<br/>approve or reject"]
ADMIN -->|approved| GRANT["Create agent/user grant<br/>with requested tool_allow"]
ADMIN -->|rejected| DONE["Request closed"]
11. Custom Tools
Define shell-based tools at runtime via the HTTP API -- no recompile or restart needed. Custom tools are stored in the custom_tools PostgreSQL table and loaded dynamically into the agent's tool registry.
Lifecycle
flowchart TD
subgraph Startup
GLOBAL["LoadGlobal()<br/>Fetch all tools with agent_id IS NULL<br/>Register into global registry"]
end
subgraph "Per-Agent Resolution"
RESOLVE["LoadForAgent(globalReg, agentID)"] --> CHECK{"Agent has<br/>custom tools?"}
CHECK -->|No| USE_GLOBAL["Use global registry as-is"]
CHECK -->|Yes| CLONE["Clone global registry<br/>Register per-agent tools<br/>Return cloned registry"]
end
subgraph "Cache Invalidation"
EVENT["cache:custom_tools event"] --> RELOAD["ReloadGlobal()<br/>Unregister old, register new"]
RELOAD --> INVALIDATE["AgentRouter.InvalidateAll()<br/>Force re-resolve on next request"]
end
Scope
| Scope | agent_id |
Behavior |
|---|---|---|
| Global | NULL |
Available to all agents |
| Per-agent | UUID | Available only to the specified agent |
Command Execution
- Template rendering:
{{.key}}placeholders replaced with shell-escaped argument values (single-quote wrapping with embedded quote escaping) - Deny pattern check: Same deny patterns as the
exectool (blockscurl|sh, reverse shells, etc.) - Execution:
sh -c <rendered_command>with configurable timeout (default 60s) and optional working directory - Environment variables: Stored encrypted (AES-256-GCM) in the database, decrypted at runtime and injected into the command environment
JSON Config Example
{
"name": "dns_lookup",
"description": "Look up DNS records for a domain",
"parameters": {
"type": "object",
"properties": {
"domain": { "type": "string", "description": "Domain name" },
"record_type": { "type": "string", "enum": ["A", "AAAA", "MX", "CNAME", "TXT"] }
},
"required": ["domain"]
},
"command": "dig +short {{.record_type}} {{.domain}}",
"timeout_seconds": 10,
"enabled": true
}
12. Credential Scrubbing
Tool output is automatically scrubbed before being returned to the LLM. Enabled by default in the registry.
Static Patterns
| Type | Pattern |
|---|---|
| OpenAI | sk-[a-zA-Z0-9]{20,} |
| Anthropic | sk-ant-[a-zA-Z0-9-]{20,} |
| GitHub PAT | ghp_, gho_, ghu_, ghs_, ghr_ + 36 alphanumeric characters |
| AWS | AKIA[A-Z0-9]{16} |
| Generic key-value | (api_key|token|secret|password|bearer|authorization)[:=]value (case-insensitive) |
| Connection strings | postgres://, mysql://, mongodb://, redis:// patterns |
| Env var patterns | KEY=, SECRET=, CREDENTIAL=, DSN=, VIRTUAL_*= patterns |
| Long hex strings | 64+ character hex strings (potential encryption keys) |
All matches are replaced with [REDACTED].
Dynamic Scrubbing
In addition to static patterns, values can be registered at runtime for scrubbing. This is used for server IPs and other deployment-specific secrets that are not known at compile time. The AddDynamicScrubValues() function thread-safely adds values to a scrub list that is checked alongside static patterns.
13. Rate Limiter
The tool registry supports per-session rate limiting via ToolRateLimiter. When configured, each ExecuteWithContext call checks rateLimiter.Allow(sessionKey) before tool execution. Rate-limited calls receive an error result without executing the tool.
File Reference
Core Infrastructure
| File | Purpose |
|---|---|
internal/tools/{registry,types,policy,result}.go |
Registry, interfaces, PolicyEngine (7-step pipeline), result types |
internal/tools/{context_keys,rate_limiter}.go |
Context key definitions, per-session rate limiting |
internal/tools/{scrub,scrub_server}.go |
Credential scrubbing and dynamic value registration |
Filesystem Tools
| File | Purpose |
|---|---|
internal/tools/filesystem{,_list,_write}.go |
read_file, write_file, list_files, edit tools |
internal/tools/edit.go |
edit tool: targeted file modifications |
internal/tools/{context_file,memory,workspace}_interceptor.go |
File routing: context files, memory, team workspace |
internal/tools/workspace_dir.go |
Workspace directory resolution for team/user context |
Runtime & Shell Tools
| File | Purpose |
|---|---|
internal/tools/shell.go |
exec tool: deny patterns, approval workflow, sandbox routing |
internal/tools/exec_approval.go |
Approval workflow for restricted shell commands |
internal/tools/credentialed_exec.go |
credentialed_exec: direct exec mode with credential injection |
internal/tools/credential_{context,presets}.go |
TOOLS.md supplement + preset definitions (gh, gcloud, aws, etc.) |
Web Tools
| File | Purpose |
|---|---|
internal/tools/web_search{,_brave,_ddg}.go |
web_search tool (Brave, DuckDuckGo) |
internal/tools/web_fetch{,_convert,_convert_handlers,_convert_utils,_hidden}.go |
web_fetch tool: fetch, HTML→Markdown, element handlers |
internal/tools/web_shared.go |
Shared web utilities |
Memory, Knowledge & Sessions
| File | Purpose |
|---|---|
internal/tools/{memory,knowledge_graph,skill_search}.go |
Memory search, KG queries, skill BM25 search |
internal/tools/sessions{,_history,_send}.go |
Session list, history, send tools |
internal/tools/subagent{,_spawn_tool,_config,_exec,_control,_tracing}.go |
SubagentManager: spawn, cancel, steer, tracing |
Media Tools
| File | Purpose |
|---|---|
internal/tools/create_image.go |
create_image tool (OpenAI, Gemini, MiniMax, DashScope) |
internal/tools/create_image_{dashscope,minimax}.go |
Provider-specific image generation |
internal/tools/create_audio.go |
create_audio tool (MiniMax, ElevenLabs, Suno) |
internal/tools/create_audio_{minimax,elevenlabs,suno}.go |
Provider-specific audio generation |
internal/tools/create_video.go |
create_video tool (MiniMax) |
internal/tools/tts.go |
tts tool: text-to-speech (OpenAI, ElevenLabs, Edge, MiniMax) |
internal/tools/read_{image,audio,video,document}.go |
Media reading tools (vision, transcription, analysis) |
internal/tools/read_{audio,video,document}_resolve.go |
Resolve service integrations |
internal/tools/read_document_gemini.go |
Gemini file API for documents |
internal/tools/gemini_file_api.go |
Google Gemini file API wrapper |
internal/tools/media_provider_chain.go |
Media provider routing and fallback chain |
Skills & Content Tools
| File | Purpose |
|---|---|
internal/tools/use_skill.go |
use_skill tool: marker for observability |
internal/tools/publish_skill.go |
publish_skill tool: skill registration in database |
Team Collaboration Tools
| File | Purpose |
|---|---|
internal/tools/team_tool_manager.go |
Shared backend: team cache (5-min TTL), resolution |
internal/tools/team_tasks_tool.go |
team_tasks tool: task board operations |
internal/tools/team_tasks_{read,mutations,lifecycle,followup}.go |
Task CRUD, state transitions, dependency handling |
internal/tools/team_message_tool.go |
team_message tool: mailbox (send, broadcast, read) |
internal/tools/team_tool_{cache,dispatch,helpers,validation}.go |
Team tool infrastructure |
internal/tools/team_access_policy.go |
Access control policies for team tools |
Messaging, Automation & Custom Tools
| File | Purpose |
|---|---|
internal/tools/{message,telegram_forum,cron,datetime}.go |
Messaging, forum topics, cron scheduling, datetime |
internal/tools/announce_queue.go |
Message queueing with debouncing |
internal/tools/{dynamic_loader,dynamic_tool}.go |
Dynamic/custom tool loading and execution |
internal/tools/openai_compat_call.go |
OpenAI-compatible endpoint calling utilities |
MCP & Infrastructure
| File | Purpose |
|---|---|
internal/mcp/{manager,bridge_tool}.go |
MCP server connections, bridge tool |