logos-messaging/logos-messaging-go-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-go-bindings.git synced 2026-03-28 06:43:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

removing cancel func

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-01-09 17:14:01 +01:00
parent b69cc5afa6
commit 81c1572072
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
waku/nwaku.go
View File

@ -433,7 +433,6 @@ type WakuNode struct {
wakuCtx unsafe.Pointer
wakuCfg *WakuConfig
logger *zap.Logger
cancel context.CancelFunc
MsgChan chan common.Envelope
TopicHealthChan chan topicHealth
}
@ -442,6 +441,7 @@ func newWakuNode(config *WakuConfig, logger *zap.Logger) (*WakuNode, error) {
n := &WakuNode{
wakuCfg: config,
logger: logger,
}
wg := sync.WaitGroup{}
@ -469,7 +469,6 @@ func newWakuNode(config *WakuConfig, logger *zap.Logger) (*WakuNode, error) {
n.MsgChan = make(chan common.Envelope, MsgChanBufferSize)
n.TopicHealthChan = make(chan topicHealth, TopicHealthChanBufferSize)
n.logger = logger.Named("nwaku")
// Notice that the events for self node are handled by the 'MyEventCallback' method
C.cGoWakuSetEventCallback(n.wakuCtx)
@ -544,7 +543,6 @@ func (n *WakuNode) OnEvent(eventStr string) {
}
func (n *WakuNode) parseMessageEvent(eventStr string) {
fmt.Println("----------- got message event: ", eventStr)
envelope, err := common.NewEnvelope(eventStr)
if err != nil {
n.logger.Error("could not parse message", zap.Error(err))

5
waku/nwaku_test.go
View File

@ -35,6 +35,9 @@ func TestBasicWaku(t *testing.T) {
// ctx := context.Background()
logger, err := zap.NewDevelopment()
require.NoError(t, err)
nwakuConfig := WakuConfig{
Nodekey: "11d0dcea28e86f81937a3bd1163473c7fbc0a0db54fd72914849bc47bdf78710",
Relay: true,
@ -50,7 +53,7 @@ func TestBasicWaku(t *testing.T) {
storeNodeMa, err := ma.NewMultiaddr(storeNodeInfo.ListenAddresses[0])
require.NoError(t, err)
w, err := newWakuNode(&nwakuConfig, nil)
w, err := newWakuNode(&nwakuConfig, logger.Named("nwaku"))
require.NoError(t, err)
require.NoError(t, w.Start())