Allow the operation repo to be paused

* If a createUser fails, let's pause the operation repo. We will still poll, but we won't flush it is paused.
* After a create user request is uncached, update the `originalPushToken` property to be the push token associated with this request. Because, we update the push subscription before sending this request.

Author: nan-li

iOS_SDK/OneSignalSDK/OneSignalOSCore/Source/OSOperationRepo.swift

@@ -43,6 +43,7 @@ public class OSOperationRepo: NSObject {
 
     // TODO: This should come from a config, plist, method, remote params
     var pollIntervalSeconds = 5
+    public var paused = false
 
     /**
      Initilize this Operation Repo. Read from the cache. Executors may not be available by this time.
@@ -108,6 +109,11 @@ public class OSOperationRepo: NSObject {
     }
 
     @objc public func flushDeltaQueue() {
+        guard !paused else {
+            OneSignalLog.onesignalLog(.LL_DEBUG, message: "OSOperationRepo not flushing queue due to being paused")
+            return
+        }
+        
         guard !OneSignalConfigManager.shouldAwaitAppIdAndLogMissingPrivacyConsent(forMethod: nil) else {
             return
         }

iOS_SDK/OneSignalSDK/OneSignalUser/Source/OSUserRequests.swift

@@ -328,17 +328,21 @@ class OSUserExecutor {
                     executePendingRequests()
                 }
             }
+            OSOperationRepo.sharedInstance.paused = false
         } onFailure: { error in
             OneSignalLog.onesignalLog(.LL_ERROR, message: "OSUserExecutor create user request failed with error: \(error.debugDescription)")
             if let nsError = error as? NSError {
                 let responseType = OSNetworkingUtils.getResponseStatusType(nsError.code)
                 if responseType != .retryable {
-                    // Fail, no retry, remove from cache and queue
-                    // TODO: This leaves the SDK in a bad state, revisit why this can happen
-                    removeFromQueue(request)
+                    // A failed create user request would leave the SDK in a bad state
+                    // Don't remove the request from cache and pause the operation repo
+                    // We will retry this request on a new session
+                    OSOperationRepo.sharedInstance.paused = true
+                    request.sentToClient = false
                 }
+            } else {
+                executePendingRequests()
             }
-            executePendingRequests()
         }
     }
 
@@ -600,7 +604,7 @@ class OSRequestCreateUser: OneSignalRequest, OSUserRequest {
 
     var identityModel: OSIdentityModel
     var pushSubscriptionModel: OSSubscriptionModel
-    let originalPushToken: String?
+    var originalPushToken: String?
 
     func prepareForExecution() -> Bool {
         guard let appId = OneSignalConfigManager.getAppId() else {
@@ -617,6 +621,7 @@ class OSRequestCreateUser: OneSignalRequest, OSUserRequest {
     func updatePushSubscriptionModel(_ pushSubscriptionModel: OSSubscriptionModel) {
         self.pushSubscriptionModel = pushSubscriptionModel
         self.parameters?["subscriptions"] = [pushSubscriptionModel.jsonRepresentation()]
+        self.originalPushToken = pushSubscriptionModel.address
     }
 
     init(identityModel: OSIdentityModel, propertiesModel: OSPropertiesModel, pushSubscriptionModel: OSSubscriptionModel, originalPushToken: String?) {