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

fix: queried multiaddress

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-04-11 13:11:09 +03:00
parent ddfd2ce9ec
commit e7c5a05ed0
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
waku/v2/api/publish/default_verifier.go
View File

@ -6,6 +6,7 @@ import (
"github.com/libp2p/go-libp2p/core/peer"
"github.com/waku-org/go-waku/waku/v2/protocol/pb"
"github.com/waku-org/go-waku/waku/v2/protocol/store"
"github.com/waku-org/go-waku/waku/v2/utils"
)
func NewDefaultStorenodeMessageVerifier(store *store.WakuStore) StorenodeMessageVerifier {
@ -19,10 +20,12 @@ type defaultStorenodeMessageVerifier struct {
}
func (d *defaultStorenodeMessageVerifier) MessageHashesExist(ctx context.Context, requestID []byte, peerInfo peer.AddrInfo, pageSize uint64, messageHashes []pb.MessageHash) ([]pb.MessageHash, error) {
addrs := utils.EncapsulatePeerID(peerInfo.ID, peerInfo.Addrs...)
var opts []store.RequestOption
opts = append(opts, store.WithRequestID(requestID))
opts = append(opts, store.WithPeerAddr(peerInfo.Addrs...))
opts = append(opts, store.WithPeer(peerInfo.ID))
opts = append(opts, store.WithPeerAddr(addrs...))
opts = append(opts, store.WithPaging(false, pageSize))
opts = append(opts, store.IncludeData(false))