mirror of
https://github.com/NginxProxyManager/nginx-proxy-manager.git
synced 2025-04-29 18:42:28 +00:00
111 lines
3.1 KiB
Go
111 lines
3.1 KiB
Go
package handler
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"net/http"
|
|
|
|
c "npm/internal/api/context"
|
|
h "npm/internal/api/http"
|
|
"npm/internal/api/middleware"
|
|
"npm/internal/entity/setting"
|
|
|
|
"github.com/go-chi/chi/v5"
|
|
"gorm.io/gorm"
|
|
)
|
|
|
|
// GetSettings will return a list of Settings
|
|
// Route: GET /settings
|
|
func GetSettings() func(http.ResponseWriter, *http.Request) {
|
|
return func(w http.ResponseWriter, r *http.Request) {
|
|
pageInfo, err := getPageInfoFromRequest(r)
|
|
if err != nil {
|
|
h.ResultErrorJSON(w, r, http.StatusBadRequest, err.Error(), nil)
|
|
return
|
|
}
|
|
|
|
settings, err := setting.List(pageInfo, middleware.GetFiltersFromContext(r))
|
|
if err != nil {
|
|
h.ResultErrorJSON(w, r, http.StatusBadRequest, err.Error(), nil)
|
|
} else {
|
|
h.ResultResponseJSON(w, r, http.StatusOK, settings)
|
|
}
|
|
}
|
|
}
|
|
|
|
// GetSetting will return a single Setting
|
|
// Route: GET /settings/{name}
|
|
func GetSetting() func(http.ResponseWriter, *http.Request) {
|
|
return func(w http.ResponseWriter, r *http.Request) {
|
|
name := chi.URLParam(r, "name")
|
|
|
|
item, err := setting.GetByName(name)
|
|
switch err {
|
|
case gorm.ErrRecordNotFound:
|
|
h.NotFound(w, r)
|
|
case nil:
|
|
h.ResultResponseJSON(w, r, http.StatusOK, item)
|
|
default:
|
|
h.ResultErrorJSON(w, r, http.StatusBadRequest, err.Error(), nil)
|
|
}
|
|
}
|
|
}
|
|
|
|
// CreateSetting will create a Setting
|
|
// Route: POST /settings
|
|
func CreateSetting() func(http.ResponseWriter, *http.Request) {
|
|
return func(w http.ResponseWriter, r *http.Request) {
|
|
bodyBytes, _ := r.Context().Value(c.BodyCtxKey).([]byte)
|
|
|
|
var newSetting setting.Model
|
|
err := json.Unmarshal(bodyBytes, &newSetting)
|
|
if err != nil {
|
|
h.ResultErrorJSON(w, r, http.StatusBadRequest, h.ErrInvalidPayload.Error(), nil)
|
|
return
|
|
}
|
|
|
|
// Check if the setting already exists
|
|
if _, err := setting.GetByName(newSetting.Name); err == nil {
|
|
h.ResultErrorJSON(w, r, http.StatusBadRequest, fmt.Sprintf("Setting with name '%s' already exists", newSetting.Name), nil)
|
|
return
|
|
}
|
|
|
|
if err = newSetting.Save(); err != nil {
|
|
h.ResultErrorJSON(w, r, http.StatusBadRequest, fmt.Sprintf("Unable to save Setting: %s", err.Error()), nil)
|
|
return
|
|
}
|
|
|
|
h.ResultResponseJSON(w, r, http.StatusOK, newSetting)
|
|
}
|
|
}
|
|
|
|
// UpdateSetting updates a setting
|
|
// Route: PUT /settings/{name}
|
|
// TODO: Add validation for the setting value, for system settings they should be validated against the setting name and type
|
|
func UpdateSetting() func(http.ResponseWriter, *http.Request) {
|
|
return func(w http.ResponseWriter, r *http.Request) {
|
|
settingName := chi.URLParam(r, "name")
|
|
|
|
setting, err := setting.GetByName(settingName)
|
|
switch err {
|
|
case gorm.ErrRecordNotFound:
|
|
h.NotFound(w, r)
|
|
case nil:
|
|
bodyBytes, _ := r.Context().Value(c.BodyCtxKey).([]byte)
|
|
if err := json.Unmarshal(bodyBytes, &setting); err != nil {
|
|
h.ResultErrorJSON(w, r, http.StatusBadRequest, h.ErrInvalidPayload.Error(), nil)
|
|
return
|
|
}
|
|
|
|
if err := setting.Save(); err != nil {
|
|
h.ResultErrorJSON(w, r, http.StatusBadRequest, err.Error(), nil)
|
|
return
|
|
}
|
|
|
|
h.ResultResponseJSON(w, r, http.StatusOK, setting)
|
|
default:
|
|
h.ResultErrorJSON(w, r, http.StatusBadRequest, err.Error(), nil)
|
|
}
|
|
}
|
|
}
|