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\Resource\Resource;
18: use Nexus\Mcp\Core\Schema\Result\ListResourcesResult;
19: use Nexus\Mcp\Core\Schema\Result\ReadResourceResult;
20: use Nexus\Mcp\Server\AbstractPaginatedStore;
21: use Nexus\Mcp\Server\Exception\ResourceNotFoundException;
22: use Nexus\Mcp\Server\ServerContext;
23:
24: /**
25: * In-memory implementation of `ResourceStoreInterface`.
26: *
27: * @extends AbstractPaginatedStore<ResourceEntry>
28: */
29: final readonly class ResourceStore extends AbstractPaginatedStore implements ResourceStoreInterface
30: {
31: protected const string STORE_LABEL = 'Resource store';
32:
33: #[\Override]
34: public function list(?Cursor $cursor): ListResourcesResult
35: {
36: return $this->paginate(
37: $cursor,
38: static fn(ResourceEntry $entry): Resource => $entry->resource,
39: static fn(array $resources, ?Cursor $nextCursor): ListResourcesResult => new ListResourcesResult($resources, $nextCursor),
40: );
41: }
42:
43: #[\Override]
44: public function read(string $uri, ServerContext $context): ReadResourceResult
45: {
46: $entry = $this->entries[$uri] ?? throw new ResourceNotFoundException($uri, $context->requestId);
47:
48: return $entry->reader->read($uri, $context);
49: }
50: }
51: