mleku
bbebbe2b02
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.
79 lines
2.3 KiB
Go
79 lines
2.3 KiB
Go
package openapi
|
|
|
|
import (
|
|
"net/http"
|
|
"strings"
|
|
|
|
"github.com/danielgtaylor/huma/v2"
|
|
|
|
"realy.lol/chk"
|
|
"realy.lol/context"
|
|
"realy.lol/log"
|
|
"realy.lol/lol"
|
|
"realy.lol/realy/helpers"
|
|
"realy.lol/store"
|
|
)
|
|
|
|
// NukeInput is the parameters for the HTTP API method nuke. Note that it has a confirmation
|
|
// header that must be provided to prevent accidental invocation of this method.
|
|
type NukeInput struct {
|
|
Auth string `header:"Authorization" doc:"nostr nip-98 (and expiring variant)" required:"true"`
|
|
Confirm string `header:"X-Confirm" doc:"must put 'Yes I Am Sure' in this field as confirmation"`
|
|
}
|
|
|
|
// NukeOutput is basically nothing, a 200 or 204 HTTP status response is normal.
|
|
type NukeOutput struct{}
|
|
|
|
// RegisterNuke is the implementation of the Nuke HTTP API method.
|
|
func (x *Operations) RegisterNuke(api huma.API) {
|
|
lol.Tracer("RegisterNuke")
|
|
defer func() { lol.Tracer("end RegisterNuke") }()
|
|
name := "Nuke"
|
|
description := "Nuke all events in the database"
|
|
path := x.path + "/nuke"
|
|
scopes := []string{"admin", "write"}
|
|
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 *NukeInput) (output *NukeOutput, err error) {
|
|
lol.Tracer("Nuke", input)
|
|
defer func() { lol.Tracer("end Nuke", output, err) }()
|
|
r := ctx.Value("http-request").(*http.Request)
|
|
// w := ctx.Value("http-response").(http.ResponseWriter)
|
|
remote := helpers.GetRemoteFromReq(r)
|
|
authed, pubkey := x.AdminAuth(r, remote)
|
|
if !authed {
|
|
// pubkey = ev.Pubkey
|
|
err = huma.Error401Unauthorized("user not authorized for action")
|
|
return
|
|
}
|
|
if input.Confirm != "Yes I Am Sure" {
|
|
err = huma.Error403Forbidden("Confirm missing or incorrect")
|
|
return
|
|
}
|
|
log.I.F("database nuke request from %s pubkey %0x",
|
|
remote, pubkey)
|
|
sto := x.Storage()
|
|
log.I.F("nuking")
|
|
if nuke, ok := sto.(store.Nukener); ok {
|
|
log.I.F("nuking")
|
|
if err = nuke.Nuke(); chk.E(err) {
|
|
if strings.HasPrefix(err.Error(), "Value log GC attempt") {
|
|
err = nil
|
|
}
|
|
return
|
|
}
|
|
} else {
|
|
log.I.F("nuking failed")
|
|
}
|
|
return
|
|
})
|
|
}
|