Initialize handshake when the server is in SSE mode. Returns the negotiated session id. The initialize response itself arrives as a s

Try to parse a JSON string, returning the original string if parsing fails.

Validate, deduplicate, and normalize a list of OAuth scope tokens. Each token must conform to the RFC 6750 grammar (see ``_validate_scope_tok

Validate message content for tool_use/tool_result constraints. - User messages with tool_result content must contain ONLY tool results.

Convert a ValueSchema to a JSON Schema dict without top-level object wrapping. Recursively expands nested object (json) types into their sub-sche

Register a static text resource at build time.

Convenience: register a static text resource.

Parse files with a fast AST pass to find declared @tool function names.

Create a ToolCatalog and add the provided toolkits.

Create a minimal Toolkit to host locally discovered tools.

Run the evaluation suite in capture mode - records tool calls without scoring. Capture mode runs each case and records the tool call

Load modules and collect the expected tool callables. Returns a list of (callable, module) pairs.

Compute the final score by normalizing the total score with the total weight.

Configure Amazon Q Developer to connect to an Arcade Cloud MCP gateway. Amazon Q requires an explicit ``"type": "http"`` on remote entries — with

Configure VS Code to connect to an Arcade Cloud MCP gateway.

Configure Windsurf to connect to an Arcade Cloud MCP gateway. Windsurf's docs show remote HTTP servers as ``{"serverUrl": ..., "headers": ...}``

Context manager providing read and write streams for connection. Creates the in-memory channels used by the transport and starts the

Create an ignore pattern based on user preferences.

Recursively create a new toolkit directory structure from jinja2 templates.

Create a context for the current request. Args: resource_owner: The authenticated resource owner from front-door auth.

High-level discovery that returns a ToolCatalog. This function is pure (does not sys.exit); callers should handle errors.

Create the configuration directory if it does not exist.

Check if two fully-qualified tool names are equal, ignoring the version.

Extract type and field parameters from a function parameter.

Fetch OAuth configuration from the Coordinator.

Fetch organizations the user belongs to. Args: coordinator_url: Base URL of the Coordinator access_token: Valid access token

Find candidate Python files for auto-discovery in common locations.

Creates a fully-qualified tool name from a tool name and a ToolkitDefinition.

Get the Claude Desktop configuration file path.

Get the path to the Arcade configuration directory.

Get the path to the test server entrypoint.

Get a list of evaluation files starting with 'eval_' and ending with '.py' in the given directory. Args: directory: The directory to

Return OAuth Protected Resource Metadata (RFC 9728) if supported. Returns: Metadata dictionary with 'resource' and 'authorization

Retrieve tools from Python source code.

Retrieve tools from a Python file.

Handle a server-initiated request by sending appropriate mock response.

Handle typed httpx exceptions. Args: exc: An httpx exception instance mapper: The BaseHTTPErrorMapper instance to use

Handle a response message from the client. Args: message: Response message

Check if a background asyncio.Task is tracked.

Hash the text

Perform a health check of the worker

Configure standard logging to route through Loguru. This should be called after Loguru is configured to ensure all standard logging calls are

Returns True if the given type is a string literal, i.e. a Literal[str] or Literal[str, str, ...] etc.

Load tools from an MCP server via stdio. Results are cached by command to avoid starting multiple subprocesses for the same server. Conc

Load tools from a remote MCP server via URL (HTTP or SSE transport). Results are cached to avoid redundant connections when multiple models

Attempt to load a Toolkit from an installed package name.

Logs the user out of Arcade.

Main entry point.

Create a handler that reads a file, returning text or bytes.

Create a handler that returns static text.

Normalize and validate a version string to canonical semver. Raises: TypeError: if version is not a string. ValueError: if version

Intercept tools/call to collect and return server spans.

Register the component with the given router.

Register the necessary routes to the application.

Display a helpful error message if the required dependency is missing. Args: package_name: The name of the package to import (e.g.,

Run a single MCP connection. Args: read_stream: Stream for reading messages write_stream: Stream for writing

Run MCP server with stdio transport.

Save OAuth credentials to the config file using WhoAmI response. Picks the org/project marked as default, or falls back to the first one

Select the default project. Args: projects: List of projects Returns: Default project, or first project, or None if emp

Send a progress notification.

Send tool list changed notification.

Serve the FastAPI app with force quit capability.

Configure logging with Loguru.

Converts a space delimited name to snake_case.

Start the MCP server as a subprocess. Args: transport: Transport type ("stdio" or "http") port: Port for HTTP transport (opt

Run startup phase of lifespan.

Stop the read stream.

Convert to dictionary for JSON serialization.

Track MCP server start event. Args: transport: The transport type ("http" or "stdio") host: The host address (None fo