feature:add configuration apis according to cloud-runtimes-jvm 1.0.4version

Author: recklessctrip

pom.xml

@@ -72,7 +72,7 @@
         <java.version>8</java.version>
         <file.encoding>UTF-8</file.encoding>
         <maven.version>3.8.1</maven.version>
-        <cloud-runtimes.version>1.0.3.RELEASE</cloud-runtimes.version>
+        <cloud-runtimes.version>1.0.4.RELEASE</cloud-runtimes.version>
         <reactor-core.version>3.3.11.RELEASE</reactor-core.version>
         <junit.version>5.3.1</junit.version>
         <mockito-core.version>3.6.0</mockito-core.version>

sdk/src/main/java/group/rxcloud/capa/configuration/AbstractCapaConfigurationClient.java

@@ -17,10 +17,16 @@
 package group.rxcloud.capa.configuration;
 
 
+import group.rxcloud.cloudruntimes.domain.core.configuration.ConfigurationItem;
 import group.rxcloud.cloudruntimes.domain.core.configuration.ConfigurationRequestItem;
 import group.rxcloud.cloudruntimes.domain.core.configuration.SaveConfigurationRequest;
+import group.rxcloud.cloudruntimes.domain.core.configuration.SubConfigurationResp;
+import group.rxcloud.cloudruntimes.utils.TypeRef;
+import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
+import java.util.List;
+
 /**
  * Abstract class with convenient methods common between client implementations.
  *
@@ -37,4 +43,14 @@ public Mono<Void> saveConfiguration(SaveConfigurationRequest saveConfigurationRe
     public Mono<Void> deleteConfiguration(ConfigurationRequestItem configurationRequestItem) {
         return Mono.error(new UnsupportedOperationException("unsupported delete configuration"));
     }
+
+    @Override
+    public <T> Mono<List<ConfigurationItem<T>>> getConfiguration(ConfigurationRequestItem configurationRequestItem, TypeRef<T> type) {
+        return Mono.error(new UnsupportedOperationException("unsupported get configuration with ConfigurationRequestItem as parameter"));
+    }
+
+    @Override
+    public <T> Flux<SubConfigurationResp<T>> subscribeConfiguration(ConfigurationRequestItem configurationRequestItem, TypeRef<T> type) {
+        return Flux.error(new UnsupportedOperationException("unsupported subscribe configuration with ConfigurationRequestItem as parameter"));
+    }
 }

sdk/src/main/java/group/rxcloud/capa/configuration/CapaConfigurationClient.java

@@ -42,6 +42,9 @@ public interface CapaConfigurationClient extends DefaultCloudRuntimesClient {
     @Override
     <T> Mono<List<ConfigurationItem<T>>> getConfiguration(String storeName, String appId, List<String> keys, Map<String, String> metadata, String group, String label, TypeRef<T> type);
 
+    @Override
+    <T> Mono<List<ConfigurationItem<T>>> getConfiguration(ConfigurationRequestItem configurationRequestItem, TypeRef<T> type);
+
     @Override
     <T> Flux<SubConfigurationResp<T>> subscribeConfiguration(String storeName, String appId, List<String> keys, Map<String, String> metadata, TypeRef<T> type);
 
@@ -51,6 +54,9 @@ public interface CapaConfigurationClient extends DefaultCloudRuntimesClient {
     @Override
     <T> Flux<SubConfigurationResp<T>> subscribeConfiguration(String storeName, String appId, List<String> keys, Map<String, String> metadata, String group, String label, TypeRef<T> type);
 
+    @Override
+    <T> Flux<SubConfigurationResp<T>> subscribeConfiguration(ConfigurationRequestItem configurationRequestItem, TypeRef<T> type);
+
     @Override
     Mono<Void> saveConfiguration(SaveConfigurationRequest saveConfigurationRequest);
 

sdk/src/main/java/group/rxcloud/capa/configuration/CapaConfigurationClientStore.java

@@ -27,7 +27,11 @@
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
-import java.util.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 

sdk/src/test/java/group/rxcloud/capa/configuration/CapaConfigurationClientBuilderTest.java

@@ -40,7 +40,7 @@ public void testBuild_WithCapaConfigStoreBuilderListAsParametersConstructor() {
     }
 
     @Test
-    public void testBuild_WithCapaConfigStoreBuilderSuppierAsParametersConstructor() {
+    public void testBuild_WithCapaConfigStoreBuilderSupplierAsParametersConstructor() {
         CapaConfigStoreBuilder storeBuilder = Mockito.mock(CapaConfigStoreBuilder.class);
         CapaConfigStore configStore = Mockito.mock(CapaConfigStore.class);
         Mockito.when(storeBuilder.build()).thenReturn(configStore);

sdk/src/test/java/group/rxcloud/capa/configuration/CapaConfigurationClientStoreTest.java

@@ -55,7 +55,18 @@ public void testSaveConfiguration_FailWhenThrowUnsupportedOperationException() {
     public void testDeleteConfiguration_FailWhenThrowUnsupportedOperationException() {
         CapaConfigurationClientStore clientStore = new CapaConfigurationClientStore(Collections.emptyList());
         Assertions.assertThrows(UnsupportedOperationException.class, () -> clientStore.deleteConfiguration(new ConfigurationRequestItem()).block());
+    }
 
+    @Test
+    public void testGetConfiguration_FailWhenThrowUnsupportedOperationException() {
+        CapaConfigurationClientStore clientStore = new CapaConfigurationClientStore(Collections.emptyList());
+        Assertions.assertThrows(UnsupportedOperationException.class, () -> clientStore.getConfiguration(new ConfigurationRequestItem(),TypeRef.STRING).block());
+    }
+
+    @Test
+    public void testSubscribeConfiguration_FailWhenThrowUnsupportedOperationException() {
+        CapaConfigurationClientStore clientStore = new CapaConfigurationClientStore(Collections.emptyList());
+        Assertions.assertThrows(UnsupportedOperationException.class, () -> clientStore.subscribeConfiguration(new ConfigurationRequestItem(),TypeRef.STRING).blockFirst());
     }
 
     @Test