[Push] Add push messages history getter, add account to subscription

Example/IntegrationTests/Push/PushTests.swift

@@ -147,6 +147,7 @@ final class PushTests: XCTestCase {
     func testDappSendsPushMessage() async {
         let expectation = expectation(description: "expects wallet to receive push message")
         let pushMessage = PushMessage.stub()
+        var pushSubscription: PushSubscription!
         let uri = try! await dappPairingClient.create()
         try! await walletPairingClient.pair(uri: uri)
         try! await dappPushClient.request(account: Account.stub(), topic: uri.topic)
@@ -160,14 +161,18 @@ final class PushTests: XCTestCase {
                 XCTFail()
                 return
             }
+            pushSubscription = subscription
             Task(priority: .userInitiated) { try! await dappPushClient.notify(topic: subscription.topic, message: pushMessage) }
         }.store(in: &publishers)
 
-        walletPushClient.pushMessagePublisher.sink { receivedPushMessage in
+        walletPushClient.pushMessagePublisher.sink { [unowned self] receivedPushMessage in
+            let messageHistory = walletPushClient.getMessageHistory(topic: pushSubscription.topic)
             XCTAssertEqual(pushMessage, receivedPushMessage)
+            XCTAssertTrue(messageHistory.contains(receivedPushMessage))
             expectation.fulfill()
         }.store(in: &publishers)
 
+
         wait(for: [expectation], timeout: InputConfig.defaultTimeout)
 
     }

Sources/WalletConnectPush/Client/Dapp/ProposalResponseSubscriber.swift

@@ -46,7 +46,7 @@ class ProposalResponseSubscriber {
         let selfpublicKeyHex = payload.request.publicKey
         let (topic, _) = try generateAgreementKeys(peerPublicKeyHex: peerPublicKeyHex, selfpublicKeyHex: selfpublicKeyHex)
 
-        let pushSubscription = PushSubscription(topic: topic, relay: relay, metadata: metadata)
+        let pushSubscription = PushSubscription(topic: topic, account: payload.request.account, relay: relay, metadata: metadata)
         subscriptionsStore.set(pushSubscription, forKey: topic)
         kms.deletePrivateKey(for: selfpublicKeyHex)
         try await networkingInteractor.subscribe(topic: topic)

Sources/WalletConnectPush/Client/Wallet/PushMessagesProvider.swift

@@ -0,0 +1,15 @@
+
+import Foundation
+import WalletConnectUtils
+
+class PushMessagesProvider {
+    private let history: RPCHistory
+
+    init(history: RPCHistory) {
+        self.history = history
+    }
+
+    public func getMessageHistory(topic: String) -> [PushMessage] {
+        history.getAll(of: PushMessage.self, topic: topic)
+    }
+}

Sources/WalletConnectPush/Client/Wallet/PushRequestResponder.swift

@@ -51,7 +51,7 @@ class PushRequestResponder {
         let response = RPCResponse(id: requestId, result: responseParams)
 
         let requestParams = try requestRecord.request.params!.get(PushRequestParams.self)
-        let pushSubscription = PushSubscription(topic: pushTopic, relay: RelayProtocolOptions(protocol: "irn", data: nil), metadata: requestParams.metadata)
+        let pushSubscription = PushSubscription(topic: pushTopic, account: requestParams.account, relay: RelayProtocolOptions(protocol: "irn", data: nil), metadata: requestParams.metadata)
         subscriptionsStore.set(pushSubscription, forKey: pushTopic)
 
         try await networkingInteractor.respond(topic: pairingTopic, response: response, protocolMethod: PushRequestProtocolMethod())

Sources/WalletConnectPush/Client/Wallet/WalletPushClient.swift

@@ -36,6 +36,7 @@ public class WalletPushClient {
     private let proposeResponder: PushRequestResponder
     private let pushMessageSubscriber: PushMessageSubscriber
     private let subscriptionsProvider: SubscriptionsProvider
+    private let pushMessagesProvider: PushMessagesProvider
     private let resubscribeService: PushResubscribeService
 
     init(logger: ConsoleLogging,
@@ -45,6 +46,7 @@ public class WalletPushClient {
          proposeResponder: PushRequestResponder,
          pushMessageSubscriber: PushMessageSubscriber,
          subscriptionsProvider: SubscriptionsProvider,
+         pushMessagesProvider: PushMessagesProvider,
          deletePushSubscriptionService: DeletePushSubscriptionService,
          deletePushSubscriptionSubscriber: DeletePushSubscriptionSubscriber,
          resubscribeService: PushResubscribeService) {
@@ -54,6 +56,7 @@ public class WalletPushClient {
         self.echoClient = echoClient
         self.pushMessageSubscriber = pushMessageSubscriber
         self.subscriptionsProvider = subscriptionsProvider
+        self.pushMessagesProvider = pushMessagesProvider
         self.deletePushSubscriptionService = deletePushSubscriptionService
         self.deletePushSubscriptionSubscriber = deletePushSubscriptionSubscriber
         self.resubscribeService = resubscribeService
@@ -72,6 +75,10 @@ public class WalletPushClient {
         subscriptionsProvider.getActiveSubscriptions()
     }
 
+    public func getMessageHistory(topic: String) -> [PushMessage] {
+        pushMessagesProvider.getMessageHistory(topic: topic)
+    }
+
     public func delete(topic: String) async throws {
         try await deletePushSubscriptionService.delete(topic: topic)
     }

Sources/WalletConnectPush/Client/Wallet/WalletPushClientFactory.swift

@@ -36,6 +36,7 @@ public struct WalletPushClientFactory {
         let deletePushSubscriptionService = DeletePushSubscriptionService(networkingInteractor: networkInteractor, kms: kms, logger: logger, pushSubscriptionStore: subscriptionStore)
         let deletePushSubscriptionSubscriber = DeletePushSubscriptionSubscriber(networkingInteractor: networkInteractor, kms: kms, logger: logger, pushSubscriptionStore: subscriptionStore)
         let resubscribeService = PushResubscribeService(networkInteractor: networkInteractor, subscriptionsStorage: subscriptionStore)
+        let pushMessagesProvider = PushMessagesProvider(history: history)
         return WalletPushClient(
             logger: logger,
             kms: kms,
@@ -44,6 +45,7 @@ public struct WalletPushClientFactory {
             proposeResponder: proposeResponder,
             pushMessageSubscriber: pushMessageSubscriber,
             subscriptionsProvider: subscriptionProvider,
+            pushMessagesProvider: pushMessagesProvider,
             deletePushSubscriptionService: deletePushSubscriptionService,
             deletePushSubscriptionSubscriber: deletePushSubscriptionSubscriber,
             resubscribeService: resubscribeService

Sources/WalletConnectPush/Types/PushSubscription.swift

@@ -4,6 +4,7 @@ import WalletConnectPairing
 
 public struct PushSubscription: Codable, Equatable {
     let topic: String
+    let account: Account
     let relay: RelayProtocolOptions
     let metadata: AppMetadata
 }

Sources/WalletConnectUtils/RPCHistory/RPCHistory.swift

@@ -65,6 +65,16 @@ public final class RPCHistory {
         }
     }
 
+    public func getAll<Object: Codable>(of type: Object.Type, topic: String) -> [Object] {
+        return storage.getAll()
+            .filter{$0.topic == topic}
+            .compactMap { record in
+                guard let object = try? record.request.params?.get(Object.self)
+                else { return nil }
+                return object
+            }
+    }
+
     public func deleteAll(forTopic topic: String) {
         deleteAll(forTopics: [topic])
     }