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\Extension\Tasks\Server\Handler;
15:
16: use Nexus\Mcp\Core\Exception\InvalidParamsException;
17: use Nexus\Mcp\Core\Handler\AbstractContext;
18: use Nexus\Mcp\Core\Handler\RequestHandlerInterface;
19: use Nexus\Mcp\Core\Schema\JsonRpc\JsonRpcRequest;
20: use Nexus\Mcp\Extension\Tasks\Schema\Request\GetTaskRequest;
21: use Nexus\Mcp\Extension\Tasks\Schema\Result\GetTaskResult;
22: use Nexus\Mcp\Extension\Tasks\Server\Store\TaskStoreInterface;
23: use Nexus\Mcp\Server\ServerContext;
24:
25: /**
26: * Handles the `tasks/get` request by delegating to a `TaskStoreInterface`.
27: *
28: * @implements RequestHandlerInterface<'tasks/get', GetTaskResult, ServerContext>
29: */
30: final readonly class GetTaskRequestHandler implements RequestHandlerInterface
31: {
32: public function __construct(private TaskStoreInterface $store)
33: {
34: }
35:
36: #[\Override]
37: public function handle(JsonRpcRequest $request, AbstractContext $context): GetTaskResult
38: {
39: \assert($request instanceof GetTaskRequest);
40:
41: $record = $this->store->findTask($request->params->taskId);
42:
43: if (null === $record) {
44: throw new InvalidParamsException($context->requestId, '"params.taskId" does not name a known task.');
45: }
46:
47: return new GetTaskResult(
48: taskId: $record->taskId,
49: status: $record->status,
50: createdAt: $record->createdAt,
51: lastUpdatedAt: $record->lastUpdatedAt,
52: ttlMs: $record->ttlMs,
53: result: $record->result,
54: error: $record->error,
55: inputRequests: $record->pendingInputRequests,
56: statusMessage: $record->statusMessage,
57: pollIntervalMs: $record->pollIntervalMs,
58: );
59: }
60: }
61: