bugfix/sourceUrl configuration

Former-commit-id: 42c1159

Author: YunaBraska

README.md

@@ -38,12 +38,11 @@ nats.server.hb_fail_count=3
 ```yaml
 nats:
   source:
-    default: "https://nats-linux.zip"
-```
-```yaml
-nats:
-  source:
-    default: "file://${user.dir}/src/test/resources/natsserver/mac.zip"
+    mac: "https://nats-mac.zip"
+    linux: "https://nats-linux.zip"
+    solaris: "https://nats-solaris.zip"
+    windows: "https://nats-windows.zip"
+    default: "file://${user.dir}/nats-foo-bar.zip"
 ```
 
 ### TODO

pom.xml

@@ -12,7 +12,7 @@
 
     <groupId>berlin.yuna</groupId>
     <artifactId>nats-streaming-server-embedded</artifactId>
-    <version>0.4.3</version>
+    <version>0.4.4</version>
     <packaging>jar</packaging>
 
     <name>${project.artifactId}</name>

src/main/java/berlin/yuna/natsserver/annotation/EnableNatsServerContextCustomizer.java

@@ -2,6 +2,7 @@
 
 import berlin.yuna.natsserver.config.NatsServerConfig;
 import berlin.yuna.natsserver.logic.NatsServer;
+import berlin.yuna.system.logic.SystemUtil;
 import org.slf4j.Logger;
 import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
 import org.springframework.beans.factory.support.DefaultSingletonBeanRegistry;
@@ -51,7 +52,7 @@ public void customizeContext(ConfigurableApplicationContext context, MergedConte
 
         NatsServer natsServerBean = new NatsServer(enableNatsServer.natsServerConfig());
         natsServerBean.port(overwritePort(natsServerBean));
-        String sourceUrl = environment.getProperty("nats.source.default");
+        String sourceUrl = overwriteSourceUrl(environment, natsServerBean.source());
         natsServerBean.source(isEmpty(sourceUrl) ? natsServerBean.source() : sourceUrl);
         natsServerBean.setNatsServerConfig(mergeConfig(environment, natsServerBean.getNatsServerConfig()));
 
@@ -67,6 +68,10 @@ public void customizeContext(ConfigurableApplicationContext context, MergedConte
         ((DefaultSingletonBeanRegistry) beanFactory).registerDisposableBean(NatsServer.BEAN_NAME, natsServerBean);
     }
 
+    private String overwriteSourceUrl(final ConfigurableEnvironment environment, final String fallback) {
+        return environment.getProperty("nats.source.default", environment.getProperty("nats.source." + SystemUtil.getOsType().toString().toLowerCase(), fallback));
+    }
+
     private int overwritePort(NatsServer natsServerBean) {
         return enableNatsServer.port() != (Integer) NatsServerConfig.PORT.getDefaultValue() ? enableNatsServer.port() : natsServerBean.port();
     }