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

fix: return value check, support numShardsInNetwork

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-07-14 12:25:18 +02:00
parent aba84ffc7b
commit d750a706a1
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

1
waku/common/config.go
View File

@ -36,4 +36,5 @@ type WakuConfig struct {
DnsAddrsNameServers []string `json:"dnsAddrsNameServers,omitempty"` DnsAddrsNameServers []string `json:"dnsAddrsNameServers,omitempty"`
Discv5EnrAutoUpdate bool `json:"discv5EnrAutoUpdate,omitempty"` Discv5EnrAutoUpdate bool `json:"discv5EnrAutoUpdate,omitempty"`
MaxConnections int `json:"maxConnections,omitempty"` MaxConnections int `json:"maxConnections,omitempty"`
NumShardsInNetwork uint16 `json:"numShardsInNetwork"`
} }

8
waku/nwaku.go
View File

@ -398,16 +398,16 @@ func NewWakuNode(config *common.WakuConfig, nodeName string) (*WakuNode, error)
defer C.free(unsafe.Pointer(cJsonConfig)) defer C.free(unsafe.Pointer(cJsonConfig))
defer C.freeResp(resp) defer C.freeResp(resp)
wg.Add(1)
n.wakuCtx = C.cGoWakuNew(cJsonConfig, resp)
wg.Wait()
if C.getRet(resp) != C.RET_OK { if C.getRet(resp) != C.RET_OK {
errMsg := C.GoStringN(C.getMyCharPtr(resp), C.int(C.getMyCharLen(resp))) errMsg := C.GoStringN(C.getMyCharPtr(resp), C.int(C.getMyCharLen(resp)))
Error("error wakuNew for %s: %v", nodeName, errMsg) Error("error wakuNew for %s: %v", nodeName, errMsg)
return nil, errors.New(errMsg) return nil, errors.New(errMsg)
} }
wg.Add(1)
n.wakuCtx = C.cGoWakuNew(cJsonConfig, resp)
wg.Wait()
n.MsgChan = make(chan common.Envelope, MsgChanBufferSize) n.MsgChan = make(chan common.Envelope, MsgChanBufferSize)
n.TopicHealthChan = make(chan topicHealth, TopicHealthChanBufferSize) n.TopicHealthChan = make(chan topicHealth, TopicHealthChanBufferSize)
n.ConnectionChangeChan = make(chan connectionChange, ConnectionChangeChanBufferSize) n.ConnectionChangeChan = make(chan connectionChange, ConnectionChangeChanBufferSize)