update TelemetryHandlers tests

Node/Sources/Node/NetworkingProtocol/Network.swift

@@ -92,6 +92,10 @@ public final class Network: Sendable {
     public var peersCount: Int {
         peer.peersCount
     }
+
+    public var networkKey: String {
+        peer.publicKey.description
+    }
 }
 
 struct HandlerDef: StreamHandler {

Node/Sources/Node/NodeDataSource.swift

@@ -87,4 +87,8 @@ extension NodeDataSource: TelemetryDataSource {
     public func getPeersCount() async throws -> Int {
         networkManager.peersCount
     }
+
+    public func getNetworkKey() async throws -> String {
+        networkManager.network.networkKey
+    }
 }

RPC/Sources/RPC/DataSource/DataSource.swift

@@ -23,6 +23,7 @@ public protocol ChainDataSource: Sendable {
 public protocol TelemetryDataSource: Sendable {
     func name() async throws -> String
     func getPeersCount() async throws -> Int
+    func getNetworkKey() async throws -> String
 }
 
 public typealias DataSource = ChainDataSource & SystemDataSource & TelemetryDataSource

RPC/Sources/RPC/Handlers/TelemetryHandlers.swift

@@ -67,8 +67,7 @@ public enum TelemetryHandlers {
         }
 
         public func handle(request _: Request) async throws -> Response? {
-            // TODO: implement
-            nil
+            try await source.getNetworkKey()
         }
     }
 }

RPC/Tests/RPCTests/TelemetryHandlersTests.swift

@@ -0,0 +1,72 @@
+import Blockchain
+import Testing
+import TracingUtils
+import Vapor
+import XCTVapor
+
+@testable import RPC
+@testable import Utils
+
+struct TelemetryDummySource: TelemetryDataSource {
+    func name() async throws -> String {
+        "TestNode"
+    }
+
+    func getPeersCount() async throws -> Int {
+        42
+    }
+
+    func getNetworkKey() async throws -> String {
+        "Ed25519:TestKey"
+    }
+}
+
+final class TelemetryHandlersTests {
+    var app: Application
+
+    init() throws {
+        app = Application(.testing)
+
+        let rpcController = JSONRPCController(
+            handlers: TelemetryHandlers.getHandlers(source: TelemetryDummySource())
+        )
+        try app.register(collection: rpcController)
+    }
+
+    deinit {
+        app.shutdown()
+    }
+
+    @Test func name() throws {
+        let req = JSONRequest(jsonrpc: "2.0", method: "telemetry_name", params: nil, id: 1)
+        var buffer = ByteBuffer()
+        try buffer.writeJSONEncodable(req)
+        try app.test(.POST, "/", headers: ["Content-Type": "application/json"], body: buffer) { res in
+            #expect(res.status == .ok)
+            let resp = try res.content.decode(JSONResponse.self, using: JSONDecoder())
+            #expect((resp.result!.value as! Utils.JSON).string == "TestNode")
+        }
+    }
+
+    @Test func peersCount() throws {
+        let req = JSONRequest(jsonrpc: "2.0", method: "telemetry_peersCount", params: nil, id: 2)
+        var buffer = ByteBuffer()
+        try buffer.writeJSONEncodable(req)
+        try app.test(.POST, "/", headers: ["Content-Type": "application/json"], body: buffer) { res in
+            #expect(res.status == .ok)
+            let resp = try res.content.decode(JSONResponse.self, using: JSONDecoder())
+            #expect((resp.result!.value as! Utils.JSON).number == 42)
+        }
+    }
+
+    @Test func networkKey() throws {
+        let req = JSONRequest(jsonrpc: "2.0", method: "telemetry_networkKey", params: nil, id: 3)
+        var buffer = ByteBuffer()
+        try buffer.writeJSONEncodable(req)
+        try app.test(.POST, "/", headers: ["Content-Type": "application/json"], body: buffer) { res in
+            #expect(res.status == .ok)
+            let resp = try res.content.decode(JSONResponse.self, using: JSONDecoder())
+            #expect((resp.result!.value as! Utils.JSON).string == "Ed25519:TestKey")
+        }
+    }
+}