feat: first pass at lnurlp

This commit is contained in:
Amarpreet Minhas 2023-12-31 20:08:48 -05:00 committed by asara
parent 900f01166f
commit ce9fc3516a
3 changed files with 80 additions and 6 deletions

62
lnurlp/lnurlp.go Normal file
View file

@ -0,0 +1,62 @@
package lnurlp
import (
"context"
b64 "encoding/base64"
"encoding/json"
"fmt"
"net/http"
"strings"
"git.minhas.io/asara/well-goknown/logger"
"git.minhas.io/asara/well-goknown/redis"
)
type ErrorMessage struct {
Error string `json:"error"`
}
type Response struct {
Payload string `json:"request_key"`
}
func GetLnurlpUser(w http.ResponseWriter, r *http.Request) {
ctx := context.TODO()
l := logger.Get()
// connect to redis
redisCli := redis.LnurlpRedisConn.Client
// search for user@domain
search := getRkey("lnurlp", "asara", r.Host)
addr, err := redisCli.Get(ctx, search).Result()
if err != nil {
l.Info().Msg(fmt.Sprintf("get %s: not found", search))
w.WriteHeader(http.StatusNotFound)
json.NewEncoder(w).Encode(&ErrorMessage{
Error: "username not registered",
})
return
}
dec, err := b64.StdEncoding.DecodeString(addr)
if err != nil {
l.Error().Msg(fmt.Sprintf("get %s: unable to decode key", search))
w.WriteHeader(http.StatusInternalServerError)
json.NewEncoder(w).Encode(&ErrorMessage{
Error: "internal server error",
})
return
}
l.Info().Msg(fmt.Sprintf("get %s: found and returned", search))
w.Header().Set("Content-Type", "application/json")
w.WriteHeader(http.StatusOK)
w.Write(dec)
}
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)
}

14
main.go
View file

@ -4,6 +4,7 @@ import (
"net/http"
"git.minhas.io/asara/well-goknown/config"
"git.minhas.io/asara/well-goknown/lnurlp"
"git.minhas.io/asara/well-goknown/logger"
"git.minhas.io/asara/well-goknown/matrix"
"git.minhas.io/asara/well-goknown/nostr"
@ -22,6 +23,10 @@ func main() {
if err != nil {
l.Fatal().Msg("unable to connect to redis")
}
redis.LnurlpRedisConn, err = redis.New("localhost:6379", "", redis.LnurlpKeyspace)
if err != nil {
l.Fatal().Msg("unable to connect to redis")
}
// matrix endpoints
l.Debug().Msg("enabling matrix server endpoint")
@ -33,12 +38,17 @@ func main() {
l.Debug().Msg("enabling nostr user endpoint")
http.HandleFunc("/.well-known/nostr.json", nostr.GetNostrAddr)
addr := config.GetConfig().LndAddr
if addr != "" {
// enable requesting of nostr addresses
lndAddr := config.GetConfig().LndAddr
if lndAddr != "" {
l.Debug().Msg("enabling nostr request endpoint")
http.HandleFunc("/request/nostr", nostr.RequestNostrAddr)
}
//lnurlp endpoints
l.Debug().Msg("enabling lnurlp endpoint")
http.HandleFunc("/.well-known/lnurlp/", lnurlp.GetLnurlpUser)
// start server
port := config.GetConfig().ListenAddr
l.Info().Msgf("starting server on %s", port)

View file

@ -7,8 +7,9 @@ import (
)
const (
NostrKeyspace = iota
LndKeyspace = iota
NostrKeyspace = iota
LndKeyspace = iota
LnurlpKeyspace = iota
)
type Redis struct {
@ -16,8 +17,9 @@ type Redis struct {
}
var (
NostrRedisConn *Redis
LndRedisConn *Redis
NostrRedisConn *Redis
LndRedisConn *Redis
LnurlpRedisConn *Redis
)
func New(address string, password string, database int) (*Redis, error) {