list.go 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113
  1. package sites
  2. import (
  3. "net/http"
  4. "os"
  5. "path/filepath"
  6. "strings"
  7. "github.com/0xJacky/Nginx-UI/internal/config"
  8. "github.com/0xJacky/Nginx-UI/internal/nginx"
  9. "github.com/0xJacky/Nginx-UI/internal/site"
  10. "github.com/0xJacky/Nginx-UI/model"
  11. "github.com/0xJacky/Nginx-UI/query"
  12. "github.com/gin-gonic/gin"
  13. "github.com/samber/lo"
  14. "github.com/spf13/cast"
  15. "github.com/uozi-tech/cosy"
  16. )
  17. func GetSiteList(c *gin.Context) {
  18. name := c.Query("name")
  19. enabled := c.Query("enabled")
  20. orderBy := c.Query("sort_by")
  21. sort := c.DefaultQuery("order", "desc")
  22. queryEnvGroupId := cast.ToUint64(c.Query("env_group_id"))
  23. configFiles, err := os.ReadDir(nginx.GetConfPath("sites-available"))
  24. if err != nil {
  25. cosy.ErrHandler(c, err)
  26. return
  27. }
  28. enabledConfig, err := os.ReadDir(nginx.GetConfPath("sites-enabled"))
  29. if err != nil {
  30. cosy.ErrHandler(c, err)
  31. return
  32. }
  33. s := query.Site
  34. sTx := s.Preload(s.EnvGroup)
  35. if queryEnvGroupId != 0 {
  36. sTx.Where(s.EnvGroupID.Eq(queryEnvGroupId))
  37. }
  38. sites, err := sTx.Find()
  39. if err != nil {
  40. cosy.ErrHandler(c, err)
  41. return
  42. }
  43. sitesMap := lo.SliceToMap(sites, func(item *model.Site) (string, *model.Site) {
  44. return filepath.Base(item.Path), item
  45. })
  46. enabledConfigMap := make(map[string]bool)
  47. for i := range enabledConfig {
  48. enabledConfigMap[enabledConfig[i].Name()] = true
  49. }
  50. var configs []config.Config
  51. for i := range configFiles {
  52. file := configFiles[i]
  53. fileInfo, _ := file.Info()
  54. if file.IsDir() {
  55. continue
  56. }
  57. // name filter
  58. if name != "" && !strings.Contains(file.Name(), name) {
  59. continue
  60. }
  61. // status filter
  62. if enabled != "" {
  63. if enabled == "true" && !enabledConfigMap[file.Name()] {
  64. continue
  65. }
  66. if enabled == "false" && enabledConfigMap[file.Name()] {
  67. continue
  68. }
  69. }
  70. var (
  71. envGroupId uint64
  72. envGroup *model.EnvGroup
  73. )
  74. if site, ok := sitesMap[file.Name()]; ok {
  75. envGroupId = site.EnvGroupID
  76. envGroup = site.EnvGroup
  77. }
  78. // env group filter
  79. if queryEnvGroupId != 0 && envGroupId != queryEnvGroupId {
  80. continue
  81. }
  82. indexedSite := site.GetIndexedSite(file.Name())
  83. configs = append(configs, config.Config{
  84. Name: file.Name(),
  85. ModifiedAt: fileInfo.ModTime(),
  86. Size: fileInfo.Size(),
  87. IsDir: fileInfo.IsDir(),
  88. Enabled: enabledConfigMap[file.Name()],
  89. EnvGroupID: envGroupId,
  90. EnvGroup: envGroup,
  91. Urls: indexedSite.Urls,
  92. })
  93. }
  94. configs = config.Sort(orderBy, sort, configs)
  95. c.JSON(http.StatusOK, gin.H{
  96. "data": configs,
  97. })
  98. }