package nostr

import (
	"context"
	b64 "encoding/base64"
	"encoding/json"
	"errors"
	"fmt"
	"net/http"
	"strings"
	"time"

	"git.minhas.io/asara/well-goknown/lnd"
	"git.minhas.io/asara/well-goknown/logger"
	"git.minhas.io/asara/well-goknown/redis"
	"github.com/nbd-wtf/go-nostr/nip19"
)

type nostrWellKnown struct {
	Names  map[string]string   `json:"names"`
	Relays map[string][]string `json:"relays,omitempty"`
}

type NostrRequest struct {
	Name     string `json:"name"`
	Key      string `json:"key"`
	Hostname string
	Relays   []string `json:"relays,omitempty"`
}

func RequestNostrAddr(w http.ResponseWriter, r *http.Request) {
	ctx := context.TODO()
	l := logger.Get()
	switch r.Method {
	case "GET":
		l.Debug().Msg("get nostr register form")
		http.ServeFile(w, r, "html/nostr_form.html")
	case "POST":
		r.ParseForm()
		redisCli, err := redis.New("localhost:6379", "", redis.NostrDb)
		if err != nil {
			l.Error().Msg("unable to connect to redis")
			w.WriteHeader(http.StatusInternalServerError)
			return
		}
		// check if the user already exists
		rKey := getRkey("verified", r.FormValue("Name"), getHostname(r.Host))
		exists := redisCli.Client.Exists(ctx, rKey)
		if exists.Val() == 1 {
			w.WriteHeader(http.StatusConflict)
			return
		}
		rKey = getRkey("requested", r.FormValue("Name"), getHostname(r.Host))
		exists = redisCli.Client.Exists(ctx, rKey)
		if exists.Val() == 1 {
			w.WriteHeader(http.StatusConflict)
			return
		}

		// get the hexkey
		hexKey, err := convertNpubToHex(r.FormValue("Key"))
		if err != nil {
			l.Error().Msg("unable to convert npub to hex")
			w.WriteHeader(http.StatusBadRequest)
			return
		}

		// create the struct
		relays := make(map[string][]string)
		names := map[string]string{r.FormValue("Name"): hexKey}
		user := nostrWellKnown{}
		if r.FormValue("Relays") != "" {
			relays = map[string][]string{
				hexKey: strings.Split(r.FormValue("Relays"), ","),
			}
			user = nostrWellKnown{Names: names, Relays: relays}
		} else {
			user = nostrWellKnown{Names: names}
		}
		jsonUser, _ := json.Marshal(user)
		enc := b64.StdEncoding.EncodeToString([]byte(jsonUser))

		// generate the payment request
		exp := time.Until(time.Now().Add(time.Minute * 15))
		// paymentReq, err := lnd.Request(rKey, jsonUser, exp)
		_, err = lnd.Request(rKey, jsonUser, exp)
		if err != nil {
			w.WriteHeader(http.StatusServiceUnavailable)
			return
		}
		requestKey := getRkey("requested", r.FormValue("Name"), getHostname(r.Host))
		err = redisCli.Client.Set(ctx, requestKey, enc, exp).Err()
		if err != nil {
			l.Error().Msg("unable to connect to redis")
		}
	}
}

func GetNostrAddr(w http.ResponseWriter, r *http.Request) {
	ctx := context.TODO()
	l := logger.Get()
	// get query string for username
	r.ParseForm()

	// connect to redis
	redisCli, err := redis.New("localhost:6379", "", redis.NostrDb)
	if err != nil {
		l.Error().Msg("unable to connect to redis")
		w.WriteHeader(http.StatusInternalServerError)
		return
	}

	requestedName := r.FormValue("name")
	// search for user@domain
	search := getRkey("verified", requestedName, getHostname(r.Host))
	addr, err := redisCli.Client.Get(ctx, search).Result()
	if err != nil {
		w.WriteHeader(http.StatusNotFound)
		return
	}
	dec, err := b64.StdEncoding.DecodeString(addr)
	if err != nil {
		w.WriteHeader(http.StatusInternalServerError)
		return
	}

	w.Header().Set("Content-Type", "application/json")
	w.WriteHeader(http.StatusOK)
	w.Write(dec)
}

func AddNostrAddr(n NostrRequest) {
	ctx := context.TODO()
	l := logger.Get()
	// transform request to well known struct
	relays := make(map[string][]string)
	user := nostrWellKnown{}
	hexKey, err := convertNpubToHex(n.Key)
	if err != nil {
		l.Error().Msg("unable to convert npub to hex")
	}
	names := map[string]string{n.Name: hexKey}

	if n.Relays != nil {
		relays = map[string][]string{hexKey: n.Relays}
		user = nostrWellKnown{Names: names, Relays: relays}
	} else {
		user = nostrWellKnown{Names: names}
	}
	jsonUser, _ := json.Marshal(user)

	redisCli, err := redis.New("localhost:6379", "", redis.NostrDb)
	if err != nil {
		l.Error().Msg("unable to connect to redis")
	}
	nameKey := getRkey("verified", n.Name, n.Hostname)
	enc := b64.StdEncoding.EncodeToString([]byte(jsonUser))
	err = redisCli.Client.Set(ctx, nameKey, enc, 0).Err()
	if err != nil {
		l.Error().Msg("unable to connect to redis")
	}
}

func getHostname(hostname string) string {
	// remove port for local testing
	return hostname
}

func convertNpubToHex(npub string) (string, error) {
	if !strings.HasPrefix(npub, "npub1") {
		return "", errors.New("Not an npub key")
	}
	_, hex, err := nip19.Decode(npub)
	if err != nil {
		return "", errors.New("Unable to decode npub")
	}

	return hex.(string), nil

}

func getRkey(prefix string, user string, hostname string) string {
	if strings.Contains(hostname, ":") {
		hostname = strings.Split(hostname, ":")[0]
	}
	return fmt.Sprintf("%s:%s@%s", prefix, user, hostname)
}