Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/MHSanaei/3x-ui.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMHSanaei <mc.sanaei@gmail.com>2023-02-09 22:18:06 +0300
committerMHSanaei <mc.sanaei@gmail.com>2023-02-09 22:18:06 +0300
commitb73e4173a3c1e69e02ad6b4e3b43e425e57a5be9 (patch)
treed95d2f5e903d97082e11eb9f9023c165b1bde388 /web/controller/server.go
3x-ui
Diffstat (limited to 'web/controller/server.go')
-rw-r--r--web/controller/server.go85
1 files changed, 85 insertions, 0 deletions
diff --git a/web/controller/server.go b/web/controller/server.go
new file mode 100644
index 00000000..d59b3400
--- /dev/null
+++ b/web/controller/server.go
@@ -0,0 +1,85 @@
+package controller
+
+import (
+ "github.com/gin-gonic/gin"
+ "time"
+ "x-ui/web/global"
+ "x-ui/web/service"
+)
+
+type ServerController struct {
+ BaseController
+
+ serverService service.ServerService
+
+ lastStatus *service.Status
+ lastGetStatusTime time.Time
+
+ lastVersions []string
+ lastGetVersionsTime time.Time
+}
+
+func NewServerController(g *gin.RouterGroup) *ServerController {
+ a := &ServerController{
+ lastGetStatusTime: time.Now(),
+ }
+ a.initRouter(g)
+ a.startTask()
+ return a
+}
+
+func (a *ServerController) initRouter(g *gin.RouterGroup) {
+ g = g.Group("/server")
+
+ g.Use(a.checkLogin)
+ g.POST("/status", a.status)
+ g.POST("/getXrayVersion", a.getXrayVersion)
+ g.POST("/installXray/:version", a.installXray)
+}
+
+func (a *ServerController) refreshStatus() {
+ a.lastStatus = a.serverService.GetStatus(a.lastStatus)
+}
+
+func (a *ServerController) startTask() {
+ webServer := global.GetWebServer()
+ c := webServer.GetCron()
+ c.AddFunc("@every 2s", func() {
+ now := time.Now()
+ if now.Sub(a.lastGetStatusTime) > time.Minute*3 {
+ return
+ }
+ a.refreshStatus()
+ })
+}
+
+func (a *ServerController) status(c *gin.Context) {
+ a.lastGetStatusTime = time.Now()
+
+ jsonObj(c, a.lastStatus, nil)
+}
+
+func (a *ServerController) getXrayVersion(c *gin.Context) {
+ now := time.Now()
+ if now.Sub(a.lastGetVersionsTime) <= time.Minute {
+ jsonObj(c, a.lastVersions, nil)
+ return
+ }
+
+ versions, err := a.serverService.GetXrayVersions()
+ if err != nil {
+ jsonMsg(c, I18n(c , "getVersion"), err)
+ return
+ }
+
+ a.lastVersions = versions
+ a.lastGetVersionsTime = time.Now()
+
+ jsonObj(c, versions, nil)
+}
+
+func (a *ServerController) installXray(c *gin.Context) {
+ version := c.Param("version")
+ err := a.serverService.UpdateXray(version)
+ jsonMsg(c, I18n(c , "install") + " xray", err)
+}