added server and client debug prints

ChristianMct · Apr 22, 2024 · 02dff7f · 02dff7f
1 parent c24f65b
commit 02dff7f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/client.go b/client.go
@@ -166,8 +166,11 @@ func (hc *HeliumClient) Register(ctx context.Context) (upstream *coordinator.Cha
 				}
 				return
 			}
-			eventsStream <- api.ToNodeEvent(apiEvent)
 
+			ev := api.ToNodeEvent(apiEvent)
+			log.Printf("[client] received event: %s", ev)
+			eventsStream <- ev
+			log.Printf("[client] fwd event: %s", ev)
 		}
 	}()
 

diff --git a/server.go b/server.go
@@ -221,7 +221,7 @@ func (hsv *HeliumServer) Register(_ *pb.Void, stream pb.Helium_RegisterServer) e
 			break
 		}
 	}
-	hsv.Logf("done sending past events to %s, stream is live", nodeID)
+	hsv.Logf("done sending %d past events to %s, stream is live", present, nodeID)
 
 	// Processes the node's sendQueue. The sendQueue channel is closed when exiting the loop
 	cancelled := stream.Context().Done()
@@ -234,6 +234,7 @@ func (hsv *HeliumServer) Register(_ *pb.Void, stream pb.Helium_RegisterServer) e
 					done = true
 					hsv.Logf("error on stream send for %s: %s", nodeID, err)
 				}
+				hsv.Logf("sent to node %s: %s", nodeID, evt)
 			} else {
 				done = true
 				hsv.Logf("update queue for %s closed", nodeID)