formatting fixes

Author: andybharness

settings.gradle

@@ -4,7 +4,7 @@ dependencyResolutionManagement {
     versionCatalogs {
         libs {
             // main sdk version
-            version('sdk', '1.8.3');
+            version('sdk', '1.9.0-SNAPSHOT');
 
             // sdk deps
             version('okhttp3', '4.12.0')

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

@@ -71,7 +71,9 @@ public CompletableFuture<List<Segment>> retrieveSegments() {
       completableFuture.complete(segments);
     } catch (Throwable e) {
       log.error(
-          "Exception was raised when fetching segments 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;

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

@@ -1,45 +1,45 @@
 package io.harness.cf.client.connector;
 
-import javax.net.SocketFactory;
 import java.io.IOException;
 import java.net.InetAddress;
 import java.net.Socket;
+import javax.net.SocketFactory;
 
 final class DelegatingSocketFactory extends SocketFactory {
-    private final SocketFactory delegate;
-
-    public DelegatingSocketFactory(SocketFactory delegate) {
-        this.delegate = delegate;
-    }
-
-    @Override
-    public Socket createSocket() throws IOException {
-        return configureSocket(delegate.createSocket());
-    }
-
-    @Override
-    public Socket createSocket(String host, int port) throws IOException {
-        return configureSocket(delegate.createSocket(host, port));
-    }
-
-    @Override
-    public Socket createSocket(String host, int port, InetAddress localAddress,
-                               int localPort) throws IOException {
-        return configureSocket(delegate.createSocket(host, port, localAddress, localPort));
-    }
-
-    @Override
-    public Socket createSocket(InetAddress host, int port) throws IOException {
-        return configureSocket(delegate.createSocket(host, port));
-    }
-
-    @Override
-    public Socket createSocket(InetAddress host, int port, InetAddress localAddress,
-                               int localPort) throws IOException {
-        return configureSocket(delegate.createSocket(host, port, localAddress, localPort));
-    }
-
-    Socket configureSocket(Socket socket) {
-        return socket;
-    }
-}
+  private final SocketFactory delegate;
+
+  public DelegatingSocketFactory(SocketFactory delegate) {
+    this.delegate = delegate;
+  }
+
+  @Override
+  public Socket createSocket() throws IOException {
+    return configureSocket(delegate.createSocket());
+  }
+
+  @Override
+  public Socket createSocket(String host, int port) throws IOException {
+    return configureSocket(delegate.createSocket(host, port));
+  }
+
+  @Override
+  public Socket createSocket(String host, int port, InetAddress localAddress, int localPort)
+      throws IOException {
+    return configureSocket(delegate.createSocket(host, port, localAddress, localPort));
+  }
+
+  @Override
+  public Socket createSocket(InetAddress host, int port) throws IOException {
+    return configureSocket(delegate.createSocket(host, port));
+  }
+
+  @Override
+  public Socket createSocket(InetAddress host, int port, InetAddress localAddress, int localPort)
+      throws IOException {
+    return configureSocket(delegate.createSocket(host, port, localAddress, localPort));
+  }
+
+  Socket configureSocket(Socket socket) {
+    return socket;
+  }
+}

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

@@ -88,18 +88,20 @@ ApiClient makeApiClient(int retryBackOfDelay) {
 
     setupTls(apiClient);
 
-    final OkHttpClient.Builder builder = apiClient
-      .getHttpClient()
-      .newBuilder();
+    final OkHttpClient.Builder builder = apiClient.getHttpClient().newBuilder();
 
     ProxyConfig.configureTls(builder);
 
     // if http client response is 403 we need to reauthenticate
-    apiClient.setHttpClient(builder.proxy(ProxyConfig.getProxyConfig())
-      .proxyAuthenticator(ProxyConfig.getProxyAuthentication())
-      .addInterceptor(this::reauthInterceptor)
-      .addInterceptor(new NewRetryInterceptor(options.getMaxRequestRetry(), retryBackOfDelay, isShuttingDown))
-      .build());
+    apiClient.setHttpClient(
+        builder
+            .proxy(ProxyConfig.getProxyConfig())
+            .proxyAuthenticator(ProxyConfig.getProxyAuthentication())
+            .addInterceptor(this::reauthInterceptor)
+            .addInterceptor(
+                new NewRetryInterceptor(
+                    options.getMaxRequestRetry(), retryBackOfDelay, isShuttingDown))
+            .build());
 
     return apiClient;
   }

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

@@ -157,7 +157,8 @@ 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);
+        log.warn(
+            "Unable to parse  Retry-After header value: `{}` as integer or date", retryAfterValue);
       }
     }
 

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

@@ -2,13 +2,12 @@
 
 import java.net.InetSocketAddress;
 import java.net.Proxy;
+import javax.net.ssl.SSLSocketFactory;
 import lombok.extern.slf4j.Slf4j;
 import okhttp3.Authenticator;
 import okhttp3.Credentials;
 import okhttp3.OkHttpClient;
 
-import javax.net.ssl.SSLSocketFactory;
-
 @Slf4j
 public class ProxyConfig {
 

src/test/java/io/harness/cf/client/api/EvaluatorIntegrationTest.java

@@ -35,7 +35,7 @@ public List<DynamicTest> getTestCases() throws Exception {
 
     assertTrue(
         testCasesDirectory.exists(),
-        "ff-test-cases folder missing - please check 'git submodule init' has been run");
+        "ff-test-cases folder missing - please check 'git submodule update --init' has been run");
 
     try (Stream<Path> pathStream = Files.walk(Paths.get(testCasesBasePath))) {
       pathStream

src/test/java/io/harness/cf/client/api/dispatchers/JwtMissingFieldsAuthDispatcher.java

@@ -60,7 +60,7 @@ public MockResponse dispatch(@NotNull RecordedRequest recordedRequest) {
       case SIMPLE_BOOL_FLAG_ENDPOINT:
         assertHeaders(recordedRequest);
         return makeMockSingleBoolFlagResponse(200, "simplebool", "off", version.get());
-        // TODO add metrics here
+      // TODO add metrics here
       default:
         throw new UnsupportedOperationException(
             "ERROR: url not mapped " + recordedRequest.getPath());