Файловый менеджер

Файловый менеджер - Редактировать - /home/tuudkjt/globeasy/wp-content/plugins/woocommerce/vendor/wordpress/mcp-adapter/includes/Core/McpComponentRegistry.php

Назад
<?php /** * MCP Component Registry for managing tools, resources, and prompts. * * @package McpAdapter / declare( strict_types=1 ); namespace WP\MCP\Core; use WP\MCP\Domain\Prompts\Contracts\McpPromptBuilderInterface; use WP\MCP\Domain\Prompts\McpPrompt; use WP\MCP\Domain\Prompts\RegisterAbilityAsMcpPrompt; use WP\MCP\Domain\Resources\McpResource; use WP\MCP\Domain\Resources\RegisterAbilityAsMcpResource; use WP\MCP\Domain\Tools\McpTool; use WP\MCP\Domain\Tools\RegisterAbilityAsMcpTool; use WP\MCP\Infrastructure\ErrorHandling\Contracts\McpErrorHandlerInterface; use WP\MCP\Infrastructure\Observability\Contracts\McpObservabilityHandlerInterface; /* * Registry for managing MCP server components (tools, resources, prompts). / class McpComponentRegistry { /* * Tools registered to the server. * * @var array / private array $tools = array(); /* * Resources registered to the server. * * @var array / private array $resources = array(); /* * Prompts registered to the server. * * @var array / private array $prompts = array(); /* * MCP Server instance. * * @var \WP\MCP\Core\McpServer / private McpServer $mcp_server; /* * Error handler instance. * * @var \WP\MCP\Infrastructure\ErrorHandling\Contracts\McpErrorHandlerInterface / private McpErrorHandlerInterface $error_handler; /* * Observability handler instance. * * @var \WP\MCP\Infrastructure\Observability\Contracts\McpObservabilityHandlerInterface / private McpObservabilityHandlerInterface $observability_handler; /* * Whether MCP validation is enabled. * * @var bool / private bool $mcp_validation_enabled; /* * Whether to record component registration. * * @var bool / private bool $should_record_component_registration; /* * Constructor. * * @param \WP\MCP\Core\McpServer $mcp_server MCP server instance. * @param \WP\MCP\Infrastructure\ErrorHandling\Contracts\McpErrorHandlerInterface $error_handler Error handler instance. * @param \WP\MCP\Infrastructure\Observability\Contracts\McpObservabilityHandlerInterface $observability_handler Observability handler instance. * @param bool $mcp_validation_enabled Whether MCP validation is enabled. / public function __construct( McpServer $mcp_server, McpErrorHandlerInterface $error_handler, McpObservabilityHandlerInterface $observability_handler, bool $mcp_validation_enabled ) { $this->mcp_server = $mcp_server; $this->error_handler = $error_handler; $this->observability_handler = $observability_handler; $this->mcp_validation_enabled = $mcp_validation_enabled; // Allow filtering whether component registration events should be recorded. // Default is false to avoid polluting observability logs during startup. $this->should_record_component_registration = apply_filters( 'mcp_adapter_observability_record_component_registration', false ); } /* * Register tools to the server. * * @param array $tools Array of ability names (strings) to convert to MCP tools. * * @return void / public function register_tools( array $tools ): void { foreach ( $tools as $tool_item ) { if ( ! is_string( $tool_item ) ) { continue; } // Treat as ability name $ability = wp_get_ability( $tool_item ); if ( ! $ability ) { $this->error_handler->log( "WordPress ability '{$tool_item}' does not exist.", array( "RegisterAbilityAsMcpTool::{$tool_item}" ) ); // Track ability tool registration failure. if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'failed', 'component_type' => 'ability_tool', 'component_name' => $tool_item, 'failure_reason' => 'ability_not_found', 'server_id' => $this->mcp_server->get_server_id(), ) ); } continue; } $tool = RegisterAbilityAsMcpTool::make( $ability, $this->mcp_server ); // Check if tool creation returned an error if ( is_wp_error( $tool ) ) { $this->error_handler->log( $tool->get_error_message(), array( "RegisterAbilityAsMcpTool::{$tool_item}" ) ); // Track ability tool registration failure. if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'failed', 'component_type' => 'ability_tool', 'component_name' => $tool_item, 'error_code' => $tool->get_error_code(), 'server_id' => $this->mcp_server->get_server_id(), ) ); } continue; } // If registry has validation enabled, validate the tool (bypassing server's validation flag) if ( $this->mcp_validation_enabled ) { $context_to_use = "McpComponentRegistry::register_tools::{$tool_item}"; $validation_result = \WP\MCP\Domain\Tools\McpToolValidator::validate_tool_instance( $tool, $context_to_use ); // Check if validation returned an error if ( is_wp_error( $validation_result ) ) { $this->error_handler->log( $validation_result->get_error_message(), array( "RegisterAbilityAsMcpTool::{$tool_item}" ) ); // Track ability tool registration failure. if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'failed', 'component_type' => 'ability_tool', 'component_name' => $tool_item, 'error_code' => $validation_result->get_error_code(), 'server_id' => $this->mcp_server->get_server_id(), ) ); } continue; } } // Add the processed tools to this server. $this->tools[ $tool->get_name() ] = $tool; // Track successful ability tool registration. if ( ! $this->should_record_component_registration ) { continue; } $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'success', 'component_type' => 'ability_tool', 'component_name' => $tool_item, 'server_id' => $this->mcp_server->get_server_id(), ) ); } } /* * Register a McpTool instance directly to the server. * * @param \WP\MCP\Domain\Tools\McpTool $tool The tool instance to register. * * @return void / public function add_tool( McpTool $tool ): void { // Set the MCP server before validation (validation needs it to check if validation is enabled) $tool->set_mcp_server( $this->mcp_server ); // Validate if validation is enabled (call validator directly to respect registry's validation flag) if ( $this->mcp_validation_enabled ) { $context_to_use = "McpComponentRegistry::add_tool::{$tool->get_name()}"; $validation_result = \WP\MCP\Domain\Tools\McpToolValidator::validate_tool_instance( $tool, $context_to_use ); // Check if validation returned an error if ( is_wp_error( $validation_result ) ) { $this->error_handler->log( $validation_result->get_error_message(), array( "McpComponentRegistry::add_tool::{$tool->get_name()}" ) ); // Track tool registration failure if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'failed', 'component_type' => 'tool', 'component_name' => $tool->get_name(), 'error_code' => $validation_result->get_error_code(), 'server_id' => $this->mcp_server->get_server_id(), ) ); } return; } } // Add the tool to this server $this->tools[ $tool->get_name() ] = $tool; // Track successful tool registration if ( ! $this->should_record_component_registration ) { return; } $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'success', 'component_type' => 'tool', 'component_name' => $tool->get_name(), 'server_id' => $this->mcp_server->get_server_id(), ) ); } /* * Register resources to the server. * * @param array $abilities Array of ability names to convert to MCP resources. * * @return void / public function register_resources( array $abilities ): void { foreach ( $abilities as $ability_name ) { if ( ! is_string( $ability_name ) ) { continue; } $ability = wp_get_ability( $ability_name ); if ( ! $ability ) { $this->error_handler->log( "WordPress ability '{$ability_name}' does not exist.", array( "RegisterAbilityAsMcpResource::{$ability_name}" ) ); // Track resource registration failure. if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'failed', 'component_type' => 'resource', 'component_name' => $ability_name, 'failure_reason' => 'ability_not_found', 'server_id' => $this->mcp_server->get_server_id(), ) ); } continue; } $resource = RegisterAbilityAsMcpResource::make( $ability, $this->mcp_server ); // Check if resource creation returned an error if ( is_wp_error( $resource ) ) { $this->error_handler->log( $resource->get_error_message(), array( "RegisterAbilityAsMcpResource::{$ability_name}" ) ); // Track resource registration failure. if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'failed', 'component_type' => 'resource', 'component_name' => $ability_name, 'error_code' => $resource->get_error_code(), 'server_id' => $this->mcp_server->get_server_id(), ) ); } continue; } // Add the processed resources to this server. $this->resources[ $resource->get_uri() ] = $resource; // Track successful resource registration. if ( ! $this->should_record_component_registration ) { continue; } $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'success', 'component_type' => 'resource', 'component_name' => $ability_name, 'server_id' => $this->mcp_server->get_server_id(), ) ); } } /* * Register prompts to the server. * * @param array $prompts Array of prompts to register. Can be ability names (strings) or prompt builder class names. * * @return void / public function register_prompts( array $prompts ): void { foreach ( $prompts as $prompt_item ) { if ( ! is_string( $prompt_item ) ) { continue; } // Check if it's a class that implements McpPromptBuilderInterface if ( class_exists( $prompt_item ) && in_array( McpPromptBuilderInterface::class, class_implements( $prompt_item ) ?: array(), true ) ) { // Create instance of the prompt builder class try { /* @var \WP\MCP\Domain\Prompts\Contracts\McpPromptBuilderInterface $builder / $builder = new $prompt_item(); $prompt = $builder->build(); } catch ( \Throwable $e ) { $this->error_handler->log( "Failed to build prompt from class '{$prompt_item}': {$e->getMessage()}", array( "McpPromptBuilder::{$prompt_item}" ) ); if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'failed', 'component_type' => 'prompt', 'component_name' => $prompt_item, 'failure_reason' => 'builder_exception', 'server_id' => $this->mcp_server->get_server_id(), ) ); } continue; } // Set the MCP server after building $prompt->set_mcp_server( $this->mcp_server ); // Validate if validation is enabled (call validator directly to respect registry's validation flag) if ( $this->mcp_validation_enabled ) { $context_to_use = "McpPromptBuilder::{$prompt_item}"; $validation_result = \WP\MCP\Domain\Prompts\McpPromptValidator::validate_prompt_instance( $prompt, $context_to_use ); // Check if validation returned an error if ( is_wp_error( $validation_result ) ) { $this->error_handler->log( $validation_result->get_error_message(), array( "McpPromptBuilder::{$prompt_item}" ) ); // Track prompt registration failure if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'failed', 'component_type' => 'prompt', 'component_name' => $prompt_item, 'error_code' => $validation_result->get_error_code(), 'server_id' => $this->mcp_server->get_server_id(), ) ); } continue; } } // Add the prompt to this server $this->prompts[ $prompt->get_name() ] = $prompt; // Track successful prompt registration if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'success', 'component_type' => 'prompt', 'component_name' => $prompt_item, 'server_id' => $this->mcp_server->get_server_id(), ) ); } } else { // Treat as ability name (legacy behavior) $ability = wp_get_ability( $prompt_item ); if ( ! $ability ) { $this->error_handler->log( "WordPress ability '{$prompt_item}' does not exist.", array( "RegisterAbilityAsMcpPrompt::{$prompt_item}" ) ); // Track prompt registration failure. if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'failed', 'component_type' => 'prompt', 'component_name' => $prompt_item, 'failure_reason' => 'ability_not_found', 'server_id' => $this->mcp_server->get_server_id(), ) ); } continue; } // Use RegisterMcpPrompt to handle all validation and processing. $prompt = RegisterAbilityAsMcpPrompt::make( $ability, $this->mcp_server ); // Check if prompt creation returned an error if ( is_wp_error( $prompt ) ) { $this->error_handler->log( $prompt->get_error_message(), array( "RegisterAbilityAsMcpPrompt::{$prompt_item}" ) ); // Track prompt registration failure. if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'failed', 'component_type' => 'prompt', 'component_name' => $prompt_item, 'error_code' => $prompt->get_error_code(), 'server_id' => $this->mcp_server->get_server_id(), ) ); } continue; } // Add the processed prompts to this server. $this->prompts[ $prompt->get_name() ] = $prompt; // Track successful prompt registration. if ( $this->should_record_component_registration ) { $this->observability_handler->record_event( 'mcp.component.registration', array( 'status' => 'success', 'component_type' => 'prompt', 'component_name' => $prompt_item, 'server_id' => $this->mcp_server->get_server_id(), ) ); } } } } /* * Get all tools registered to the server. * * @return \WP\MCP\Domain\Tools\McpTool[] / public function get_tools(): array { return $this->tools; } /* * Get all resources registered to the server. * * @return \WP\MCP\Domain\Resources\McpResource[] / public function get_resources(): array { return $this->resources; } /* * Get all prompts registered to the server. * * @return \WP\MCP\Domain\Prompts\McpPrompt[] / public function get_prompts(): array { return $this->prompts; } /* * Get a specific tool by name. * * @param string $tool_name Tool name. * * @return \WP\MCP\Domain\Tools\McpTool\|null / public function get_tool( string $tool_name ): ?McpTool { return $this->tools[ $tool_name ] ?? null; } /* * Get a specific resource by URI. * * @param string $resource_uri Resource URI. * * @return \WP\MCP\Domain\Resources\McpResource\|null / public function get_resource( string $resource_uri ): ?McpResource { return $this->resources[ $resource_uri ] ?? null; } /* * Get a specific prompt by name. * * @param string $prompt_name Prompt name. * * @return \WP\MCP\Domain\Prompts\McpPrompt\|null */ public function get_prompt( string $prompt_name ): ?McpPrompt { return $this->prompts[ $prompt_name ] ?? null; } }

| ver. 1.6 | Github | . | PHP 8.1.34 | Генерация страницы: 0 | proxy | phpinfo | Настройка