diff options
Diffstat (limited to 'src/main/java/at/gv/egiz/moazs')
-rw-r--r-- | src/main/java/at/gv/egiz/moazs/App2MzsService.java | 1 | ||||
-rw-r--r-- | src/main/java/at/gv/egiz/moazs/config/DeliveryRequestAugmenterConfig.java | 25 | ||||
-rw-r--r-- | src/main/java/at/gv/egiz/moazs/preprocess/ConfigProfileGenerator.java | 87 | ||||
-rw-r--r-- | src/main/java/at/gv/egiz/moazs/preprocess/DeliveryRequestAugmenter.java (renamed from src/main/java/at/gv/egiz/moazs/DeliveryRequestAugmenter.java) | 11 |
4 files changed, 101 insertions, 23 deletions
diff --git a/src/main/java/at/gv/egiz/moazs/App2MzsService.java b/src/main/java/at/gv/egiz/moazs/App2MzsService.java index 622f1dc..19eb856 100644 --- a/src/main/java/at/gv/egiz/moazs/App2MzsService.java +++ b/src/main/java/at/gv/egiz/moazs/App2MzsService.java @@ -1,6 +1,7 @@ package at.gv.egiz.moazs; import at.gv.egiz.moazs.pipeline.DeliveryPipeline; +import at.gv.egiz.moazs.preprocess.DeliveryRequestAugmenter; import at.gv.egiz.moazs.repository.DeliveryRepository; import at.gv.zustellung.app2mzs.xsd.App2MzsPortType; import at.gv.zustellung.app2mzs.xsd.DeliveryRequestType; diff --git a/src/main/java/at/gv/egiz/moazs/config/DeliveryRequestAugmenterConfig.java b/src/main/java/at/gv/egiz/moazs/config/DeliveryRequestAugmenterConfig.java index 93615c4..d5b52c5 100644 --- a/src/main/java/at/gv/egiz/moazs/config/DeliveryRequestAugmenterConfig.java +++ b/src/main/java/at/gv/egiz/moazs/config/DeliveryRequestAugmenterConfig.java @@ -1,31 +1,20 @@ package at.gv.egiz.moazs.config; +import at.gv.egiz.moazs.preprocess.ConfigProfileGenerator; import at.gv.zustellung.app2mzs.xsd.ConfigType; -import org.springframework.beans.factory.annotation.Value; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; -import static at.gv.zustellung.app2mzs.xsd.ConfigType.configTypeBuilder; -import static at.gv.zustellung.app2mzs.xsd.ServerType.serverTypeBuilder; +import java.util.Map; @Configuration public class DeliveryRequestAugmenterConfig { - - @Value("${msg.default.url}") - private String zuseUrlID; - @Bean - public ConfigType defaultMzsConfig() { - - var server = serverTypeBuilder() - .withZUSEUrlID(zuseUrlID) - .withX509(null) //todo load cert! - .build(); - - return configTypeBuilder() - .withPerformQueryPersonRequest(false) - .withServer(server) - .build(); + @Autowired + Map<String, ConfigType> deliveryRequestConfigs(ConfigProfileGenerator generator) { + return generator.generate(); } + } diff --git a/src/main/java/at/gv/egiz/moazs/preprocess/ConfigProfileGenerator.java b/src/main/java/at/gv/egiz/moazs/preprocess/ConfigProfileGenerator.java new file mode 100644 index 0000000..cba776d --- /dev/null +++ b/src/main/java/at/gv/egiz/moazs/preprocess/ConfigProfileGenerator.java @@ -0,0 +1,87 @@ +package at.gv.egiz.moazs.preprocess; + +import at.gv.zustellung.app2mzs.xsd.ConfigType; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.core.env.AbstractEnvironment; +import org.springframework.core.env.EnumerablePropertySource; +import org.springframework.core.env.Environment; +import org.springframework.core.env.MutablePropertySources; +import org.springframework.stereotype.Component; + +import java.util.Arrays; +import java.util.HashMap; +import java.util.Map; +import java.util.Map.Entry; +import java.util.Set; +import java.util.stream.Collectors; +import java.util.stream.StreamSupport; + +import static at.gv.zustellung.app2mzs.xsd.ConfigType.configTypeBuilder; +import static at.gv.zustellung.app2mzs.xsd.ServerType.serverTypeBuilder; +import static java.util.stream.Collectors.toMap; + +@Component +public class ConfigProfileGenerator { + + @Autowired + private Environment env; + + private final String profilePrefix = "delivery-request-configuration-profiles."; + private final String tnvzRequestKey = "perform-query-person-request"; + private final String msgUrlKey = "msg.url"; + + public Map<String, ConfigType> generate() { + MutablePropertySources propSrcs = ((AbstractEnvironment) env).getPropertySources(); + + Map<String, Set<String>> groupedKeys = StreamSupport.stream(propSrcs.spliterator(), false) + .filter(ps -> ps instanceof EnumerablePropertySource) + .map(ps -> ((EnumerablePropertySource) ps).getPropertyNames()) + .flatMap(Arrays::stream) + .filter(propName -> propName.startsWith(profilePrefix)) + .map(name -> name.substring(name.indexOf(".") + 1)) + .collect( + Collectors.groupingBy( + this::keepPrefix, + Collectors.mapping( + this::removePrefix, + Collectors.toSet()))); + + return groupedKeys.entrySet().stream() + .collect(toMap(Entry::getKey, this::createConfig)); + } + + private String keepPrefix(String name) { + return name.substring(0, name.indexOf(".")); + } + + private String removePrefix(String name) { + return name.substring(name.indexOf(".") + 1); + } + + private ConfigType createConfig(Entry<String, Set<String>> entry) { + + var profile = entry.getKey(); + + var values = new HashMap<String,String>(); + + entry.getValue().stream() + .forEach(key -> { + var assembledKey = profilePrefix + "." + profile + "." + key; + var value = env.getProperty(assembledKey); + values.put(key, value); + }); + + var server = serverTypeBuilder() + .withZUSEUrlID(values.get(msgUrlKey)) + .build(); + + Boolean performQueryPersonRequest = values.get(tnvzRequestKey) == null + ? null : Boolean.getBoolean(values.get(tnvzRequestKey)); + + return configTypeBuilder() + .withPerformQueryPersonRequest(performQueryPersonRequest) + .withServer(server) + .build(); + } + +} diff --git a/src/main/java/at/gv/egiz/moazs/DeliveryRequestAugmenter.java b/src/main/java/at/gv/egiz/moazs/preprocess/DeliveryRequestAugmenter.java index 96197d0..623af38 100644 --- a/src/main/java/at/gv/egiz/moazs/DeliveryRequestAugmenter.java +++ b/src/main/java/at/gv/egiz/moazs/preprocess/DeliveryRequestAugmenter.java @@ -1,4 +1,4 @@ -package at.gv.egiz.moazs; +package at.gv.egiz.moazs.preprocess; import at.gv.zustellung.app2mzs.xsd.ConfigType; import at.gv.zustellung.app2mzs.xsd.DeliveryRequestType; @@ -7,9 +7,10 @@ import at.gv.zustellung.app2mzs.xsd.ServerType; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; -import static at.gv.egiz.moazs.util.NullCoalesce.coalesce; +import java.util.Map; + import static at.gv.zustellung.app2mzs.xsd.ConfigType.configTypeBuilder; -import static at.gv.zustellung.app2mzs.xsd.ServerType.*; +import static at.gv.zustellung.app2mzs.xsd.ServerType.serverTypeBuilder; @Component public class DeliveryRequestAugmenter { @@ -17,8 +18,8 @@ public class DeliveryRequestAugmenter { private final ConfigType defaultMzsConfig; @Autowired - public DeliveryRequestAugmenter(ConfigType defaultMzsConfig) { - this.defaultMzsConfig = defaultMzsConfig; + public DeliveryRequestAugmenter(Map<String, ConfigType> deliveryRequestConfigs) { + this.defaultMzsConfig = deliveryRequestConfigs.get("default"); } /** |