Get value from cache if not expired

Log an info message.

Log an error message.

Log a debug message.

Log a warning message.

Log an exception with traceback.

Execute a template's plan with mapped values. Returns dict with: results: list of result dicts summary: optional narr

Get a lazy logger that will be configured on first use and writes asynchronously

Pause for effect

Get configuration value. If value is a string, return it directly. Otherwise, treat it as an environment variable name and fetch from

Override send_message to ensure URLs point to gateway endpoint with site parameter.

Log a message with additional context information. Args: level: Log level message: Log message c

Write chunk to response

Process all stores from the input file.

Pause for dramatic effect

Print text with thought trace background

Print commentary with typewriter effect

Search for documents matching the query and site. Args: query: Search query string site: Site identifier or

Record error occurrence.

Cleanup connections

Connect to WebSocket with authentication.

Add participant to conversation.

Pause for dramatic effect

Clear all cache entries

Set value in cache with current timestamp

Get embedding for the provided text using the specified provider and model. Args: text: The text to embed provider: Optional

Get the specified embedding provider config or the preferred one if not specified.

Record response time for operation.

Convert message to dictionary.

Route an LLM request to the specified endpoint, with dispatch based on llm_type. Args: prompt: The text prompt to send to the LLM

Factory function to create a vector database client with the appropriate configuration. Uses a global cache to avoid repeated initialization

* Render multiple items/results

* Escape HTML special characters to prevent XSS

* Safely set HTML content using DOMPurify sanitization * DOMPurify is recognized by CodeQL as a trusted sanitizer

Print commentary with typewriter effect

Simplified search interface that combines client creation and search in one call. Args: query: The search query site: Site t

Create valid OAuth token.

Start continuous monitoring.

Factory for creating test messages.

Ensure URL is properly formatted. Args: url: Input URL Returns: Fixed URL

Safely extract text from an XML element. Args: element: XML element or None Returns: Text content or empty string

Stop monitoring and return final metrics.

Store message as Message objects in handler.messages. Args: message: The message to store (dict or Message object)

Compile a semantic query JSON into SQL. Returns (sql_string, db_config) where db_config has: - primary_db: path to the main databas

Record latency measurement.

Execute a SQL query that may span multiple databases. Args: sql: The full SQL string (may include ATTACH DATABASE statements) db_

Connect to WebSocket.

Get authentication headers for OpenSearch requests. Supports both basic auth (username:password) and API key authentication.

Send a chat completion request, trying providers in order until one succeeds.

Create a new conversation.

Disconnect WebSocket.

Get list of all sites available in the database. For backends that don't support get_sites, returns an empty list to indicate

Resolve an ontology property to source column info for a given type. Returns dict with 'type' key: 'direct', 'fk_ref', or 'join'.

Run all dependency checks.

Get or initialize Elasticsearch client. Returns: AsyncElasticsearch: Elasticsearch async client instance

Print section header

Synchronous version for immediate state update

Get or initialize Qdrant client. Returns: AsyncQdrantClient: Qdrant client instance

Send message when no matching items are found.

Get embeddings for a batch of texts. Args: texts: List of texts to embed provider: Optional provider name, defaults to prefe

Attempt WebSocket connection with authentication.

Convert NLWeb message list into an AppSDK-compatible payload. The resulting object has the shape required by AppSDK tools: { "st

Get conversation statistics.

Check if a path is a URL. Args: path: Path to check Returns: True if the path is a URL, False otherwise

Record a received message.

Print section header

Send message from participant.

Send a message through WebSocket.

Execute a database query with retry logic for transient failures. Args: query_func: Function that performs the database

Get or initialize Elasticsearch client. Returns: AsyncElasticsearch: Elasticsearch async client instance

Get or create a Milvus client. Args: embedding_size: Size of the embeddings ("small"=1536 or "large"=3072) Retu

Create an AppSDK-compatible error payload.

Delete all documents for a specific site from the database. Args: site: Site identifier to delete documents for endpoint_nam

Add a log message to the queue for async processing

* Ensure database is initialized