settings.go 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125
  1. package settings
  2. import (
  3. "github.com/caarlos0/env/v11"
  4. "github.com/spf13/cast"
  5. "gopkg.in/ini.v1"
  6. "log"
  7. "os"
  8. "reflect"
  9. "strings"
  10. "time"
  11. )
  12. var (
  13. buildTime string
  14. LastModified string
  15. Conf *ini.File
  16. ConfPath string
  17. EnvPrefix = "NGINX_UI_"
  18. )
  19. var sections = map[string]interface{}{
  20. "server": &ServerSettings,
  21. "nginx": &NginxSettings,
  22. "openai": &OpenAISettings,
  23. "casdoor": &CasdoorSettings,
  24. "logrotate": &LogrotateSettings,
  25. }
  26. func init() {
  27. t := time.Unix(cast.ToInt64(buildTime), 0)
  28. LastModified = strings.ReplaceAll(t.Format(time.RFC1123), "UTC", "GMT")
  29. }
  30. func Init(confPath string) {
  31. ConfPath = confPath
  32. Setup()
  33. }
  34. func Setup() {
  35. var err error
  36. Conf, err = ini.LooseLoad(ConfPath)
  37. if err != nil {
  38. log.Fatalf("settings.Setup: %v\n", err)
  39. }
  40. MapTo()
  41. parseEnv(&ServerSettings, "SERVER_")
  42. parseEnv(&NginxSettings, "NGINX_")
  43. parseEnv(&OpenAISettings, "OPENAI_")
  44. parseEnv(&CasdoorSettings, "CASDOOR_")
  45. parseEnv(&LogrotateSettings, "LOGROTATE_")
  46. // if in official docker, set the restart cmd of nginx to "nginx -s stop",
  47. // then the supervisor of s6-overlay will start the nginx again.
  48. if cast.ToBool(os.Getenv("NGINX_UI_OFFICIAL_DOCKER")) {
  49. NginxSettings.RestartCmd = "nginx -s stop"
  50. }
  51. err = Save()
  52. if err != nil {
  53. log.Fatalf("settings.Setup: %v\n", err)
  54. }
  55. }
  56. func MapTo() {
  57. for k, v := range sections {
  58. mapTo(k, v)
  59. }
  60. }
  61. func Save() (err error) {
  62. for k, v := range sections {
  63. reflectFrom(k, v)
  64. }
  65. err = Conf.SaveTo(ConfPath)
  66. if err != nil {
  67. return
  68. }
  69. return
  70. }
  71. func ProtectedFill(targetSettings interface{}, newSettings interface{}) {
  72. s := reflect.TypeOf(targetSettings).Elem()
  73. vt := reflect.ValueOf(targetSettings).Elem()
  74. vn := reflect.ValueOf(newSettings).Elem()
  75. // copy the values from new to target settings if it is not protected
  76. for i := 0; i < s.NumField(); i++ {
  77. if s.Field(i).Tag.Get("protected") != "true" {
  78. vt.Field(i).Set(vn.Field(i))
  79. }
  80. }
  81. }
  82. func mapTo(section string, v interface{}) {
  83. err := Conf.Section(section).MapTo(v)
  84. if err != nil {
  85. log.Fatalf("Cfg.MapTo %s err: %v", section, err)
  86. }
  87. }
  88. func reflectFrom(section string, v interface{}) {
  89. err := Conf.Section(section).ReflectFrom(v)
  90. if err != nil {
  91. log.Fatalf("Cfg.ReflectFrom %s err: %v", section, err)
  92. }
  93. }
  94. func parseEnv(ptr interface{}, prefix string) {
  95. err := env.ParseWithOptions(ptr, env.Options{
  96. Prefix: EnvPrefix + prefix,
  97. UseFieldNameByDefault: true,
  98. })
  99. if err != nil {
  100. log.Fatalf("settings.parseEnv: %v\n", err)
  101. }
  102. }