package config import ( "os" "runtime" "testing" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/suite" ) // Test file is missing func TestMissingFile(t *testing.T) { filename := "test" _, err := LoadConf(filename) assert.NotNil(t, err) } type ConfigTestSuite struct { suite.Suite ConfGorushDefault ConfYaml ConfGorush ConfYaml } func (suite *ConfigTestSuite) SetupTest() { var err error suite.ConfGorushDefault, err = LoadConf("") if err != nil { panic("failed to load default config.yml") } suite.ConfGorush, err = LoadConf("config.yml") if err != nil { panic("failed to load config.yml from file") } } func (suite *ConfigTestSuite) TestValidateConfDefault() { // Core assert.Equal(suite.T(), "", suite.ConfGorushDefault.Core.Address) assert.Equal(suite.T(), "8088", suite.ConfGorushDefault.Core.Port) assert.Equal(suite.T(), true, suite.ConfGorushDefault.Core.Enabled) assert.Equal(suite.T(), int64(runtime.NumCPU()), suite.ConfGorushDefault.Core.WorkerNum) assert.Equal(suite.T(), int64(8192), suite.ConfGorushDefault.Core.QueueNum) assert.Equal(suite.T(), "release", suite.ConfGorushDefault.Core.Mode) assert.Equal(suite.T(), false, suite.ConfGorushDefault.Core.Sync) assert.Equal(suite.T(), false, suite.ConfGorushDefault.Core.SSL) assert.Equal(suite.T(), "cert.pem", suite.ConfGorushDefault.Core.CertPath) assert.Equal(suite.T(), "key.pem", suite.ConfGorushDefault.Core.KeyPath) assert.Equal(suite.T(), int64(100), suite.ConfGorushDefault.Core.MaxNotification) assert.Equal(suite.T(), "", suite.ConfGorushDefault.Core.HTTPProxy) // Pid assert.Equal(suite.T(), false, suite.ConfGorushDefault.Core.PID.Enabled) assert.Equal(suite.T(), "gorush.pid", suite.ConfGorushDefault.Core.PID.Path) assert.Equal(suite.T(), true, suite.ConfGorushDefault.Core.PID.Override) assert.Equal(suite.T(), false, suite.ConfGorushDefault.Core.AutoTLS.Enabled) assert.Equal(suite.T(), ".cache", suite.ConfGorushDefault.Core.AutoTLS.Folder) assert.Equal(suite.T(), "", suite.ConfGorushDefault.Core.AutoTLS.Host) // Api assert.Equal(suite.T(), "/api/push", suite.ConfGorushDefault.API.PushURI) assert.Equal(suite.T(), "/api/stat/go", suite.ConfGorushDefault.API.StatGoURI) assert.Equal(suite.T(), "/api/stat/app", suite.ConfGorushDefault.API.StatAppURI) assert.Equal(suite.T(), "/api/config", suite.ConfGorushDefault.API.ConfigURI) assert.Equal(suite.T(), "/sys/stats", suite.ConfGorushDefault.API.SysStatURI) assert.Equal(suite.T(), "/metrics", suite.ConfGorushDefault.API.MetricURI) // Android assert.Equal(suite.T(), true, suite.ConfGorushDefault.Android.Enabled) assert.Equal(suite.T(), "YOUR_API_KEY", suite.ConfGorushDefault.Android.APIKey) assert.Equal(suite.T(), 0, suite.ConfGorushDefault.Android.MaxRetry) // iOS assert.Equal(suite.T(), false, suite.ConfGorushDefault.Ios.Enabled) assert.Equal(suite.T(), "key.pem", suite.ConfGorushDefault.Ios.KeyPath) assert.Equal(suite.T(), "", suite.ConfGorushDefault.Ios.Password) assert.Equal(suite.T(), false, suite.ConfGorushDefault.Ios.Production) assert.Equal(suite.T(), 0, suite.ConfGorushDefault.Ios.MaxRetry) assert.Equal(suite.T(), "", suite.ConfGorushDefault.Ios.KeyID) assert.Equal(suite.T(), "", suite.ConfGorushDefault.Ios.TeamID) // log assert.Equal(suite.T(), "string", suite.ConfGorushDefault.Log.Format) assert.Equal(suite.T(), "stdout", suite.ConfGorushDefault.Log.AccessLog) assert.Equal(suite.T(), "debug", suite.ConfGorushDefault.Log.AccessLevel) assert.Equal(suite.T(), "stderr", suite.ConfGorushDefault.Log.ErrorLog) assert.Equal(suite.T(), "error", suite.ConfGorushDefault.Log.ErrorLevel) assert.Equal(suite.T(), true, suite.ConfGorushDefault.Log.HideToken) assert.Equal(suite.T(), "memory", suite.ConfGorushDefault.Stat.Engine) assert.Equal(suite.T(), "localhost:6379", suite.ConfGorushDefault.Stat.Redis.Addr) assert.Equal(suite.T(), "", suite.ConfGorushDefault.Stat.Redis.Password) assert.Equal(suite.T(), 0, suite.ConfGorushDefault.Stat.Redis.DB) assert.Equal(suite.T(), "bolt.db", suite.ConfGorushDefault.Stat.BoltDB.Path) assert.Equal(suite.T(), "gorush", suite.ConfGorushDefault.Stat.BoltDB.Bucket) assert.Equal(suite.T(), "bunt.db", suite.ConfGorushDefault.Stat.BuntDB.Path) assert.Equal(suite.T(), "level.db", suite.ConfGorushDefault.Stat.LevelDB.Path) // gRPC assert.Equal(suite.T(), false, suite.ConfGorushDefault.GRPC.Enabled) assert.Equal(suite.T(), "9000", suite.ConfGorushDefault.GRPC.Port) } func (suite *ConfigTestSuite) TestValidateConf() { // Core assert.Equal(suite.T(), "8088", suite.ConfGorush.Core.Port) assert.Equal(suite.T(), true, suite.ConfGorush.Core.Enabled) assert.Equal(suite.T(), int64(runtime.NumCPU()), suite.ConfGorush.Core.WorkerNum) assert.Equal(suite.T(), int64(8192), suite.ConfGorush.Core.QueueNum) assert.Equal(suite.T(), "release", suite.ConfGorush.Core.Mode) assert.Equal(suite.T(), false, suite.ConfGorush.Core.Sync) assert.Equal(suite.T(), false, suite.ConfGorush.Core.SSL) assert.Equal(suite.T(), "cert.pem", suite.ConfGorush.Core.CertPath) assert.Equal(suite.T(), "key.pem", suite.ConfGorush.Core.KeyPath) assert.Equal(suite.T(), int64(100), suite.ConfGorush.Core.MaxNotification) assert.Equal(suite.T(), "", suite.ConfGorush.Core.HTTPProxy) // Pid assert.Equal(suite.T(), false, suite.ConfGorush.Core.PID.Enabled) assert.Equal(suite.T(), "gorush.pid", suite.ConfGorush.Core.PID.Path) assert.Equal(suite.T(), true, suite.ConfGorush.Core.PID.Override) assert.Equal(suite.T(), false, suite.ConfGorush.Core.AutoTLS.Enabled) assert.Equal(suite.T(), ".cache", suite.ConfGorush.Core.AutoTLS.Folder) assert.Equal(suite.T(), "", suite.ConfGorush.Core.AutoTLS.Host) // Api assert.Equal(suite.T(), "/api/push", suite.ConfGorush.API.PushURI) assert.Equal(suite.T(), "/api/stat/go", suite.ConfGorush.API.StatGoURI) assert.Equal(suite.T(), "/api/stat/app", suite.ConfGorush.API.StatAppURI) assert.Equal(suite.T(), "/api/config", suite.ConfGorush.API.ConfigURI) assert.Equal(suite.T(), "/sys/stats", suite.ConfGorush.API.SysStatURI) assert.Equal(suite.T(), "/metrics", suite.ConfGorush.API.MetricURI) // Android assert.Equal(suite.T(), true, suite.ConfGorush.Android.Enabled) assert.Equal(suite.T(), "YOUR_API_KEY", suite.ConfGorush.Android.APIKey) assert.Equal(suite.T(), 0, suite.ConfGorush.Android.MaxRetry) // iOS assert.Equal(suite.T(), false, suite.ConfGorush.Ios.Enabled) assert.Equal(suite.T(), "key.pem", suite.ConfGorush.Ios.KeyPath) assert.Equal(suite.T(), "", suite.ConfGorush.Ios.Password) assert.Equal(suite.T(), false, suite.ConfGorush.Ios.Production) assert.Equal(suite.T(), 0, suite.ConfGorush.Ios.MaxRetry) assert.Equal(suite.T(), "", suite.ConfGorush.Ios.KeyID) assert.Equal(suite.T(), "", suite.ConfGorush.Ios.TeamID) // log assert.Equal(suite.T(), "string", suite.ConfGorush.Log.Format) assert.Equal(suite.T(), "stdout", suite.ConfGorush.Log.AccessLog) assert.Equal(suite.T(), "debug", suite.ConfGorush.Log.AccessLevel) assert.Equal(suite.T(), "stderr", suite.ConfGorush.Log.ErrorLog) assert.Equal(suite.T(), "error", suite.ConfGorush.Log.ErrorLevel) assert.Equal(suite.T(), true, suite.ConfGorush.Log.HideToken) assert.Equal(suite.T(), "memory", suite.ConfGorush.Stat.Engine) assert.Equal(suite.T(), "localhost:6379", suite.ConfGorush.Stat.Redis.Addr) assert.Equal(suite.T(), "", suite.ConfGorush.Stat.Redis.Password) assert.Equal(suite.T(), 0, suite.ConfGorush.Stat.Redis.DB) assert.Equal(suite.T(), "bolt.db", suite.ConfGorush.Stat.BoltDB.Path) assert.Equal(suite.T(), "gorush", suite.ConfGorush.Stat.BoltDB.Bucket) assert.Equal(suite.T(), "bunt.db", suite.ConfGorush.Stat.BuntDB.Path) assert.Equal(suite.T(), "level.db", suite.ConfGorush.Stat.LevelDB.Path) // gRPC assert.Equal(suite.T(), false, suite.ConfGorush.GRPC.Enabled) assert.Equal(suite.T(), "9000", suite.ConfGorush.GRPC.Port) } func TestConfigTestSuite(t *testing.T) { suite.Run(t, new(ConfigTestSuite)) } func TestLoadConfigFromEnv(t *testing.T) { os.Setenv("GORUSH_CORE_PORT", "9001") os.Setenv("GORUSH_GRPC_ENABLED", "true") os.Setenv("GORUSH_CORE_MAX_NOTIFICATION", "200") os.Setenv("GORUSH_IOS_KEY_ID", "ABC123DEFG") os.Setenv("GORUSH_IOS_TEAM_ID", "DEF123GHIJ") ConfGorush, err := LoadConf("config.yml") if err != nil { panic("failed to load config.yml from file") } assert.Equal(t, "9001", ConfGorush.Core.Port) assert.Equal(t, int64(200), ConfGorush.Core.MaxNotification) assert.True(t, ConfGorush.GRPC.Enabled) assert.Equal(t, "ABC123DEFG", ConfGorush.Ios.KeyID) assert.Equal(t, "DEF123GHIJ", ConfGorush.Ios.TeamID) }