Identity Model Repo listens for JWT changes

* As a refresher, the Identity Model Repo holds all Identity Models present during an app run, which can include past users that have pending updates, while the Identity Model Store contains only the current user's Identity Model.
* Let the OSIdentityModelRepo be the listener for changes to JWT token updates, and it needs to pass on that information to the User Manager who manages the JWT Config and fires other listeners of token changes.

Author: nan-li

iOS_SDK/OneSignalSDK/OneSignalCore/Source/OneSignalCommonDefines.h

@@ -327,6 +327,7 @@ typedef enum {GET, POST, HEAD, PUT, DELETE, OPTIONS, CONNECT, TRACE, PATCH} HTTP
 #define OS_PUSH_SUBSCRIPTION_MODEL_STORE_KEY                                @"OS_PUSH_SUBSCRIPTION_MODEL_STORE_KEY"
 #define OS_SUBSCRIPTION_MODEL_STORE_KEY                                     @"OS_SUBSCRIPTION_MODEL_STORE_KEY"
 #define OS_MODEL_STORE_LISTENER_POSTFIX                                     @"_LISTENER"
+#define OS_IDENTITY_MODEL_REPO                                              @"OS_IDENTITY_MODEL_REPO"
 
 // Deltas
 #define OS_ADD_ALIAS_DELTA                                                  @"OS_ADD_ALIAS_DELTA"

iOS_SDK/OneSignalSDK/OneSignalUser/Source/OSIdentityModelRepo.swift

@@ -26,6 +26,7 @@
  */
 
 import Foundation
+import OneSignalCore
 import OneSignalOSCore
 
 /**
@@ -40,11 +41,13 @@ import OneSignalOSCore
  */
 class OSIdentityModelRepo {
     let lock = NSLock()
-    var models: [String: OSIdentityModel] = [:]
+    private var models: [String: OSIdentityModel] = [:]
 
     func add(model: OSIdentityModel) {
         lock.withLock {
             models[model.modelId] = model
+            // listen for changes to model's JWT Token
+            model.changeNotifier.subscribe(self, key: OS_IDENTITY_MODEL_REPO)
         }
     }
 
@@ -54,6 +57,55 @@ class OSIdentityModelRepo {
         }
     }
 
+    func get(externalId: String) -> OSIdentityModel? {
+        lock.withLock {
+            for model in models.values {
+                if model.externalId == externalId {
+                    return model
+                }
+            }
+            return nil
+        }
+    }
+
+    /**
+     There may be multiple Identity Models with the same external ID, so update them all.
+     This can be optimized in the future to re-use an Identity Model if multiple logins are made for the same user.
+     */
+    func updateJwtToken(externalId: String, token: String) {
+        var found = false
+        lock.withLock {
+            for model in models.values {
+                if model.externalId == externalId {
+                    model.jwtBearerToken = token
+                    found = true
+                }
+            }
+        }
+        if !found {
+            OneSignalLog.onesignalLog(ONE_S_LOG_LEVEL.LL_ERROR, message: "Update User JWT called for external ID \(externalId) that does not exist")
+        }
+    }
+}
+
+extension OSIdentityModelRepo: OSModelChangedHandler {
+    /**
+     Listen for updates to the JWT Token and notify the User Manager of this change.
+     */
+    public func onModelUpdated(args: OSModelChangedArgs, hydrating: Bool) {
+        guard
+            args.property == OS_JWT_BEARER_TOKEN,
+            let model = args.model as? OSIdentityModel,
+            let externalId = model.externalId,
+            let token = args.newValue as? String
+        else {
+            return
+        }
+        print("❌ OSIdentityModelRepo onModelUpdated for \(externalId): \(token)")
+        OneSignalUserManagerImpl.sharedInstance.jwtConfig.onJwtTokenChanged(externalId: externalId, to: token)
+    }
+}
+
 extension OSIdentityModelRepo: OSLoggable {
     func logSelf() {
         print("💛 OSIdentityModelRepo has the following models: ")