Merge pull request #469 from Iterable/tapash/mob-2532-add-offline-test

[MOB-2532] - Feature flags tests for offline processor

Author: tapashmajumder

tests/offline-events-tests/RequestHandlerTests.swift

@@ -714,6 +714,99 @@ class RequestHandlerTests: XCTestCase {
         wait(for: [expectation1], timeout: testExpectationTimeout)
     }
 
+    func testNoRemoteConfigurationUsesOnline() throws {
+        let expectation1 = expectation(description: "getRemoteConfiguration is called")
+        var mapper = [String: Data?]()
+        mapper["getRemoteConfiguration"] = nil
+        let networkSession = MockNetworkSession(statusCode: 200, urlPatternDataMapping: mapper)
+        networkSession.requestCallback = { request in
+            if request.url!.absoluteString.contains(Const.Path.getRemoteConfiguration) {
+                expectation1.fulfill()
+            }
+        }
+        let localStorage = MockLocalStorage()
+        localStorage.email = "[email protected]"
+        let internalAPI = InternalIterableAPI.initializeForTesting(networkSession: networkSession, localStorage: localStorage)
+        wait(for: [expectation1], timeout: testExpectationTimeout)
+
+        let expectation2 = expectation(description: #function)
+        networkSession.requestCallback = { request in
+            if request.url!.absoluteString.contains("track") {
+                let processor = request.allHTTPHeaderFields?[JsonKey.Header.requestProcessor]!
+                XCTAssertEqual(processor, Const.ProcessorTypeName.online)
+                expectation2.fulfill()
+            }
+        }
+        internalAPI.track("myEvent")
+        wait(for: [expectation2], timeout: testExpectationTimeout)
+    }
+
+    func testDefaultUsesOnlineMode() throws {
+        let expectation1 = expectation(description: "getRemoteConfiguration is called")
+        let remoteConfigurationData = """
+        {
+            "offlineMode": false,
+            "offlineModeBeta": false
+        }
+        """.data(using: .utf8)!
+        var mapper = [String: Data?]()
+        mapper["getRemoteConfiguration"] = remoteConfigurationData
+        let networkSession = MockNetworkSession(statusCode: 200, urlPatternDataMapping: mapper)
+        networkSession.requestCallback = { request in
+            if request.url!.absoluteString.contains(Const.Path.getRemoteConfiguration) {
+                expectation1.fulfill()
+            }
+        }
+        let localStorage = MockLocalStorage()
+        localStorage.email = "[email protected]"
+        let internalAPI = InternalIterableAPI.initializeForTesting(networkSession: networkSession, localStorage: localStorage)
+        wait(for: [expectation1], timeout: testExpectationTimeout)
+
+        let expectation2 = expectation(description: #function)
+        networkSession.requestCallback = { request in
+            if request.url!.absoluteString.contains("track") {
+                let processor = request.allHTTPHeaderFields?[JsonKey.Header.requestProcessor]!
+                XCTAssertEqual(processor, Const.ProcessorTypeName.online)
+                expectation2.fulfill()
+            }
+        }
+        internalAPI.track("myEvent")
+        wait(for: [expectation2], timeout: testExpectationTimeout)
+    }
+
+    func testFeatureFlagTurnOnOfflineMode() throws {
+        let expectation1 = expectation(description: "getRemoteConfiguration is called")
+        let remoteConfigurationData = """
+        {
+            "offlineMode": false,
+            "offlineModeBeta": true
+        }
+        """.data(using: .utf8)!
+        var mapper = [String: Data?]()
+        mapper["getRemoteConfiguration"] = remoteConfigurationData
+        let networkSession = MockNetworkSession(statusCode: 200, urlPatternDataMapping: mapper)
+        networkSession.requestCallback = { request in
+            if request.url!.absoluteString.contains(Const.Path.getRemoteConfiguration) {
+                expectation1.fulfill()
+            }
+        }
+        let localStorage = MockLocalStorage()
+        localStorage.email = "[email protected]"
+        let internalAPI = InternalIterableAPI.initializeForTesting(networkSession: networkSession, localStorage: localStorage)
+        wait(for: [expectation1], timeout: testExpectationTimeout)
+
+        let expectation2 = expectation(description: #function)
+        networkSession.requestCallback = { request in
+            if request.url!.absoluteString.contains("track") {
+                let processor = request.allHTTPHeaderFields?[JsonKey.Header.requestProcessor]!
+                XCTAssertEqual(processor, Const.ProcessorTypeName.offline)
+                expectation2.fulfill()
+            }
+        }
+        internalAPI.track("myEvent")
+        wait(for: [expectation2], timeout: testExpectationTimeout)
+    }
+
     private func handleRequestWithSuccessAndFailure(requestGenerator: (RequestHandlerProtocol) -> Future<SendRequestValue, SendRequestError>,
                                                      path: String,
                                                      bodyDict: [AnyHashable: Any]) throws {