expose client id

Example/IntegrationTests/Relay/RelayClientEndToEndTests.swift

@@ -10,18 +10,19 @@ final class RelayClientEndToEndTests: XCTestCase {
     private var publishers = Set<AnyCancellable>()
 
     func makeRelayClient() -> RelayClient {
-        let clientIdStorage = ClientIdStorage(keychain: KeychainStorageMock())
+        let didKeyFactory = ED25519DIDKeyFactory()
+        let clientIdStorage = ClientIdStorage(keychain: KeychainStorageMock(), didKeyFactory: didKeyFactory)
         let socketAuthenticator = SocketAuthenticator(
             clientIdStorage: clientIdStorage,
-            didKeyFactory: ED25519DIDKeyFactory(),
+            didKeyFactory: didKeyFactory,
             relayHost: InputConfig.relayHost
         )
         let urlFactory = RelayUrlFactory(socketAuthenticator: socketAuthenticator)
         let socket = WebSocket(url: urlFactory.create(host: InputConfig.relayHost, projectId: InputConfig.projectId))
 
         let logger = ConsoleLogger()
         let dispatcher = Dispatcher(socket: socket, socketConnectionHandler: ManualSocketConnectionHandler(socket: socket), logger: logger)
-        return RelayClient(dispatcher: dispatcher, logger: logger, keyValueStorage: RuntimeKeyValueStorage())
+        return RelayClient(dispatcher: dispatcher, logger: logger, keyValueStorage: RuntimeKeyValueStorage(), clientIdStorage: clientIdStorage)
     }
 
     func testSubscribe() {

Sources/WalletConnectNetworking/NetworkingClient.swift

@@ -6,4 +6,5 @@ public protocol NetworkingClient {
     var socketConnectionStatusPublisher: AnyPublisher<SocketConnectionStatus, Never> { get }
     func connect() throws
     func disconnect(closeCode: URLSessionWebSocketTask.CloseCode) throws
+    func getClientId() throws -> String
 }

Sources/WalletConnectNetworking/NetworkingInteractor.swift

@@ -180,4 +180,8 @@ extension NetworkingInteractor: NetworkingClient {
     public func disconnect(closeCode: URLSessionWebSocketTask.CloseCode) throws {
         try relayClient.disconnect(closeCode: closeCode)
     }
+
+    public func getClientId() throws -> String {
+        try relayClient.getClientId()
+    }
 }

Sources/WalletConnectRelay/ClientAuth/ClientIdStorage.swift

@@ -3,14 +3,18 @@ import WalletConnectKMS
 
 protocol ClientIdStoring {
     func getOrCreateKeyPair() throws -> SigningPrivateKey
+    func getClientId() throws -> String
 }
 
 struct ClientIdStorage: ClientIdStoring {
     private let key = "com.walletconnect.iridium.client_id"
     private let keychain: KeychainStorageProtocol
+    private let didKeyFactory: ED25519DIDKeyFactory
 
-    init(keychain: KeychainStorageProtocol) {
+    init(keychain: KeychainStorageProtocol,
+         didKeyFactory: ED25519DIDKeyFactory) {
         self.keychain = keychain
+        self.didKeyFactory = didKeyFactory
     }
 
     func getOrCreateKeyPair() throws -> SigningPrivateKey {
@@ -22,4 +26,10 @@ struct ClientIdStorage: ClientIdStoring {
             return privateKey
         }
     }
+
+    func getClientId() throws -> String {
+        let privateKey: SigningPrivateKey = try keychain.read(key: key)
+        let pubKey = privateKey.publicKey.rawRepresentation
+        return didKeyFactory.make(pubKey: pubKey, prefix: true)
+    }
 }

Sources/WalletConnectRelay/RelayClient.swift

@@ -41,6 +41,8 @@ public final class RelayClient {
         requestAcknowledgePublisherSubject.eraseToAnyPublisher()
     }
 
+    private let clientIdStorage: ClientIdStorage
+
     private var dispatcher: Dispatching
     private let rpcHistory: RPCHistory
     private let logger: ConsoleLogging
@@ -52,11 +54,13 @@ public final class RelayClient {
     init(
         dispatcher: Dispatching,
         logger: ConsoleLogging,
-        keyValueStorage: KeyValueStorage
+        keyValueStorage: KeyValueStorage,
+        clientIdStorage: ClientIdStorage
     ) {
         self.logger = logger
         self.dispatcher = dispatcher
         self.rpcHistory = RPCHistoryFactory.createForRelay(keyValueStorage: keyValueStorage)
+        self.clientIdStorage = clientIdStorage
         setUpBindings()
     }
 
@@ -82,9 +86,11 @@ public final class RelayClient {
         socketConnectionType: SocketConnectionType = .automatic,
         logger: ConsoleLogging = ConsoleLogger(loggingLevel: .off)
     ) {
+        let didKeyFactory = ED25519DIDKeyFactory()
+        let clientIdStorage = ClientIdStorage(keychain: keychainStorage, didKeyFactory: didKeyFactory)
         let socketAuthenticator = SocketAuthenticator(
-            clientIdStorage: ClientIdStorage(keychain: keychainStorage),
-            didKeyFactory: ED25519DIDKeyFactory(),
+            clientIdStorage: clientIdStorage,
+            didKeyFactory: didKeyFactory,
             relayHost: relayHost
         )
         let relayUrlFactory = RelayUrlFactory(socketAuthenticator: socketAuthenticator)
@@ -101,7 +107,7 @@ public final class RelayClient {
             socketConnectionHandler = ManualSocketConnectionHandler(socket: socket)
         }
         let dispatcher = Dispatcher(socket: socket, socketConnectionHandler: socketConnectionHandler, logger: logger)
-        self.init(dispatcher: dispatcher, logger: logger, keyValueStorage: keyValueStorage)
+        self.init(dispatcher: dispatcher, logger: logger, keyValueStorage: keyValueStorage, clientIdStorage: clientIdStorage)
     }
 
     /// Connects web socket
@@ -231,6 +237,10 @@ public final class RelayClient {
         }
     }
 
+    public func getClientId() throws -> String {
+        try clientIdStorage.getClientId()
+    }
+
     // FIXME: Parse data to string once before trying to decode -> respond error on fail
     private func handlePayloadMessage(_ payload: String) {
         if let request = tryDecode(RPCRequest.self, from: payload) {