feat: block-fetch BatchDone callback function support (#791)

protocol/blockfetch/blockfetch.go

@@ -88,6 +88,7 @@ type BlockFetch struct {
 
 type Config struct {
 	BlockFunc         BlockFunc
+	BatchDoneFunc     BatchDoneFunc
 	RequestRangeFunc  RequestRangeFunc
 	BatchStartTimeout time.Duration
 	BlockTimeout      time.Duration
@@ -102,6 +103,7 @@ type CallbackContext struct {
 
 // Callback function types
 type BlockFunc func(CallbackContext, uint, ledger.Block) error
+type BatchDoneFunc func(CallbackContext) error
 type RequestRangeFunc func(CallbackContext, common.Point, common.Point) error
 
 func New(protoOptions protocol.ProtocolOptions, cfg *Config) *BlockFetch {
@@ -132,6 +134,12 @@ func WithBlockFunc(blockFunc BlockFunc) BlockFetchOptionFunc {
 	}
 }
 
+func WithBatchDoneFunc(batchDoneFunc BatchDoneFunc) BlockFetchOptionFunc {
+	return func(c *Config) {
+		c.BatchDoneFunc = batchDoneFunc
+	}
+}
+
 func WithRequestRangeFunc(
 	requestRangeFunc RequestRangeFunc,
 ) BlockFetchOptionFunc {

protocol/blockfetch/client.go

@@ -283,6 +283,12 @@ func (c *Client) handleBatchDone() error {
 			"role", "client",
 			"connection_id", c.callbackContext.ConnectionId.String(),
 		)
+	// Notify the user if requested
+	if c.blockUseCallback && c.config.BatchDoneFunc != nil {
+		if err := c.config.BatchDoneFunc(c.callbackContext); err != nil {
+			return err
+		}
+	}
 	c.busyMutex.Unlock()
 	return nil
 }