Fill with secret

Author: juancgalvis

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/RabbitMqConfig.java

@@ -225,4 +225,11 @@ public HandlerRegistry defaultHandlerRegistry() {
         return HandlerRegistry.register();
     }
 
+    @Bean
+    @ConditionalOnMissingBean(AsyncPropsDomain.SecretFiller.class)
+    public AsyncPropsDomain.SecretFiller defaultSecretFiller() {
+        return ignored -> {
+        };
+    }
+
 }

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/props/AsyncProps.java

@@ -17,6 +17,7 @@
 @Builder
 public class AsyncProps {
     private String appName;
+    private String secret;
 
     @NestedConfigurationProperty
     @Builder.Default

async/async-rabbit-starter-eda/src/main/java/org/reactivecommons/async/rabbit/config/props/AsyncPropsDomain.java

@@ -5,6 +5,7 @@
 import org.reactivecommons.async.rabbit.config.RabbitProperties;
 import org.reactivecommons.async.rabbit.config.exceptions.InvalidConfigurationException;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.util.StringUtils;
 
 import java.util.HashMap;
 
@@ -15,7 +16,8 @@
 public class AsyncPropsDomain extends HashMap<String, AsyncProps> {
     public AsyncPropsDomain(@Value("${spring.application.name}") String defaultAppName,
                             RabbitProperties defaultRabbitProperties,
-                            AsyncPropsDomainProperties configured) {
+                            AsyncPropsDomainProperties configured,
+                            SecretFiller secretFiller) {
         super(configured);
         this.computeIfAbsent(DEFAULT_DOMAIN, k -> new AsyncProps());
         super.forEach((key, value) -> { // To ensure that each domain has an appName
@@ -38,6 +40,9 @@ public AsyncPropsDomain(@Value("${spring.application.name}") String defaultAppNa
             if (value.getBrokerConfigProps() == null) {
                 value.setBrokerConfigProps(new BrokerConfigProps(value));
             }
+            if (StringUtils.hasText(value.getSecret()) && secretFiller != null) {
+                secretFiller.fillWithSecret(value);
+            }
         });
     }
 
@@ -56,6 +61,7 @@ public static AsyncPropsDomainBuilder builder() {
     public static class AsyncPropsDomainBuilder {
         private String defaultAppName;
         private RabbitProperties defaultRabbitProperties;
+        private SecretFiller secretFiller;
         private final HashMap<String, AsyncProps> domains = new HashMap<>();
 
 
@@ -70,6 +76,12 @@ public AsyncPropsDomainBuilder withDefaultAppName(String defaultAppName) {
             return this;
         }
 
+
+        public AsyncPropsDomainBuilder withSecretFiller(SecretFiller secretFiller) {
+            this.secretFiller = secretFiller;
+            return this;
+        }
+
         public AsyncPropsDomainBuilder withDomain(String domain, AsyncProps props) {
             domains.put(domain, props);
             return this;
@@ -80,9 +92,13 @@ public AsyncPropsDomain build() {
             if (defaultRabbitProperties == null) {
                 defaultRabbitProperties = new RabbitProperties();
             }
-            return new AsyncPropsDomain(defaultAppName, defaultRabbitProperties, domainProperties);
+            return new AsyncPropsDomain(defaultAppName, defaultRabbitProperties, domainProperties, secretFiller);
         }
 
     }
 
+    public interface SecretFiller {
+        void fillWithSecret(AsyncProps props);
+    }
+
 }