Gleipnir/nidus-sync
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Factor out common post parsing code for sms message

Browse source
This commit is contained in:
Eli Ribble 2026-02-18 08:09:53 +00:00
parent b0ee388986
commit 2626e044ca
No known key found for this signature in database
2 changed files with 37 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

33
sync/routes.go
View file

@ -69,7 +69,7 @@ func Router() chi.Router {
r.Method("GET", "/source/{globalid}", auth.NewEnsureAuth(getSource))
r.Method("GET", "/stadia", auth.NewEnsureAuth(getStadia))
r.Method("GET", "/sudo", authenticatedHandler(getSudo))
r.Method("POST", "/sudo/sms", auth.NewEnsureAuth(postSudoSMS))
r.Method("POST", "/sudo/sms", authenticatedHandlerPost(postSudoSMS))
r.Method("GET", "/trap/{globalid}", auth.NewEnsureAuth(getTrap))
r.Method("GET", "/text/{destination}", auth.NewEnsureAuth(getTextMessages))
r.Method("GET", "/upload", authenticatedHandler(getUploadList))
@ -94,7 +94,7 @@ func newError(mesg_format string, args ...interface{}) *errorWithStatus {
}
}
type handlerFunction[T any] func(context.Context, *models.User) (string, T, *errorWithStatus)
type handlerFunctionGet[T any] func(context.Context, *models.User) (string, T, *errorWithStatus)
type wrappedHandler func(http.ResponseWriter, *http.Request)
type contentAuthenticated[T any] struct {
C T
@ -103,7 +103,7 @@ type contentAuthenticated[T any] struct {
}
// w http.ResponseWriter, r *http.Request, u *models.User) {
func authenticatedHandler[T any](f handlerFunction[T]) http.Handler {
func authenticatedHandler[T any](f handlerFunctionGet[T]) http.Handler {
return auth.NewEnsureAuth(func(w http.ResponseWriter, r *http.Request, u *models.User) {
ctx := r.Context()
userContent, err := contentForUser(ctx, u)
@ -125,3 +125,30 @@ func authenticatedHandler[T any](f handlerFunction[T]) http.Handler {
})
})
}
type handlerFunctionPost[T any] func(context.Context, *models.User, T) (string, *errorWithStatus)
func authenticatedHandlerPost[T any](f handlerFunctionPost[T]) http.Handler {
return auth.NewEnsureAuth(func(w http.ResponseWriter, r *http.Request, u *models.User) {
err := r.ParseForm()
if err != nil {
respondError(w, "Failed to parse form", err, http.StatusBadRequest)
return
}
var content T
err = decoder.Decode(&content, r.PostForm)
if err != nil {
respondError(w, "Failed to decode form", err, http.StatusBadRequest)
return
}
ctx := r.Context()
path, e := f(ctx, u, content)
if e != nil {
http.Error(w, e.Error(), e.Status)
return
}
http.Redirect(w, r, path, http.StatusFound)
})
}

21
sync/sudo.go
View file

@ -30,20 +30,13 @@ type FormSMS struct {
Phone string `schema:"smsPhone"`
}
func postSudoSMS(w http.ResponseWriter, r *http.Request, u *models.User) {
err := r.ParseForm()
if err != nil {
respondError(w, "Failed to parse form", err, http.StatusInternalServerError)
return
}
var sms FormSMS
err = decoder.Decode(&sms, r.PostForm)
if err != nil {
respondError(w, "Failed to decode form", err, http.StatusInternalServerError)
return
func postSudoSMS(ctx context.Context, u *models.User, sms FormSMS) (string, *errorWithStatus) {
if u.Role != enums.UserroleRoot {
return "", &errorWithStatus{
Message: "You must have sudo powers to do this",
Status: http.StatusForbidden,
}
}
log.Info().Str("msg", sms.Message).Str("phone", sms.Phone).Msg("Got SMS")
http.Redirect(w, r, "/sudo", http.StatusFound)
return "/sudo", nil
}