Fixed max replicas value (#212)

source and sink have been updated successfully, but there is an issue with the return value, fix this issue

Author: tuteng

mesh-worker-service/src/main/java/io/functionmesh/compute/util/FunctionsUtil.java

@@ -302,6 +302,10 @@ public static FunctionConfig createFunctionConfigFromV1alpha1Function(String ten
             customRuntimeOptions.setClusterName(v1alpha1FunctionSpec.getClusterName());
         }
 
+        if (v1alpha1FunctionSpec.getMaxReplicas() != null && v1alpha1FunctionSpec.getMaxReplicas() > 0) {
+            customRuntimeOptions.setMaxReplicas(v1alpha1FunctionSpec.getMaxReplicas());
+        }
+
         if (v1alpha1FunctionSpecInput.getTopics() != null) {
             for (String topic : v1alpha1FunctionSpecInput.getTopics()) {
                 ConsumerConfig consumerConfig = new ConsumerConfig();

mesh-worker-service/src/main/java/io/functionmesh/compute/util/SinksUtil.java

@@ -298,6 +298,9 @@ public static SinkConfig createSinkConfigFromV1alpha1Sink(
         if (Strings.isNotEmpty(v1alpha1SinkSpec.getClusterName())) {
             customRuntimeOptions.setClusterName(v1alpha1SinkSpec.getClusterName());
         }
+        if (v1alpha1SinkSpec.getMaxReplicas() != null && v1alpha1SinkSpec.getMaxReplicas() > 0) {
+            customRuntimeOptions.setMaxReplicas(v1alpha1SinkSpec.getMaxReplicas());
+        }
 
         if (v1alpha1SinkSpecInput.getTopics() != null) {
             for (String topic : v1alpha1SinkSpecInput.getTopics()) {

mesh-worker-service/src/main/java/io/functionmesh/compute/util/SourcesUtil.java

@@ -279,6 +279,10 @@ public static SourceConfig createSourceConfigFromV1alpha1Source(String tenant, S
             customRuntimeOptions.setClusterName(v1alpha1SourceSpec.getClusterName());
         }
 
+        if (v1alpha1SourceSpec.getMaxReplicas() != null && v1alpha1SourceSpec.getMaxReplicas() > 0) {
+            customRuntimeOptions.setMaxReplicas(v1alpha1SourceSpec.getMaxReplicas());
+        }
+
         if (v1alpha1SourceSpec.getSourceConfig() != null) {
             sourceConfig.setConfigs(new HashMap<>(v1alpha1SourceSpec.getSourceConfig()));
         }
@@ -300,6 +304,7 @@ public static SourceConfig createSourceConfigFromV1alpha1Source(String tenant, S
             sourceConfig.setRuntimeFlags(v1alpha1SourceSpec.getRuntimeFlags());
         }
 
+
         if (v1alpha1SourceSpec.getJava() != null && Strings.isNotEmpty(v1alpha1SourceSpec.getJava().getJar())) {
             sourceConfig.setArchive(v1alpha1SourceSpec.getJava().getJar());
         }

mesh-worker-service/src/test/java/io/functionmesh/compute/rest/api/SinksImpTest.java

@@ -729,7 +729,7 @@ public void testGetSinkInfo() throws ApiException, IOException {
         Double cpu = 0.1;
         Long ram = 1L;
         String clusterName = "test-pulsar";
-        String customRuntimeOptions = "{\"clusterName\":\"" + clusterName + "\",\"maxReplicas\":0}";
+        String customRuntimeOptions = "{\"clusterName\":\"" + clusterName + "\",\"maxReplicas\":1}";
         Map<String, Object> configs = new HashMap<>();
         configs.put("elasticSearchUrl", "https://testing-es.app");
 

mesh-worker-service/src/test/java/io/functionmesh/compute/rest/api/SourcesImpTest.java

@@ -756,7 +756,7 @@ public void testGetSourceInfo()
         Double cpu = 0.1;
         Long ram = 1L;
         String clusterName = "test-pulsar";
-        String customRuntimeOptions = "{\"clusterName\":\"" + clusterName + "\",\"maxReplicas\":0}";
+        String customRuntimeOptions = "{\"clusterName\":\"" + clusterName + "\",\"maxReplicas\":1}";
         Map<String, Object> configs = new HashMap<>();
         String configsName = "test-sourceConfig";
         configs.put("name", configsName);