Add logging for batch header hash for batcher-node

disperser/batcher/grpc/dispatcher.go

@@ -71,6 +71,10 @@ func (c *dispatcher) sendAllChunks(ctx context.Context, state *core.IndexedOpera
 				return
 			}
 
+			batchHeaderHash, err := batchHeader.GetBatchHeaderHash()
+			if err != nil {
+				return
+			}
 			requestedAt := time.Now()
 			sig, err := c.sendChunks(ctx, blobMessages, batchHeader, &op)
 			if err != nil {
@@ -79,13 +83,15 @@ func (c *dispatcher) sendAllChunks(ctx context.Context, state *core.IndexedOpera
 					Signature: nil,
 					Operator:  id,
 				}
+				c.logger.Warn("Failed to send chunks to operator", "batchHeaderHash", batchHeaderHash, "operator", op.Socket)
 				c.metrics.ObserveLatency(false, float64(time.Since(requestedAt).Milliseconds()))
 			} else {
 				update <- core.SignerMessage{
 					Signature: sig,
 					Operator:  id,
 					Err:       nil,
 				}
+				c.logger.Debug("Successfully sent chunks to operator", "batchHeaderHash", batchHeaderHash, "operator", op.Socket)
 				c.metrics.ObserveLatency(true, float64(time.Since(requestedAt).Milliseconds()))
 			}
 

node/node.go

@@ -281,7 +281,12 @@ func (n *Node) ProcessBatch(ctx context.Context, header *core.BatchHeader, blobs
 	start := time.Now()
 	log := n.Logger
 
-	log.Debug("Processing batch", "num of blobs", len(blobs))
+	batchHeaderHash, err := header.GetBatchHeaderHash()
+	if err != nil {
+		return nil, err
+	}
+
+	log.Debug("Processing batch", "num of blobs", len(blobs), "batchHeaderHash", batchHeaderHash)
 
 	if len(blobs) == 0 {
 		return nil, errors.New("ProcessBatch: number of blobs must be greater than zero")
@@ -301,11 +306,6 @@ func (n *Node) ProcessBatch(ctx context.Context, header *core.BatchHeader, blobs
 	}
 	n.Metrics.AcceptBatches("received", batchSize)
 
-	batchHeaderHash, err := header.GetBatchHeaderHash()
-	if err != nil {
-		return nil, err
-	}
-
 	// Store the batch.
 	// Run this in a goroutine so we can parallelize the batch storing and batch
 	// verifaction work.