test wip

sourcenetwork · Jun 26, 2024 · ffd0d74 · ffd0d74
1 parent 6a5071e
commit ffd0d74
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/internal/db/messages.go b/internal/db/messages.go
@@ -75,6 +75,7 @@ func (db *db) handleMessages(ctx context.Context, sub *event.Subscription) {
 					}
 				})
 				go onceReps.Do(func() {
+					log.Info("Loading replicators")
 					err := db.loadAndPublishReplicators(ctx)
 					if err != nil {
 						log.ErrorContextE(ctx, "Failed to load replicators", err)

diff --git a/net/server.go b/net/server.go
@@ -358,6 +358,7 @@ func (s *server) updateReplicators(evt event.Replicator) {
 
 	if evt.Docs != nil {
 		for update := range evt.Docs {
+			log.Info("Replicator update", corelog.Any("to peer", evt.Info.ID))
 			if err := s.pushLog(s.peer.ctx, update, evt.Info.ID); err != nil {
 				log.ErrorContextE(
 					s.peer.ctx,