mirror of
https://github.com/acepanel/panel.git
synced 2026-02-04 11:27:17 +08:00
128 lines
3.3 KiB
Go
128 lines
3.3 KiB
Go
package phpmyadmin
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"regexp"
|
|
"strings"
|
|
|
|
"github.com/go-rat/chix"
|
|
"github.com/spf13/cast"
|
|
|
|
"github.com/TheTNB/panel/internal/app"
|
|
"github.com/TheTNB/panel/internal/service"
|
|
"github.com/TheTNB/panel/pkg/firewall"
|
|
"github.com/TheTNB/panel/pkg/io"
|
|
"github.com/TheTNB/panel/pkg/shell"
|
|
"github.com/TheTNB/panel/pkg/systemctl"
|
|
)
|
|
|
|
type Service struct{}
|
|
|
|
func NewService() *Service {
|
|
return &Service{}
|
|
}
|
|
|
|
func (s *Service) Info(w http.ResponseWriter, r *http.Request) {
|
|
files, err := io.ReadDir(fmt.Sprintf("%s/server/phpmyadmin", app.Root))
|
|
if err != nil {
|
|
service.Error(w, http.StatusInternalServerError, "找不到 phpMyAdmin 目录")
|
|
return
|
|
}
|
|
|
|
var phpmyadmin string
|
|
for _, f := range files {
|
|
if strings.HasPrefix(f.Name(), "phpmyadmin_") {
|
|
phpmyadmin = f.Name()
|
|
}
|
|
}
|
|
if len(phpmyadmin) == 0 {
|
|
service.Error(w, http.StatusInternalServerError, "找不到 phpMyAdmin 目录")
|
|
return
|
|
}
|
|
|
|
conf, err := io.Read(fmt.Sprintf("%s/server/vhost/phpmyadmin.conf", app.Root))
|
|
if err != nil {
|
|
service.Error(w, http.StatusInternalServerError, err.Error())
|
|
return
|
|
}
|
|
match := regexp.MustCompile(`listen\s+(\d+);`).FindStringSubmatch(conf)
|
|
if len(match) == 0 {
|
|
service.Error(w, http.StatusInternalServerError, "找不到 phpMyAdmin 端口")
|
|
return
|
|
}
|
|
|
|
service.Success(w, chix.M{
|
|
"path": phpmyadmin,
|
|
"port": cast.ToInt(match[1]),
|
|
})
|
|
}
|
|
|
|
func (s *Service) UpdatePort(w http.ResponseWriter, r *http.Request) {
|
|
req, err := service.Bind[UpdatePort](r)
|
|
if err != nil {
|
|
service.Error(w, http.StatusUnprocessableEntity, err.Error())
|
|
return
|
|
}
|
|
|
|
conf, err := io.Read(fmt.Sprintf("%s/server/vhost/phpmyadmin.conf", app.Root))
|
|
if err != nil {
|
|
service.Error(w, http.StatusInternalServerError, err.Error())
|
|
return
|
|
}
|
|
conf = regexp.MustCompile(`listen\s+(\d+);`).ReplaceAllString(conf, "listen "+cast.ToString(req.Port)+";")
|
|
if err = io.Write(fmt.Sprintf("%s/server/vhost/phpmyadmin.conf", app.Root), conf, 0644); err != nil {
|
|
service.ErrorSystem(w)
|
|
return
|
|
}
|
|
|
|
fw := firewall.NewFirewall()
|
|
err = fw.Port(firewall.FireInfo{
|
|
Port: req.Port,
|
|
Protocol: "tcp",
|
|
}, firewall.OperationAdd)
|
|
if err != nil {
|
|
service.Error(w, http.StatusInternalServerError, err.Error())
|
|
return
|
|
}
|
|
|
|
if err = systemctl.Reload("openresty"); err != nil {
|
|
_, err = shell.Execf("openresty -t")
|
|
service.Error(w, http.StatusInternalServerError, fmt.Sprintf("重载OpenResty失败: %v", err))
|
|
return
|
|
}
|
|
|
|
service.Success(w, nil)
|
|
}
|
|
|
|
func (s *Service) GetConfig(w http.ResponseWriter, r *http.Request) {
|
|
config, err := io.Read(fmt.Sprintf("%s/server/vhost/phpmyadmin.conf", app.Root))
|
|
if err != nil {
|
|
service.Error(w, http.StatusInternalServerError, err.Error())
|
|
return
|
|
}
|
|
|
|
service.Success(w, config)
|
|
}
|
|
|
|
func (s *Service) UpdateConfig(w http.ResponseWriter, r *http.Request) {
|
|
req, err := service.Bind[UpdateConfig](r)
|
|
if err != nil {
|
|
service.Error(w, http.StatusUnprocessableEntity, err.Error())
|
|
return
|
|
}
|
|
|
|
if err = io.Write(fmt.Sprintf("%s/server/vhost/phpmyadmin.conf", app.Root), req.Config, 0644); err != nil {
|
|
service.Error(w, http.StatusInternalServerError, err.Error())
|
|
return
|
|
}
|
|
|
|
if err = systemctl.Reload("openresty"); err != nil {
|
|
_, err = shell.Execf("openresty -t")
|
|
service.Error(w, http.StatusInternalServerError, fmt.Sprintf("重载OpenResty失败: %v", err))
|
|
return
|
|
}
|
|
|
|
service.Success(w, nil)
|
|
}
|