Sync create store

WalletConnect · Jun 19, 2023 · d8b9365 · d8b9365
1 parent d40a93c
commit d8b9365
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/Sources/WalletConnectPush/Client/Wallet/WalletPushClient.swift b/Sources/WalletConnectPush/Client/Wallet/WalletPushClient.swift
@@ -50,6 +50,7 @@ public class WalletPushClient {
  private let notifyUpdateRequester: NotifyUpdateRequester
  private let notifyUpdateResponseSubscriber: NotifyUpdateResponseSubscriber
  private let notifyProposeResponder: NotifyProposeResponder
+ private let subscriptionsStore: SyncStore<PushSubscription>
 
  init(logger: ConsoleLogging,
  kms: KeyManagementServiceProtocol,
@@ -65,7 +66,8 @@ public class WalletPushClient {
  pushSubscribeResponseSubscriber: PushSubscribeResponseSubscriber,
  notifyUpdateRequester: NotifyUpdateRequester,
  notifyUpdateResponseSubscriber: NotifyUpdateResponseSubscriber,
- notifyProposeResponder: NotifyProposeResponder
+ notifyProposeResponder: NotifyProposeResponder,
+ subscriptionsStore: SyncStore<PushSubscription>
  ) {
  self.logger = logger
  self.pairingRegisterer = pairingRegisterer
@@ -81,10 +83,12 @@ public class WalletPushClient {
  self.notifyUpdateRequester = notifyUpdateRequester
  self.notifyUpdateResponseSubscriber = notifyUpdateResponseSubscriber
  self.notifyProposeResponder = notifyProposeResponder
+ self.subscriptionsStore = subscriptionsStore
  setupSubscriptions()
  }
 
  public func subscribe(metadata: AppMetadata, account: Account, onSign: @escaping SigningCallback) async throws {
+ try await subscriptionsStore.initialize(for: account)
  try await pushSubscribeRequester.subscribe(metadata: metadata, account: account, onSign: onSign)
  }
 

diff --git a/Sources/WalletConnectPush/Client/Wallet/WalletPushClientFactory.swift b/Sources/WalletConnectPush/Client/Wallet/WalletPushClientFactory.swift
@@ -78,7 +78,8 @@ public struct WalletPushClientFactory {
  pushSubscribeResponseSubscriber: pushSubscribeResponseSubscriber,
  notifyUpdateRequester: notifyUpdateRequester,
  notifyUpdateResponseSubscriber: notifyUpdateResponseSubscriber,
- notifyProposeResponder: notifyProposeResponder
+ notifyProposeResponder: notifyProposeResponder,
+ subscriptionsStore: subscriptionStore
  )
  }
 }