Handle 404 errors for undefined routes.

Check if item(s) might exist in a Bloom filter (BF.EXISTS or BF.MEXISTS). Args: redis: Redis client instance filter_name: Name of

Verify Graphiti is initialised (lightweight attribute check).

Verify MongoDB connectivity via ping command.

Verify Neo4j connectivity via verify_connectivity.

Verify PostgreSQL connectivity via a lightweight SELECT 1.

Check if rate limit is exceeded. Args: identifier: User identifier (user_id or IP) scope: Rate limit scope

Verify Redis connectivity via PING.

Ask a clarifying question when the requested research scope is unclear.

Clean and normalize markdown content.

Close all MCP upstream connections during lifespan shutdown.

Compress raw researcher messages into a concise summary.

Format logs for console with INFO/META structure.

Execute crawl_webpage tool calls from the researcher.

Crawl a URL and optionally extract structured data. - **url**: URL to crawl - **mode**: Output mode (markdown, html, text, summary)

Fetch and return rendered markdown content from a URL using Crawl4AI.

Create a Bloom filter (BF.RESERVE). Args: redis: Redis client instance filter_name: Name of the filter error_rate: Error

Create a cached embedding generator. Args: model: Embedding model to use cache_max_size: Maximum cache size Returns:

Factory function to create embedding cache.

Factory function to create extraction tools. Args: db_pool: Database connection pool use_graphiti: Whether to use Graphiti

Factory function to create ingestion pipeline functions. Args: config: Ingestion configuration documents_folder: Folder cont

Create a Redis search index (FT.CREATE). Args: redis: Redis client instance index_name: Name of the index prefix: Key pre

Factory: create a Neo4j subgraph expansion context. Wraps the driver in a configuration object that can be passed as a DI dependency. This ke

Apply cursor-based pagination.

Template for safe SQL queries.

Delete a single key or entire namespace.

Remove messages that match the predicate.

Delete an entire hash. Args: redis: Redis client instance object_type: Entity type for namespacing key: Hash key identifi

Delete a specific field from a hash. Args: redis: Redis client instance object_type: Entity type for namespacing key: Has

Delete a Redis search index (FT.DROPINDEX). Args: redis: Redis client instance index_name: Name of the index to delete Retur

Delete user and invalidate cache. Endpoint example: DELETE /api/v1/users/123 Behavior: - Deletes user from database - Invalidate

Pre-deployment checklist.

Find circular obligations and multi-hop override chains. Args: config: Neo4j subgraph configuration with driver. group_ids: Neo4j

Detect contradicting obligation patterns in the legal knowledge graph. Finds: - Circular obligations: Party A owes Party B who owes

Template an incident diagnosis workflow.

Discover URLs for a domain via sitemap without full crawl.

Run migrations with the provided database connection. Args: connection: Active database connection from the engine

Generate embedding for a search query. Args: query: Search query model: Embedding model to use Returns: Query e

Execute multiple Redis commands in a pipeline. Args: redis: Redis client instance operations: List of operations like:

Describe the application architecture and available MCP surface.

Extract structured data AND create a summary. Args: content: Content to process schema_type: Predefined sche

Extract code blocks with language detection.

Extract from multiple documents. Args: documents: List of (text, document_id) tuples use_graphiti: Whether to use Graphiti (

Extract images with captions.

Extract tables from document.

Extract title from markdown content.