add rpcs

Networking/Sources/Networking/Peer.swift

@@ -157,6 +157,11 @@ public final class Peer<Handler: StreamHandler>: Sendable {
             }
         }
     }
+
+    // there should be only one connection per peer
+    public func getPeersCount() -> Int {
+        impl.connections.value.byId.values.count
+    }
 }
 
 final class PeerImpl<Handler: StreamHandler>: Sendable {

Node/Sources/Node/NetworkingProtocol/Network.swift

@@ -77,6 +77,10 @@ public final class Network: Sendable {
     public func listenAddress() throws -> NetAddr {
         try peer.listenAddress()
     }
+
+    public func getPeersCount() -> Int {
+        peer.getPeersCount()
+    }
 }
 
 struct HandlerDef: StreamHandler {

Node/Sources/Node/NetworkingProtocol/NetworkManager.swift

@@ -104,6 +104,10 @@ public final class NetworkManager: Sendable {
             )
         }
     }
+
+    public func getPeersCount() -> Int {
+        network.getPeersCount()
+    }
 }
 
 struct HandlerImpl: NetworkProtocolHandler {

Node/Sources/Node/NodeDataSource.swift

@@ -30,7 +30,6 @@ public final class NodeDataSource: DataSource {
     }
 
     public func getPeersCount() async throws -> Int {
-        // TODO: implememnt
-        0
+        networkManager.getPeersCount()
     }
 }

RPC/Sources/RPC/Handlers/ChainHandler.swift

@@ -10,6 +10,7 @@ struct ChainHandler {
 
         return [
             "chain_getBlock": handler.getBlock,
+            "chain_getState": handler.getState,
         ]
     }
 
@@ -32,4 +33,21 @@ struct ChainHandler {
             ]
         }
     }
+
+    func getState(request: JSONRequest) async throws -> any Encodable {
+        let hash = request.params?["hash"] as? String
+        if let hash {
+            guard let data = Data(fromHexString: hash), let data32 = Data32(data) else {
+                throw JSONError(code: -32602, message: "Invalid block hash")
+            }
+            let state = try await source.getState(hash: data32)
+            // return state root for now
+            return state?.stateRoot.description
+        } else {
+            // return best block state by default
+            let block = try await source.getBestBlock()
+            let state = try await source.getState(hash: block.hash)
+            return state?.stateRoot.description
+        }
+    }
 }