updates

Signed-off-by: liran2000 <[email protected]>

Author: liran2000

tools/flagd-http-connector/src/main/java/dev/openfeature/contrib/tools/flagd/resolver/process/storage/connector/sync/http/HttpConnector.java

@@ -55,6 +55,7 @@ public class HttpConnector implements QueueSource {
 
     @NonNull
     private String url;
+    private URI uri;
 
     /**
      * HttpConnector constructor.
@@ -71,6 +72,7 @@ public HttpConnector(HttpConnectorOptions httpConnectorOptions) {
                 httpConnectorOptions.getProxyPort()));
         }
         this.url = httpConnectorOptions.getUrl();
+        uri = URI.create(url);
         this.headers = httpConnectorOptions.getHeaders();
         this.httpClientExecutor = httpConnectorOptions.getHttpClientExecutor();
         scheduler = Executors.newScheduledThreadPool(httpConnectorOptions.getScheduledThreadPoolSize());
@@ -154,7 +156,7 @@ private boolean fetchAndUpdate() {
             }
         }
         HttpRequest.Builder requestBuilder = HttpRequest.newBuilder()
-            .uri(URI.create(url))
+            .uri(uri)
             .timeout(Duration.ofSeconds(requestTimeoutSeconds))
             .GET();
         headers.forEach(requestBuilder::header);
@@ -188,6 +190,11 @@ private boolean fetchAndUpdate() {
             log.warn("Unable to offer file content to queue: queue is full");
             return false;
         }
+        updateCache(payload);
+        return true;
+    }
+
+    private void updateCache(String payload) {
         if (payloadCache != null) {
             log.debug("scheduling cache update if needed");
             scheduler.execute(() -> {
@@ -202,7 +209,6 @@ private boolean fetchAndUpdate() {
                 }
             );
         }
-        return true;
     }
 
     private static boolean isSuccessful(HttpResponse<String> response) {

tools/flagd-http-connector/src/main/java/dev/openfeature/contrib/tools/flagd/resolver/process/storage/connector/sync/http/HttpConnectorOptions.java

@@ -1,6 +1,8 @@
 package dev.openfeature.contrib.tools.flagd.resolver.process.storage.connector.sync.http;
 
 import java.lang.reflect.Method;
+import java.net.MalformedURLException;
+import java.net.URISyntaxException;
 import java.net.URL;
 import java.util.HashMap;
 import java.util.Map;
@@ -117,7 +119,7 @@ private void validate(String url, Integer pollIntervalSeconds, Integer linkedBlo
             Integer scheduledThreadPoolSize, Integer requestTimeoutSeconds, Integer connectTimeoutSeconds,
             String proxyHost, Integer proxyPort, PayloadCacheOptions payloadCacheOptions,
             PayloadCache payloadCache, Boolean useFailsafeCache, Boolean usePollingCache) {
-        new URL(url).toURI();
+        validateUrl(url);
         if (linkedBlockingQueueCapacity != null
                 && (linkedBlockingQueueCapacity < 1 || linkedBlockingQueueCapacity > 1000)) {
             throw new IllegalArgumentException("linkedBlockingQueueCapacity must be between 1 and 1000");
@@ -170,4 +172,8 @@ private void validate(String url, Integer pollIntervalSeconds, Integer linkedBlo
             }
         }
     }
+
+    private static void validateUrl(String url) throws URISyntaxException, MalformedURLException {
+        new URL(url).toURI();
+    }
 }