pass new context to getDocHeads

sourcenetwork · Jun 27, 2024 · 9433d54 · 9433d54
1 parent fb13a22
commit 9433d54
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/internal/db/p2p_replicator.go b/internal/db/p2p_replicator.go
@@ -131,7 +131,7 @@ func (db *db) SetReplicator(ctx context.Context, rep client.Replicator) error {
 		db.events.Publish(event.NewMessage(event.ReplicatorName, event.Replicator{
 			Info:    rep.Info,
 			Schemas: storedSchemas,
-			Docs:    db.getDocsHeads(ctx, addedCols),
+			Docs:    db.getDocsHeads(context.Background(), addedCols),
 		}))
 	})
 

diff --git a/net/peer.go b/net/peer.go
@@ -219,8 +219,6 @@ func NewPeer(
 		cancel:     cancel,
 	}
 
-	p.bus.Publish(event.NewMessage(event.PeerInfoName, event.PeerInfo{Info: p.PeerInfo()}))
-
 	p.server, err = newServer(p, options.GRPCDialOptions...)
 	if err != nil {
 		return nil, err
@@ -282,6 +280,8 @@ func (p *Peer) Start() error {
 		}
 	}()
 
+	p.bus.Publish(event.NewMessage(event.PeerInfoName, event.PeerInfo{Info: p.PeerInfo()}))
+
 	return nil
 }