80 lines
1.6 KiB
Go
80 lines
1.6 KiB
Go
package settings
|
|
|
|
import (
|
|
"errors"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/ihexxa/gocfg"
|
|
|
|
"github.com/ihexxa/quickshare/src/db/sitestore"
|
|
"github.com/ihexxa/quickshare/src/db/userstore"
|
|
"github.com/ihexxa/quickshare/src/depidx"
|
|
q "github.com/ihexxa/quickshare/src/handlers"
|
|
)
|
|
|
|
type SettingsSvc struct {
|
|
cfg gocfg.ICfg
|
|
deps *depidx.Deps
|
|
}
|
|
|
|
func NewSettingsSvc(cfg gocfg.ICfg, deps *depidx.Deps) (*SettingsSvc, error) {
|
|
return &SettingsSvc{
|
|
cfg: cfg,
|
|
deps: deps,
|
|
}, nil
|
|
}
|
|
|
|
func (h *SettingsSvc) Health(c *gin.Context) {
|
|
// TODO: currently it checks nothing
|
|
c.JSON(q.Resp(200))
|
|
}
|
|
|
|
type ClientCfgMsg struct {
|
|
ClientCfg *sitestore.ClientConfig `json:"clientCfg"`
|
|
}
|
|
|
|
func (h *SettingsSvc) GetClientCfg(c *gin.Context) {
|
|
// TODO: add cache
|
|
siteCfg, err := h.deps.SiteStore().GetCfg()
|
|
if err != nil {
|
|
c.JSON(q.ErrResp(c, 500, err))
|
|
return
|
|
}
|
|
|
|
c.JSON(200, &ClientCfgMsg{ClientCfg: siteCfg.ClientCfg})
|
|
}
|
|
|
|
func (h *SettingsSvc) SetClientCfg(c *gin.Context) {
|
|
var err error
|
|
req := &ClientCfgMsg{}
|
|
if err = c.ShouldBindJSON(&req); err != nil {
|
|
c.JSON(q.ErrResp(c, 400, err))
|
|
return
|
|
}
|
|
h.deps.Log().Info(req.ClientCfg)
|
|
|
|
if err = validateClientCfg(req.ClientCfg); err != nil {
|
|
c.JSON(q.ErrResp(c, 400, err))
|
|
return
|
|
}
|
|
|
|
role := c.MustGet(q.RoleParam).(string)
|
|
if role != userstore.AdminRole {
|
|
c.JSON(q.ErrResp(c, 401, q.ErrUnauthorized))
|
|
return
|
|
}
|
|
|
|
err = h.deps.SiteStore().SetClientCfg(req.ClientCfg)
|
|
if err != nil {
|
|
c.JSON(q.ErrResp(c, 500, err))
|
|
return
|
|
}
|
|
c.JSON(q.Resp(200))
|
|
}
|
|
|
|
func validateClientCfg(cfg *sitestore.ClientConfig) error {
|
|
if cfg.SiteName == "" {
|
|
return errors.New("site name is empty")
|
|
}
|
|
return nil
|
|
}
|