logos-messaging/logos-messaging-go-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-go-bindings.git synced 2026-01-02 14:03:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

requiring user to pass context

Browse Source
This commit is contained in:
Gabriel mermelstein 2024-12-13 17:25:40 +01:00
parent fe86a6d1f1
commit 0b5ad1d78a
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
waku/nwaku.go
View File

@ -425,9 +425,7 @@ func (w *Waku) DialPeer(address multiaddr.Multiaddr) error {
}
// TODO: change pubsub topic to shard notation everywhere
func (w *Waku) RelayPublish(message *pb.WakuMessage, pubsubTopic string) (pb.MessageHash, error) {
ctx, cancel := context.WithTimeout(w.ctx, requestTimeout)
defer cancel()
func (w *Waku) RelayPublish(ctx context.Context, message *pb.WakuMessage, pubsubTopic string) (pb.MessageHash, error) {
return w.node.RelayPublish(ctx, message, pubsubTopic)
}

4
waku/nwaku_test.go
View File

@ -457,7 +457,9 @@ func TestRelay(t *testing.T) {
}
// send message
pubsubTopic := FormatWakuRelayTopic(senderNodeWakuConfig.ClusterID, senderNodeWakuConfig.Shards[0])
senderNode.RelayPublish(message, pubsubTopic)
ctx, cancel := context.WithTimeout(context.Background(), requestTimeout)
defer cancel()
senderNode.RelayPublish(ctx, message, pubsubTopic)
wg := sync.WaitGroup{}
wg.Add(1)