Retry-After mapping to internal retryAfterSeconds

jkasten2 · jkasten2 · commit 0e1f4a9590dd · 2024-04-30T18:45:28.000-04:00
Add all the framework to parse Retry-After from the HTTP client layer,
through to the code calling it, to the OperationRepo.
This commit doesn't change any of the logic yet, but gets everything in
place before making behavior changes and adding the tests.
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/common/exceptions/BackendException.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/common/exceptions/BackendException.kt
@@ -12,4 +12,9 @@ class BackendException(
      * The response, if one exists.
      */
     val response: String? = null,
+    /**
+     * Optional Integer value maybe returned from the backend.
+     * The module handing this should delay any future requests by this time.
+     */
+    val retryAfterSeconds: Int? = null,
 ) : Exception()
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/core/internal/backend/impl/ParamsBackendService.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/core/internal/backend/impl/ParamsBackendService.kt
@@ -34,7 +34,7 @@ internal class ParamsBackendService(
         val response = _http.get(paramsUrl, CacheKeys.REMOTE_PARAMS)
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
 
         val responseJson = JSONObject(response.payload!!)
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/core/internal/config/ConfigModel.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/core/internal/config/ConfigModel.kt
@@ -111,6 +111,16 @@ class ConfigModel : Model() {
             setIntProperty(::httpGetTimeout.name, value)
         }
 
+    /**
+     * The fallback Retry-After to use if the header is present, but the server
+     * give us a format we can't parse.
+     */
+    var httpRetryAfterParseFailFallback: Int
+        get() = getIntProperty(::httpRetryAfterParseFailFallback.name) { 60 }
+        set(value) {
+            setIntProperty(::httpRetryAfterParseFailFallback.name, value)
+        }
+
     /**
      * Maximum time in milliseconds a user can spend out of focus before a new session is created.
      */
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/core/internal/http/HttpResponse.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/core/internal/http/HttpResponse.kt
@@ -18,6 +18,11 @@ class HttpResponse(
      * When non-null, the throwable that was thrown during processing.
      */
     val throwable: Throwable? = null,
+    /**
+     * Optional Integer value maybe returned from the backend.
+     * The module handing this should delay any future requests by this time.
+     */
+    val retryAfterSeconds: Int? = null,
 ) {
     /**
      * Whether the response is a successful one.
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/core/internal/http/impl/HttpClient.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/core/internal/http/impl/HttpClient.kt
@@ -171,6 +171,8 @@ internal class HttpClient(
                     // Network request is made from getResponseCode()
                     httpResponse = con.responseCode
 
+                    val retryAfter = retryAfterFromResponse(con)
+
                     when (httpResponse) {
                         HttpURLConnection.HTTP_NOT_MODIFIED -> {
                             val cachedResponse =
@@ -181,7 +183,7 @@ internal class HttpClient(
                             Logging.debug("HttpClient: ${method ?: "GET"} $url - Using Cached response due to 304: " + cachedResponse)
 
                             // TODO: SHOULD RETURN OK INSTEAD OF NOT_MODIFIED TO MAKE TRANSPARENT?
-                            retVal = HttpResponse(httpResponse, cachedResponse)
+                            retVal = HttpResponse(httpResponse, cachedResponse, retryAfterSeconds = retryAfter)
                         }
                         HttpURLConnection.HTTP_ACCEPTED, HttpURLConnection.HTTP_CREATED, HttpURLConnection.HTTP_OK -> {
                             val inputStream = con.inputStream
@@ -208,7 +210,7 @@ internal class HttpClient(
                                 }
                             }
 
-                            retVal = HttpResponse(httpResponse, json)
+                            retVal = HttpResponse(httpResponse, json, retryAfterSeconds = retryAfter)
                         }
                         else -> {
                             Logging.debug("HttpClient: ${method ?: "GET"} $url - FAILED STATUS: $httpResponse")
@@ -229,7 +231,7 @@ internal class HttpClient(
                                 Logging.warn("HttpClient: $method HTTP Code: $httpResponse No response body!")
                             }
 
-                            retVal = HttpResponse(httpResponse, jsonResponse)
+                            retVal = HttpResponse(httpResponse, jsonResponse, retryAfterSeconds = retryAfter)
                         }
                     }
                 } catch (t: Throwable) {
@@ -253,6 +255,22 @@ internal class HttpClient(
         return timeout + 5000
     }
 
+    /**
+     * Reads the HTTP Retry-After from the response.
+     * Only supports number format, not the date format.
+     */
+    private fun retryAfterFromResponse(con: HttpURLConnection): Int? {
+        val retryAfterStr = con.getHeaderField("Retry-After")
+        return if (retryAfterStr != null) {
+            Logging.debug("HttpClient: Response Retry-After: $retryAfterStr")
+            retryAfterStr.toIntOrNull() ?: _configModelStore.model.httpRetryAfterParseFailFallback
+        } else if (con.responseCode == 429) {
+            _configModelStore.model.httpRetryAfterParseFailFallback
+        } else {
+            null
+        }
+    }
+
     companion object {
         private const val OS_API_VERSION = "1"
         private const val OS_ACCEPT_HEADER = "application/vnd.onesignal.v$OS_API_VERSION+json"
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/core/internal/operations/IOperationExecutor.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/core/internal/operations/IOperationExecutor.kt
@@ -37,6 +37,11 @@ class ExecutionResponse(
      * When specified, any operations that should be prepended to the operation repo.
      */
     val operations: List<Operation>? = null,
+    /**
+     * Optional Integer value maybe returned from the backend.
+     * The module handing this should delay any future requests by this time.
+     */
+    val retryAfterSeconds: Int? = null,
 )
 
 enum class ExecutionResult {
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/session/internal/outcomes/impl/OutcomeEventsBackendService.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/session/internal/outcomes/impl/OutcomeEventsBackendService.kt
@@ -49,7 +49,7 @@ internal class OutcomeEventsBackendService(private val _http: IHttpClient) :
         val response = _http.post("outcomes/measure", jsonObject)
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
     }
 }
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/backend/impl/IdentityBackendService.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/backend/impl/IdentityBackendService.kt
@@ -23,7 +23,7 @@ internal class IdentityBackendService(
         val response = _httpClient.patch("apps/$appId/users/by/$aliasLabel/$aliasValue/identity", requestJSONObject)
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
 
         val responseJSON = JSONObject(response.payload!!)
@@ -40,7 +40,7 @@ internal class IdentityBackendService(
         val response = _httpClient.delete("apps/$appId/users/by/$aliasLabel/$aliasValue/identity/$aliasLabelToDelete")
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
     }
 }
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/backend/impl/SubscriptionBackendService.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/backend/impl/SubscriptionBackendService.kt
@@ -24,7 +24,7 @@ internal class SubscriptionBackendService(
         val response = _httpClient.post("apps/$appId/users/by/$aliasLabel/$aliasValue/subscriptions", requestJSON)
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
 
         val responseJSON = JSONObject(response.payload!!)
@@ -48,7 +48,7 @@ internal class SubscriptionBackendService(
         val response = _httpClient.patch("apps/$appId/subscriptions/$subscriptionId", requestJSON)
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
     }
 
@@ -59,7 +59,7 @@ internal class SubscriptionBackendService(
         val response = _httpClient.delete("apps/$appId/subscriptions/$subscriptionId")
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
     }
 
@@ -76,7 +76,7 @@ internal class SubscriptionBackendService(
         val response = _httpClient.patch("apps/$appId/subscriptions/$subscriptionId/owner", requestJSON)
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
     }
 
@@ -87,7 +87,7 @@ internal class SubscriptionBackendService(
         val response = _httpClient.get("apps/$appId/subscriptions/$subscriptionId/user/identity")
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
 
         val responseJSON = JSONObject(response.payload!!)
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/backend/impl/UserBackendService.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/backend/impl/UserBackendService.kt
@@ -39,7 +39,7 @@ internal class UserBackendService(
         val response = _httpClient.post("apps/$appId/users", requestJSON)
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
 
         return JSONConverter.convertToCreateUserResponse(JSONObject(response.payload!!))
@@ -68,7 +68,7 @@ internal class UserBackendService(
         val response = _httpClient.patch("apps/$appId/users/by/$aliasLabel/$aliasValue", jsonObject)
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
     }
 
@@ -80,7 +80,7 @@ internal class UserBackendService(
         val response = _httpClient.get("apps/$appId/users/by/$aliasLabel/$aliasValue")
 
         if (!response.isSuccess) {
-            throw BackendException(response.statusCode, response.payload)
+            throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)
         }
 
         return JSONConverter.convertToCreateUserResponse(JSONObject(response.payload))
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/operations/impl/executors/IdentityOperationExecutor.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/operations/impl/executors/IdentityOperationExecutor.kt
@@ -61,23 +61,27 @@ internal class IdentityOperationExecutor(
 
                 return when (responseType) {
                     NetworkUtils.ResponseStatusType.RETRYABLE ->
-                        ExecutionResponse(ExecutionResult.FAIL_RETRY)
+                        ExecutionResponse(ExecutionResult.FAIL_RETRY, retryAfterSeconds = ex.retryAfterSeconds)
                     NetworkUtils.ResponseStatusType.INVALID ->
                         ExecutionResponse(ExecutionResult.FAIL_NORETRY)
                     NetworkUtils.ResponseStatusType.CONFLICT ->
-                        ExecutionResponse(ExecutionResult.FAIL_CONFLICT)
+                        ExecutionResponse(ExecutionResult.FAIL_CONFLICT, retryAfterSeconds = ex.retryAfterSeconds)
                     NetworkUtils.ResponseStatusType.UNAUTHORIZED ->
-                        ExecutionResponse(ExecutionResult.FAIL_UNAUTHORIZED)
+                        ExecutionResponse(ExecutionResult.FAIL_UNAUTHORIZED, retryAfterSeconds = ex.retryAfterSeconds)
                     NetworkUtils.ResponseStatusType.MISSING -> {
                         if (ex.statusCode == 404 && _newRecordState.isInMissingRetryWindow(lastOperation.onesignalId)) {
-                            return ExecutionResponse(ExecutionResult.FAIL_RETRY)
+                            return ExecutionResponse(ExecutionResult.FAIL_RETRY, retryAfterSeconds = ex.retryAfterSeconds)
                         }
 
                         val rebuildOps = _buildUserService.getRebuildOperationsIfCurrentUser(lastOperation.appId, lastOperation.onesignalId)
                         if (rebuildOps == null) {
                             return ExecutionResponse(ExecutionResult.FAIL_NORETRY)
                         } else {
-                            return ExecutionResponse(ExecutionResult.FAIL_RETRY, operations = rebuildOps)
+                            return ExecutionResponse(
+                                ExecutionResult.FAIL_RETRY,
+                                operations = rebuildOps,
+                                retryAfterSeconds = ex.retryAfterSeconds,
+                            )
                         }
                     }
                 }
@@ -100,17 +104,17 @@ internal class IdentityOperationExecutor(
 
                 return when (responseType) {
                     NetworkUtils.ResponseStatusType.RETRYABLE ->
-                        ExecutionResponse(ExecutionResult.FAIL_RETRY)
+                        ExecutionResponse(ExecutionResult.FAIL_RETRY, retryAfterSeconds = ex.retryAfterSeconds)
                     NetworkUtils.ResponseStatusType.CONFLICT ->
                         // A conflict indicates the alias doesn't exist on the user it's being deleted from. This is good!
                         ExecutionResponse(ExecutionResult.SUCCESS)
                     NetworkUtils.ResponseStatusType.INVALID ->
                         ExecutionResponse(ExecutionResult.FAIL_NORETRY)
                     NetworkUtils.ResponseStatusType.UNAUTHORIZED ->
-                        ExecutionResponse(ExecutionResult.FAIL_UNAUTHORIZED)
+                        ExecutionResponse(ExecutionResult.FAIL_UNAUTHORIZED, retryAfterSeconds = ex.retryAfterSeconds)
                     NetworkUtils.ResponseStatusType.MISSING -> {
                         return if (ex.statusCode == 404 && _newRecordState.isInMissingRetryWindow(lastOperation.onesignalId)) {
-                            ExecutionResponse(ExecutionResult.FAIL_RETRY)
+                            ExecutionResponse(ExecutionResult.FAIL_RETRY, retryAfterSeconds = ex.retryAfterSeconds)
                         } else {
                             // This means either the User or the Alias was already
                             // deleted, either way the end state is the same, the
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/operations/impl/executors/LoginUserOperationExecutor.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/operations/impl/executors/LoginUserOperationExecutor.kt
@@ -211,9 +211,9 @@ internal class LoginUserOperationExecutor(
 
             return when (responseType) {
                 NetworkUtils.ResponseStatusType.RETRYABLE ->
-                    ExecutionResponse(ExecutionResult.FAIL_RETRY)
+                    ExecutionResponse(ExecutionResult.FAIL_RETRY, retryAfterSeconds = ex.retryAfterSeconds)
                 NetworkUtils.ResponseStatusType.UNAUTHORIZED ->
-                    ExecutionResponse(ExecutionResult.FAIL_UNAUTHORIZED)
+                    ExecutionResponse(ExecutionResult.FAIL_UNAUTHORIZED, retryAfterSeconds = ex.retryAfterSeconds)
                 else ->
                     ExecutionResponse(ExecutionResult.FAIL_PAUSE_OPREPO)
             }
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/operations/impl/executors/RefreshUserOperationExecutor.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/operations/impl/executors/RefreshUserOperationExecutor.kt
@@ -133,18 +133,22 @@ internal class RefreshUserOperationExecutor(
 
             return when (responseType) {
                 NetworkUtils.ResponseStatusType.RETRYABLE ->
-                    ExecutionResponse(ExecutionResult.FAIL_RETRY)
+                    ExecutionResponse(ExecutionResult.FAIL_RETRY, retryAfterSeconds = ex.retryAfterSeconds)
                 NetworkUtils.ResponseStatusType.UNAUTHORIZED ->
-                    ExecutionResponse(ExecutionResult.FAIL_UNAUTHORIZED)
+                    ExecutionResponse(ExecutionResult.FAIL_UNAUTHORIZED, retryAfterSeconds = ex.retryAfterSeconds)
                 NetworkUtils.ResponseStatusType.MISSING -> {
                     if (ex.statusCode == 404 && _newRecordState.isInMissingRetryWindow(op.onesignalId)) {
-                        return ExecutionResponse(ExecutionResult.FAIL_RETRY)
+                        return ExecutionResponse(ExecutionResult.FAIL_RETRY, retryAfterSeconds = ex.retryAfterSeconds)
                     }
                     val operations = _buildUserService.getRebuildOperationsIfCurrentUser(op.appId, op.onesignalId)
-                    if (operations == null) {
-                        return ExecutionResponse(ExecutionResult.FAIL_NORETRY)
+                    return if (operations == null) {
+                        ExecutionResponse(ExecutionResult.FAIL_NORETRY)
                     } else {
-                        return ExecutionResponse(ExecutionResult.FAIL_RETRY, operations = operations)
+                        ExecutionResponse(
+                            ExecutionResult.FAIL_RETRY,
+                            operations = operations,
+                            retryAfterSeconds = ex.retryAfterSeconds,
+                        )
                     }
                 }
                 else ->
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/operations/impl/executors/SubscriptionOperationExecutor.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/operations/impl/executors/SubscriptionOperationExecutor.kt
diff --git a/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/operations/impl/executors/UpdateUserOperationExecutor.kt b/OneSignalSDK/onesignal/core/src/main/java/com/onesignal/user/internal/operations/impl/executors/UpdateUserOperationExecutor.kt
diff --git a/OneSignalSDK/onesignal/core/src/test/java/com/onesignal/core/internal/http/HttpClientTests.kt b/OneSignalSDK/onesignal/core/src/test/java/com/onesignal/core/internal/http/HttpClientTests.kt
diff --git a/OneSignalSDK/onesignal/in-app-messages/src/main/java/com/onesignal/inAppMessages/internal/backend/impl/InAppBackendService.kt b/OneSignalSDK/onesignal/in-app-messages/src/main/java/com/onesignal/inAppMessages/internal/backend/impl/InAppBackendService.kt
diff --git a/OneSignalSDK/onesignal/notifications/src/main/java/com/onesignal/notifications/internal/backend/impl/NotificationBackendService.kt b/OneSignalSDK/onesignal/notifications/src/main/java/com/onesignal/notifications/internal/backend/impl/NotificationBackendService.kt

Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ internal class ParamsBackendService(`
`34`	`34`	`val response = _http.get(paramsUrl, CacheKeys.REMOTE_PARAMS)`
`35`	`35`
`36`	`36`	`if (!response.isSuccess) {`
`37`		`- throw BackendException(response.statusCode, response.payload)`
	`37`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`38`	`38`	`}`
`39`	`39`
`40`	`40`	`val responseJson = JSONObject(response.payload!!)`
Original file line number	Diff line number	Diff line change
`@@ -49,7 +49,7 @@ internal class OutcomeEventsBackendService(private val _http: IHttpClient) :`
`49`	`49`	`val response = _http.post("outcomes/measure", jsonObject)`
`50`	`50`
`51`	`51`	`if (!response.isSuccess) {`
`52`		`- throw BackendException(response.statusCode, response.payload)`
	`52`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`53`	`53`	`}`
`54`	`54`	`}`
`55`	`55`	`}`
Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,7 @@ internal class IdentityBackendService(`
`23`	`23`	`val response = _httpClient.patch("apps/$appId/users/by/$aliasLabel/$aliasValue/identity", requestJSONObject)`
`24`	`24`
`25`	`25`	`if (!response.isSuccess) {`
`26`		`- throw BackendException(response.statusCode, response.payload)`
	`26`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`27`	`27`	`}`
`28`	`28`
`29`	`29`	`val responseJSON = JSONObject(response.payload!!)`
`@@ -40,7 +40,7 @@ internal class IdentityBackendService(`
`40`	`40`	`val response = _httpClient.delete("apps/$appId/users/by/$aliasLabel/$aliasValue/identity/$aliasLabelToDelete")`
`41`	`41`
`42`	`42`	`if (!response.isSuccess) {`
`43`		`- throw BackendException(response.statusCode, response.payload)`
	`43`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`44`	`44`	`}`
`45`	`45`	`}`
`46`	`46`	`}`
Original file line number	Diff line number	Diff line change
`@@ -24,7 +24,7 @@ internal class SubscriptionBackendService(`
`24`	`24`	`val response = _httpClient.post("apps/$appId/users/by/$aliasLabel/$aliasValue/subscriptions", requestJSON)`
`25`	`25`
`26`	`26`	`if (!response.isSuccess) {`
`27`		`- throw BackendException(response.statusCode, response.payload)`
	`27`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`28`	`28`	`}`
`29`	`29`
`30`	`30`	`val responseJSON = JSONObject(response.payload!!)`
`@@ -48,7 +48,7 @@ internal class SubscriptionBackendService(`
`48`	`48`	`val response = _httpClient.patch("apps/$appId/subscriptions/$subscriptionId", requestJSON)`
`49`	`49`
`50`	`50`	`if (!response.isSuccess) {`
`51`		`- throw BackendException(response.statusCode, response.payload)`
	`51`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`52`	`52`	`}`
`53`	`53`	`}`
`54`	`54`
`@@ -59,7 +59,7 @@ internal class SubscriptionBackendService(`
`59`	`59`	`val response = _httpClient.delete("apps/$appId/subscriptions/$subscriptionId")`
`60`	`60`
`61`	`61`	`if (!response.isSuccess) {`
`62`		`- throw BackendException(response.statusCode, response.payload)`
	`62`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`63`	`63`	`}`
`64`	`64`	`}`
`65`	`65`
`@@ -76,7 +76,7 @@ internal class SubscriptionBackendService(`
`76`	`76`	`val response = _httpClient.patch("apps/$appId/subscriptions/$subscriptionId/owner", requestJSON)`
`77`	`77`
`78`	`78`	`if (!response.isSuccess) {`
`79`		`- throw BackendException(response.statusCode, response.payload)`
	`79`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`80`	`80`	`}`
`81`	`81`	`}`
`82`	`82`
`@@ -87,7 +87,7 @@ internal class SubscriptionBackendService(`
`87`	`87`	`val response = _httpClient.get("apps/$appId/subscriptions/$subscriptionId/user/identity")`
`88`	`88`
`89`	`89`	`if (!response.isSuccess) {`
`90`		`- throw BackendException(response.statusCode, response.payload)`
	`90`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`91`	`91`	`}`
`92`	`92`
`93`	`93`	`val responseJSON = JSONObject(response.payload!!)`
Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,7 @@ internal class UserBackendService(`
`39`	`39`	`val response = _httpClient.post("apps/$appId/users", requestJSON)`
`40`	`40`
`41`	`41`	`if (!response.isSuccess) {`
`42`		`- throw BackendException(response.statusCode, response.payload)`
	`42`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`43`	`43`	`}`
`44`	`44`
`45`	`45`	`return JSONConverter.convertToCreateUserResponse(JSONObject(response.payload!!))`
`@@ -68,7 +68,7 @@ internal class UserBackendService(`
`68`	`68`	`val response = _httpClient.patch("apps/$appId/users/by/$aliasLabel/$aliasValue", jsonObject)`
`69`	`69`
`70`	`70`	`if (!response.isSuccess) {`
`71`		`- throw BackendException(response.statusCode, response.payload)`
	`71`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`72`	`72`	`}`
`73`	`73`	`}`
`74`	`74`
`@@ -80,7 +80,7 @@ internal class UserBackendService(`
`80`	`80`	`val response = _httpClient.get("apps/$appId/users/by/$aliasLabel/$aliasValue")`
`81`	`81`
`82`	`82`	`if (!response.isSuccess) {`
`83`		`- throw BackendException(response.statusCode, response.payload)`
	`83`	`+ throw BackendException(response.statusCode, response.payload, response.retryAfterSeconds)`
`84`	`84`	`}`
`85`	`85`
`86`	`86`	`return JSONConverter.convertToCreateUserResponse(JSONObject(response.payload))`