Compare commits
1 commit
ce9fc3516a
...
7c31e7316a
Author | SHA1 | Date | |
---|---|---|---|
7c31e7316a |
3 changed files with 80 additions and 6 deletions
62
lnurlp/lnurlp.go
Normal file
62
lnurlp/lnurlp.go
Normal 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
14
main.go
|
@ -4,6 +4,7 @@ import (
|
||||||
"net/http"
|
"net/http"
|
||||||
|
|
||||||
"git.minhas.io/asara/well-goknown/config"
|
"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/logger"
|
||||||
"git.minhas.io/asara/well-goknown/matrix"
|
"git.minhas.io/asara/well-goknown/matrix"
|
||||||
"git.minhas.io/asara/well-goknown/nostr"
|
"git.minhas.io/asara/well-goknown/nostr"
|
||||||
|
@ -22,6 +23,10 @@ func main() {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
l.Fatal().Msg("unable to connect to redis")
|
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
|
// matrix endpoints
|
||||||
l.Debug().Msg("enabling matrix server endpoint")
|
l.Debug().Msg("enabling matrix server endpoint")
|
||||||
|
@ -33,12 +38,17 @@ func main() {
|
||||||
l.Debug().Msg("enabling nostr user endpoint")
|
l.Debug().Msg("enabling nostr user endpoint")
|
||||||
http.HandleFunc("/.well-known/nostr.json", nostr.GetNostrAddr)
|
http.HandleFunc("/.well-known/nostr.json", nostr.GetNostrAddr)
|
||||||
|
|
||||||
addr := config.GetConfig().LndAddr
|
// enable requesting of nostr addresses
|
||||||
if addr != "" {
|
lndAddr := config.GetConfig().LndAddr
|
||||||
|
if lndAddr != "" {
|
||||||
l.Debug().Msg("enabling nostr request endpoint")
|
l.Debug().Msg("enabling nostr request endpoint")
|
||||||
http.HandleFunc("/request/nostr", nostr.RequestNostrAddr)
|
http.HandleFunc("/request/nostr", nostr.RequestNostrAddr)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//lnurlp endpoints
|
||||||
|
l.Debug().Msg("enabling lnurlp endpoint")
|
||||||
|
http.HandleFunc("/.well-known/lnurlp/", lnurlp.GetLnurlpUser)
|
||||||
|
|
||||||
// start server
|
// start server
|
||||||
port := config.GetConfig().ListenAddr
|
port := config.GetConfig().ListenAddr
|
||||||
l.Info().Msgf("starting server on %s", port)
|
l.Info().Msgf("starting server on %s", port)
|
||||||
|
|
|
@ -9,6 +9,7 @@ import (
|
||||||
const (
|
const (
|
||||||
NostrKeyspace = iota
|
NostrKeyspace = iota
|
||||||
LndKeyspace = iota
|
LndKeyspace = iota
|
||||||
|
LnurlpKeyspace = iota
|
||||||
)
|
)
|
||||||
|
|
||||||
type Redis struct {
|
type Redis struct {
|
||||||
|
@ -18,6 +19,7 @@ type Redis struct {
|
||||||
var (
|
var (
|
||||||
NostrRedisConn *Redis
|
NostrRedisConn *Redis
|
||||||
LndRedisConn *Redis
|
LndRedisConn *Redis
|
||||||
|
LnurlpRedisConn *Redis
|
||||||
)
|
)
|
||||||
|
|
||||||
func New(address string, password string, database int) (*Redis, error) {
|
func New(address string, password string, database int) (*Redis, error) {
|
||||||
|
|
Loading…
Reference in a new issue