Observe locally and remotely created orders to reset the last sync timestamp for each time range tab.

Author: jaclync

WooCommerce/Classes/ViewRelated/Dashboard/Stats v4/StoreStatsAndTopPerformersViewController.swift

@@ -35,11 +35,18 @@ final class StoreStatsAndTopPerformersViewController: ButtonBarPagerTabStripView
     private let usageTracksEventEmitter = StoreStatsUsageTracksEventEmitter()
     private let dashboardViewModel: DashboardViewModel
 
+    private let pushNotificationsManager: PushNotesManager
+    private var localOrdersSubscription: AnyCancellable?
+    private var remoteOrdersSubscription: AnyCancellable?
+
     // MARK: - View Lifecycle
 
-    init(siteID: Int64, dashboardViewModel: DashboardViewModel) {
+    init(siteID: Int64,
+         dashboardViewModel: DashboardViewModel,
+         pushNotificationsManager: PushNotesManager = ServiceLocator.pushNotesManager) {
         self.siteID = siteID
         self.dashboardViewModel = dashboardViewModel
+        self.pushNotificationsManager = pushNotificationsManager
         super.init(nibName: nil, bundle: nil)
     }
 
@@ -54,6 +61,8 @@ final class StoreStatsAndTopPerformersViewController: ButtonBarPagerTabStripView
 
         super.viewDidLoad()
         configureView()
+        observeRemotelyCreatedOrdersToResetLastSyncTimestamp()
+        observeLocallyCreatedOrdersToResetLastSyncTimestamp()
     }
 
     override func viewWillAppear(_ animated: Bool) {
@@ -255,6 +264,35 @@ private extension StoreStatsAndTopPerformersViewController {
             periodViewController.refreshControl.endRefreshing()
         }
     }
+
+    func observeRemotelyCreatedOrdersToResetLastSyncTimestamp() {
+        let siteID = self.siteID
+        remoteOrdersSubscription = Publishers
+            .Merge(pushNotificationsManager.inactiveNotifications, pushNotificationsManager.foregroundNotificationsToView)
+            .filter { $0.kind == .storeOrder && $0.siteID == siteID }
+            .sink { [weak self] _ in
+                self?.resetLastSyncTimestamp()
+            }
+    }
+
+    func observeLocallyCreatedOrdersToResetLastSyncTimestamp() {
+        let action = OrderAction.observeInsertedOrders(siteID: siteID) { [weak self] observableInsertedOrders in
+            guard let self = self else { return }
+            self.localOrdersSubscription = observableInsertedOrders
+                .filter { $0.isNotEmpty }
+                .sink { [weak self] _ in
+                    guard let self = self else { return }
+                    self.resetLastSyncTimestamp()
+                }
+        }
+        ServiceLocator.stores.dispatch(action)
+    }
+
+    func resetLastSyncTimestamp() {
+        periodVCs.forEach { periodVC in
+            periodVC.lastFullSyncTimestamp = nil
+        }
+    }
 }
 
 // MARK: - Placeholders