|JsonRpcResponse */ public function handle(JsonRpcRequest $request, ServerContext $context): Generator|JsonRpcResponse { try { $prompt = $this->resolvePrompt($request->get('name'), $context); } catch (InvalidArgumentException $invalidArgumentException) { throw new JsonRpcException($invalidArgumentException->getMessage(), -32602, $request->id); } try { // @phpstan-ignore-next-line $response = Container::getInstance()->call([$prompt, 'handle']); } catch (ValidationException $validationException) { $response = Response::error('Invalid params: '.ValidationMessages::from($validationException)); } return is_iterable($response) ? $this->toJsonRpcStreamedResponse($request, $response, $this->serializable($prompt)) : $this->toJsonRpcResponse($request, $response, $this->serializable($prompt)); } /** * @return callable(ResponseFactory): array */ protected function serializable(Prompt $prompt): callable { return fn (ResponseFactory $factory): array => $factory->mergeMeta([ 'description' => $prompt->description(), 'messages' => $factory->responses()->map(fn (Response $response): array => [ 'role' => $response->role()->value, 'content' => $response->content()->toPrompt($prompt), ])->all(), ]); } }