Whether the cache is empty.

Number of entries currently in the cache.

Build a channel error for this adapter.

Broadcast a JSON-serialized event to all subscribers. Returns the number of receivers that got the message.

Create a simple text message (no tool calls).

Access the raw key bytes. Use sparingly — prefer `derive_subkey`.

Number of plugins.

Score a prompt's complexity across 13 dimensions using default config.

Parse back into components. Returns None if format is invalid.

Add a context value.

Transition to a new state, recording the transition with an optional reason. Returns `Err` if the transition is invalid.

Attempt to register a new subagent run. Returns `SpawnResult::Accepted` with run details if the spawn is allowed, or `SpawnResult::Rejected` if limit

Store a response in the cache. Skips storage if the request has tool definitions.

Try each provider in order with circuit breaker + retry. Providers that don't list the requested model are skipped to avoid unnecessary 404s (e.g. se

Get current config snapshot (cheap Arc clone).

Record a transient failure. Non-transient errors should NOT be recorded (e.g., auth failures, context length exceeded, model not found).

Scan text for credential leaks. Returns a `LeakScanResult` with all matches found. If any match has `LeakAction::Block`, `should_block` is `true`. If

Builds a minimal [`CompletionRequest`] with a single user message.

HTTP-like status code for protocol responses.

Process a single SSE data payload and return any stream deltas.

Parse a markdown string into a `MarkdownIR`.

Record a completed LLM call. Call this AFTER the LLM call completes.

Select the best available key using round-robin. Returns `None` if all keys are in cooldown.

Returns the OpenAI-compatible base URL. If `OPENAI_API_KEY` looks like an OpenRouter key (`sk-or-*`), use the OpenRouter endpoint automatically.

Returns the OpenAI API key from `OPENAI_API_KEY`, if set and non-empty.

Replace `{key}` placeholders in a template with provided values. ``` use frankclaw_runtime::prompts::render; let result = render("Hello {name}, you a

Generate a cryptographically secure random token (256 bits, base64url encoded). Suitable for: gateway auth tokens, webhook secrets, pairing codes.

Pick a model that works with the detected endpoint.

Store bytes as a media file, scanning for malware first if a scanner is configured. Returns metadata on success, or `MalwareDetected` if the file is f

Build an OpenAI-compatible chat completions request body.

Extract unique HTTP(S) URLs from a message. - Strips markdown link syntax first (so `[click](url)` is ignored). - Deduplicates URLs. - Filters out SS

Per-model cost lookup table for multi-provider LLM support. Returns (input_cost_per_token, output_cost_per_token) as f64 pairs. Ollama and other loca

Strip Unicode control characters that could be used for prompt injection. Removes: - Unicode category Cc (control chars) except \t, \n, \r (which are

Returns the Anthropic API key from `ANTHROPIC_API_KEY`, if set and non-empty.

Mark the job as stuck with a reason.

Send a JSON-RPC request and receive the response.

Helper to create a temp store for tests.

Attempt recovery from stuck state. Returns `Err` if the job is not stuck or has exceeded max repair attempts.

Build a compact ARIA tree snapshot from CDP `Accessibility.getFullAXTree` nodes. Returns the indented tree text and a map of element references.

Check if a message starts with a known command.

Encrypt plaintext with a 256-bit key using ChaCha20-Poly1305. Each call generates a fresh random nonce. The nonce is stored alongside the ciphertext

Estimate total tokens for a slice of messages.

Fire an event, running all matching handlers. Handlers for both the general type and specific type:action pair are run. Execution is fire-and-forget:

Optimize a message list to fit within the model's context window. Strategy: 1. If messages fit within budget, return as-is. 2. Otherwise, drop oldest

Validate that a browser navigation URL is not targeting private/internal IPs. Uses the same SSRF blocklist as media fetches.