Merge branch 'main' into FFM-12489-add-proxy-support

Author: andybharness

src/main/java/io/harness/cf/client/api/InnerClient.java

@@ -209,7 +209,9 @@ public void onConnected() {
   @Override
   public void onDisconnected(String reason) {
 
-    SdkCodes.warnStreamDisconnected(reason);
+    if (!reason.contains("SDK_SHUTDOWN")) {
+      SdkCodes.warnStreamDisconnected(reason);
+    }
 
     if (!closing && !pollProcessor.isRunning()) {
       log.debug("onDisconnected triggered, starting poller to get latest flags");

src/main/java/io/harness/cf/client/api/PollingProcessor.java

@@ -71,7 +71,7 @@ public CompletableFuture<List<Segment>> retrieveSegments() {
       completableFuture.complete(segments);
     } catch (Throwable e) {
       log.error(
-          "Exception was raised when fetching flags data with the message {}", e.getMessage(), e);
+          "Exception was raised when fetching segments data with the message {}", e.getMessage(), e);
       completableFuture.completeExceptionally(e);
     }
     return completableFuture;
@@ -81,8 +81,7 @@ public void retrieveAll() {
     try {
       CompletableFuture.allOf(retrieveFlags(), retrieveSegments()).join();
     } catch (CompletionException | CancellationException ex) {
-      log.warn("retrieveAll failed: {} - {}", ex.getClass().getSimpleName(), ex.getMessage());
-      log.trace("retrieveAll failed", ex);
+      log.warn("retrieveAll failed: {} - {}", ex.getClass().getSimpleName(), ex.getMessage(), ex);
     }
   }
 

src/main/java/io/harness/cf/client/connector/EventSource.java

@@ -202,13 +202,14 @@ public void onResponse(@NotNull Call call, @NotNull Response response) throws IO
     } catch (Throwable ex) {
       log.warn("SSE Stream aborted: " + getExceptionMsg(ex));
       log.trace("SSE Stream aborted trace", ex);
-      updater.onDisconnected(getExceptionMsg(ex));
+
+      updater.onDisconnected((isShuttingDown.get() ? "SDK_SHUTDOWN: " : "") + getExceptionMsg(ex));
     }
   }
 
   private String getExceptionMsg(Throwable ex) {
     return (ex.getMessage() == null || "null".equals(ex.getMessage()))
-        ? ex.getClass().getSimpleName()
+        ? ex.getClass().getCanonicalName()
         : ex.getMessage();
   }
 

src/main/java/io/harness/cf/client/connector/NewRetryInterceptor.java

@@ -105,7 +105,7 @@ public Response intercept(@NotNull Chain chain) throws IOException {
         limitReached = !retryForever && tryCount >= maxTryCount;
 
         if (isShuttingDown.get()) {
-          log.warn(
+          log.trace(
               "Request attempt {} to {} was not successful, [{}], SDK is shutting down, no retries will be attempted",
               tryCount,
               chain.request().url(),
@@ -147,6 +147,7 @@ int getRetryAfterHeaderInSeconds(Response response) {
     try {
       seconds = Integer.parseInt(retryAfterValue);
     } catch (NumberFormatException ignored) {
+      log.trace("Unable to parse Retry-After header as integer: {}", retryAfterValue);
     }
 
     if (seconds <= 0) {
@@ -156,6 +157,7 @@ int getRetryAfterHeaderInSeconds(Response response) {
           seconds = (int) Duration.between(Instant.now(), then.toInstant()).getSeconds();
         }
       } catch (ParseException ignored) {
+        log.warn("Unable to parse  Retry-After header value: `{}` as integer or date", retryAfterValue);
       }
     }