* * @throws JsonRpcException */ public function handle(JsonRpcRequest $request, ServerContext $context): Generator|JsonRpcResponse { if (is_null($request->get('name'))) { throw new JsonRpcException( 'Missing [name] parameter.', -32602, $request->id, ); } $tool = $context ->tools() ->first( fn ($tool): bool => $tool->name() === $request->params['name'], fn () => throw new JsonRpcException( "Tool [{$request->params['name']}] not found.", -32602, $request->id, )); try { // @phpstan-ignore-next-line $response = Container::getInstance()->call([$tool, 'handle']); } catch (ValidationException $validationException) { $response = Response::error(ValidationMessages::from($validationException)); } return is_iterable($response) ? $this->toJsonRpcStreamedResponse($request, $response, $this->serializable($tool)) : $this->toJsonRpcResponse($request, $response, $this->serializable($tool)); } /** * @return callable(ResponseFactory): array */ protected function serializable(Tool $tool): callable { return fn (ResponseFactory $factory): array => $factory->mergeStructuredContent( $factory->mergeMeta([ 'content' => $factory->responses()->map(fn (Response $response): array => $response->content()->toTool($tool))->all(), 'isError' => $factory->responses()->contains(fn (Response $response): bool => $response->isError()), ]) ); } }