Move telemetry test timeouts to shared constant, then increase from 3 to 20 seconds

Author: jkebinger

sdk/src/test/java/com/reforge/sdk/integration/telemetry/ContextShapeIntegrationTestCaseDescriptor.java

@@ -14,8 +14,6 @@
 import com.reforge.sdk.integration.IntegrationTestFunction;
 import com.reforge.sdk.integration.PrefabContextFactory;
 import com.reforge.sdk.integration.TelemetryAccumulator;
-import java.time.Duration;
-import java.time.temporal.ChronoUnit;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
@@ -88,7 +86,7 @@ protected void performVerification(Sdk sdk) {
     TelemetryAccumulator telemetryAccumulator = getTelemetryAccumulator(sdk);
 
     await()
-      .atMost(Duration.of(3, ChronoUnit.SECONDS))
+      .atMost(TELEMETRY_AWAIT_TIMEOUT)
       .untilAsserted(() -> {
         List<Prefab.ContextShape> actualShapes = telemetryAccumulator
           .getTelemetryEventsList()

sdk/src/test/java/com/reforge/sdk/integration/telemetry/EvaluationSummaryIntegrationTestCaseDescriptor.java

@@ -19,8 +19,6 @@
 import com.reforge.sdk.integration.IntegrationTestClientOverrides;
 import com.reforge.sdk.integration.IntegrationTestFunction;
 import com.reforge.sdk.integration.PrefabContextFactory;
-import java.time.Duration;
-import java.time.temporal.ChronoUnit;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
@@ -103,7 +101,7 @@ protected void performVerification(Sdk sdk) {
       .collect(toImmutableMap(ExpectedDatum::getKey, Function.identity()));
 
     await()
-      .atMost(Duration.of(3, ChronoUnit.SECONDS))
+      .atMost(TELEMETRY_AWAIT_TIMEOUT)
       .untilAsserted(() -> {
         List<Prefab.ConfigEvaluationSummary> actualSummaries = getTelemetryAccumulator(
           sdk

sdk/src/test/java/com/reforge/sdk/integration/telemetry/ExampleContextIntegrationTestCaseDescriptor.java

@@ -17,8 +17,6 @@
 import com.reforge.sdk.integration.IntegrationTestFunction;
 import com.reforge.sdk.integration.PrefabContextFactory;
 import com.reforge.sdk.integration.TelemetryAccumulator;
-import java.time.Duration;
-import java.time.temporal.ChronoUnit;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
@@ -75,7 +73,7 @@ protected void performVerification(Sdk sdk) {
     sdk.configClient().get("my-test-key", contextSetToSend);
     TelemetryAccumulator telemetryAccumulator = getTelemetryAccumulator(sdk);
     await()
-      .atMost(Duration.of(3, ChronoUnit.SECONDS))
+      .atMost(TELEMETRY_AWAIT_TIMEOUT)
       .untilAsserted(() -> {
         List<Prefab.Context> actualContexts = telemetryAccumulator
           .getTelemetryEventsList()

sdk/src/test/java/com/reforge/sdk/integration/telemetry/TelemetryIntegrationTestCaseDescriptor.java

@@ -14,6 +14,8 @@
 import com.reforge.sdk.integration.IntegrationTestCaseDescriptorIF;
 import com.reforge.sdk.integration.IntegrationTestClientOverrides;
 import com.reforge.sdk.integration.TelemetryAccumulator;
+import java.time.Duration;
+import java.time.temporal.ChronoUnit;
 import java.util.Optional;
 import java.util.stream.Collectors;
 import java.util.stream.StreamSupport;
@@ -28,6 +30,11 @@ public abstract class TelemetryIntegrationTestCaseDescriptor
     TelemetryIntegrationTestCaseDescriptor.class
   );
 
+  protected static final Duration TELEMETRY_AWAIT_TIMEOUT = Duration.of(
+    20,
+    ChronoUnit.SECONDS
+  );
+
   public TelemetryIntegrationTestCaseDescriptor(
     String name,
     IntegrationTestClientOverrides clientOverrides,