Report progress for the current operation. Works in both foreground (MCP progress notifications) and background (Docket task executio

Resolve $ref at root level to meet MCP spec requirements. MCP specification requires outputSchema to have "type": "object" at the root level.

Run a MCP server or connect to a remote one. Args: server_spec: Python file, object specification (file:obj), config file, or URL

Fetch URL with comprehensive SSRF protection and DNS pinning. Security measures: 1. HTTPS only 2. DNS resolution with IP validation 3

Store an event and return its ID. Args: stream_id: ID of the stream the event belongs to message: The JSON-RPC messag

Validate OIDC proxy.

Verify a token by trying the server, then each verifier in order. Each source is tried independently. If a source raises an exception,

Create a wrapper function without injected parameters. Returns a wrapper that excludes Context and Docket dependency parameters, making it sa

Wrap a Tool to delegate execution to the server's middleware.

Add a component to unified storage. Args: component: The component to add. Returns: The component that was a

Convert MCP messages to Google GenAI content.

Attempts to connect to the Hue bridge using settings.

Prefix unprefixed custom API scopes with identifier_uri for Azure. This helper centralizes the scope prefixing logic used in both aut

Convert Google GenAI response to CreateMessageResultWithTools.

Return a deep copy of *obj* with non-local ``$ref`` values removed. Local refs (starting with ``#``) are kept intact. Remote refs (``http://

Transform non-MCP errors to proper MCP errors.

Check if a newer version of FastMCP is available. Returns: The latest version string if newer than current, None otherwise.

Build ``name(param: type, ...) -> return_type`` from a tool's JSON schemas.

Generate the full CLI script source code.

Generate a Goose deeplink for installing an MCP extension. Args: name: Human-readable display name for the extension. command: Th

Get the current HTTP request. Tries MCP SDK's request_ctx first, then falls back to FastMCP's HTTP context. In background tasks, returns a sy

Atomically increment the current progress value.

Send an initialize request to the server. This method performs the MCP initialization handshake with the server, exchanging capabilit

Check if a client_id looks like a CIMD URL. CIMD URLs must be HTTPS with a host and non-root path.

Check if a compatible pydocket (>= 0.19.0) is installed and importable. Three things have to be true for fastmcp's task features to work: 1

Check if an IP address is allowed (must be globally routable unicast). Uses ip.is_global which catches: - Private (10.x, 172.16-31.x, 192.168

List tools with all transforms applied. Applies transforms sequentially: base → transforms (in order). Each transform receives the re

Resolve a server name (or ``source:name``) to a transport. Raises :class:`ValueError` when the name is not found or is ambiguous.

Run the server using HTTP transport. Args: transport: Transport protocol to use - "http" (default), "streamable-http", or "sse"

Send a notification to the client immediately. Args: notification: An MCP notification instance (e.g., ToolListChangedNotificatio

Set the total/target value for progress tracking.

Validate JWT assertion from client. Args: assertion: The JWT assertion string client_id: Expected client_id (must mat

Validate an OIDC configuration against the source dict.

Combines parameter and request body schemas into a single schema. Handles parameter name collisions by adding location suffixes. This is

Extract CSRF token from HTML form.

Get all additional HTTP routes including from mounted servers. Collects custom HTTP routes registered via ``@server.custom_route()``

Check if a JSON schema represents an object type.

Merge defaults with provided data at all levels.

Convert a JSON Schema property name to its CLI flag form. Replicates cyclopts' default_name_transform: camelCase → snake_case, lowercase, und

Builds and executes the middleware chain.

Convert a display name to a URL-safe identifier. Lowercases, replaces non-alphanumeric runs with hyphens, and strips leading/trailing hyphens

Sanitize a string into a valid Python identifier.

Extract the logical return value from a ToolResult.

Acquire the reload lock, reload if needed, then run *coro_fn*. Holding the lock across both the reload and the read prevents concurre

Apply session-specific visibility transforms to components. This helper applies session-level enable/disable rules by marking components with

Decode JWT header without signature verification. Useful for extracting the key ID (kid) for JWKS lookup. Args: token: JWT token str

Recursively discover all Python files under a directory. Excludes __init__.py files (they're for package structure, not components). Args:

Look up an app-visible tool by original name, bypassing transforms. Searches for a tool named ``tool_name`` tagged with the given app

Get or create an authenticated ATProto client.

Extract FastMCP metadata from a component's meta dict. Handles both the current `fastmcp` namespace and the legacy `_fastmcp` namespace for c

Get a cached or new OnBehalfOfCredential for OBO token exchange. Credentials are cached by user assertion so the Azure SDK's internal

Get a resource by URI, filtering disabled resources. Overrides Provider.get_resource() to add visibility filtering after all transfor

Get the session ID for this transport, if available.

Query the status of a background task. Sends a 'tasks/get' MCP protocol request over the existing transport. Args: task_

List resource templates with all transforms applied. Components may be marked as disabled but are NOT filtered here.

Load server from filesystem.

Normalize a timeout value to a timedelta. Args: value: Timeout value as int/float (seconds), timedelta, or None Returns: tim

Paginate a sequence of items. Args: items: The full sequence to paginate. cursor: Optional cursor from a previous request. None f

Read the file content.

Read a resource by its URI. For static resources, provide the exact URI. For templated resources, provide the URI with templa

Registers all methods marked with @mcp_tool with the FastMCP server. Args: mcp_server: The FastMCP server instance to register to

Replay events that occurred after the specified event ID. Args: last_event_id: The ID of the last event the client received

Serialize tools to compact markdown, using ~65-70% fewer tokens than JSON.

Transform ctx: Context into ctx: Context = CurrentContext(). Transforms ALL params typed as Context to use Docket's DI system, unless they al

Validate that a JSON schema follows MCP elicitation requirements. This ensures the schema is compatible with MCP elicitation requirements: -

Verify GitHub OAuth token by calling GitHub API.

Verify a bearer token using OAuth 2.0 Token Introspection (RFC 7662). This method makes a POST request to the introspection endpoint

Get the current FastMCP server instance. This dependency provides access to the active FastMCP server. Returns: A dependency that re

Build a ``Client`` from a resolved server spec. Applies ``auth='oauth'`` automatically for HTTP-based targets unless the caller explicitly pa

Build a uvx command for running a FastMCP server. Goose requires uvx (not uv run) as the command. The uvx format is: uvx [--with pkg] [--

Get the correct npx command for the current platform.

Get the token to verify from the upstream token set. When verify_id_token is enabled, returns the id_token from the upstream token re

Return a new schema with *param* removed from `properties`, `required`, and (if no longer referenced) `$defs`.

Convert MCP content to Google GenAI Part.

Scan ``~/.claude.json`` for global and project-scoped MCP servers.

Return a human-readable type label for a property schema.

Helper method to time any operation.

Start OAuth transaction and route through consent interstitial. Flow: 1. Validate client's resource matches server's resource URL (se

Combine multiple lifespans into a single lifespan. Useful when mounting FastMCP into FastAPI and you need to run both your app's lifespan and

Create a test JWT token.

Derive JWT signing key from a high-entropy key material and server salt.