ChineseSubFinder/internal/backend/controllers/v1/daemon_things.go

package v1

import (
	"net/http"

	"github.com/allanpk716/ChineseSubFinder/internal/types/backend"
	"github.com/allanpk716/ChineseSubFinder/pkg/settings"
	"github.com/gin-gonic/gin"
)

func (cb ControllerBase) DaemonStartHandler(c *gin.Context) {
	var err error
	defer func() {
		// 统一的异常处理
		cb.ErrorProcess(c, "DaemonStartHandler", err)
	}()

	if cb.cronHelper.CronHelperRunning() == false {
		go func() {
			cb.cronHelper.Start(settings.GetSettings(true).CommonSettings.RunScanAtStartUp)
		}()
	}

	c.JSON(http.StatusOK, backend.ReplyCommon{
		Message: "ok",
	})
}

func (cb ControllerBase) DaemonStopHandler(c *gin.Context) {
	var err error
	defer func() {
		// 统一的异常处理
		cb.ErrorProcess(c, "DaemonStopHandler", err)
	}()

	if cb.cronHelper.CronHelperRunning() == true {
		go func() {
			cb.cronHelper.Stop()
		}()
	}

	c.JSON(http.StatusOK, backend.ReplyCommon{
		Message: "ok",
	})
}

func (cb ControllerBase) DaemonStatusHandler(c *gin.Context) {
	var err error
	defer func() {
		// 统一的异常处理
		cb.ErrorProcess(c, "DaemonStatusHandler", err)
	}()

	c.JSON(http.StatusOK, backend.ReplyJobStatus{
		Status: cb.cronHelper.CronRunningStatusString(),
	})
}