multiregion config files

riposte-typesafe-config/src/main/java/com/nike/riposte/typesafeconfig/TypesafeConfigServer.java

@@ -81,7 +81,7 @@ public void launchServer(String[] args) throws Exception {
     protected void infrastructureInit() {
         MainClassUtils.setupJbossLoggingToUseSlf4j();
 
-        Pair<String, String> appIdAndEnvironmentPair = MainClassUtils.getAppIdAndEnvironmentFromSystemProperties();
+        Pair<String, String> appIdAndEnvironmentPair = getAppIdAndEnvironmentPair();
         Config appConfig = TypesafeConfigUtil
             .loadConfigForAppIdAndEnvironment(appIdAndEnvironmentPair.getLeft(), appIdAndEnvironmentPair.getRight());
 
@@ -97,6 +97,19 @@ protected void infrastructureInit() {
         setAppConfig(appConfig);
     }
 
+    /**
+     * Allow the appId and Environment to be overridden when loading TypesafeConfig files.
+     * This will support resolution of different TypesafeConfig files without globally modifying the
+     * appId or environment.  This would allow region specific property files
+     * while still maintaining the same appId or environment variables.
+     *
+     * @return {@code Pair<String,String>} with the {@code Left} the appId of the TypesafeConfig to load
+     * and the {@code Right} the Environment.
+     */
+    protected Pair<String,String> getAppIdAndEnvironmentPair(){
+        return MainClassUtils.getAppIdAndEnvironmentFromSystemProperties();
+    }
+
     /**
      * Creates the {@link Server} instance using {@link #getServerConfig(Config)} and {@link #getAppConfig()}, then
      * calls {@link Server#startup()}. DO NOT CALL THIS DIRECTLY. Use {@link #launchServer(String[])} when you're ready

riposte-typesafe-config/src/test/java/com/nike/riposte/typesafeconfig/TypesafeConfigServerTest.java

@@ -1,5 +1,6 @@
 package com.nike.riposte.typesafeconfig;
 
+import com.nike.internal.util.Pair;
 import com.nike.riposte.server.config.ServerConfig;
 import com.nike.riposte.server.http.Endpoint;
 import com.nike.riposte.server.http.RequestInfo;
@@ -21,6 +22,7 @@
 import java.util.Collections;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.Executor;
+import java.util.concurrent.atomic.AtomicBoolean;
 
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.util.ResourceLeakDetector;
@@ -115,6 +117,30 @@ public void verify_essential_behavior() throws Exception {
         assertThat(ResourceLeakDetector.getLevel()).isEqualTo(ResourceLeakDetector.Level.PARANOID);
     }
 
+    @Test
+    public void getAppIdAndEnvironmentPair(){
+        // given
+        setAppAndEnvironment("typesafeconfigserver", "compiletimetest");
+
+        AtomicBoolean called = new AtomicBoolean(false);
+        // when
+        TypesafeConfigServer server = new TypesafeConfigServer(){
+            protected ServerConfig getServerConfig(Config appConfig){
+                return null;
+            }
+
+            @Override
+            protected Pair<String, String> getAppIdAndEnvironmentPair() {
+                called.set(true);
+                return super.getAppIdAndEnvironmentPair();
+            }
+        };
+        server.infrastructureInit();
+
+        // then (verify that getAppIdAndEnvironmentPair was called from infrastructureInit)
+        assertThat(called.get()).isTrue();
+    }
+
     private static class SomeEndpoint extends StandardEndpoint<Void, String> {
 
         public static final String MATCHING_PATH = "/typesafeConfigValue";