move to tool - draft - cont.

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

Author: liran2000

pom.xml

@@ -40,6 +40,7 @@
         <module>providers/configcat</module>
         <module>providers/statsig</module>
         <module>providers/multiprovider</module>
+        <module>tools/flagd-http-connector</module>
     </modules>
 
     <scm>

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/util/ConcurrentUtils.java

@@ -0,0 +1,35 @@
+# Changelog
+
+## [0.1.2](https://github.com/open-feature/java-sdk-contrib/compare/dev.openfeature.contrib.tools.junitopenfeature-v0.1.1...dev.openfeature.contrib.tools.junitopenfeature-v0.1.2) (2024-12-03)
+
+
+### ✨ New Features
+
+* added interception of parameterized tests to Junit OpenFeature Extension ([#1093](https://github.com/open-feature/java-sdk-contrib/issues/1093)) ([a78c906](https://github.com/open-feature/java-sdk-contrib/commit/a78c906b24b53f7d25eb01aad85ed614eb30ca05))
+
+## [0.1.1](https://github.com/open-feature/java-sdk-contrib/compare/dev.openfeature.contrib.tools.junitopenfeature-v0.1.0...dev.openfeature.contrib.tools.junitopenfeature-v0.1.1) (2024-09-27)
+
+
+### 🐛 Bug Fixes
+
+* race condition causing default when multiple flags are used ([#983](https://github.com/open-feature/java-sdk-contrib/issues/983)) ([356a973](https://github.com/open-feature/java-sdk-contrib/commit/356a973cf2b6ddf82b8311ea200fa30df4f1d048))
+
+## [0.1.0](https://github.com/open-feature/java-sdk-contrib/compare/dev.openfeature.contrib.tools.junitopenfeature-v0.0.3...dev.openfeature.contrib.tools.junitopenfeature-v0.1.0) (2024-09-25)
+
+
+### 🐛 Bug Fixes
+
+* **deps:** update dependency org.apache.commons:commons-lang3 to v3.17.0 ([#932](https://github.com/open-feature/java-sdk-contrib/issues/932)) ([c598d9f](https://github.com/open-feature/java-sdk-contrib/commit/c598d9f0a61f2324fb85d72fdfea34811283c575))
+
+
+### 🐛 Bug Fixes
+
+* added missing dependency and installation instruction ([#895](https://github.com/open-feature/java-sdk-contrib/issues/895)) ([6748d02](https://github.com/open-feature/java-sdk-contrib/commit/6748d02403f0ceecb6cb9ecdfb2fecf98423a7db))
+* **deps:** update dependency org.apache.commons:commons-lang3 to v3.16.0 ([#908](https://github.com/open-feature/java-sdk-contrib/issues/908)) ([d21cfe3](https://github.com/open-feature/java-sdk-contrib/commit/d21cfe3ac7da1ff6e1a4dc2ee4b0db5c24ed4847))
+
+## [0.0.2](https://github.com/open-feature/java-sdk-contrib/compare/dev.openfeature.contrib.tools.junitopenfeature-v0.0.1...dev.openfeature.contrib.tools.junitopenfeature-v0.0.2) (2024-07-29)
+
+
+### ✨ New Features
+
+* Add JUnit5 extension for OpenFeature ([#888](https://github.com/open-feature/java-sdk-contrib/issues/888)) ([9fff9db](https://github.com/open-feature/java-sdk-contrib/commit/9fff9db4bcee3c3ae8128a1b2fb040f53df1d5ed))

tools/flagd-http-connector/CHANGELOG.md

@@ -0,0 +1,81 @@
+# Http Connector
+
+## Introduction
+Http Connector is a tool for [flagd](https://github.com/open-feature/flagd) in-process resolver.
+
+This mode performs flag evaluations locally (in-process). 
+Flag configurations for evaluation are obtained via gRPC protocol using 
+[sync protobuf schema](https://buf.build/open-feature/flagd/file/main:sync/v1/sync_service.proto) service definition.
+
+## Http Connector functionality
+
+HttpConnector is responsible for polling data from a specified URL at regular intervals.  
+It is leveraging Http cache mechanism with 'ETag' header, then when receiving 304 Not Modified response,
+reducing traffic, reducing rate limits effects and changes updates. Can be enabled via useHttpCache option.  
+The implementation is using Java HttpClient.
+
+## Use cases and benefits
+* Reduce infrastructure/devops work, without additional containers needed.
+* Use as an additional provider for fallback / internal backup service via multi-provider.
+
+### What happens if the Http source is down when application is starting ?
+
+It supports optional fail-safe initialization via cache, such that on initial fetch error following by
+source downtime window, initial payload  is taken from cache to avoid starting with default values until
+the source is back up. Therefore, the cache ttl expected to be higher than the expected source
+down-time to recover from during initialization.
+
+### Sample flow
+Sample flow can use:
+- Github as the flags payload source.
+- Redis cache as a fail-safe initialization cache.
+
+Sample flow of initialization during Github down-time window, showing that application can still use flags
+values as fetched from cache.
+```mermaid
+sequenceDiagram
+    participant Provider
+    participant Github
+    participant Redis
+    
+    break source downtime
+        Provider->>Github: initialize
+        Github->>Provider: failure
+    end
+    Provider->>Redis: fetch
+    Redis->>Provider: last payload
+
+```
+
+## Usage
+
+### Installation
+<!-- x-release-please-start-version -->
+```xml
+<dependency>
+  <groupId>dev.openfeature.contrib.tools</groupId>
+  <artifactId>flagd-http-connector</artifactId>
+  <version>0.0.1</version>
+</dependency>
+```
+<!-- x-release-please-end-version -->
+
+### Usage example
+
+```java
+
+HttpConnectorOptions httpConnectorOptions = HttpConnectorOptions.builder()
+    .url("http://example.com/flags")
+    .build();
+HttpConnector connector = HttpConnector.builder()
+    .httpConnectorOptions(httpConnectorOptions)
+    .build();
+
+FlagdOptions options =
+    FlagdOptions.builder()
+        .resolverType(Config.Resolver.IN_PROCESS)
+        .customConnector(connector)
+        .build();
+
+FlagdProvider flagdProvider = new FlagdProvider(options);
+```

tools/flagd-http-connector/README.md

@@ -0,0 +1,54 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>dev.openfeature.contrib</groupId>
+        <artifactId>parent</artifactId>
+        <version>0.1.0</version>
+        <relativePath>../../pom.xml</relativePath>
+    </parent>
+    <groupId>dev.openfeature.contrib.tools</groupId>
+    <artifactId>flagd-http-connector</artifactId>
+    <version>0.0.1</version> <!--x-release-please-version -->
+
+    <name>flagd-http-connector</name>
+    <description>Flagd Http Connector</description>
+    <url>https://openfeature.dev</url>
+
+    <developers>
+        <developer>
+            <id>liran2000</id>
+            <name>Liran Mendelovich</name>
+            <organization>OpenFeature</organization>
+            <url>https://openfeature.dev/</url>
+        </developer>
+    </developers>
+
+    <dependencies>
+        <dependency>
+            <groupId>dev.openfeature.contrib.providers</groupId>
+            <artifactId>flagd</artifactId>
+            <version>0.11.8</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.17.0</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+    </dependencies>
+
+</project>

tools/flagd-http-connector/pom.xml

@@ -0,0 +1,49 @@
+package dev.openfeature.contrib.tools.flagd.resolver.process.storage.connector.sync.http;
+
+import java.net.http.HttpClient;
+import java.net.http.HttpRequest;
+import java.net.http.HttpResponse;
+import lombok.SneakyThrows;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * Fetches content from a given HTTP endpoint using caching headers to optimize network usage.
+ * If cached ETag or Last-Modified values are available, they are included in the request headers
+ * to potentially receive a 304 Not Modified response, reducing data transfer.
+ * Updates the cached ETag and Last-Modified values upon receiving a 200 OK response.
+ * It does not store the cached response, assuming not needed after first successful fetching.
+ * Non thread-safe.
+ *
+ * @param httpClient the HTTP client used to send the request
+ * @param httpRequestBuilder the builder for constructing the HTTP request
+ * @return the HTTP response received from the server
+ */
+@Slf4j
+public class HttpCacheFetcher {
+    private String cachedETag = null;
+    private String cachedLastModified = null;
+
+    @SneakyThrows
+    public HttpResponse<String> fetchContent(HttpClient httpClient, HttpRequest.Builder httpRequestBuilder) {
+        if (cachedETag != null) {
+            httpRequestBuilder.header("If-None-Match", cachedETag);
+        }
+        if (cachedLastModified != null) {
+            httpRequestBuilder.header("If-Modified-Since", cachedLastModified);
+        }
+
+        HttpRequest request = httpRequestBuilder.build();
+        HttpResponse<String> httpResponse = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
+
+        if (httpResponse.statusCode() == 200) {
+            if (httpResponse.headers() != null) {
+                cachedETag = httpResponse.headers().firstValue("ETag").orElse(null);
+                cachedLastModified = httpResponse.headers().firstValue("Last-Modified").orElse(null);
+            }
+            log.debug("fetched new content");
+        } else if (httpResponse.statusCode() == 304) {
+            log.debug("got 304 Not Modified");
+        }
+        return httpResponse;
+    }
+}