McpToolRegistrationService class

构造 McpToolRegistrationService。

new McpToolRegistrationService(configProvider?: IConfigurationProvider<LangChainToolingConfiguration>)

参数

使用发现的工具和服务器配置注册 MCP 工具服务器和更新代理选项。 调用此项以基于当前的 MCP 环境启用动态 LangChain 工具访问。

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)[]>>>

参数

返回

已注册 MCP 服务器的已更新代理实例。

将聊天历史记录从 LangGraph CompiledStateGraph 发送到 MCP 平台。

这是最高级别且最易于使用的 API。 它从图形中检索当前状态，提取消息，将其转换为 ChatHistoryMessage 格式，并将其发送到 MCP 平台进行实时威胁防护。

示例

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>

参数

返回

解析为 OperationResult 的 Promise，指示成功或失败。

从 BaseChatMessageHistory 实例检索消息并将其发送到 MCP 平台。

使用 LangChain 的内存抽象（例如 InMemoryChatMessageHistory、RedisChatMessageHistory 等）时使用此 API。

示例

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>

参数

返回

解析为 OperationResult 的 Promise，指示成功或失败。

将一组 LangChain 消息发送到 MCP 平台，以便进行实时威胁防护。

这是接受原始 BaseMessage 数组的最低级别 API。 如果已提取消息或高级 API 未涵盖自定义消息源，请使用此功能。

此方法将提供的 BaseMessage 数组转换为 ChatHistoryMessage 格式，并将其发送到 MCP 平台。 as-is 发送空数组，以便向平台注册用户消息。

示例

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>

参数

返回

解析为 OperationResult 的 Promise，指示成功或失败。

从 LangGraph StateSnapshot 中提取消息并将其发送到 MCP 平台。

如果已有 StateSnapshot（例如上 graph.getState() 一次调用），并且想要避免再次提取状态，请使用此 API。

示例

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>

参数

返回

解析为 OperationResult 的 Promise，指示成功或失败。