From 5fe32f7decac51c51ea90ceb062660a225be83b4 Mon Sep 17 00:00:00 2001
From: Gabriel mermelstein <gabrielmermelstein@gmail.com>
Date: Mon, 16 Dec 2024 13:14:06 +0100
Subject: [PATCH] adding topic health change event

---
 waku/nwaku.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/waku/nwaku.go b/waku/nwaku.go
index b6ab7d7..cb72564 100644
--- a/waku/nwaku.go
+++ b/waku/nwaku.go
@@ -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
 	}