Mirror/nostdress
1
0
Fork 0
mirror of https://github.com/believethehype/nostdress.git synced 2026-06-14 21:23:34 -07:00
Code Issues Packages Projects Releases Wiki Activity

walk through relays to download profile pic on creation

Browse Source
This commit is contained in:
Believethehype
2023-04-30 18:40:18 +02:00
parent e0cff06335
commit 2f366e1f35
2 changed files with 55 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files
db.go
+1 -1
View File
@@ -50,7 +50,7 @@ func SaveName(
domain = strings.ToLower(domain)
if params.Npub != "" && s.GetNostrProfile {
NostrProfile, err := GetNostrProfileMetaData(params.Npub)
NostrProfile, err := GetNostrProfileMetaData(params.Npub, 0)
if err == nil {
err = addImageToProfile(params, NostrProfile.Picture)
if err != nil {
nostr.go
+54 -42
View File
@@ -146,56 +146,68 @@ func handleNip05(w http.ResponseWriter, r *http.Request) {
}
}
func GetNostrProfileMetaData(npub string) (nostr.ProfileMetadata, error) {
func GetNostrProfileMetaData(npub string, index int) (nostr.ProfileMetadata, error) {
ctx, _ := context.WithTimeout(context.Background(), 3*time.Second)
var metadata *nostr.ProfileMetadata
// connect to first relay, todo, check on all/for errors
rel := Relays[0]
log.Printf("Get Image from: %s . If you receive an error use another relay on first position in RELAYS option", rel)
url := rel
relay, err := nostr.RelayConnect(ctx, url)
if err != nil {
log.Printf("Could not get Image")
if index < len(Relays) {
rel := Relays[index]
log.Printf("Get Image from: %s", rel)
url := rel
relay, err := nostr.RelayConnect(ctx, url)
if err != nil {
log.Printf("Could not get Connect, trying next relay")
return GetNostrProfileMetaData(npub, index+1)
//return *metadata, err
}
// create filters
var filters nostr.Filters
if _, v, err := nip19.Decode(npub); err == nil {
t := make(map[string][]string)
t["p"] = []string{v.(string)}
filters = []nostr.Filter{{
Authors: []string{v.(string)},
Kinds: []int{0},
// limit = 3, get the three most recent notes
Limit: 1,
}}
} else {
log.Printf("Could not find Profile, trying next relay")
return GetNostrProfileMetaData(npub, index+1)
//return *metadata, err
}
sub, err := relay.Subscribe(ctx, filters)
evs := make([]nostr.Event, 0)
go func() {
<-sub.EndOfStoredEvents
}()
for ev := range sub.Events {
evs = append(evs, *ev)
}
relay.Close()
if len(evs) > 0 {
metadata, err = nostr.ParseMetadata(evs[0])
log.Printf("Success getting Nostr Profile")
} else {
err = fmt.Errorf("no profile found for npub %s on relay %s", npub, url)
log.Printf("Could not find Profile, trying next relay")
return GetNostrProfileMetaData(npub, index+1)
}
return *metadata, err
}
// create filters
var filters nostr.Filters
if _, v, err := nip19.Decode(npub); err == nil {
t := make(map[string][]string)
t["p"] = []string{v.(string)}
filters = []nostr.Filter{{
Authors: []string{v.(string)},
Kinds: []int{0},
// limit = 3, get the three most recent notes
Limit: 1,
}}
} else {
return *metadata, err
return *metadata, fmt.Errorf("Couldn't download Profile for given relays")
}
sub, err := relay.Subscribe(ctx, filters)
evs := make([]nostr.Event, 0)
go func() {
<-sub.EndOfStoredEvents
}()
for ev := range sub.Events {
evs = append(evs, *ev)
}
relay.Close()
if len(evs) > 0 {
metadata, err = nostr.ParseMetadata(evs[0])
} else {
err = fmt.Errorf("no profile found for npub %s on relay %s", npub, url)
}
log.Printf("Success getting Nostr Profile")
return *metadata, err
}