diff options
Diffstat (limited to 'internal/api/client')
| -rw-r--r-- | internal/api/client/admin/admin.go | 4 | ||||
| -rw-r--r-- | internal/api/client/admin/mediarefetch.go | 93 |
2 files changed, 97 insertions, 0 deletions
diff --git a/internal/api/client/admin/admin.go b/internal/api/client/admin/admin.go index 7032a5b95..569354c96 100644 --- a/internal/api/client/admin/admin.go +++ b/internal/api/client/admin/admin.go @@ -46,6 +46,7 @@ const ( // AccountsActionPath is used for taking action on a single account. AccountsActionPath = AccountsPathWithID + "/action" MediaCleanupPath = BasePath + "/media_cleanup" + MediaRefetchPath = BasePath + "/media_refetch" // ExportQueryKey is for requesting a public export of some data. ExportQueryKey = "export" @@ -63,6 +64,8 @@ const ( MinShortcodeDomainKey = "min_shortcode_domain" // LimitKey is for specifying maximum number of results to return. LimitKey = "limit" + // DomainQueryKey is for specifying a domain during admin actions. + DomainQueryKey = "domain" ) // Module implements the ClientAPIModule interface for admin-related actions (reports, emojis, etc) @@ -90,6 +93,7 @@ func (m *Module) Route(r router.Router) error { r.AttachHandler(http.MethodDelete, DomainBlocksPathWithID, m.DomainBlockDELETEHandler) r.AttachHandler(http.MethodPost, AccountsActionPath, m.AccountActionPOSTHandler) r.AttachHandler(http.MethodPost, MediaCleanupPath, m.MediaCleanupPOSTHandler) + r.AttachHandler(http.MethodPost, MediaRefetchPath, m.MediaRefetchPOSTHandler) r.AttachHandler(http.MethodGet, EmojiCategoriesPath, m.EmojiCategoriesGETHandler) return nil } diff --git a/internal/api/client/admin/mediarefetch.go b/internal/api/client/admin/mediarefetch.go new file mode 100644 index 000000000..9c8a30c1b --- /dev/null +++ b/internal/api/client/admin/mediarefetch.go @@ -0,0 +1,93 @@ +/* + GoToSocial + Copyright (C) 2021-2022 GoToSocial Authors admin@gotosocial.org + + This program is free software: you can redistribute it and/or modify + it under the terms of the GNU Affero General Public License as published by + the Free Software Foundation, either version 3 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU Affero General Public License for more details. + + You should have received a copy of the GNU Affero General Public License + along with this program. If not, see <http://www.gnu.org/licenses/>. +*/ + +package admin + +import ( + "fmt" + "net/http" + + "github.com/gin-gonic/gin" + "github.com/superseriousbusiness/gotosocial/internal/api" + "github.com/superseriousbusiness/gotosocial/internal/gtserror" + "github.com/superseriousbusiness/gotosocial/internal/oauth" +) + +// MediaRefetchPOSTHandler swagger:operation POST /api/v1/admin/media_refetch mediaRefetch +// +// Refetch media specified in the database but missing from storage. +// Currently, this only includes remote emojis. +// This endpoint is useful when data loss has occurred, and you want to try to recover to a working state. +// +// --- +// tags: +// - admin +// +// produces: +// - application/json +// +// security: +// - OAuth2 Bearer: +// - admin +// +// parameters: +// - +// name: domain +// in: query +// description: >- +// Domain to refetch media from. +// If empty, all domains will be refetched. +// type: string +// +// responses: +// '202': +// description: >- +// Request accepted and will be processed. +// Check the logs for progress / errors. +// '400': +// description: bad request +// '401': +// description: unauthorized +// '403': +// description: forbidden +// '404': +// description: not found +// '406': +// description: not acceptable +// '500': +// description: internal server error +func (m *Module) MediaRefetchPOSTHandler(c *gin.Context) { + authed, err := oauth.Authed(c, true, true, true, true) + if err != nil { + api.ErrorHandler(c, gtserror.NewErrorUnauthorized(err, err.Error()), m.processor.InstanceGet) + return + } + + if !*authed.User.Admin { + err := fmt.Errorf("user %s not an admin", authed.User.ID) + api.ErrorHandler(c, gtserror.NewErrorForbidden(err, err.Error()), m.processor.InstanceGet) + return + } + + if errWithCode := m.processor.AdminMediaRefetch(c.Request.Context(), authed, c.Query(DomainQueryKey)); errWithCode != nil { + api.ErrorHandler(c, errWithCode, m.processor.InstanceGet) + return + } + + c.Status(http.StatusAccepted) +} |