Add additional synchronized blocks to get methods

Author: jennantilla

OneSignalSDK/onesignal/core/src/main/java/com/onesignal/common/modeling/Model.kt

@@ -51,12 +51,15 @@ open class Model(
      * specified, must also specify [_parentModel]
      */
     private val _parentProperty: String? = null,
+    private val modelSynchronizationLock: Any = Any(),
 ) : IEventNotifier<IModelChangedHandler> {
     /**
      * A unique identifier for this model.
      */
     var id: String
-        get() = getStringProperty(::id.name)
+        get() = synchronized(modelSynchronizationLock) {
+            getStringProperty(::id.name)
+        }
         set(value) {
             setStringProperty(::id.name, value)
         }
@@ -123,7 +126,8 @@ open class Model(
         id: String?,
         model: Model,
     ) {
-        data.clear()
+        val newData = mutableMapOf<String, Any?>()
+
         for (item in model.data) {
             if (item.value is Model) {
                 val childModel = item.value as Model
@@ -138,7 +142,7 @@ open class Model(
             newData[::id.name] = id
         }
 
-        synchronized(initializationLock) {
+        synchronized(modelSynchronizationLock) {
             data.clear()
             data.putAll(newData)
         }
@@ -665,7 +669,7 @@ open class Model(
      * @return The resulting [JSONObject].
      */
     fun toJSON(): JSONObject {
-        synchronized(initializationLock) {
+        synchronized(modelSynchronizationLock) {
             val jsonObject = JSONObject()
             for (kvp in data) {
                 when (val value = kvp.value) {
@@ -697,5 +701,7 @@ open class Model(
     override fun unsubscribe(handler: IModelChangedHandler) = changeNotifier.unsubscribe(handler)
 
     override val hasSubscribers: Boolean
-        get() = changeNotifier.hasSubscribers
+        get() = synchronized(modelSynchronizationLock) {
+            changeNotifier.hasSubscribers
+        }
 }

OneSignalSDK/onesignal/core/src/main/java/com/onesignal/common/modeling/ModelStore.kt

@@ -68,7 +68,9 @@ abstract class ModelStore<TModel>(
     }
 
     override fun get(id: String): TModel? {
-        return models.firstOrNull { it.id == id }
+        synchronized(models) {
+            return models.firstOrNull { it.id == id }
+        }
     }
 
     override fun remove(
@@ -173,5 +175,9 @@ abstract class ModelStore<TModel>(
     override fun unsubscribe(handler: IModelStoreChangeHandler<TModel>) = changeSubscription.unsubscribe(handler)
 
     override val hasSubscribers: Boolean
-        get() = changeSubscription.hasSubscribers
+        get() {
+            synchronized(changeSubscription) {
+                return changeSubscription.hasSubscribers
+            }
+        }
 }