feat(springboot cloudconfig): A new library that implement a backend of Spring Cloud Config

Originally from https://github.com/fangkehou-team/dapr-spring, this library created a backend of SpringCloudConfig just like SpringCloudVault.
The original library only uses secret store as config store api is not stable at that time.
As the configuration api is stable now, the config loader using that api would be implemented later.

Signed-off-by: lony2003 <[email protected]>

Author: lony2003

dapr-spring/dapr-spring-cloudconfig/pom.xml

@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>io.dapr.spring</groupId>
+        <artifactId>dapr-spring-parent</artifactId>
+        <version>0.14.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>dapr-spring-cloudconfig</artifactId>
+    <name>dapr-spring-cloudconfig</name>
+    <description>Dapr Spring Cloud Config</description>
+    <packaging>jar</packaging>
+
+    <dependencies>
+        <dependency>
+            <groupId>io.dapr.spring</groupId>
+            <artifactId>dapr-spring-boot-autoconfigure</artifactId>
+            <version>${project.parent.version}</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+
+</project>

dapr-spring/dapr-spring-cloudconfig/src/main/java/io/dapr/spring/boot/cloudconfig/autoconfigure/DaprCloudConfigAutoConfiguration.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright (c) 2016-2024 Team Fangkehou
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.dapr.spring.boot.cloudconfig.autoconfigure;
+
+import io.dapr.spring.boot.cloudconfig.config.DaprCloudConfigProperties;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+import io.dapr.client.DaprClient;
+
+@Configuration(proxyBeanMethods = false)
+@EnableConfigurationProperties(DaprCloudConfigProperties.class)
+@ConditionalOnProperty(name = "dapr.secretstore.enabled", matchIfMissing = true)
+@ConditionalOnClass(DaprClient.class)
+public class DaprCloudConfigAutoConfiguration {
+
+}

dapr-spring/dapr-spring-cloudconfig/src/main/java/io/dapr/spring/boot/cloudconfig/config/CloudConfigPropertiesDaprConnectionDetails.java

@@ -0,0 +1,46 @@
+/*
+ * Copyright 2024 The Dapr Authors
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package io.dapr.spring.boot.cloudconfig.config;
+
+import io.dapr.spring.boot.autoconfigure.client.DaprClientProperties;
+import io.dapr.spring.boot.autoconfigure.client.DaprConnectionDetails;
+
+class CloudConfigPropertiesDaprConnectionDetails implements DaprConnectionDetails {
+
+  private final DaprClientProperties daprClientProperties;
+
+  public CloudConfigPropertiesDaprConnectionDetails(DaprClientProperties daprClientProperties) {
+    this.daprClientProperties = daprClientProperties;
+  }
+
+  @Override
+  public String httpEndpoint() {
+    return this.daprClientProperties.getHttpEndpoint();
+  }
+
+  @Override
+  public String grpcEndpoint() {
+    return this.daprClientProperties.getGrpcEndpoint();
+  }
+
+  @Override
+  public Integer httpPort() {
+    return this.daprClientProperties.getHttpPort();
+  }
+
+  @Override
+  public Integer grpcPort() {
+    return this.daprClientProperties.getGrpcPort();
+  }
+}

dapr-spring/dapr-spring-cloudconfig/src/main/java/io/dapr/spring/boot/cloudconfig/config/DaprCloudConfigClientManager.java

@@ -0,0 +1,87 @@
+/*
+ * Copyright (c) 2016-2024 Team Fangkehou
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.dapr.spring.boot.cloudconfig.config;
+
+import io.dapr.client.DaprClient;
+import io.dapr.client.DaprClientBuilder;
+import io.dapr.client.DaprPreviewClient;
+import io.dapr.config.Properties;
+import io.dapr.spring.boot.autoconfigure.client.DaprClientProperties;
+import io.dapr.spring.boot.autoconfigure.client.DaprConnectionDetails;
+
+
+public class DaprCloudConfigClientManager {
+
+    private static DaprClient daprClient;
+    private static DaprPreviewClient daprPreviewClient;
+    private final DaprCloudConfigProperties daprCloudConfigProperties;
+    private final DaprClientProperties daprClientConfig;
+
+    public DaprCloudConfigClientManager(DaprCloudConfigProperties daprCloudConfigProperties,
+                                        DaprClientProperties daprClientConfig) {
+        this.daprCloudConfigProperties = daprCloudConfigProperties;
+        this.daprClientConfig = daprClientConfig;
+
+        DaprClientBuilder daprClientBuilder = createDaprClientBuilder(
+                createDaprConnectionDetails(daprClientConfig)
+        );
+
+        if (DaprCloudConfigClientManager.daprClient == null) {
+            DaprCloudConfigClientManager.daprClient = daprClientBuilder.build();
+        }
+
+        if (DaprCloudConfigClientManager.daprPreviewClient == null) {
+            DaprCloudConfigClientManager.daprPreviewClient = daprClientBuilder.buildPreviewClient();
+        }
+    }
+
+    private DaprConnectionDetails createDaprConnectionDetails(DaprClientProperties properties) {
+        return new CloudConfigPropertiesDaprConnectionDetails(properties);
+    }
+    DaprClientBuilder createDaprClientBuilder(DaprConnectionDetails daprConnectionDetails) {
+        DaprClientBuilder builder = new DaprClientBuilder();
+        if (daprConnectionDetails.httpEndpoint() != null) {
+            builder.withPropertyOverride(Properties.HTTP_ENDPOINT, daprConnectionDetails.httpEndpoint());
+        }
+        if (daprConnectionDetails.grpcEndpoint() != null) {
+            builder.withPropertyOverride(Properties.GRPC_ENDPOINT, daprConnectionDetails.grpcEndpoint());
+        }
+        if (daprConnectionDetails.httpPort() != null) {
+            builder.withPropertyOverride(Properties.HTTP_PORT, String.valueOf(daprConnectionDetails.httpPort()));
+        }
+        if (daprConnectionDetails.grpcPort() != null) {
+            builder.withPropertyOverride(Properties.GRPC_PORT, String.valueOf(daprConnectionDetails.grpcPort()));
+        }
+        return builder;
+    }
+
+    public static DaprPreviewClient getDaprPreviewClient() {
+        return DaprCloudConfigClientManager.daprPreviewClient;
+    }
+
+    public static DaprClient getDaprClient() {
+        return DaprCloudConfigClientManager.daprClient;
+    }
+
+    public DaprCloudConfigProperties getDaprCloudConfigProperties() {
+        return daprCloudConfigProperties;
+    }
+
+    public DaprClientProperties getDaprClientConfig() {
+        return daprClientConfig;
+    }
+}

dapr-spring/dapr-spring-cloudconfig/src/main/java/io/dapr/spring/boot/cloudconfig/config/DaprCloudConfigProperties.java

@@ -0,0 +1,54 @@
+/*
+ * Copyright (c) 2016-2024 Team Fangkehou
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.dapr.spring.boot.cloudconfig.config;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+/**
+ * The properties for creating dapr client.
+ */
+@ConfigurationProperties(DaprCloudConfigProperties.PROPERTY_PREFIX)
+public class DaprCloudConfigProperties {
+
+    public static final String PROPERTY_PREFIX = "dapr.cloudconfig";
+
+    /**
+     * whether enable secret store
+     */
+    private Boolean enabled = true;
+
+    /**
+     * get config timeout
+     */
+    private Integer timeout = 2000;
+
+    public Integer getTimeout() {
+        return timeout;
+    }
+
+    public void setTimeout(Integer timeout) {
+        this.timeout = timeout;
+    }
+
+    public Boolean getEnabled() {
+        return enabled;
+    }
+
+    public void setEnabled(Boolean enabled) {
+        this.enabled = enabled;
+    }
+}

dapr-spring/dapr-spring-cloudconfig/src/main/java/io/dapr/spring/boot/cloudconfig/configdata/config/DaprConfigurationConfigDataLoader.java

@@ -0,0 +1,123 @@
+/*
+ * Copyright (c) 2016-2024 Team Fangkehou
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.dapr.spring.boot.cloudconfig.configdata.config;
+
+import io.dapr.client.DaprClient;
+import io.dapr.spring.boot.cloudconfig.config.DaprCloudConfigClientManager;
+import io.dapr.spring.boot.cloudconfig.config.DaprCloudConfigProperties;
+import io.dapr.spring.boot.cloudconfig.parser.DaprSecretStoreParserHandler;
+import org.apache.commons.logging.Log;
+import org.springframework.boot.context.config.ConfigData;
+import org.springframework.boot.context.config.ConfigDataLoader;
+import org.springframework.boot.context.config.ConfigDataLoaderContext;
+import org.springframework.boot.context.config.ConfigDataResourceNotFoundException;
+import org.springframework.boot.logging.DeferredLogFactory;
+import org.springframework.core.env.PropertySource;
+import reactor.core.publisher.Mono;
+
+import java.io.IOException;
+import java.time.Duration;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+
+import static org.springframework.boot.context.config.ConfigData.Option.*;
+
+public class DaprConfigurationConfigDataLoader implements ConfigDataLoader<DaprConfigurationConfigDataResource> {
+
+    private final Log log;
+
+    private DaprClient daprClient;
+
+    private DaprCloudConfigProperties daprSecretStoreConfig;
+
+    public DaprConfigurationConfigDataLoader(DeferredLogFactory logFactory, DaprClient daprClient,
+                                             DaprCloudConfigProperties daprSecretStoreConfig) {
+        this.log = logFactory.getLog(getClass());
+        this.daprClient = daprClient;
+        this.daprSecretStoreConfig = daprSecretStoreConfig;
+    }
+
+
+    /**
+     * Load {@link ConfigData} for the given resource.
+     *
+     * @param context the loader context
+     * @param resource the resource to load
+     * @return the loaded config data or {@code null} if the location should be skipped
+     * @throws IOException on IO error
+     * @throws ConfigDataResourceNotFoundException if the resource cannot be found
+     */
+    @Override
+    public ConfigData load(ConfigDataLoaderContext context, DaprConfigurationConfigDataResource resource)
+            throws IOException, ConfigDataResourceNotFoundException {
+        DaprCloudConfigClientManager daprClientSecretStoreConfigManager =
+                getBean(context, DaprCloudConfigClientManager.class);
+
+        daprClient = DaprCloudConfigClientManager.getDaprClient();
+        daprSecretStoreConfig = daprClientSecretStoreConfigManager.getDaprCloudConfigProperties();
+
+        if (resource.getSecretName() == null) {
+            return fetchConfig(resource.getStoreName());
+        } else {
+            return fetchConfig(resource.getStoreName(), resource.getSecretName());
+        }
+    }
+
+    private ConfigData fetchConfig(String storeName) {
+        Mono<Map<String, Map<String, String>>> secretMapMono = daprClient.getBulkSecret(storeName);
+
+        Map<String, Map<String, String>> secretMap =
+                secretMapMono.block(Duration.ofMillis(daprSecretStoreConfig.getTimeout()));
+
+        if (secretMap == null) {
+            return new ConfigData(Collections.emptyList(), IGNORE_IMPORTS, IGNORE_PROFILES, PROFILE_SPECIFIC);
+        }
+
+        List<PropertySource<?>> sourceList = new ArrayList<>();
+
+        for (Map.Entry<String, Map<String, String>> entry : secretMap.entrySet()) {
+            sourceList.addAll(DaprSecretStoreParserHandler.getInstance().parseDaprSecretStoreData(entry.getKey(),
+                    entry.getValue()));
+        }
+
+        return new ConfigData(sourceList, IGNORE_IMPORTS, IGNORE_PROFILES, PROFILE_SPECIFIC);
+    }
+
+    private ConfigData fetchConfig(String storeName, String secretName) {
+        Mono<Map<String, String>> secretMapMono = daprClient.getSecret(storeName, secretName);
+
+        Map<String, String> secretMap = secretMapMono.block(Duration.ofMillis(daprSecretStoreConfig.getTimeout()));
+
+        if (secretMap == null) {
+            return new ConfigData(Collections.emptyList(), IGNORE_IMPORTS, IGNORE_PROFILES, PROFILE_SPECIFIC);
+        }
+
+        List<PropertySource<?>> sourceList = new ArrayList<>(
+                DaprSecretStoreParserHandler.getInstance().parseDaprSecretStoreData(secretName, secretMap));
+
+        return new ConfigData(sourceList, IGNORE_IMPORTS, IGNORE_PROFILES, PROFILE_SPECIFIC);
+    }
+
+    protected <T> T getBean(ConfigDataLoaderContext context, Class<T> type) {
+        if (context.getBootstrapContext().isRegistered(type)) {
+            return context.getBootstrapContext().get(type);
+        }
+        return null;
+    }
+}