wip

Layr-Labs · Feb 6, 2025 · 6c86687 · 6c86687
1 parent 03f9438
commit 6c86687
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/pkg/rpcServer/eventHandlers.go b/pkg/rpcServer/eventHandlers.go
@@ -116,12 +116,14 @@ func (rpc *RpcServer) StreamIndexedBlocks(request *v1.StreamIndexedBlocksRequest
 		rpc.Logger.Debug("Received block", zap.Any("data", data))
 		blockProcessedData := data.(*eventBusTypes.BlockProcessedData)
 
-		resp, err := rpc.buildBlockResponse(blockProcessedData, request.GetIncludeStateChanges())
-		if err != nil {
-			return err
-		}
+		if onlyBlocksWithData && processedBlockHasData(blockProcessedData) {
+			resp, err := rpc.buildBlockResponse(blockProcessedData, request.GetIncludeStateChanges())
+			if err != nil {
+				return err
+			}
 
-		return g.SendMsg(resp)
+			return g.SendMsg(resp)
+		}
 	})
 	if err != nil {
 		return err