highperfocused/go-nostr
1
0
Fork 0
mirror of https://github.com/nbd-wtf/go-nostr.git synced 2025-07-05 21:12:10 +02:00
Code Issues Packages Projects Releases Wiki Activity

nip46: client small tweaks.

Browse Source
This commit is contained in:
fiatjaf
2024-04-25 18:25:35 -03:00
parent 2a85932a4f
commit 76997c619b
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
nip46/client.go
View File

@ -109,10 +109,12 @@ func NewBunker(
} }
go func() { go func() {
now := nostr.Now()
events := pool.SubMany(ctx, relays, nostr.Filters{ events := pool.SubMany(ctx, relays, nostr.Filters{
{ {
Tags: nostr.TagMap{"p": []string{clientPublicKey}}, Tags: nostr.TagMap{"p": []string{clientPublicKey}},
Kinds: []int{nostr.KindNostrConnect}, Kinds: []int{nostr.KindNostrConnect},
Since: &now,
}, },
}) })
for ie := range events { for ie := range events {
@ -202,8 +204,8 @@ func (bunker *BunkerClient) RPC(ctx context.Context, method string, params []str
respWaiter := make(chan Response) respWaiter := make(chan Response)
bunker.listeners.Store(id, respWaiter) bunker.listeners.Store(id, respWaiter)
hasWorked := false hasWorked := false
for _, r := range bunker.relays { for _, r := range bunker.relays {
relay, err := bunker.pool.EnsureRelay(r) relay, err := bunker.pool.EnsureRelay(r)
if err == nil { if err == nil {
@ -211,6 +213,7 @@ func (bunker *BunkerClient) RPC(ctx context.Context, method string, params []str
} }
relay.Publish(ctx, evt) relay.Publish(ctx, evt)
} }
if !hasWorked { if !hasWorked {
return "", fmt.Errorf("couldn't connect to any relay") return "", fmt.Errorf("couldn't connect to any relay")
} }