Gossip does not stream messages in a continuous fashion

[harsh4786]

I'm trying to connect to a node and listen to messages, the problem is it just receives a burst of messages and then the messages stop. Why would that be happening? Here's the code I'm trying to run:-
https://github.com/harsh4786/hopchat/blob/master/src/main.rs

[thomaseizinger]

With messages you mean gossipsub messages?

At a first glance, your code looks good but I don't see any part that would actually publish to the topic you are subscribed to. If nobody publishes messages, you can't receive anything :)

[harsh4786]

Thank you so much for digging this deep! 😃 What exactly do you mean by running kad.bootstrap() on an interval?

[harsh4786]

This is the official wormhole go implementation of p2p:
https://github.com/wormhole-foundation/wormhole/blob/main/node/pkg/p2p/p2p.go#L260

this is the spy node implementation in go which uses the above p2p:
https://github.com/wormhole-foundation/wormhole/blob/main/node/cmd/spy/spy.go#L52

and these are the arguments to the cli, notice the —network argument in the docker command:

https://github.com/wormhole-foundation/wormhole/tree/12-19-wormchain_-_contract_deploy_test/relayer/spy_relayer#running-the-whole-stack-for-testing

[harsh4786]

How should I call the kad.bootstrap() on an interval, if you could please elaborate on that? 😅

[thomaseizinger]

How should I call the kad.bootstrap() on an interval, if you could please elaborate on that? 😅

Have a timer that fires every couple of minutes and call bootstrap as a result.

[thomaseizinger]

This is the official wormhole go implementation of p2p: https://github.com/wormhole-foundation/wormhole/blob/main/node/pkg/p2p/p2p.go#L260

this is the spy node implementation in go which uses the above p2p: https://github.com/wormhole-foundation/wormhole/blob/main/node/cmd/spy/spy.go#L52

and these are the arguments to the cli, notice the —network argument in the docker command:

https://github.com/wormhole-foundation/wormhole/tree/12-19-wormchain_-_contract_deploy_test/relayer/spy_relayer#running-the-whole-stack-for-testing

You'll need to figure out what the kademlia protocol string is. The wormhole devs will know what that is if you ask them :)

[harsh4786]

How should I call the kad.bootstrap() on an interval, if you could please elaborate on that? 😅

Have a timer that fires every couple of minutes and call bootstrap as a result.

Ok so i did this, now it does bootstrap at a certain interval but then i still dont get new messages:
https://github.com/harsh4786/hopchat/blob/master/src/main.rs#L153

[thomaseizinger]

Because your kademlia protocol is still wrong: https://github.com/harsh4786/hopchat/blob/428ed740aa8cec713ec23a0e49e62100f5699b80/src/main.rs#L67

[thomaseizinger]

You are not actually bootstrapping. You only connect to the bootnode, nothing else. Activate the logs and you'll see it yourself :)

[thomaseizinger]

I am closing this as resolved because it is a configuration bug.

[harsh4786]

okay, thank you so much for all the help, i really appreciate it! Can i chat with you here if i face any further issues on this topic?

[thomaseizinger]

Sure!