McpToolRegistrationService class

Construct a McpToolRegistrationService.

new McpToolRegistrationService(configProvider?: IConfigurationProvider<LangChainToolingConfiguration>)

Parameters

Registers MCP tool servers and updates agent options with discovered tools and server configs. Call this to enable dynamic LangChain tool access based on the current MCP environment.

function addToolServersToAgent(agent: ReactAgent<AgentTypeConfig<Record<string, any>, undefined, AnyAnnotationRoot, readonly AgentMiddleware<any, any, any, readonly (ClientTool | ServerTool)[]>[], readonly (ClientTool | ServerTool)[]>>, authorization: Authorization, authHandlerName: string, turnContext: TurnContext, authToken: string): Promise<ReactAgent<AgentTypeConfig<Record<string, any>, undefined, AnyAnnotationRoot, readonly AgentMiddleware<any, any, any, readonly (ClientTool | ServerTool)[]>[], readonly (ClientTool | ServerTool)[]>>>

Parameters

Returns

The updated Agent instance with registered MCP servers.

Sends chat history from a LangGraph CompiledStateGraph to the MCP platform.

This is the highest-level and easiest-to-use API. It retrieves the current state from the graph, extracts messages, converts them to ChatHistoryMessage format, and sends them to the MCP platform for real-time threat protection.

Example

const config = { configurable: { thread_id: '1' } };
const result = await service.sendChatHistoryAsync(turnContext, graph, config);
if (result.succeeded) {
  console.log('Chat history sent successfully');
}

function sendChatHistoryAsync(turnContext: TurnContext, graph: CompiledStateGraph<unknown, unknown, string, StateDefinition, StateDefinition, StateDefinition, unknown, unknown, unknown>, config: RunnableConfig<Record<string, any>>, limit?: number, toolOptions?: ToolOptions): Promise<OperationResult>

Parameters

Returns

A Promise resolving to an OperationResult indicating success or failure.

Retrieves messages from a BaseChatMessageHistory instance and sends them to the MCP platform.

Use this API when working with LangChain's memory abstractions (e.g., InMemoryChatMessageHistory, RedisChatMessageHistory, etc.).

Example

const chatHistory = new InMemoryChatMessageHistory();
// ... add messages to history ...
const result = await service.sendChatHistoryFromChatHistoryAsync(turnContext, chatHistory);

function sendChatHistoryFromChatHistoryAsync(turnContext: TurnContext, chatHistory: BaseChatMessageHistory, limit?: number, toolOptions?: ToolOptions): Promise<OperationResult>

Parameters

Returns

A Promise resolving to an OperationResult indicating success or failure.

Sends an array of LangChain messages to the MCP platform for real-time threat protection.

This is the lowest-level API that accepts raw BaseMessage arrays. Use this when you have already extracted messages or have a custom message source not covered by the higher-level APIs.

This method converts the provided BaseMessage array to ChatHistoryMessage format and sends them to the MCP platform. Empty arrays are sent as-is to register the user message with the platform.

Example

const messages = await messageHistory.getMessages();
const result = await service.sendChatHistoryFromMessagesAsync(turnContext, messages, 50);
if (result.succeeded) {
  console.log('Chat history sent successfully');
} else {
  console.error('Failed to send chat history:', result.errors);
}

function sendChatHistoryFromMessagesAsync(turnContext: TurnContext, messages: BaseMessage<MessageStructure<MessageToolSet>, MessageType>[], limit?: number, toolOptions?: ToolOptions): Promise<OperationResult>

Parameters

Returns

A Promise resolving to an OperationResult indicating success or failure.

Extracts messages from a LangGraph StateSnapshot and sends them to the MCP platform.

Use this API when you already have a StateSnapshot (e.g., from a previous graph.getState() call) and want to avoid fetching state again.

Example

const config = { configurable: { thread_id: '1' } };
const stateSnapshot = await graph.getState(config);
const result = await service.sendChatHistoryFromStateAsync(turnContext, stateSnapshot);

function sendChatHistoryFromStateAsync(turnContext: TurnContext, stateSnapshot: StateSnapshot, limit?: number, toolOptions?: ToolOptions): Promise<OperationResult>

Parameters

Returns

A Promise resolving to an OperationResult indicating success or failure.