1 files changed, 82 insertions, 3 deletions
diff --git a/tests/plugins/config/config_test.go b/tests/plugins/config/config_test.go
index dc387086..a0c2932b 100755
--- a/tests/plugins/config/config_test.go
+++ b/tests/plugins/config/config_test.go
@@ -19,7 +19,7 @@ func TestViperProvider_Init(t *testing.T) {
 		t.Fatal(err)
 	}
 	vp := &config.Viper{}
-	vp.Path = ".rr.yaml"
+	vp.Path = "configs/.rr.yaml"
 	vp.Prefix = "rr"
 	vp.Flags = nil
 
@@ -73,7 +73,7 @@ func TestConfigOverwriteFail(t *testing.T) {
 		t.Fatal(err)
 	}
 	vp := &config.Viper{}
-	vp.Path = ".rr.yaml"
+	vp.Path = "configs/.rr.yaml"
 	vp.Prefix = "rr"
 	vp.Flags = []string{"rpc.listen=tcp//not_exist"}
 
@@ -95,7 +95,7 @@ func TestConfigOverwriteValid(t *testing.T) {
 		t.Fatal(err)
 	}
 	vp := &config.Viper{}
-	vp.Path = ".rr.yaml"
+	vp.Path = "configs/.rr.yaml"
 	vp.Prefix = "rr"
 	vp.Flags = []string{"rpc.listen=tcp://localhost:6061"}
 
@@ -136,3 +136,82 @@ func TestConfigOverwriteValid(t *testing.T) {
 		}
 	}
 }
+
+func TestConfigEnvVariables(t *testing.T) {
+	container, err := endure.NewContainer(nil, endure.RetryOnFail(false), endure.SetLogLevel(endure.ErrorLevel))
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	err = os.Setenv("SUPER_RPC_ENV", "tcp://localhost:6061")
+	assert.NoError(t, err)
+
+	vp := &config.Viper{}
+	vp.Path = "configs/.rr-env.yaml"
+	vp.Prefix = "rr"
+
+	err = container.RegisterAll(
+		&logger.ZapLogger{},
+		&rpc.Plugin{},
+		vp,
+		&Foo2{},
+	)
+	assert.NoError(t, err)
+
+	err = container.Init()
+	assert.NoError(t, err)
+
+	errCh, err := container.Serve()
+	assert.NoError(t, err)
+
+	// stop by CTRL+C
+	c := make(chan os.Signal, 1)
+	signal.Notify(c, os.Interrupt)
+
+	tt := time.NewTicker(time.Second * 3)
+	defer tt.Stop()
+
+	for {
+		select {
+		case e := <-errCh:
+			assert.NoError(t, e.Error)
+			assert.NoError(t, container.Stop())
+			return
+		case <-c:
+			er := container.Stop()
+			assert.NoError(t, er)
+			return
+		case <-tt.C:
+			assert.NoError(t, container.Stop())
+			return
+		}
+	}
+}
+
+func TestConfigEnvVariablesFail(t *testing.T) {
+	container, err := endure.NewContainer(nil, endure.RetryOnFail(false), endure.SetLogLevel(endure.ErrorLevel))
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	err = os.Setenv("SUPER_RPC_ENV", "tcp://localhost:6065")
+	assert.NoError(t, err)
+
+	vp := &config.Viper{}
+	vp.Path = "configs/.rr-env.yaml"
+	vp.Prefix = "rr"
+
+	err = container.RegisterAll(
+		&logger.ZapLogger{},
+		&rpc.Plugin{},
+		vp,
+		&Foo2{},
+	)
+	assert.NoError(t, err)
+
+	err = container.Init()
+	assert.NoError(t, err)
+
+	_, err = container.Serve()
+	assert.Error(t, err)
+}