mirror of
https://github.com/logos-messaging/logos-messaging-go-bindings.git
synced 2026-01-05 23:43:05 +00:00
removing debug logs
This commit is contained in:
parent
33d56c35c7
commit
f2cb392871
@ -592,7 +592,6 @@ type topicHealth struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (n *WakuNode) OnEvent(eventStr string) {
|
func (n *WakuNode) OnEvent(eventStr string) {
|
||||||
fmt.Println("---------- GABRIEL received event: ", eventStr)
|
|
||||||
jsonEvent := jsonEvent{}
|
jsonEvent := jsonEvent{}
|
||||||
err := json.Unmarshal([]byte(eventStr), &jsonEvent)
|
err := json.Unmarshal([]byte(eventStr), &jsonEvent)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@ -604,7 +603,6 @@ func (n *WakuNode) OnEvent(eventStr string) {
|
|||||||
case "message":
|
case "message":
|
||||||
n.parseMessageEvent(eventStr)
|
n.parseMessageEvent(eventStr)
|
||||||
case "relay_topic_health_change":
|
case "relay_topic_health_change":
|
||||||
fmt.Println("Received topic health change event")
|
|
||||||
n.parseTopicHealthChangeEvent(eventStr)
|
n.parseTopicHealthChangeEvent(eventStr)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -624,9 +622,6 @@ func (n *WakuNode) parseTopicHealthChangeEvent(eventStr string) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
n.logger.Error("could not parse topic health change", zap.Error(err))
|
n.logger.Error("could not parse topic health change", zap.Error(err))
|
||||||
}
|
}
|
||||||
|
|
||||||
fmt.Println("-------- topicHealth.PubsubTopic: ", topicHealth.PubsubTopic)
|
|
||||||
fmt.Println("-------- topicHealth.TopicHealth: ", topicHealth.TopicHealth)
|
|
||||||
n.TopicHealthChan <- topicHealth
|
n.TopicHealthChan <- topicHealth
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user