mirror of
https://github.com/drakkan/sftpgo.git
synced 2024-11-24 16:40:26 +00:00
259 lines
8.1 KiB
Go
259 lines
8.1 KiB
Go
package httpd
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"net/http"
|
|
|
|
"github.com/go-chi/render"
|
|
|
|
"github.com/drakkan/sftpgo/v2/common"
|
|
"github.com/drakkan/sftpgo/v2/dataprovider"
|
|
"github.com/drakkan/sftpgo/v2/logger"
|
|
"github.com/drakkan/sftpgo/v2/vfs"
|
|
)
|
|
|
|
const (
|
|
quotaUpdateModeAdd = "add"
|
|
quotaUpdateModeReset = "reset"
|
|
)
|
|
|
|
type quotaUsage struct {
|
|
UsedQuotaSize int64 `json:"used_quota_size"`
|
|
UsedQuotaFiles int `json:"used_quota_files"`
|
|
}
|
|
|
|
func getUsersQuotaScans(w http.ResponseWriter, r *http.Request) {
|
|
r.Body = http.MaxBytesReader(w, r.Body, maxRequestSize)
|
|
render.JSON(w, r, common.QuotaScans.GetUsersQuotaScans())
|
|
}
|
|
|
|
func getFoldersQuotaScans(w http.ResponseWriter, r *http.Request) {
|
|
r.Body = http.MaxBytesReader(w, r.Body, maxRequestSize)
|
|
render.JSON(w, r, common.QuotaScans.GetVFoldersQuotaScans())
|
|
}
|
|
|
|
func updateUserQuotaUsage(w http.ResponseWriter, r *http.Request) {
|
|
r.Body = http.MaxBytesReader(w, r.Body, maxRequestSize)
|
|
var usage quotaUsage
|
|
err := render.DecodeJSON(r.Body, &usage)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", http.StatusBadRequest)
|
|
return
|
|
}
|
|
doUpdateUserQuotaUsage(w, r, getURLParam(r, "username"), usage)
|
|
}
|
|
|
|
func updateUserQuotaUsageCompat(w http.ResponseWriter, r *http.Request) {
|
|
r.Body = http.MaxBytesReader(w, r.Body, maxRequestSize)
|
|
var u dataprovider.User
|
|
err := render.DecodeJSON(r.Body, &u)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", http.StatusBadRequest)
|
|
return
|
|
}
|
|
usage := quotaUsage{
|
|
UsedQuotaSize: u.UsedQuotaSize,
|
|
UsedQuotaFiles: u.UsedQuotaFiles,
|
|
}
|
|
|
|
doUpdateUserQuotaUsage(w, r, u.Username, usage)
|
|
}
|
|
|
|
func updateFolderQuotaUsage(w http.ResponseWriter, r *http.Request) {
|
|
r.Body = http.MaxBytesReader(w, r.Body, maxRequestSize)
|
|
var usage quotaUsage
|
|
err := render.DecodeJSON(r.Body, &usage)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", http.StatusBadRequest)
|
|
return
|
|
}
|
|
doUpdateFolderQuotaUsage(w, r, getURLParam(r, "name"), usage)
|
|
}
|
|
|
|
func updateFolderQuotaUsageCompat(w http.ResponseWriter, r *http.Request) {
|
|
r.Body = http.MaxBytesReader(w, r.Body, maxRequestSize)
|
|
var f vfs.BaseVirtualFolder
|
|
err := render.DecodeJSON(r.Body, &f)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", http.StatusBadRequest)
|
|
return
|
|
}
|
|
usage := quotaUsage{
|
|
UsedQuotaSize: f.UsedQuotaSize,
|
|
UsedQuotaFiles: f.UsedQuotaFiles,
|
|
}
|
|
doUpdateFolderQuotaUsage(w, r, f.Name, usage)
|
|
}
|
|
|
|
func startUserQuotaScan(w http.ResponseWriter, r *http.Request) {
|
|
r.Body = http.MaxBytesReader(w, r.Body, maxRequestSize)
|
|
doStartUserQuotaScan(w, r, getURLParam(r, "username"))
|
|
}
|
|
|
|
func startUserQuotaScanCompat(w http.ResponseWriter, r *http.Request) {
|
|
r.Body = http.MaxBytesReader(w, r.Body, maxRequestSize)
|
|
var u dataprovider.User
|
|
err := render.DecodeJSON(r.Body, &u)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", http.StatusBadRequest)
|
|
return
|
|
}
|
|
doStartUserQuotaScan(w, r, u.Username)
|
|
}
|
|
|
|
func startFolderQuotaScan(w http.ResponseWriter, r *http.Request) {
|
|
r.Body = http.MaxBytesReader(w, r.Body, maxRequestSize)
|
|
doStartFolderQuotaScan(w, r, getURLParam(r, "name"))
|
|
}
|
|
|
|
func startFolderQuotaScanCompat(w http.ResponseWriter, r *http.Request) {
|
|
r.Body = http.MaxBytesReader(w, r.Body, maxRequestSize)
|
|
var f vfs.BaseVirtualFolder
|
|
err := render.DecodeJSON(r.Body, &f)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", http.StatusBadRequest)
|
|
return
|
|
}
|
|
doStartFolderQuotaScan(w, r, f.Name)
|
|
}
|
|
|
|
func doUpdateUserQuotaUsage(w http.ResponseWriter, r *http.Request, username string, usage quotaUsage) {
|
|
if usage.UsedQuotaFiles < 0 || usage.UsedQuotaSize < 0 {
|
|
sendAPIResponse(w, r, errors.New("invalid used quota parameters, negative values are not allowed"),
|
|
"", http.StatusBadRequest)
|
|
return
|
|
}
|
|
mode, err := getQuotaUpdateMode(r)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", http.StatusBadRequest)
|
|
return
|
|
}
|
|
user, err := dataprovider.UserExists(username)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", getRespStatus(err))
|
|
return
|
|
}
|
|
if mode == quotaUpdateModeAdd && !user.HasQuotaRestrictions() && dataprovider.GetQuotaTracking() == 2 {
|
|
sendAPIResponse(w, r, errors.New("this user has no quota restrictions, only reset mode is supported"),
|
|
"", http.StatusBadRequest)
|
|
return
|
|
}
|
|
if !common.QuotaScans.AddUserQuotaScan(user.Username) {
|
|
sendAPIResponse(w, r, err, "A quota scan is in progress for this user", http.StatusConflict)
|
|
return
|
|
}
|
|
defer common.QuotaScans.RemoveUserQuotaScan(user.Username)
|
|
err = dataprovider.UpdateUserQuota(&user, usage.UsedQuotaFiles, usage.UsedQuotaSize, mode == quotaUpdateModeReset)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", getRespStatus(err))
|
|
} else {
|
|
sendAPIResponse(w, r, err, "Quota updated", http.StatusOK)
|
|
}
|
|
}
|
|
|
|
func doUpdateFolderQuotaUsage(w http.ResponseWriter, r *http.Request, name string, usage quotaUsage) {
|
|
if usage.UsedQuotaFiles < 0 || usage.UsedQuotaSize < 0 {
|
|
sendAPIResponse(w, r, errors.New("invalid used quota parameters, negative values are not allowed"),
|
|
"", http.StatusBadRequest)
|
|
return
|
|
}
|
|
mode, err := getQuotaUpdateMode(r)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", http.StatusBadRequest)
|
|
return
|
|
}
|
|
folder, err := dataprovider.GetFolderByName(name)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", getRespStatus(err))
|
|
return
|
|
}
|
|
if !common.QuotaScans.AddVFolderQuotaScan(folder.Name) {
|
|
sendAPIResponse(w, r, err, "A quota scan is in progress for this folder", http.StatusConflict)
|
|
return
|
|
}
|
|
defer common.QuotaScans.RemoveVFolderQuotaScan(folder.Name)
|
|
err = dataprovider.UpdateVirtualFolderQuota(&folder, usage.UsedQuotaFiles, usage.UsedQuotaSize, mode == quotaUpdateModeReset)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", getRespStatus(err))
|
|
} else {
|
|
sendAPIResponse(w, r, err, "Quota updated", http.StatusOK)
|
|
}
|
|
}
|
|
|
|
func doStartUserQuotaScan(w http.ResponseWriter, r *http.Request, username string) {
|
|
if dataprovider.GetQuotaTracking() == 0 {
|
|
sendAPIResponse(w, r, nil, "Quota tracking is disabled!", http.StatusForbidden)
|
|
return
|
|
}
|
|
user, err := dataprovider.UserExists(username)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", getRespStatus(err))
|
|
return
|
|
}
|
|
if !common.QuotaScans.AddUserQuotaScan(user.Username) {
|
|
sendAPIResponse(w, r, err, fmt.Sprintf("Another scan is already in progress for user %#v", username),
|
|
http.StatusConflict)
|
|
return
|
|
}
|
|
go doUserQuotaScan(user) //nolint:errcheck
|
|
sendAPIResponse(w, r, err, "Scan started", http.StatusAccepted)
|
|
}
|
|
|
|
func doStartFolderQuotaScan(w http.ResponseWriter, r *http.Request, name string) {
|
|
if dataprovider.GetQuotaTracking() == 0 {
|
|
sendAPIResponse(w, r, nil, "Quota tracking is disabled!", http.StatusForbidden)
|
|
return
|
|
}
|
|
folder, err := dataprovider.GetFolderByName(name)
|
|
if err != nil {
|
|
sendAPIResponse(w, r, err, "", getRespStatus(err))
|
|
return
|
|
}
|
|
if !common.QuotaScans.AddVFolderQuotaScan(folder.Name) {
|
|
sendAPIResponse(w, r, err, fmt.Sprintf("Another scan is already in progress for folder %#v", name),
|
|
http.StatusConflict)
|
|
return
|
|
}
|
|
go doFolderQuotaScan(folder) //nolint:errcheck
|
|
sendAPIResponse(w, r, err, "Scan started", http.StatusAccepted)
|
|
}
|
|
|
|
func doUserQuotaScan(user dataprovider.User) error {
|
|
defer common.QuotaScans.RemoveUserQuotaScan(user.Username)
|
|
numFiles, size, err := user.ScanQuota()
|
|
if err != nil {
|
|
logger.Warn(logSender, "", "error scanning user quota %#v: %v", user.Username, err)
|
|
return err
|
|
}
|
|
err = dataprovider.UpdateUserQuota(&user, numFiles, size, true)
|
|
logger.Debug(logSender, "", "user quota scanned, user: %#v, error: %v", user.Username, err)
|
|
return err
|
|
}
|
|
|
|
func doFolderQuotaScan(folder vfs.BaseVirtualFolder) error {
|
|
defer common.QuotaScans.RemoveVFolderQuotaScan(folder.Name)
|
|
f := vfs.VirtualFolder{
|
|
BaseVirtualFolder: folder,
|
|
VirtualPath: "/",
|
|
}
|
|
numFiles, size, err := f.ScanQuota()
|
|
if err != nil {
|
|
logger.Warn(logSender, "", "error scanning folder %#v: %v", folder.Name, err)
|
|
return err
|
|
}
|
|
err = dataprovider.UpdateVirtualFolderQuota(&folder, numFiles, size, true)
|
|
logger.Debug(logSender, "", "virtual folder %#v scanned, error: %v", folder.Name, err)
|
|
return err
|
|
}
|
|
|
|
func getQuotaUpdateMode(r *http.Request) (string, error) {
|
|
mode := quotaUpdateModeReset
|
|
if _, ok := r.URL.Query()["mode"]; ok {
|
|
mode = r.URL.Query().Get("mode")
|
|
if mode != quotaUpdateModeReset && mode != quotaUpdateModeAdd {
|
|
return "", errors.New("invalid mode")
|
|
}
|
|
}
|
|
return mode, nil
|
|
}
|