[User Model] Subscription Already Exists

* Updates to support creating a subscription when the subscription already exists for the owner.

Author: brismithers

OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/backend/ISubscriptionBackendService.kt

@@ -14,9 +14,9 @@ interface ISubscriptionBackendService {
      * @param aliasValue The identifier within the [aliasLabel] that identifies the user to retrieve.
      * @param subscription The subscription to create.
      *
-     * @return The ID of the subscription created.
+     * @return The ID of the subscription created.  Or null if the subscription is already part of the current user.
      */
-    suspend fun createSubscription(appId: String, aliasLabel: String, aliasValue: String, subscription: SubscriptionObject): String
+    suspend fun createSubscription(appId: String, aliasLabel: String, aliasValue: String, subscription: SubscriptionObject): String?
 
     /**
      * Update an existing subscription with the properties provided.

OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/backend/impl/SubscriptionBackendService.kt

@@ -11,41 +11,21 @@ internal class SubscriptionBackendService(
     private val _httpClient: IHttpClient
 ) : ISubscriptionBackendService {
 
-    override suspend fun createSubscription(appId: String, aliasLabel: String, aliasValue: String, subscription: SubscriptionObject): String {
+    override suspend fun createSubscription(appId: String, aliasLabel: String, aliasValue: String, subscription: SubscriptionObject): String? {
         val requestJSON = JSONObject()
             .put("subscription", JSONConverter.convertToJSON(subscription))
             .put("retain_previous_owner", true)
 
         val response = _httpClient.post("apps/$appId/users/by/$aliasLabel/$aliasValue/subscriptions", requestJSON)
 
         if (!response.isSuccess) {
-            // TODO: Temporary work around code until resolved on backend
-            if (response.statusCode == 500 && response.payload != null) {
-                val payload = JSONObject(response.payload!!)
-                if (payload.getBoolean("success") || payload.getJSONObject("subscription").has("id")) {
-                    val responseJSON = JSONObject(response.payload!!)
-                    val subscriptionJSON = responseJSON.safeJSONObject("subscription")
-                    if (subscriptionJSON == null || !subscriptionJSON.has("id")) {
-                        throw BackendException(response.statusCode, response.payload)
-                    }
-
-                    return subscriptionJSON.getString("id")
-                }
-            } else if (response.statusCode == 400 && response.payload != null) {
-                val errors = JSONObject(response.payload!!)
-                    .getJSONArray("errors")
-                if (errors.length() > 0 && errors.getJSONObject(0).getString("title").contains("Subscription already belongs to target user")) {
-                    throw BackendException(409, response.payload)
-                }
-            }
-            // TODO: End Temporary work around code until resolved on backend
             throw BackendException(response.statusCode, response.payload)
         }
 
         val responseJSON = JSONObject(response.payload!!)
         val subscriptionJSON = responseJSON.safeJSONObject("subscription")
         if (subscriptionJSON == null || !subscriptionJSON.has("id")) {
-            throw BackendException(response.statusCode, response.payload)
+            return null
         }
 
         return subscriptionJSON.getString("id")

OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/operations/impl/executors/SubscriptionOperationExecutor.kt

@@ -90,17 +90,24 @@ internal class SubscriptionOperationExecutor(
                 IdentityConstants.ONESIGNAL_ID,
                 createOperation.onesignalId,
                 subscription
-            )
+            ) ?: return ExecutionResponse(ExecutionResult.SUCCESS)
 
             // update the subscription model with the new ID, if it's still active.
             val subscriptionModel = _subscriptionModelStore.get(createOperation.subscriptionId)
-            subscriptionModel?.setStringProperty(SubscriptionModel::id.name, backendSubscriptionId, ModelChangeTags.HYDRATE)
+            subscriptionModel?.setStringProperty(
+                SubscriptionModel::id.name,
+                backendSubscriptionId,
+                ModelChangeTags.HYDRATE
+            )
 
             if (_configModelStore.model.pushSubscriptionId == createOperation.subscriptionId) {
                 _configModelStore.model.pushSubscriptionId = backendSubscriptionId
             }
 
-            return ExecutionResponse(ExecutionResult.SUCCESS, mapOf(createOperation.subscriptionId to backendSubscriptionId))
+            return ExecutionResponse(
+                ExecutionResult.SUCCESS,
+                mapOf(createOperation.subscriptionId to backendSubscriptionId)
+            )
         } catch (ex: BackendException) {
             return if (ex.statusCode == 409) {
                 ExecutionResponse(ExecutionResult.FAIL_NORETRY)