Class MCPServerManagerImpl

Implements

MCPServerManager

Constructors

constructor

new MCPServerManagerImpl(): MCPServerManagerImpl
Returns MCPServerManagerImpl

Properties

`Protected` `Optional`client

client?: MCPFrontendNotificationService

`Protected` `Readonly`credentialStore

credentialStore: MCPOAuthCredentialStore

`Protected` `Readonly`logger

logger: ILogger

`Protected` `Readonly`oauthClientProviderFactory

oauthClientProviderFactory: MCPOAuthClientProviderFactory

`Protected`roots

roots: undefined | string[]

`Protected`serverListeners

serverListeners: Map<string, Disposable> = ...

`Protected`servers

servers: Map<string, MCPServer> = ...

Methods

addOrUpdateServer

addOrUpdateServer(description: MCPServerDescription): Promise<void>
Adds or updates a server and waits until manager state is safe for dependent follow-up operations such as autostart.
Parameters
- description: MCPServerDescription
Returns Promise<void>
Implementation of MCPServerManager.addOrUpdateServer
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:157

callTool

callTool(
    serverName: string,
    toolName: string,
    arg_string: string,
): Promise<
    {
        _meta?: {
            "io.modelcontextprotocol/related-task"?: { taskId: string };
            progressToken?: string | number;
            [key: string]: unknown;
        };
        content: (
            | {
                _meta?: { [key: string]: unknown };
                annotations?: {
                    audience?: ("user" | "assistant")[];
                    lastModified?: string;
                    priority?: number;
                };
                text: string;
                type: "text";
            }
            | {
                _meta?: { [key: string]: unknown };
                annotations?: {
                    audience?: ("user" | "assistant")[];
                    lastModified?: string;
                    priority?: number;
                };
                data: string;
                mimeType: string;
                type: "image";
            }
            | {
                _meta?: { [key: string]: unknown };
                annotations?: {
                    audience?: ("user" | "assistant")[];
                    lastModified?: string;
                    priority?: number;
                };
                data: string;
                mimeType: string;
                type: "audio";
            }
            | {
                _meta?: { [key: string]: unknown };
                annotations?: {
                    audience?: ("user" | "assistant")[];
                    lastModified?: string;
                    priority?: number;
                };
                description?: string;
                icons?: {
                    mimeType?: string;
                    sizes?: string[];
                    src: string;
                    theme?: "light"
                    | "dark";
                }[];
                mimeType?: string;
                name: string;
                size?: number;
                title?: string;
                type: "resource_link";
                uri: string;
            }
            | {
                _meta?: { [key: string]: unknown };
                annotations?: {
                    audience?: ("user" | "assistant")[];
                    lastModified?: string;
                    priority?: number;
                };
                resource: | {
                    _meta?: { [key: string]: unknown };
                    mimeType?: string;
                    text: string;
                    uri: string;
                }
                | {
                    _meta?: { [key: string]: unknown };
                    blob: string;
                    mimeType?: string;
                    uri: string;
                };
                type: "resource";
            }
        )[];
        isError?: boolean;
        structuredContent?: { [key: string]: unknown };
        [key: string]: unknown;
    },
>
Parameters
- serverName: string
- toolName: string
- arg_string: string
Returns Promise<
    {
        _meta?: {
            "io.modelcontextprotocol/related-task"?: { taskId: string };
            progressToken?: string | number;
            [key: string]: unknown;
        };
        content: (
            | {
                _meta?: { [key: string]: unknown };
                annotations?: {
                    audience?: ("user" | "assistant")[];
                    lastModified?: string;
                    priority?: number;
                };
                text: string;
                type: "text";
            }
            | {
                _meta?: { [key: string]: unknown };
                annotations?: {
                    audience?: ("user" | "assistant")[];
                    lastModified?: string;
                    priority?: number;
                };
                data: string;
                mimeType: string;
                type: "image";
            }
            | {
                _meta?: { [key: string]: unknown };
                annotations?: {
                    audience?: ("user" | "assistant")[];
                    lastModified?: string;
                    priority?: number;
                };
                data: string;
                mimeType: string;
                type: "audio";
            }
            | {
                _meta?: { [key: string]: unknown };
                annotations?: {
                    audience?: ("user" | "assistant")[];
                    lastModified?: string;
                    priority?: number;
                };
                description?: string;
                icons?: {
                    mimeType?: string;
                    sizes?: string[];
                    src: string;
                    theme?: "light"
                    | "dark";
                }[];
                mimeType?: string;
                name: string;
                size?: number;
                title?: string;
                type: "resource_link";
                uri: string;
            }
            | {
                _meta?: { [key: string]: unknown };
                annotations?: {
                    audience?: ("user" | "assistant")[];
                    lastModified?: string;
                    priority?: number;
                };
                resource: | {
                    _meta?: { [key: string]: unknown };
                    mimeType?: string;
                    text: string;
                    uri: string;
                }
                | {
                    _meta?: { [key: string]: unknown };
                    blob: string;
                    mimeType?: string;
                    uri: string;
                };
                type: "resource";
            }
        )[];
        isError?: boolean;
        structuredContent?: { [key: string]: unknown };
        [key: string]: unknown;
    },
>
Implementation of MCPServerManager.callTool
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:102

`Protected`clearOAuthCredentialsIfConnectionScopeChanged

clearOAuthCredentialsIfConnectionScopeChanged(
oldDescription: MCPServerDescription,
newDescription: MCPServerDescription,
): Promise<void>
Parameters
- oldDescription: MCPServerDescription
- newDescription: MCPServerDescription
Returns Promise<void>
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:237

`Protected`clearOAuthCredentialsIfDisabled

clearOAuthCredentialsIfDisabled(
oldDescription: MCPServerDescription,
newDescription: MCPServerDescription,
): Promise<void>
Parameters
- oldDescription: MCPServerDescription
- newDescription: MCPServerDescription
Returns Promise<void>
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:281

`Protected`configurationOnly

configurationOnly(
description: MCPServerDescription,
): Partial<MCPServerDescription>
Parameters
- description: MCPServerDescription
Returns Partial<MCPServerDescription>
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:135

`Protected`connectionChangeRequiresRestart

connectionChangeRequiresRestart(
    server: MCPServer,
    oldDescription: MCPServerDescription,
    newDescription: MCPServerDescription,
): boolean
Parameters
- server: MCPServer
- oldDescription: MCPServerDescription
- newDescription: MCPServerDescription
Returns boolean
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:209

`Protected`connectionDescription

connectionDescription(description: MCPServerDescription): object
The part of a description that decides whether a running server has to be restarted rather than merely updated in place. Anything that shapes the connection - or, for a local server, the process - belongs here; anything purely presentational does not.
Parameters
- description: MCPServerDescription
Returns object
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:224

getActiveServers

getActiveServers(): Promise<string[]>
Returns names of all servers whose status is not terminal-stopped. Includes transient pre-running states and Errored. Use for operations that must interrupt servers regardless of lifecycle progress.

Returns Promise<string[]>
Implementation of MCPServerManager.getActiveServers
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:92

getResources

getResources(
    serverName: string,
): Promise<
    {
        _meta?: {
            "io.modelcontextprotocol/related-task"?: { taskId: string };
            progressToken?: string | number;
            [key: string]: unknown;
        };
        nextCursor?: string;
        resources: {
            _meta?: { [key: string]: unknown };
            annotations?: {
                audience?: ("user" | "assistant")[];
                lastModified?: string;
                priority?: number;
            };
            description?: string;
            icons?: {
                mimeType?: string;
                sizes?: string[];
                src: string;
                theme?: "light"
                | "dark";
            }[];
            mimeType?: string;
            name: string;
            size?: number;
            title?: string;
            uri: string;
        }[];
        [key: string]: unknown;
    },
>
Parameters
- serverName: string
Returns Promise<
    {
        _meta?: {
            "io.modelcontextprotocol/related-task"?: { taskId: string };
            progressToken?: string | number;
            [key: string]: unknown;
        };
        nextCursor?: string;
        resources: {
            _meta?: { [key: string]: unknown };
            annotations?: {
                audience?: ("user" | "assistant")[];
                lastModified?: string;
                priority?: number;
            };
            description?: string;
            icons?: {
                mimeType?: string;
                sizes?: string[];
                src: string;
                theme?: "light"
                | "dark";
            }[];
            mimeType?: string;
            name: string;
            size?: number;
            title?: string;
            uri: string;
        }[];
        [key: string]: unknown;
    },
>
Implementation of MCPServerManager.getResources
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:337

getRunningServers

getRunningServers(): Promise<string[]>
Returns Promise<string[]>
Implementation of MCPServerManager.getRunningServers
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:82

getServerDescription

getServerDescription(name: string): Promise<undefined | MCPServerDescription>
Parameters
- name: string
Returns Promise<undefined | MCPServerDescription>
Implementation of MCPServerManager.getServerDescription
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:144

getServerNames

getServerNames(): Promise<string[]>
Returns Promise<string[]>
Implementation of MCPServerManager.getServerNames
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:140

getTools

getTools(
    serverName: string,
): Promise<
    {
        _meta?: {
            "io.modelcontextprotocol/related-task"?: { taskId: string };
            progressToken?: string | number;
            [x: string]: unknown;
        };
        nextCursor?: string;
        tools: {
            _meta?: Record<string, unknown>;
            annotations?: {
                destructiveHint?: boolean;
                idempotentHint?: boolean;
                openWorldHint?: boolean;
                readOnlyHint?: boolean;
                title?: string;
            };
            description?: string;
            execution?: { taskSupport?: "optional"
            | "required"
            | "forbidden" };
            icons?: {
                mimeType?: string;
                sizes?: string[];
                src: string;
                theme?: "light" | "dark";
            }[];
            inputSchema: {
                properties?: Record<string, object>;
                required?: string[];
                type: "object";
                [x: string]: unknown;
            };
            name: string;
            outputSchema?: {
                properties?: Record<string, object>;
                required?: string[];
                type: "object";
                [x: string]: unknown;
            };
            title?: string;
        }[];
        [x: string]: unknown;
    },
>
Parameters
- serverName: string
Returns Promise<
    {
        _meta?: {
            "io.modelcontextprotocol/related-task"?: { taskId: string };
            progressToken?: string | number;
            [x: string]: unknown;
        };
        nextCursor?: string;
        tools: {
            _meta?: Record<string, unknown>;
            annotations?: {
                destructiveHint?: boolean;
                idempotentHint?: boolean;
                openWorldHint?: boolean;
                readOnlyHint?: boolean;
                title?: string;
            };
            description?: string;
            execution?: { taskSupport?: "optional"
            | "required"
            | "forbidden" };
            icons?: {
                mimeType?: string;
                sizes?: string[];
                src: string;
                theme?: "light" | "dark";
            }[];
            inputSchema: {
                properties?: Record<string, object>;
                required?: string[];
                type: "object";
                [x: string]: unknown;
            };
            name: string;
            outputSchema?: {
                properties?: Record<string, object>;
                required?: string[];
                type: "object";
                [x: string]: unknown;
            };
            title?: string;
        }[];
        [x: string]: unknown;
    },
>
Implementation of MCPServerManager.getTools
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:149

hasStoredOAuthCredentials

hasStoredOAuthCredentials(serverName: string): Promise<boolean>
Parameters
- serverName: string
Returns Promise<boolean>
Implementation of MCPServerManager.hasStoredOAuthCredentials
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:73

`Protected`haveSameConfiguration

haveSameConfiguration(a: MCPServerDescription, b: MCPServerDescription): boolean
Parameters
- a: MCPServerDescription
- b: MCPServerDescription
Returns boolean
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:128

`Protected`normalizedAuthorizationServer

normalizedAuthorizationServer(
authorizationServer: undefined | string,
): undefined | string
Parameters
- authorizationServer: undefined | string
Returns undefined | string
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:272

`Protected`normalizedScopes

normalizedScopes(scopes: undefined | string[]): string
Parameters
- scopes: undefined | string[]
Returns string
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:277

readResource

readResource(
    serverName: string,
    resourceId: string,
): Promise<
    {
        _meta?: {
            "io.modelcontextprotocol/related-task"?: { taskId: string };
            progressToken?: string | number;
            [key: string]: unknown;
        };
        contents: (
            | {
                _meta?: { [key: string]: unknown };
                mimeType?: string;
                text: string;
                uri: string;
            }
            | {
                _meta?: { [key: string]: unknown };
                blob: string;
                mimeType?: string;
                uri: string;
            }
        )[];
        [key: string]: unknown;
    },
>
Parameters
- serverName: string
- resourceId: string
Returns Promise<
    {
        _meta?: {
            "io.modelcontextprotocol/related-task"?: { taskId: string };
            progressToken?: string | number;
            [key: string]: unknown;
        };
        contents: (
            | {
                _meta?: { [key: string]: unknown };
                mimeType?: string;
                text: string;
                uri: string;
            }
            | {
                _meta?: { [key: string]: unknown };
                blob: string;
                mimeType?: string;
                uri: string;
            }
        )[];
        [key: string]: unknown;
    },
>
Implementation of MCPServerManager.readResource
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:329

removeServer

removeServer(name: string): Promise<void>
Removes a server and waits for lifecycle cleanup such as OAuth authorization cancellation and credential removal.
Parameters
- name: string
Returns Promise<void>
Implementation of MCPServerManager.removeServer
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:181

setClient

setClient(client: MCPFrontendNotificationService): void
Parameters
- client: MCPFrontendNotificationService
Returns void
Implementation of MCPServerManager.setClient
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:289

setWorkspaceRoots

setWorkspaceRoots(roots: undefined | string[]): void
Parameters
- roots: undefined | string[]
Returns void
Implementation of MCPServerManager.setWorkspaceRoots
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:345

`Protected`shouldResetStatusAfterUpdate

shouldResetStatusAfterUpdate(
server: MCPServer,
restartedByCaller: boolean,
): boolean
Parameters
- server: MCPServer
- restartedByCaller: boolean
Returns boolean
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:215

`Protected`shouldRestartServer

shouldRestartServer(
oldDescription: MCPServerDescription,
newDescription: MCPServerDescription,
): boolean
Parameters
- oldDescription: MCPServerDescription
- newDescription: MCPServerDescription
Returns boolean
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:202

signOut

signOut(serverName: string): Promise<void>
Parameters
- serverName: string
Returns Promise<void>
Implementation of MCPServerManager.signOut
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:57

startServer

startServer(
serverName: string,
options?: { interactive?: boolean },
): Promise<void>
Parameters
- serverName: string
- options: { interactive?: boolean } = {}
  - Optionalinteractive?: boolean
    true when the start was initiated by a direct user action; false (default) for autostart and other non-interactive paths. Non-interactive starts do not launch a browser for OAuth authorization.
Returns Promise<void>
Implementation of MCPServerManager.startServer
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:110

stopServer

stopServer(serverName: string): Promise<void>
Parameters
- serverName: string
Returns Promise<void>
Implementation of MCPServerManager.stopServer
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:44

`Protected`stopServersAfterDisconnect

stopServersAfterDisconnect(): Promise<void>
Returns Promise<void>
- Defined in packages/ai-mcp/src/node/mcp-server-manager-impl.ts:307

Class MCPServerManagerImpl

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Returns MCPServerManagerImpl

Properties

Protected Optionalclient

Protected ReadonlycredentialStore

Protected Readonlylogger

Protected ReadonlyoauthClientProviderFactory

Protectedroots

ProtectedserverListeners

Protectedservers

Methods

addOrUpdateServer

Parameters

Returns Promise<void>

callTool

Parameters

ProtectedclearOAuthCredentialsIfConnectionScopeChanged

Parameters

Returns Promise<void>

ProtectedclearOAuthCredentialsIfDisabled

Parameters

Returns Promise<void>

ProtectedconfigurationOnly

Parameters

Returns Partial<MCPServerDescription>

ProtectedconnectionChangeRequiresRestart

Parameters

Returns boolean

ProtectedconnectionDescription

Parameters

Returns object

ProtectedconnectionScopeChanged

Parameters

Returns boolean

ProtectedcredentialScopeKey

Parameters

Returns string

disconnectClient

Parameters

Returns void

getActiveServers

Returns Promise<string[]>

getResources

Parameters

getRunningServers

Returns Promise<string[]>

getServerDescription

Parameters

Returns Promise<undefined | MCPServerDescription>

getServerNames

Returns Promise<string[]>

getTools

Parameters

hasStoredOAuthCredentials

Parameters

Returns Promise<boolean>

ProtectedhaveSameConfiguration

Parameters

Returns boolean

ProtectednormalizedAuthorizationServer

Parameters

Returns undefined | string

ProtectednormalizedScopes

Parameters

Returns string

readResource

Parameters

removeServer

Parameters

Returns Promise<void>

setClient

Parameters

Returns void

`Protected` `Optional`client

`Protected` `Readonly`credentialStore

`Protected` `Readonly`logger

`Protected` `Readonly`oauthClientProviderFactory

`Protected`roots

`Protected`serverListeners

`Protected`servers

`Protected`clearOAuthCredentialsIfConnectionScopeChanged

`Protected`clearOAuthCredentialsIfDisabled

`Protected`configurationOnly

`Protected`connectionChangeRequiresRestart

`Protected`connectionDescription

`Protected`connectionScopeChanged

`Protected`credentialScopeKey

`Protected`haveSameConfiguration

`Protected`normalizedAuthorizationServer

`Protected`normalizedScopes

`Protected`shouldResetStatusAfterUpdate

`Protected`shouldRestartServer

`Optional`interactive?: boolean

`Protected`stopServersAfterDisconnect