File Server/Resource/CompositeResourceStore.php

1:	<?php
2:
3:	declare(strict_types=1);
4:
5:	/**
6:	* This file is part of the Nexus MCP SDK package.
7:	*
8:	* (c) 2026 John Paul E. Balandan, CPA <paulbalandan@gmail.com>
9:	*
10:	* For the full copyright and license information, please view
11:	* the LICENSE file that was distributed with this source code.
12:	*/
13:
14:	namespace Nexus\Mcp\Server\Resource;
15:
16:	use Nexus\Mcp\Core\Schema\Cursor;
17:	use Nexus\Mcp\Core\Schema\Result\InputRequiredResult;
18:	use Nexus\Mcp\Core\Schema\Result\ListResourcesResult;
19:	use Nexus\Mcp\Core\Schema\Result\ReadResourceResult;
20:	use Nexus\Mcp\Server\Exception\ResourceNotRegisteredException;
21:	use Nexus\Mcp\Server\ListChangeSourceInterface;
22:	use Nexus\Mcp\Server\ServerContext;
23:
24:	/**
25:	* Chains a primary `ResourceStoreInterface` (exact-URI matches) with a fallback
26:	* `ResourceTemplateStoreInterface` (URI-template matches).
27:	*/
28:	final readonly class CompositeResourceStore implements ListChangeSourceInterface, ResourceStoreInterface
29:	{
30:	public function __construct(
31:	private ResourceStoreInterface $resourceStore,
32:	private ResourceTemplateStoreInterface $resourceTemplateStore,
33:	) {
34:	}
35:
36:	#[\Override]
37:	public function onListChanged(\Closure $listener): void
38:	{
39:	foreach ([$this->resourceStore, $this->resourceTemplateStore] as $store) {
40:	if ($store instanceof ListChangeSourceInterface) {
41:	$store->onListChanged($listener);
42:	}
43:	}
44:	}
45:
46:	#[\Override]
47:	public function list(?Cursor $cursor): ListResourcesResult
48:	{
49:	return $this->resourceStore->list($cursor);
50:	}
51:
52:	#[\Override]
53:	public function read(string $uri, ServerContext $context): InputRequiredResult\|ReadResourceResult
54:	{
55:	try {
56:	return $this->resourceStore->read($uri, $context);
57:	} catch (ResourceNotRegisteredException) {
58:	return $this->resourceTemplateStore->read($uri, $context);
59:	}
60:	}
61:	}
62:

Namespaces

Classes

Interfaces