Merge pull request #433 from Iterable/feature/mob-2177-delete-all-tasks

[MOB-2177] - Delete all tasks on logout.

Author: tapashmajumder

swift-sdk/Internal/IterableAPIInternal.swift

@@ -444,6 +444,8 @@ final class IterableAPIInternal: NSObject, PushTrackerProtocol, AuthProvider {
         storeIdentifierData()
 
         _ = inAppManager.reset()
+        
+        try? requestHandler.handleLogout()
     }
 
     private func loginNewUser() {

swift-sdk/Internal/IterableTaskScheduler.swift

@@ -38,6 +38,11 @@ class IterableTaskScheduler {
         return Result.success(taskId)
     }
 
+    func deleteAllTasks() throws {
+        ITBInfo()
+        try persistenceContextProvider.mainQueueContext().deleteAllTasks()
+    }
+    
     private let persistenceContextProvider: IterablePersistenceContextProvider
     private let notificationCenter: NotificationCenterProtocol
     private let dateProvider: DateProviderProtocol

swift-sdk/Internal/LegacyRequestHandler.swift

@@ -245,6 +245,9 @@ struct LegacyRequestHandler: RequestHandlerProtocol {
                        forResult: apiClient.track(inAppClick: messageId, clickedUrl: clickedUrl))
     }
 
+    func handleLogout() {
+    }
+
     private let apiClient: ApiClientProtocol
     private weak var authManager: IterableInternalAuthManagerProtocol?
 

swift-sdk/Internal/OfflineRequestProcessor.swift

@@ -245,6 +245,11 @@ struct OfflineRequestProcessor: RequestProcessorProtocol {
                                    identifier: #function)
     }
 
+    func deleteAllTasks() throws {
+        ITBInfo()
+        try taskScheduler.deleteAllTasks()
+    }
+    
     private let apiKey: String
     private weak var authProvider: AuthProvider?
     private weak var authManager: IterableInternalAuthManagerProtocol?

swift-sdk/Internal/RequestHandler.swift

@@ -252,6 +252,12 @@ class RequestHandler: RequestHandlerProtocol {
                                                  onFailure: onFailure)
     }
 
+    func handleLogout() throws {
+        if strategy.chooseOfflineProcessor {
+            try offlineProcessor?.deleteAllTasks()
+        }
+    }
+
     private let onlineCreator: () -> OnlineRequestProcessor
     private let offlineCreator: () -> OfflineRequestProcessor?
 

swift-sdk/Internal/RequestHandlerProtocol.swift

@@ -108,6 +108,8 @@ protocol RequestHandlerProtocol {
                       source: InAppDeleteSource?,
                       onSuccess: OnSuccessHandler?,
                       onFailure: OnFailureHandler?) -> Future<SendRequestValue, SendRequestError>
+
+    func handleLogout() throws
 
     // MARK: DEPRECATED
 

tests/offline-events-tests/RequestHandlerTests.swift

@@ -592,6 +592,25 @@ class RequestHandlerTests: XCTestCase {
         wait(for: [expectations.successExpectation, expectations.failureExpectation], timeout: 15.0)
     }
 
+    func testDeleteAllTasksOnLogout() throws {
+        let config = IterableConfig()
+        config.enableOfflineMode = true
+        let internalApi = IterableAPIInternal.initializeForTesting(config: config)
+        internalApi.email = "[email protected]"
+        
+        let taskId = IterableUtil.generateUUID()
+        try persistenceContextProvider.mainQueueContext().create(task: IterableTask(id: taskId,
+                                                                             type: .apiCall,
+                                                                             scheduledAt: Date(),
+                                                                             data: nil,
+                                                                             requestedAt: Date()))
+        try persistenceContextProvider.mainQueueContext().save()
+
+        internalApi.logoutUser()
+        
+        XCTAssertEqual(try persistenceContextProvider.mainQueueContext().findAllTasks().count, 0)
+    }
+    
     private func handleRequestWithSuccessAndFailure(requestGenerator: (RequestHandlerProtocol) -> Future<SendRequestValue, SendRequestError>,
                                                      path: String,
                                                      bodyDict: [AnyHashable: Any]) throws {