Catch deleteAllTasks exception

Author: tapashmajumder

swift-sdk/Internal/HealthMonitor.swift

@@ -86,6 +86,11 @@ class HealthMonitor {
         onError()
     }
 
+    func onDeleteAllTasksError() {
+        ITBInfo()
+        onError()
+    }
+    
     private func onError() {
         errored = true
         delegate?.onDBError()

swift-sdk/Internal/IterableTaskScheduler.swift

@@ -40,9 +40,14 @@ class IterableTaskScheduler {
         return Result.success(taskId)
     }
 
-    func deleteAllTasks() throws {
+    func deleteAllTasks() {
         ITBInfo()
-        try persistenceContextProvider.mainQueueContext().deleteAllTasks()
+        do {
+            try persistenceContextProvider.mainQueueContext().deleteAllTasks()
+        } catch let error {
+            ITBError("deleteAllTasks: \(error.localizedDescription)")
+            healthMonitor.onDeleteAllTasksError()
+        }
     }
 
     private let persistenceContextProvider: IterablePersistenceContextProvider

swift-sdk/Internal/OfflineRequestProcessor.swift

@@ -244,9 +244,9 @@ struct OfflineRequestProcessor: RequestProcessorProtocol {
                                    identifier: #function)
     }
 
-    func deleteAllTasks() throws {
+    func deleteAllTasks() {
         ITBInfo()
-        try taskScheduler.deleteAllTasks()
+        taskScheduler.deleteAllTasks()
     }
 
     private let apiKey: String

swift-sdk/Internal/RequestHandler.swift

@@ -250,7 +250,7 @@ class RequestHandler: RequestHandlerProtocol {
 
     func handleLogout() throws {
         if offlineMode {
-            try offlineProcessor?.deleteAllTasks()
+            offlineProcessor?.deleteAllTasks()
         }
     }
 

tests/offline-events-tests/HealthMonitorTests.swift

@@ -165,6 +165,24 @@ class HealthMonitorTests: XCTestCase {
         XCTAssertFalse(internalAPI.requestHandler.offlineMode)
     }
 
+    func testDeleteAllTasksException() throws {
+        let networkSession = MockNetworkSession(statusCode: 200)
+        let localStorage = MockLocalStorage()
+        localStorage.email = "[email protected]"
+        localStorage.offlineModeBeta = true
+        var input = MockPersistenceContext.Input()
+        input.deleteAllTasksCallback = {
+            throw IterableDBError.general("error deleting all tasks")
+        }
+        let context = MockPersistenceContext(input: input)
+        let internalAPI = InternalIterableAPI.initializeForTesting(networkSession: networkSession,
+                                                                   localStorage: localStorage,
+                                                                   persistenceContextProvider: MockPersistenceContextProvider(context: context))
+        XCTAssertTrue(internalAPI.requestHandler.offlineMode)
+        internalAPI.email = "[email protected]"
+        XCTAssertFalse(internalAPI.requestHandler.offlineMode)
+    }
+
     private let dateProvider = MockDateProvider()
 
     private lazy var persistenceProvider: IterablePersistenceContextProvider = {