connected; } public function initializeResult(): ?InitializeResult { return $this->initializeResult; } public function connect(): void { if ($this->connected) { return; } $this->transport->connect(); $this->connecting = true; try { $this->initializeResult = (new Initialize($this->clientInfo))->handle($this); $this->transport->setProtocolVersion($this->initializeResult->protocolVersion); $this->notify('notifications/initialized'); } catch (Throwable $throwable) { $this->disconnect(); throw $throwable; } finally { $this->connecting = false; } $this->connected = true; } public function disconnect(): void { $this->connected = false; $this->transport->disconnect(); } /** * @param Method $method * @return array */ public function dispatch(Method $method): array { if (! $this->connected && ! $this->connecting) { $this->connect(); } try { return $this->attempt($method); } catch (SessionExpiredException) { $this->connect(); return $this->attempt($method); } } /** * @param Method $method * @return array */ protected function attempt(Method $method): array { $request = new JsonRpcRequest( id: $this->nextRequestId++, method: $method->method(), params: $method->params(), ); try { $this->transport->send($request->toJson()); do { $raw = $this->transport->receive(); try { $response = json_decode($raw, true, flags: JSON_THROW_ON_ERROR); } catch (JsonException $jsonException) { throw new ClientException( 'Malformed JSON-RPC response from server: '.$jsonException->getMessage(), 0, $jsonException, ); } if (! is_array($response) || Arr::get($response, 'jsonrpc') !== '2.0') { throw new ClientException('Invalid JSON-RPC response from server.'); } $this->handleServerRequest($response); } while (Arr::get($response, 'id') !== $request->id); $hasResult = Arr::has($response, 'result'); $hasError = Arr::has($response, 'error'); $error = Arr::get($response, 'error'); if ($hasResult === $hasError) { throw new ClientException('Invalid JSON-RPC response: must contain exactly one of "result" or "error".'); } if ($hasError && ! is_array($error)) { throw new ClientException('Invalid JSON-RPC error payload.'); } } catch (Throwable $throwable) { if ($this->connected) { $this->disconnect(); } throw $throwable; } if ($hasError) { $message = Arr::get($error, 'message', 'Unknown JSON-RPC error.'); $code = Arr::get($error, 'code', 0); $data = Arr::get($error, 'data'); throw new JsonRpcException( is_string($message) ? $message : 'Unknown JSON-RPC error.', is_int($code) ? $code : 0, Arr::get($response, 'id'), is_array($data) ? $data : null, ); } $result = Arr::get($response, 'result'); return is_array($result) ? $result : []; } public function notify(string $method): void { $notification = new JsonRpcNotification($method, []); $this->transport->send($notification->toJson()); } /** * @param array $frame */ protected function handleServerRequest(array $frame): void { $id = Arr::get($frame, 'id'); $method = Arr::get($frame, 'method'); if (! is_string($method) || (! is_int($id) && ! is_string($id))) { return; } if ($method === 'ping') { $this->transport->send(JsonRpcResponse::result($id, [])->toJson()); return; } $this->transport->send(JsonRpcResponse::error( $id, -32601, "Method [{$method}] not supported by this client.", )->toJson()); } }