feat: Make EnvUtils public

Author: ferenc-csaky

flink-sql-runner/src/main/java/com/datasqrl/flinkrunner/EnvUtils.java

@@ -20,7 +20,7 @@
 import java.util.UUID;
 
 /** Utility class for environment variable operations. */
-final class EnvUtils {
+public final class EnvUtils {
 
   /**
    * Returns a map of environment variables with deployment-specific defaults.
@@ -35,7 +35,7 @@ final class EnvUtils {
    *
    * @return an immutable map containing all environment variables with defaults applied
    */
-  static Map<String, String> getEnvWithDefaults() {
+  static Map<String, String> getEnvWithDeploymentDefaults() {
     var env = new HashMap<>(System.getenv());
     env.putIfAbsent("DEPLOYMENT_ID", UUID.randomUUID().toString());
     env.putIfAbsent("DEPLOYMENT_TIMESTAMP", String.valueOf(System.currentTimeMillis()));

flink-sql-runner/src/main/java/com/datasqrl/flinkrunner/EnvVarResolver.java

@@ -37,7 +37,7 @@ public class EnvVarResolver {
   private final ObjectMapper objectMapper;
 
   public EnvVarResolver() {
-    this(EnvUtils.getEnvWithDefaults());
+    this(EnvUtils.getEnvWithDeploymentDefaults());
   }
 
   public EnvVarResolver(Map<String, String> envVars) {

flink-sql-runner/src/test/java/com/datasqrl/flinkrunner/EnvUtilsTest.java

@@ -25,7 +25,7 @@ class EnvUtilsTest {
 
   @Test
   void givenSystemEnv_whenGetEnvWithDefaults_thenReturnsEnvWithDefaults() {
-    var env = EnvUtils.getEnvWithDefaults();
+    var env = EnvUtils.getEnvWithDeploymentDefaults();
 
     assertThat(env).isNotNull();
     assertThat(env).containsKey("DEPLOYMENT_ID");
@@ -34,7 +34,7 @@ void givenSystemEnv_whenGetEnvWithDefaults_thenReturnsEnvWithDefaults() {
 
   @Test
   void givenSystemEnv_whenGetEnvWithDefaults_thenDeploymentIdIsValidUuid() {
-    var env = EnvUtils.getEnvWithDefaults();
+    var env = EnvUtils.getEnvWithDeploymentDefaults();
 
     String deploymentId = env.get("DEPLOYMENT_ID");
     assertThat(deploymentId)
@@ -44,7 +44,7 @@ void givenSystemEnv_whenGetEnvWithDefaults_thenDeploymentIdIsValidUuid() {
 
   @Test
   void givenSystemEnv_whenGetEnvWithDefaults_thenDeploymentTimestampIsValidLong() {
-    var env = EnvUtils.getEnvWithDefaults();
+    var env = EnvUtils.getEnvWithDeploymentDefaults();
 
     String timestamp = env.get("DEPLOYMENT_TIMESTAMP");
     assertThat(timestamp).isNotNull();
@@ -53,15 +53,15 @@ void givenSystemEnv_whenGetEnvWithDefaults_thenDeploymentTimestampIsValidLong()
 
   @Test
   void givenSystemEnv_whenGetEnvWithDefaults_thenReturnsImmutableMap() {
-    var env = EnvUtils.getEnvWithDefaults();
+    var env = EnvUtils.getEnvWithDeploymentDefaults();
 
     assertThatThrownBy(() -> env.put("NEW_KEY", "value"))
         .isInstanceOf(UnsupportedOperationException.class);
   }
 
   @Test
   void givenSystemEnv_whenGetEnvWithDefaults_thenIncludesSystemEnvironmentVariables() {
-    var env = EnvUtils.getEnvWithDefaults();
+    var env = EnvUtils.getEnvWithDeploymentDefaults();
     var systemEnv = System.getenv();
 
     // Verify that all system environment variables are present
@@ -72,18 +72,18 @@ void givenSystemEnv_whenGetEnvWithDefaults_thenIncludesSystemEnvironmentVariable
 
   @Test
   void givenMultipleCalls_whenGetEnvWithDefaults_thenGeneratesDifferentDeploymentIds() {
-    var env1 = EnvUtils.getEnvWithDefaults();
-    var env2 = EnvUtils.getEnvWithDefaults();
+    var env1 = EnvUtils.getEnvWithDeploymentDefaults();
+    var env2 = EnvUtils.getEnvWithDeploymentDefaults();
 
     assertThat(env1.get("DEPLOYMENT_ID")).isNotEqualTo(env2.get("DEPLOYMENT_ID"));
   }
 
   @Test
   void givenMultipleCalls_whenGetEnvWithDefaults_thenGeneratesDifferentTimestamps()
       throws InterruptedException {
-    var env1 = EnvUtils.getEnvWithDefaults();
+    var env1 = EnvUtils.getEnvWithDeploymentDefaults();
     Thread.sleep(2); // Small delay to ensure different timestamps
-    var env2 = EnvUtils.getEnvWithDefaults();
+    var env2 = EnvUtils.getEnvWithDeploymentDefaults();
 
     long timestamp1 = Long.parseLong(env1.get("DEPLOYMENT_TIMESTAMP"));
     long timestamp2 = Long.parseLong(env2.get("DEPLOYMENT_TIMESTAMP"));