McpToolRegistrationService class

Costruire un McpToolRegistrationService.

new McpToolRegistrationService(configProvider?: IConfigurationProvider<LangChainToolingConfiguration>)

Parametri

Registra i server degli strumenti MCP e aggiorna le opzioni dell'agente con gli strumenti individuati e le configurazioni del server. Chiama questa opzione per abilitare l'accesso dinamico agli strumenti LangChain in base all'ambiente MCP corrente.

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

Parametri

Valori restituiti

Istanza aggiornata di Agent con server MCP registrati.

Invia la cronologia delle chat da un LangGraph CompiledStateGraph alla piattaforma MCP.

Si tratta dell'API più semplice e di livello più semplice da usare. Recupera lo stato corrente dal grafico, estrae i messaggi, li converte in formato ChatHistoryMessage e li invia alla piattaforma MCP per la protezione dalle minacce in tempo reale.

Esempio

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>

Parametri

Valori restituiti

Promessa che viene risolta in un oggetto OperationResult che indica l'esito positivo o negativo.

Recupera i messaggi da un'istanza baseChatMessageHistory e li invia alla piattaforma MCP.

Usare questa API quando si usano le astrazioni di memoria di LangChain (ad esempio, InMemoryChatMessageHistory, RedisChatMessageHistory e così via).

Esempio

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>

Parametri

Valori restituiti

Promessa che viene risolta in un oggetto OperationResult che indica l'esito positivo o negativo.

Invia una matrice di messaggi LangChain alla piattaforma MCP per la protezione dalle minacce in tempo reale.

Si tratta dell'API di livello più basso che accetta matrici BaseMessage non elaborate. Usare questa opzione quando sono già stati estratti messaggi o si dispone di un'origine messaggio personalizzata non coperta dalle API di livello superiore.

Questo metodo converte la matrice BaseMessage fornita in formato ChatHistoryMessage e le invia alla piattaforma MCP. Le matrici vuote vengono inviate as-is per registrare il messaggio utente con la piattaforma.

Esempio

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>

Parametri

Valori restituiti

Promessa che viene risolta in un oggetto OperationResult che indica l'esito positivo o negativo.

Estrae i messaggi da un LangGraph StateSnapshot e li invia alla piattaforma MCP.

Usare questa API quando si dispone già di stateSnapshot (ad esempio, da una chiamata precedente graph.getState() ) e si vuole evitare di recuperare di nuovo lo stato.

Esempio

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>

Parametri

Valori restituiti

Promessa che viene risolta in un oggetto OperationResult che indica l'esito positivo o negativo.