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-09 17:33:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

adding topic health change event

Browse Source
This commit is contained in:
Gabriel mermelstein 2024-12-16 13:14:06 +01:00
parent 7eb7647599
commit 5fe32f7dec
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
waku/nwaku.go
View File

@ -506,6 +506,7 @@ func newWakuNode(ctx context.Context, config *WakuConfig, logger *zap.Logger) (*
// Notice that the events for self node are handled by the 'MyEventCallback' method
C.cGoWakuSetEventCallback(n.wakuCtx)
registerNode(n)
return n, nil
}
@ -583,6 +584,7 @@ type jsonEvent struct {
}
func (n *WakuNode) OnEvent(eventStr string) {
fmt.Println("---------- GABRIEL received event: ", eventStr)
jsonEvent := jsonEvent{}
err := json.Unmarshal([]byte(eventStr), &jsonEvent)
if err != nil {
@ -593,6 +595,8 @@ func (n *WakuNode) OnEvent(eventStr string) {
switch jsonEvent.EventType {
case "message":
n.parseMessageEvent(eventStr)
case "relay_topic_health_change":
fmt.Println("Received topic health change event")
}
}
@ -965,7 +969,6 @@ func (n *WakuNode) Start() error {
C.cGoWakuStart(n.wakuCtx, resp)
wg.Wait()
if C.getRet(resp) == C.RET_OK {
registerNode(n)
return nil
}