Base branded error class for MCP protocol errors, with code/data fields and factory logic to map error codes to specific error subclasses.

Defines TimeoutError class extending KyError, thrown on HTTP request timeout with request property.

Tiny, elegant fetch-based HTTP client with hooks, retries, timeout, and JSON/stream helpers.

Extracts the inner event data from AWS EventBridge or Azure Event Grid envelopes, or passes through raw Stripe events, enabling unified handling of cloud provider and Stripe webhoo

FastAPI application entrypoint and router wiring for the backend.

Helix REST API Server Exposes PCEC repair engine over HTTP for cross-language integration. Start: npx helix serve [--port 7842] [--mode observe|auto|full] /

Public async API class orchestrating mailbox rendezvous, transfer, and dilation.

Defines env var for ChatGate webhook endpoint URL.

Channel gateway — the normalized boundary between external surfaces and the runtime, per `docs/tools/CHANNEL_GATEWAY_MESSAGE_ADAPTERS.md`. Every channel (Telegram today; Slack / we

Parses auth mode from config/env; returns plugin API auth settings for OpenClaw integration.

TypeScript/JS library providing ESM and CJS endpoints for frontend frameworks to communicate with the Rust backend via webview message passing.

Validates and parses ingestion request bodies via Zod against protocol schemas, supporting versioning and batch payloads.

TypeScript/JavaScript library providing webview-to-backend communication via message passing. Ships both CJS and ESM builds plus pure TypeScript types.

McpClient — lightweight MCP client compatible with React Native. Communicates with MCP servers over Streamable HTTP (POST for requests, SSE for streaming). Does not depend on Node.

Enum of cache modes controlling context retrieval in crawl4ai.

Defines app name "Quoroom" and ID for integration constants.

Provides a Next.js request handler that wraps the Giselle AI engine, parses JSON/form bodies, routes to configured endpoints, and optionally runs after‑function logic.

Shared command definitions used by all channel implementations. Keeping the authoritative command set in one place ensures that channel parsers (e.g. Feishu) and the ChannelManager

Fetches sponsor information from OpenCollective GraphQL API with a static fallback for major sponsors.

Generates HTTP headers required for AI Gateway requests, including Stripe customer identifiers for usage attribution and billing.

Decorator to register an HTTP POST path operation on an APIRouter, configuring response models, status codes, and OpenAPI metadata.

Mnemon moth — LangChain integration. System 2 EME via per-step patching: RunnableSequence.invoke is patched to iterate each step individually. Each step is a segment. If a step's o

Validates required environment variables and creates a Supabase client for server‑side operations with cookie handling.

Parses a webhook header string into timestamp and signatures, supporting custom signature schemes. Essential for verifying incoming webhook payloads.

Unified message schema (Pydantic) for in-process use and adapter implementations. Matches the gRPC UnifiedMessage / Platform definitions.

POST endpoint that updates a Clerk user's public metadata based on request payload, with error logging.

Implements NewsletterProviderInterface for Substack, generating embed URLs and indicating iframe‑only integration.

Lazily creates and proxies platform ports (persistence, gateway, settings, notifications) for the web app, ensuring a single instance.

Base adapter interface for messaging platforms. Each platform (Telegram, Discord, WhatsApp) implements this and returns UnifiedMessage list.

Zod definitions for web page variable states (fetching, fetched, failed) and content references used in the protocol.

Loads a GitHub repository while applying ignore patterns, exposing files as LlamaIndex Documents.

Creates a DocumentLoader that walks a GitHub commit tree, filters blobs by size, and loads each file as a rag Document for downstream processing.

MCP client implementation handling connection, capability negotiation, protocol handshakes, paginated listing, caching, and request validation.

High-level MCP server facade for registering tools, resources, and prompts, and dispatching protocol requests with schema validation.

Fetches pull‑request metadata, details, and file diffs from GitHub using Octokit and GraphQL, returning structured maps for further analysis.

Button that opens a centered popup for GitHub App installation and refreshes the page when the popup closes.

Schemas for gateway CRUD and template-sync API payloads.

Loads, validates, and normalizes netlify.toml with context/branch resolution, environment variable merging, and Netlify API integration.

Implements GitHub API integration server for MCP, handling authentication and proxying requests to GitHub endpoints.

Abstraction layer for mailbox operations across different email backends.

Defines server user types, runtime configurations and conversion utilities for MCP server definitions.

Exports the full Harper WebAssembly binary as an inline data URL for immediate inclusion in JavaScript bundles.

GitHub channel — webhook-driven IM channel for PR/issue comments. Unlike other IM channels (Feishu, Slack, Telegram) which long-poll or use WebSockets, GitHub delivers messages via

Merges an APIRouter into the current one, applying shared prefix, tags, dependencies, and other settings to all its routes. Enables modular API composition.

Factory function that creates a newsletter provider instance (MailerLite, Kit, or Substack) based on configuration.

Async HTTP client for BentoML services, handling requests and responses.

Async protocol server for the Tauri desktop client, handling lint requests and shared configuration state.

Web capability — `web.fetch` + `web.search`, stdlib-only, allowlist-gated. The first capability that lets an agent read the open web, so egress is default-deny twice over: 1. **Con

Coinbase AgentKit wallet provisioning with persistence. When CDP_API_KEY_NAME and CDP_API_KEY_PRIVATE are configured, agents without a wallet address can have one auto-created duri

Sends an asynchronous JSON-RPC notification using an outbound codec resolved by method name.