Files
realy/openapi/http-rescan.go
mleku bbebbe2b02 Add tracing with lol.Tracer in multiple functions.
Introduced `lol.Tracer` for function entry/exit logging across various packages. This improves traceability and debugging of function executions while preserving existing behavior. Removed unused files `doc.go` and `nothing.go` to clean up the repository.
2025-06-29 07:32:24 +01:00

61 lines
1.6 KiB
Go

package openapi
import (
"net/http"
"github.com/danielgtaylor/huma/v2"
"realy.lol/chk"
"realy.lol/context"
"realy.lol/log"
"realy.lol/lol"
"realy.lol/realy/helpers"
"realy.lol/store"
)
type RescanInput struct {
Auth string `header:"Authorization" doc:"nostr nip-98 (and expiring variant)" required:"true"`
}
type RescanOutput struct{}
func (x *Operations) RegisterRescan(api huma.API) {
lol.Tracer("RegisterRescan")
defer func() { lol.Tracer("end RegisterRescan") }()
name := "Rescan"
description := "Rescan all events and rewrite their indexes (to enable new indexes on old events)"
path := x.path + "/rescan"
scopes := []string{"admin"}
method := http.MethodGet
huma.Register(api, huma.Operation{
OperationID: name,
Summary: name,
Path: path,
Method: method,
Tags: []string{"admin"},
Description: helpers.GenerateDescription(description, scopes),
Security: []map[string][]string{{"auth": scopes}},
DefaultStatus: 204,
}, func(ctx context.T, input *RescanInput) (output *RescanOutput, err error) {
lol.Tracer("Rescan", input)
defer func() { lol.Tracer("end Rescan", output, err) }()
r := ctx.Value("http-request").(*http.Request)
remote := helpers.GetRemoteFromReq(r)
authed, pubkey := x.AdminAuth(r, remote)
if !authed {
err = huma.Error401Unauthorized("not authorized")
return
}
log.I.F("index rescan requested on admin port from %s pubkey %0x",
remote, pubkey)
sto := x.Storage()
if rescanner, ok := sto.(store.Rescanner); ok {
log.I.F("rescanning")
if err = rescanner.Rescan(); chk.E(err) {
return
}
}
return
})
}