61 lines
1.0 KiB
Go
61 lines
1.0 KiB
Go
|
package config
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
"os"
|
||
|
|
"path/filepath"
|
||
|
|
"testing"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"github.com/micro/go-micro/config/source/env"
|
||
|
|
"github.com/micro/go-micro/config/source/file"
|
||
|
|
)
|
||
|
|
|
||
|
|
func createFileForIssue18(t *testing.T, content string) *os.File {
|
||
|
|
data := []byte(content)
|
||
|
|
path := filepath.Join(os.TempDir(), fmt.Sprintf("file.%d", time.Now().UnixNano()))
|
||
|
|
fh, err := os.Create(path)
|
||
|
|
if err != nil {
|
||
|
|
t.Error(err)
|
||
|
|
}
|
||
|
|
_, err = fh.Write(data)
|
||
|
|
if err != nil {
|
||
|
|
t.Error(err)
|
||
|
|
}
|
||
|
|
|
||
|
|
return fh
|
||
|
|
}
|
||
|
|
|
||
|
|
func TestIssue18(t *testing.T) {
|
||
|
|
fh := createFileForIssue18(t, `{
|
||
|
|
"amqp": {
|
||
|
|
"host": "rabbit.platform",
|
||
|
|
"port": 80
|
||
|
|
},
|
||
|
|
"handler": {
|
||
|
|
"exchange": "springCloudBus"
|
||
|
|
}
|
||
|
|
}`)
|
||
|
|
path := fh.Name()
|
||
|
|
defer func() {
|
||
|
|
fh.Close()
|
||
|
|
os.Remove(path)
|
||
|
|
}()
|
||
|
|
os.Setenv("AMQP_HOST", "rabbit.testing.com")
|
||
|
|
|
||
|
|
conf := NewConfig()
|
||
|
|
conf.Load(
|
||
|
|
file.NewSource(
|
||
|
|
file.WithPath(path),
|
||
|
|
),
|
||
|
|
env.NewSource(),
|
||
|
|
)
|
||
|
|
|
||
|
|
actualHost := conf.Get("amqp", "host").String("backup")
|
||
|
|
if actualHost != "rabbit.testing.com" {
|
||
|
|
t.Fatalf("Expected %v but got %v",
|
||
|
|
"rabbit.testing.com",
|
||
|
|
actualHost)
|
||
|
|
}
|
||
|
|
}
|