fix(core): use dual stack config

Author: bytestarter

volcengine-java-sdk-core/src/main/java/com/volcengine/ApiClient.java

@@ -103,6 +103,8 @@ public class ApiClient {
 
     private Set<String> customBootstrapRegion;
 
+    private Boolean useDualStack;
+
     /*
      * Constructor for ApiClient
      */
@@ -549,6 +551,26 @@ public ApiClient setCustomBootstrapRegion(Set<String> customBootstrapRegion) {
         return this;
     }
 
+    /**
+     * Get the use dual stack flag.
+     *
+     * @return use dual stack flag
+     */
+    public Boolean getUseDualStack() {
+        return this.useDualStack;
+    }
+
+    /**
+     * Set the use dual stack flag.
+     *
+     * @param useDualStack boolean
+     * @return Api client
+     */
+    public ApiClient setUseDualStack(boolean useDualStack) {
+        this.useDualStack = useDualStack;
+        return this;
+    }
+
     /**
      * Format the given parameter object into string.
      *

volcengine-java-sdk-core/src/main/java/com/volcengine/endpoint/DefaultEndpointProvider.java

@@ -678,14 +678,14 @@ private static String standardizeDomainServiceCode(String serviceCode) {
     }
 
     private static String getDefaultEndpointByServiceInfo(String service, String regionCode,
-                                                          Set<String> customBootstrapRegion) {
+                                                          Set<String> customBootstrapRegion, Boolean useDualStack) {
         String resultEndpoint = ENDPOINT;
         ServiceEndpointInfo endpointInfo = DEFAULT_ENDPOINT_MAP.get(service);
         if (endpointInfo == null || !inBootstrapRegionList(regionCode, customBootstrapRegion)) {
             return resultEndpoint;
         }
 
-        String endpointSuffix = hasEnabledDualstack() ? DUALSTACK_ENDPOINT_SUFFIX : ENDPOINT_SUFFIX;
+        String endpointSuffix = hasEnabledDualstack(useDualStack) ? DUALSTACK_ENDPOINT_SUFFIX : ENDPOINT_SUFFIX;
 
         if (endpointInfo.isGlobal) {
             if (!endpointInfo.globalEndpoint.isEmpty()) {
@@ -744,15 +744,19 @@ private static boolean inBootstrapRegionList(String region, Set<String> customBo
         return false;
     }
 
-    private static boolean hasEnabledDualstack() {
-        String enableDualstack = System.getenv("VOLC_ENABLE_DUALSTACK");
-        return enableDualstack != null && enableDualstack.equals("true");
+    private static boolean hasEnabledDualstack(Boolean useDualStack) {
+        if (useDualStack == null) {
+            String enableDualstack = System.getenv("VOLC_ENABLE_DUALSTACK");
+            return enableDualstack != null && enableDualstack.equals("true");
+        }
+
+        return useDualStack;
     }
 
     @Override
     public ResolvedEndpoint endpointFor(ResolveEndpointOption option) {
         String endpoint = DefaultEndpointProvider.getDefaultEndpointByServiceInfo(option.getService(),
-                option.getRegion(), option.getCustomBootstrapRegion());
+                option.getRegion(), option.getCustomBootstrapRegion(), option.getUseDualStack());
         ResolvedEndpoint result = new ResolvedEndpoint();
         result.setEndpoint(endpoint);
         return result;

volcengine-java-sdk-core/src/main/java/com/volcengine/endpoint/ResolveEndpointOption.java

@@ -9,6 +9,8 @@ public class ResolveEndpointOption {
 
     private Set<String> customBootstrapRegion = new HashSet<>();
 
+    private Boolean useDualStack = null;
+
     public String getService() {
         return service;
     }
@@ -33,4 +35,12 @@ public void setCustomBootstrapRegion(Set<String> customBootstrapRegion) {
         this.customBootstrapRegion = customBootstrapRegion;
     }
 
+    public Boolean getUseDualStack() {
+        return useDualStack;
+    }
+
+    public void setUseDualStack(Boolean useDualStack) {
+        this.useDualStack = useDualStack;
+    }
+
 }

volcengine-java-sdk-core/src/main/java/com/volcengine/interceptor/ResolveEndpointInterceptor.java

@@ -42,6 +42,7 @@ public InterceptorContext intercept(InterceptorContext context) throws ApiExcept
             option.setService(service);
             option.setRegion(context.getApiClient().getRegion());
             option.setCustomBootstrapRegion(context.getApiClient().getCustomBootstrapRegion());
+            option.setUseDualStack(context.getApiClient().getUseDualStack());
             ResolvedEndpoint resolvedEndpoint = endpointResolver.endpointFor(option);
             context.getRequestContext().setHost(resolvedEndpoint.getEndpoint());
         }