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
	})
}