Always perform full sync if the site’s not stored

Author: joshheald

Modules/Sources/Yosemite/Tools/POS/POSCatalogSyncCoordinator.swift

@@ -1,6 +1,7 @@
 import Foundation
 import Storage
 import CocoaLumberjackSwift
+import GRDB
 
 public protocol POSCatalogSyncCoordinatorProtocol {
     /// Performs a full catalog sync for the specified site
@@ -19,11 +20,14 @@ public protocol POSCatalogSyncCoordinatorProtocol {
 public final class POSCatalogSyncCoordinator: POSCatalogSyncCoordinatorProtocol {
     private let syncService: POSCatalogFullSyncServiceProtocol
     private let settingsStore: SiteSpecificAppSettingsStoreMethodsProtocol
+    private let grdbManager: GRDBManagerProtocol
 
     public init(syncService: POSCatalogFullSyncServiceProtocol,
-                settingsStore: SiteSpecificAppSettingsStoreMethodsProtocol? = nil) {
+                settingsStore: SiteSpecificAppSettingsStoreMethodsProtocol? = nil,
+                grdbManager: GRDBManagerProtocol) {
         self.syncService = syncService
         self.settingsStore = settingsStore ?? SiteSpecificAppSettingsStoreMethods(fileStorage: PListFileStorage())
+        self.grdbManager = grdbManager
     }
 
     public func performFullSync(for siteID: Int64) async throws -> POSCatalog {
@@ -39,6 +43,11 @@ public final class POSCatalogSyncCoordinator: POSCatalogSyncCoordinatorProtocol
     }
 
     public func shouldPerformFullSync(for siteID: Int64, maxAge: TimeInterval) -> Bool {
+        if !siteExistsInDatabase(siteID: siteID) {
+            DDLogInfo("📋 POSCatalogSyncCoordinator: Site \(siteID) not found in database, sync needed")
+            return true
+        }
+
         guard let lastSyncDate = lastFullSyncDate(for: siteID) else {
             DDLogInfo("📋 POSCatalogSyncCoordinator: No previous sync found for site \(siteID), sync needed")
             return true
@@ -61,4 +70,16 @@ public final class POSCatalogSyncCoordinator: POSCatalogSyncCoordinatorProtocol
     private func lastFullSyncDate(for siteID: Int64) -> Date? {
         return settingsStore.getPOSLastFullSyncDate(for: siteID)
     }
+
+    private func siteExistsInDatabase(siteID: Int64) -> Bool {
+        do {
+            return try grdbManager.databaseConnection.read { db in
+                return try PersistedSite.filter(key: siteID).fetchCount(db) > 0
+            }
+        } catch {
+            DDLogError("⛔️ POSCatalogSyncCoordinator: Error checking if site \(siteID) exists in database: \(error)")
+            // On error, assume site exists to avoid unnecessary syncs
+            return true
+        }
+    }
 }

Modules/Tests/YosemiteTests/Tools/POS/POSCatalogSyncCoordinatorTests.swift

@@ -1,20 +1,23 @@
 import Foundation
 import Testing
 @testable import Yosemite
-import Storage
+@testable import Storage
 
 struct POSCatalogSyncCoordinatorTests {
     private let mockSyncService: MockPOSCatalogFullSyncService
     private let mockSettingsStore: MockSiteSpecificAppSettingsStoreMethods
+    private let grdbManager: GRDBManager
     private let sut: POSCatalogSyncCoordinator
     private let sampleSiteID: Int64 = 134
 
-    init() {
+    init() throws {
         self.mockSyncService = MockPOSCatalogFullSyncService()
         self.mockSettingsStore = MockSiteSpecificAppSettingsStoreMethods()
+        self.grdbManager = try GRDBManager()
         self.sut = POSCatalogSyncCoordinator(
             syncService: mockSyncService,
-            settingsStore: mockSettingsStore
+            settingsStore: mockSettingsStore,
+            grdbManager: grdbManager
         )
     }
 
@@ -128,17 +131,55 @@ struct POSCatalogSyncCoordinatorTests {
         #expect(shouldSyncB == true)  // No previous sync
     }
 
-    @Test func shouldPerformFullSync_with_zero_maxAge_always_returns_true() {
+    @Test func shouldPerformFullSync_with_zero_maxAge_always_returns_true() throws {
         // Given - previous sync was just now
         let justNow = Date()
         mockSettingsStore.storedDates[sampleSiteID] = justNow
+        try createSiteInDatabase(siteID: sampleSiteID)
 
         // When - max age is 0 (always sync)
         let shouldSync = sut.shouldPerformFullSync(for: sampleSiteID, maxAge: 0)
 
         // Then
         #expect(shouldSync == true)
     }
+
+    // MARK: - Database Check Tests
+
+    @Test func shouldPerformFullSync_returns_true_when_site_not_in_database() {
+        // Given - site does not exist in database, but has recent sync date
+        let recentSyncDate = Date().addingTimeInterval(-30 * 60) // 30 minutes ago
+        mockSettingsStore.storedDates[sampleSiteID] = recentSyncDate
+        // Note: not creating site in database so it won't exist
+
+        // When - max age is 1 hour (normally wouldn't sync)
+        let shouldSync = sut.shouldPerformFullSync(for: sampleSiteID, maxAge: 60 * 60)
+
+        // Then - should sync because site doesn't exist in database
+        #expect(shouldSync == true)
+    }
+
+    @Test func shouldPerformFullSync_respects_time_when_site_exists_in_database() throws {
+        // Given - site exists in database with recent sync date
+        let recentSyncDate = Date().addingTimeInterval(-30 * 60) // 30 minutes ago
+        mockSettingsStore.storedDates[sampleSiteID] = recentSyncDate
+        try createSiteInDatabase(siteID: sampleSiteID)
+
+        // When - max age is 1 hour
+        let shouldSync = sut.shouldPerformFullSync(for: sampleSiteID, maxAge: 60 * 60)
+
+        // Then - should not sync because site exists and time hasn't passed
+        #expect(shouldSync == false)
+    }
+
+    // MARK: - Helper Methods
+
+    private func createSiteInDatabase(siteID: Int64) throws {
+        try grdbManager.databaseConnection.write { db in
+            let site = PersistedSite(id: siteID)
+            try site.insert(db)
+        }
+    }
 }
 
 // MARK: - Mock Services

WooCommerce/Classes/ViewRelated/MainTabBarController.swift

@@ -799,7 +799,7 @@ private extension MainTabBarController {
             return nil
         }
 
-        return POSCatalogSyncCoordinator(syncService: syncService)
+        return POSCatalogSyncCoordinator(syncService: syncService, grdbManager: ServiceLocator.grdbManager)
     }
 
     func triggerPOSCatalogSyncIfNeeded(for siteID: Int64) async {