[Devtooling-1090] Added logging for retries

resources/sdk/pureclouddotnet/templates/ApiClient.mustache

@@ -364,7 +364,7 @@ namespace {{packageName}}.Client
                 }
             }
 
-            if ((int)response.StatusCode < 200 || (int)response.StatusCode >= 300)
+            if ((int)response.StatusCode < 200 || (int)response.StatusCode >= 300) {
                 Configuration.Logger.Error(method.ToString(), url, postBody, response.Content, (int)response.StatusCode, headerParams, response.Headers?
                                                              .GroupBy(header => header?.Name)
                                                              .Select(header => new
@@ -373,7 +373,10 @@ namespace {{packageName}}.Client
                                                             Value = header.Select(x => x?.Value)?.ToList()
                                                             }).ToDictionary(header => header?.Name?.ToString(), header => String.Join(", ", header?.Value?.ToArray())) 
                                                         ?? new Dictionary<string, string>());
-
+                if ((int)response.StatusCode == 429) {
+                    Console.WriteLine("Max number of retries exceeded");
+                }
+            }
 
             return (Object) response;
         }
@@ -1128,6 +1131,7 @@ namespace {{packageName}}.Client
             {
                 try
                 {
+                    Console.WriteLine("Rate limit encountered. Retry the request in [{0}] seconds", retryAfterMs/1000);
                     Thread.Sleep((int) retryAfterMs);
                 }
                 catch (ThreadInterruptedException)

resources/sdk/pureclouddotnet/templates/test-ApiClientTests.mustache

@@ -109,6 +109,36 @@ public class ApiClientTests
         stopwatch.Stop();
     }
 
+    [Test]
+    public void InvokeTestWith_429_And_Max_Retries_Exceeded()
+    {
+        var retryConfig = new ApiClient.RetryConfiguration
+        {
+            MaxRetryTimeSec = 6,
+            RetryAfterDefaultMs = 100,
+            RetryMax = 0
+        };
+
+        var mockHttp = new MockHttpMessageHandler();
+        mockHttp.When("*").Respond((req) =>
+        {
+            var response = new HttpResponseMessage((System.Net.HttpStatusCode)429);
+            response.Headers.Add("Retry-After", "3");
+            return Task.FromResult(response);
+        });
+
+        var apiClient = new ApiClient(new {{packageName}}.Client.Configuration());
+        apiClient.RetryConfig = retryConfig;
+        apiClient.ClientOptions.HttpMessageHandler = mockHttp;
+
+        stopwatch = Stopwatch.StartNew();
+        RestResponse user = (RestResponse)apiClient.CallApi(path, method, queryParams, postBody, headerParams, formParams, fileParams, pathParams, contentType);
+
+        Assert.IsTrue(stopwatch.ElapsedMilliseconds >= 3000 && stopwatch.ElapsedMilliseconds < 3100, "Since RetryMax is 0, after one retry exception is thrown");
+        Assert.AreEqual(429, (int)user.StatusCode);
+        stopwatch.Stop();
+    }
+
     [Test]
     public void InvokeTestWith_502()
     {

resources/sdk/purecloudgo/templates/apiclient.mustache

@@ -6,6 +6,7 @@ import (
     "crypto/tls"
 	"encoding/json"
 	"fmt"
+	"log"
 	"io/ioutil"
 	"net/http"
 	"net/url"
@@ -48,6 +49,7 @@ func NewAPIClient(c *Configuration) APIClient {
 	client := retryablehttp.NewClient()
 	client.Logger = nil
 	client.HTTPClient.Timeout = timeout
+	client.Backoff = customBackoff
 
 	return APIClient{
 		client:        *client,
@@ -219,8 +221,13 @@ func (c *APIClient) CallAPI(path string, method string,
 		}
 	}
 
-
-		c.client.CheckRetry = DefaultRetryPolicy
+		c.client.CheckRetry = func(ctx context.Context, resp *http.Response, err error) (bool, error) {
+			retry, err := DefaultRetryPolicy(ctx, resp, err)
+			if !retry && resp.StatusCode == http.StatusTooManyRequests {
+				log.Println("Max Retries Exceeded")
+			}
+			return retry, err
+		}
 
 	if c.configuration.ProxyConfiguration != nil {
                 var proxyUrl *url.URL
@@ -472,3 +479,11 @@ func getFieldName(t reflect.Type, field string) string {
 func toTime(o interface{}) *time.Time {
 	return o.(*time.Time)
 }
+
+func customBackoff(min, max time.Duration, attemptNumber int, resp *http.Response) time.Duration {
+	sleep := retryablehttp.DefaultBackoff(min, max, attemptNumber, resp)
+	if resp != nil && resp.StatusCode == http.StatusTooManyRequests {
+		log.Printf("Rate limit encountered. Retry the request in [%.0f] seconds\n", sleep.Seconds())
+	}
+	return sleep
+}

resources/sdk/purecloudpython/templates/rest.mustache

@@ -98,7 +98,7 @@ class RESTClientObject(object):
         proxy_username = Configuration().proxy_username
         proxy_password = Configuration().proxy_password
 
-        retries = urllib3.util.Retry()
+        retries = CustomRetry()
         retries.allowed_methods = {'DELETE', 'GET', 'HEAD', 'OPTIONS', 'POST', 'PUT', 'PATCH', 'TRACE'}
         # https pool manager
         if proxy:
@@ -270,3 +270,19 @@ class ApiException(Exception):
             error_message += "HTTP response body: {0}\n".format(self.body)
 
         return error_message
+
+class CustomRetry(urllib3.util.Retry):
+    def __init__(self, total=0, connect=None, read=None, redirect=None, status=None, other=None, backoff_factor=0):
+        super().__init__(total=total, connect=connect, read=read, redirect=redirect, status=status, other=other, backoff_factor=backoff_factor)
+
+    def sleep(self, response=None):
+        sleep_duration = self.get_backoff_time()
+        print(f"Rate limit encountered. Retry the request in [{sleep_duration}] seconds")
+        super().sleep(response)
+
+    def increment(self, method=None, url=None, repsonse=None, error=None, _pool=None, _stacktrace=None):
+        retry = super.increment(method, url, repsonse, error, _pool, _stacktrace)
+        if retry.is_exhausted():
+            print(f"Max number of retries exceeded: {e}")
+
+        return retry

resources/sdk/webmessagingjava/templates/ApiClient.mustache

@@ -493,7 +493,7 @@ public class ApiClient implements AutoCloseable {
             return new ApiResponseWrapper<>(statusCode, reasonPhrase, headers, body, entity);
         }
         else {
-            String message = "error";
+            String message = (statusCode == 429) ? "Max number of retries exceeded" : "error";
             String body = response.readBody();
             throw new WebMessagingException(statusCode, message, headers, body);
         }