Connect applicator broadcast handlers

koinos · Jul 14, 2022 · 78d52b4 · 78d52b4
1 parent 9070f07
commit 78d52b4
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/internal/node/node.go b/internal/node/node.go
@@ -192,6 +192,10 @@ func (n *KoinosP2PNode) handleBlockBroadcast(topic string, data []byte) {
 		return
 	}
 
+	go func() {
+		n.BlockApplicator.HandleBlockBroadcast(blockBroadcast)
+	}()
+
 	// If gossip is enabled publish the block
 	if n.GossipToggle.IsEnabled() {
 		err = n.Gossip.PublishBlock(context.Background(), blockBroadcast.Block)
@@ -230,6 +234,10 @@ func (n *KoinosP2PNode) handleForkUpdate(topic string, data []byte) {
 		return
 	}
 
+	go func() {
+		n.BlockApplicator.HandleForkHeads(forkHeads)
+	}()
+
 	n.libValue.Store(forkHeads.LastIrreversibleBlock)
 }