Update to reforge.com hosts and v2 API endpoints (#4)

* Update to reforge.com hosts

* Update API endpoints from v1 to v2 and fix corresponding tests

- Update HttpClient to use /api/v2/ endpoints for SSE config and configs
- Fix HttpClientTest to expect v2 URLs instead of hardcoded v1 URLs
- Remove unnecessary header mocks from 304 response tests

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>

---------

Co-authored-by: Claude <noreply@anthropic.com>

Author: jkebinger

sdk/src/main/java/com/reforge/sdk/Options.java

@@ -19,12 +19,12 @@
 
 public class Options {
 
-  static final String DEFAULT_TELEMETRY_HOST = "https://telemetry.prefab.cloud";
+  static final String DEFAULT_TELEMETRY_HOST = "https://telemetry.reforge.com";
   static final List<String> DEFAULT_API_HOSTS = List.of(
-    "https://belt.prefab.cloud",
-    "https://suspenders.prefab.cloud"
+    "https://primary.reforge.com",
+    "https://secondary.reforge.com"
   );
-  static final List<String> DEFAULT_STREAM_HOSTS = List.of("https://stream.prefab.cloud");
+  static final List<String> DEFAULT_STREAM_HOSTS = List.of("https://stream.reforge.com");
 
   private List<String> apiHosts = DEFAULT_API_HOSTS;
   private String telemetryHost = DEFAULT_TELEMETRY_HOST;

sdk/src/main/java/com/reforge/sdk/internal/HttpClient.java

@@ -185,7 +185,7 @@ public CompletableFuture<HttpResponse<Void>> createSSEConfigConnection(
   ) {
     return executeWithFailover(
       host -> {
-        URI uri = URI.create(host + "/api/v1/sse/config");
+        URI uri = URI.create(host + "/api/v2/sse/config");
         LOG.info("Requesting SSE from {}", uri);
         HttpRequest request = getClientBuilderWithStandardHeaders()
           .header("Accept", EVENT_STREAM_MEDIA_TYPE)
@@ -212,7 +212,7 @@ public CompletableFuture<HttpResponse<Supplier<Prefab.Configs>>> requestConfigs(
   ) {
     return executeWithFailover(
       host -> {
-        URI uri = URI.create(host + "/api/v1/configs/" + offset);
+        URI uri = URI.create(host + "/api/v2/configs/" + offset);
         return requestConfigsFromURI(uri);
       },
       apiHosts

sdk/src/test/java/com/reforge/sdk/OptionsTest.java

@@ -11,7 +11,7 @@ public class OptionsTest {
   public void testTelemetryDomain() {
     Options options = new Options();
     assertThat(options.getPrefabTelemetryHost())
-      .isEqualTo("https://telemetry.prefab.cloud");
+      .isEqualTo("https://telemetry.reforge.com");
 
     options = new Options().setPrefabTelemetryHost("http://staging-prefab.cloud");
     assertThat(options.getPrefabTelemetryHost()).isEqualTo("http://staging-prefab.cloud");

sdk/src/test/java/com/reforge/sdk/integration/BaseIntegrationTestCaseDescriptor.java

@@ -85,9 +85,9 @@ private Sdk buildClient(IntegrationTestClientOverrides clientOverrides) {
 
     Options options = new Options()
       .setApikey(apiKey)
-      .setPrefabTelemetryHost("https://telemetry.staging-prefab.cloud")
-      .setApiHosts(List.of("https://api.staging-prefab.cloud"))
-      .setStreamHosts(List.of("https://stream.staging-prefab.cloud"))
+      .setPrefabTelemetryHost("https://telemetry.goatsofreforge.com")
+      .setApiHosts(List.of("https://api.goatsofreforge.com"))
+      .setStreamHosts(List.of("https://stream.goatsofreforge.com"))
       .setInitializationTimeoutSec(2000);
     clientOverrides
       .getInitTimeoutSeconds()

sdk/src/test/java/com/reforge/sdk/internal/HttpClientTest.java

@@ -180,7 +180,7 @@ void testConditionalGet304() throws Exception {
     // Use a time far enough in the past to ensure expiration.
     long past = System.currentTimeMillis() - 10_000;
 
-    URI uri = URI.create("http://a.example.com/api/v1/configs/0");
+    URI uri = URI.create("http://a.example.com/api/v2/configs/0");
     Field cacheField = HttpClient.class.getDeclaredField("configCache");
     cacheField.setAccessible(true);
     @SuppressWarnings("unchecked")
@@ -194,7 +194,7 @@ void testConditionalGet304() throws Exception {
     );
     cache.put(uri, expiredEntry);
 
-    // Mark the stubbing for sendAsync as lenient so that if it’s not invoked, we don’t fail.
+    // Mark the stubbing for sendAsync as lenient so that if it's not invoked, we don't fail.
     HttpResponse<byte[]> httpResponse304 = mock(HttpResponse.class);
     when(httpResponse304.statusCode()).thenReturn(304);
 
@@ -305,7 +305,7 @@ void testNoCacheResponseAlwaysRevalidates() throws Exception {
     )
       .thenReturn(future200);
 
-    // Invoke the request (using offset 0L, yielding a URL like "http://a.example.com/api/v1/configs/0").
+    // Invoke the request (using offset 0L, yielding a URL like "http://a.example.com/api/v2/configs/0").
     CompletableFuture<HttpResponse<Supplier<Prefab.Configs>>> firstCall = prefabHttpClient.requestConfigs(
       0L
     );
@@ -316,7 +316,7 @@ void testNoCacheResponseAlwaysRevalidates() throws Exception {
     assertThat(resp1.headers().firstValue("X-Cache")).contains("MISS");
 
     // Retrieve the cached entry.
-    URI uri = URI.create("http://a.example.com/api/v1/configs/0");
+    URI uri = URI.create("http://a.example.com/api/v2/configs/0");
     Field cacheField = HttpClient.class.getDeclaredField("configCache");
     cacheField.setAccessible(true);
     @SuppressWarnings("unchecked")
@@ -331,7 +331,6 @@ void testNoCacheResponseAlwaysRevalidates() throws Exception {
     // Now simulate a 304 Not Modified response on a subsequent request.
     HttpResponse<byte[]> response304 = mock(HttpResponse.class);
     when(response304.statusCode()).thenReturn(304);
-    HttpHeaders headers304 = HttpHeaders.of(Map.of(), (k, v) -> true);
     CompletableFuture<HttpResponse<byte[]>> future304 = CompletableFuture.completedFuture(
       response304
     );