p2p network

taikoxyz · Nov 27, 2024 · 4a07cf8 · 4a07cf8
1 parent 800e658
commit 4a07cf8
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/packages/taiko-client/driver/driver.go b/packages/taiko-client/driver/driver.go
@@ -172,7 +172,15 @@ func (d *Driver) Start() error {
 
 					return err
 				}); err != nil {
-				log.Error("Failed to join soft block topic", "error", err)
+				slog.Error("Failed to join soft block topic", "error", err)
+			}
+
+			if err := p2p.SubscribeToTopic[softblocks.TransactionBatch](
+				d.ctx,
+				d.p2pnetwork,
+				p2p.TopicNameSoftBlocks,
+			); err != nil {
+				slog.Error("Failed to subscribe to soft block topic", "error", err)
 			}
 		}()
 	}