Add support for parsing scopes from config file

Author: Tejas-Kochar

databricks-sdk-java/src/main/java/com/databricks/sdk/core/ConfigAttributeAccessor.java

@@ -2,9 +2,13 @@
 
 import com.databricks.sdk.support.InternalApi;
 import java.lang.reflect.Field;
+import java.lang.reflect.ParameterizedType;
 import java.time.Duration;
+import java.util.Arrays;
+import java.util.List;
 import java.util.Map;
 import java.util.Objects;
+import java.util.stream.Collectors;
 
 @InternalApi
 class ConfigAttributeAccessor {
@@ -63,6 +67,21 @@ public void setValueOnConfig(DatabricksConfig cfg, String value) throws IllegalA
         field.set(cfg, seconds > 0 ? Duration.ofSeconds(seconds) : null);
       } else if (field.getType() == ProxyConfig.ProxyAuthType.class) {
         field.set(cfg, ProxyConfig.ProxyAuthType.valueOf(value));
+      } else if (List.class.isAssignableFrom(field.getType())) {
+        // Handle List<String> fields (e.g., scopes)
+        // Parse comma and/or whitespace separated values from environment variable or config file
+        if (field.getGenericType() instanceof ParameterizedType) {
+          ParameterizedType paramType = (ParameterizedType) field.getGenericType();
+          if (paramType.getActualTypeArguments().length > 0
+              && paramType.getActualTypeArguments()[0] == String.class) {
+            // Split by commas and/or whitespace and filter out empty strings
+            List<String> list =
+                Arrays.stream(value.trim().split("[,\\s]+"))
+                    .filter(s -> !s.isEmpty())
+                    .collect(Collectors.toList());
+            field.set(cfg, list);
+          }
+        }
       }
       field.setAccessible(false);
     }
@@ -91,6 +110,10 @@ public String toString() {
   }
 
   public String getAsString(Object value) {
+    if (value instanceof List) {
+      // Format lists as space-separated values for consistency with input format
+      return String.join(" ", (List<String>) value);
+    }
     return value.toString();
   }
 

databricks-sdk-java/src/main/java/com/databricks/sdk/core/DatabricksConfig.java

@@ -204,6 +204,7 @@ private synchronized DatabricksConfig innerResolve() {
     try {
       ConfigLoader.resolve(this);
       ConfigLoader.validate(this);
+      sortScopes();
       ConfigLoader.fixHostIfNeeded(this);
       initHttp();
       return this;
@@ -212,6 +213,15 @@ private synchronized DatabricksConfig innerResolve() {
     }
   }
 
+  /**
+   * Sort scopes in-place for better de-duplication in the refresh token cache.
+   */
+  private void sortScopes() {
+    if (scopes != null && !scopes.isEmpty()) {
+      java.util.Collections.sort(scopes);
+    }
+  }
+
   private void initHttp() {
     if (httpClient != null) {
       return;

databricks-sdk-java/src/test/java/com/databricks/sdk/core/DatabricksConfigTest.java

@@ -322,4 +322,52 @@ public void testDisableOauthRefreshTokenEnvironmentVariable() {
 
     assertEquals(true, config.getDisableOauthRefreshToken());
   }
+
+  // Config File Scope Parsing Tests
+
+  @Test
+  public void testConfigFileScopesEmptyDefaultsToAllApis() {
+    Map<String, String> env = new HashMap<>();
+    env.put("HOME", "src/test/resources/testdata");
+
+    DatabricksConfig config = new DatabricksConfig().setProfile("scope-empty");
+    config.resolve(new Environment(env, new ArrayList<>(), System.getProperty("os.name")));
+
+    List<String> scopes = config.getScopes();
+    assertEquals(1, scopes.size());
+    assertEquals("all-apis", scopes.get(0));
+  }
+
+  @Test
+  public void testConfigFileScopesSingle() {
+    Map<String, String> env = new HashMap<>();
+    env.put("HOME", "src/test/resources/testdata");
+
+    DatabricksConfig config = new DatabricksConfig().setProfile("scope-single");
+    config.resolve(new Environment(env, new ArrayList<>(), System.getProperty("os.name")));
+
+    List<String> scopes = config.getScopes();
+    assertEquals(1, scopes.size());
+    assertEquals("clusters:read", scopes.get(0));
+  }
+
+  @Test
+  public void testConfigFileScopesMultipleSorted() {
+    Map<String, String> env = new HashMap<>();
+    env.put("HOME", "src/test/resources/testdata");
+
+    DatabricksConfig config = new DatabricksConfig().setProfile("scope-multiple");
+    config.resolve(new Environment(env, new ArrayList<>(), System.getProperty("os.name")));
+
+    List<String> scopes = config.getScopes();
+    // Should be sorted alphabetically
+    assertEquals(7, scopes.size());
+    assertEquals("clusters:read", scopes.get(0));
+    assertEquals("files:read", scopes.get(1));
+    assertEquals("iam:read", scopes.get(2));
+    assertEquals("jobs:read", scopes.get(3));
+    assertEquals("mlflow:read", scopes.get(4));
+    assertEquals("model-serving:read", scopes.get(5));
+    assertEquals("pipelines:read", scopes.get(6));
+  }
 }

databricks-sdk-java/src/test/resources/testdata/.databrickscfg

@@ -38,4 +38,15 @@ google_credentials = paw48590aw8e09t8apu
 
 [pat.with.dot]
 host = https://dbc-XXXXXXXX-YYYY.cloud.databricks.com/
-token = PT0+IC9kZXYvdXJhbmRvbSA8PT0KYFZ
+token = PT0+IC9kZXYvdXJhbmRvbSA8PT0KYFZ
+
+[scope-empty]
+host = https://example.cloud.databricks.com
+
+[scope-single]
+host = https://example.cloud.databricks.com
+scopes = clusters:read
+
+[scope-multiple]
+host = https://example.cloud.databricks.com
+scopes = clusters:read, jobs:read, pipelines:read, iam:read, files:read, mlflow:read, model-serving:read