highperfocused/go-nostr
1
0
Fork 0
mirror of https://github.com/nbd-wtf/go-nostr.git synced 2025-11-15 16:50:16 +01:00
Code Issues Packages Projects Releases Wiki Activity

updating nip77.go to 286040c

Browse Source
This commit is contained in:
fiatjaf
2024-09-14 17:08:12 -03:00
parent 495c6e6e75
commit 7ab94cc3d9
1 changed files with 4 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
nip77/nip77.go
View File

@@ -2,7 +2,6 @@ package nip77
import ( import (
"context" "context"
"encoding/hex"
"fmt" "fmt"
"sync" "sync"
@@ -41,20 +40,14 @@ func NegentropySync(ctx context.Context, store nostr.RelayStore, url string, fil
result <- fmt.Errorf("relay returned a %s: %s", env.Label(), env.Reason) result <- fmt.Errorf("relay returned a %s: %s", env.Label(), env.Reason)
return return
case *MessageEnvelope: case *MessageEnvelope:
msg, err := hex.DecodeString(env.Message) nextmsg, err := neg.Reconcile(env.Message)
if err != nil {
result <- fmt.Errorf("relay sent invalid message: %w", err)
return
}
nextmsg, err := neg.Reconcile(msg)
if err != nil { if err != nil {
result <- fmt.Errorf("failed to reconcile: %w", err) result <- fmt.Errorf("failed to reconcile: %w", err)
return return
} }
if len(nextmsg) != 0 { if nextmsg != "" {
msgb, _ := MessageEnvelope{id, hex.EncodeToString(nextmsg)}.MarshalJSON() msgb, _ := MessageEnvelope{id, nextmsg}.MarshalJSON()
r.Write(msgb) r.Write(msgb)
} }
} }
@@ -64,7 +57,7 @@ func NegentropySync(ctx context.Context, store nostr.RelayStore, url string, fil
} }
msg := neg.Initiate() msg := neg.Initiate()
open, _ := OpenEnvelope{id, filter, hex.EncodeToString(msg)}.MarshalJSON() open, _ := OpenEnvelope{id, filter, msg}.MarshalJSON()
err = <-r.Write(open) err = <-r.Write(open)
if err != nil { if err != nil {
return fmt.Errorf("failed to write to relay: %w", err) return fmt.Errorf("failed to write to relay: %w", err)