Configurable retry on invalid token

Author: valentinEmpy

cloudfoundry-client-reactor/src/main/java/org/cloudfoundry/reactor/ConnectionContext.java

@@ -56,4 +56,9 @@ public interface ConnectionContext {
      */
     Mono<Void> trust(String host, int port);
 
+    /**
+     * The number of retries after an unsuccessful request
+     */
+    Long getInvalidTokenRetries();
+
 }

cloudfoundry-client-reactor/src/main/java/org/cloudfoundry/reactor/_DefaultConnectionContext.java

@@ -146,6 +146,12 @@ public Mono<Void> trust(String host, int port) {
             .orElse(Mono.empty());
     }
 
+    @Override
+    @Value.Default
+    public Long getInvalidTokenRetries() {
+        return 5L;
+    }
+
     /**
      * The hostname of the API root. Typically something like {@code api.run.pivotal.io}.
      */

cloudfoundry-client-reactor/src/main/java/org/cloudfoundry/reactor/util/Operator.java

@@ -206,7 +206,8 @@ private Flux<HttpClientResponseWithBody> invalidateToken(Flux<HttpClientResponse
         private Flux<HttpClientResponseWithBody> processResponse(Flux<HttpClientResponseWithBody> inbound) {
             return inbound
                 .transform(this::invalidateToken)
-                .retry(t -> t instanceof InvalidTokenException)
+                .retry(this.context.getConnectionContext().getInvalidTokenRetries(),
+                    t -> t instanceof InvalidTokenException)
                 .transform(this.context.getErrorPayloadMapper()
                     .orElse(ErrorPayloadMappers.fallback()));
         }