[Access] Add compatible range to Node Version Info endpoint

access/api.go

@@ -272,4 +272,6 @@ type NodeVersionInfo struct {
 	ProtocolVersion      uint64
 	SporkRootBlockHeight uint64
 	NodeRootBlockHeight  uint64
+	StartHeight          uint64
+	EndHeight            uint64
 }

access/handler.go

@@ -100,6 +100,8 @@ func (h *Handler) GetNodeVersionInfo(
 			ProtocolVersion:      nodeVersionInfo.ProtocolVersion,
 			SporkRootBlockHeight: nodeVersionInfo.SporkRootBlockHeight,
 			NodeRootBlockHeight:  nodeVersionInfo.NodeRootBlockHeight,
+			StartHeight:          nodeVersionInfo.StartHeight,
+			EndHeight:            nodeVersionInfo.EndHeight,
 		},
 	}, nil
 }

cmd/access/node_builder/access_node_builder.go

@@ -323,7 +323,7 @@ type FlowAccessNodeBuilder struct {
 	ExecutionDataPruner        *pruner.Pruner
 	ExecutionDatastoreManager  edstorage.DatastoreManager
 	ExecutionDataTracker       tracker.Storage
-	versionControl             *version.VersionControl
+	VersionControl             *version.VersionControl
 
 	// The sync engine participants provider is the libp2p peer store for the access node
 	// which is not available until after the network has started.
@@ -978,7 +978,7 @@ func (builder *FlowAccessNodeBuilder) BuildExecutionSyncComponents() *FlowAccess
 					builder.programCacheSize > 0,
 				)
 
-				err = builder.ScriptExecutor.Initialize(builder.ExecutionIndexer, scripts, builder.versionControl)
+				err = builder.ScriptExecutor.Initialize(builder.ExecutionIndexer, scripts, builder.VersionControl)
 				if err != nil {
 					return nil, err
 				}
@@ -1813,8 +1813,8 @@ func (builder *FlowAccessNodeBuilder) Build() (cmd.Node, error) {
 			// VersionControl needs to consume BlockFinalized events.
 			node.ProtocolEvents.AddConsumer(versionControl)
 
-			builder.versionControl = versionControl
-			versionControlDependable.Init(builder.versionControl)
+			builder.VersionControl = versionControl
+			versionControlDependable.Init(builder.VersionControl)
 
 			return versionControl, nil
 		}).
@@ -1921,6 +1921,7 @@ func (builder *FlowAccessNodeBuilder) Build() (cmd.Node, error) {
 				TxResultQueryMode:   txResultQueryMode,
 				TxResultsIndex:      builder.TxResultsIndex,
 				LastFullBlockHeight: lastFullBlockHeight,
+				VersionControl:      builder.VersionControl,
 			})
 			if err != nil {
 				return nil, fmt.Errorf("could not initialize backend: %w", err)

cmd/observer/node_builder/observer_builder.go

@@ -279,7 +279,7 @@ type ObserverServiceBuilder struct {
 	ExecutionIndexerCore *indexer.IndexerCore
 	TxResultsIndex       *index.TransactionResultsIndex
 	IndexerDependencies  *cmd.DependencyList
-	versionControl       *version.VersionControl
+	VersionControl       *version.VersionControl
 
 	ExecutionDataDownloader   execution_data.Downloader
 	ExecutionDataRequester    state_synchronization.ExecutionDataRequester
@@ -1513,7 +1513,7 @@ func (builder *ObserverServiceBuilder) BuildExecutionSyncComponents() *ObserverS
 				builder.programCacheSize > 0,
 			)
 
-			err = builder.ScriptExecutor.Initialize(builder.ExecutionIndexer, scripts, builder.versionControl)
+			err = builder.ScriptExecutor.Initialize(builder.ExecutionIndexer, scripts, builder.VersionControl)
 			if err != nil {
 				return nil, err
 			}
@@ -1854,8 +1854,8 @@ func (builder *ObserverServiceBuilder) enqueueRPCServer() {
 		// VersionControl needs to consume BlockFinalized events.
 		node.ProtocolEvents.AddConsumer(versionControl)
 
-		builder.versionControl = versionControl
-		versionControlDependable.Init(builder.versionControl)
+		builder.VersionControl = versionControl
+		versionControlDependable.Init(builder.VersionControl)
 
 		return versionControl, nil
 	})
@@ -1930,6 +1930,7 @@ func (builder *ObserverServiceBuilder) enqueueRPCServer() {
 				builder.stateStreamConf.ResponseLimit,
 				builder.stateStreamConf.ClientSendBufferSize,
 			),
+			VersionControl: builder.VersionControl,
 		}
 
 		if builder.localServiceAPIEnabled {

engine/access/handle_irrecoverable_state_test.go

@@ -75,12 +75,7 @@ func (suite *IrrecoverableStateTestSuite) SetupTest() {
 	suite.state = protocol.NewState(suite.T())
 	suite.snapshot = protocol.NewSnapshot(suite.T())
 
-	rootHeader := unittest.BlockHeaderFixture()
 	params := protocol.NewParams(suite.T())
-	params.On("SporkID").Return(unittest.IdentifierFixture(), nil)
-	params.On("ProtocolVersion").Return(uint(unittest.Uint64InRange(10, 30)), nil)
-	params.On("SporkRootBlockHeight").Return(rootHeader.Height, nil)
-	params.On("SealedRoot").Return(rootHeader, nil)
 
 	suite.epochQuery = protocol.NewEpochQuery(suite.T())
 	suite.state.On("Sealed").Return(suite.snapshot, nil).Maybe()

engine/access/rest/models/model_node_version_info.go

@@ -15,4 +15,6 @@ type NodeVersionInfo struct {
 	ProtocolVersion      string `json:"protocol_version"`
 	SporkRootBlockHeight string `json:"spork_root_block_height"`
 	NodeRootBlockHeight  string `json:"node_root_block_height"`
+	StartHeight          string `json:"start_height"`
+	EndHeight            string `json:"end_height"`
 }

engine/access/rest/models/node_version_info.go

@@ -12,4 +12,6 @@ func (t *NodeVersionInfo) Build(params *access.NodeVersionInfo) {
 	t.ProtocolVersion = util.FromUint(params.ProtocolVersion)
 	t.SporkRootBlockHeight = util.FromUint(params.SporkRootBlockHeight)
 	t.NodeRootBlockHeight = util.FromUint(params.NodeRootBlockHeight)
+	t.StartHeight = util.FromUint(params.StartHeight)
+	t.EndHeight = util.FromUint(params.EndHeight)
 }

engine/access/rest/routes/node_version_info_test.go

@@ -28,13 +28,17 @@ func TestGetNodeVersionInfo(t *testing.T) {
 	t.Run("get node version info", func(t *testing.T) {
 		req := getNodeVersionInfoRequest(t)
 
+		nodeRootBlockHeight := unittest.Uint64InRange(10_000, 100_000)
+
 		params := &access.NodeVersionInfo{
 			Semver:               build.Version(),
 			Commit:               build.Commit(),
 			SporkId:              unittest.IdentifierFixture(),
 			ProtocolVersion:      unittest.Uint64InRange(10, 30),
 			SporkRootBlockHeight: unittest.Uint64InRange(1000, 10_000),
-			NodeRootBlockHeight:  unittest.Uint64InRange(10_000, 100_000),
+			NodeRootBlockHeight:  nodeRootBlockHeight,
+			StartHeight:          nodeRootBlockHeight,
+			EndHeight:            uint64(0),
 		}
 
 		backend.Mock.
@@ -55,14 +59,18 @@ func nodeVersionInfoExpectedStr(nodeVersionInfo *access.NodeVersionInfo) string
 			"spork_id": "%s",
             "protocol_version": "%d",
             "spork_root_block_height": "%d",
-            "node_root_block_height": "%d"
+            "node_root_block_height": "%d",
+            "start_height": "%d",
+            "end_height": "%d"
 		}`,
 		nodeVersionInfo.Semver,
 		nodeVersionInfo.Commit,
 		nodeVersionInfo.SporkId.String(),
 		nodeVersionInfo.ProtocolVersion,
 		nodeVersionInfo.SporkRootBlockHeight,
 		nodeVersionInfo.NodeRootBlockHeight,
+		nodeVersionInfo.StartHeight,
+		nodeVersionInfo.EndHeight,
 	)
 }
 

engine/access/rpc/backend/backend.go

@@ -16,6 +16,7 @@ import (
 	"github.com/onflow/flow-go/engine/access/rpc/connection"
 	"github.com/onflow/flow-go/engine/access/subscription"
 	"github.com/onflow/flow-go/engine/common/rpc"
+	"github.com/onflow/flow-go/engine/common/version"
 	"github.com/onflow/flow-go/fvm/blueprints"
 	"github.com/onflow/flow-go/model/flow"
 	"github.com/onflow/flow-go/model/flow/filter"
@@ -81,9 +82,9 @@ type Backend struct {
 	executionReceipts storage.ExecutionReceipts
 	connFactory       connection.ConnectionFactory
 
-	// cache the response to GetNodeVersionInfo since it doesn't change
-	nodeInfo     *access.NodeVersionInfo
-	BlockTracker subscription.BlockTracker
+	BlockTracker   subscription.BlockTracker
+	stateParams    protocol.Params
+	versionControl *version.VersionControl
 }
 
 type Params struct {
@@ -119,6 +120,7 @@ type Params struct {
 	TxResultQueryMode   IndexQueryMode
 	TxResultsIndex      *index.TransactionResultsIndex
 	LastFullBlockHeight *counters.PersistentStrictMonotonicCounter
+	VersionControl      *version.VersionControl
 }
 
 var _ TransactionErrorMessage = (*Backend)(nil)
@@ -162,9 +164,6 @@ func New(params Params) (*Backend, error) {
 	}
 	systemTxID := systemTx.ID()
 
-	// initialize node version info
-	nodeInfo := getNodeVersionInfo(params.State.Params())
-
 	transactionsLocalDataProvider := &TransactionsLocalDataProvider{
 		state:               params.State,
 		collections:         params.Collections,
@@ -243,7 +242,8 @@ func New(params Params) (*Backend, error) {
 		executionReceipts: params.ExecutionReceipts,
 		connFactory:       params.ConnFactory,
 		chainID:           params.ChainID,
-		nodeInfo:          nodeInfo,
+		stateParams:       params.State.Params(),
+		versionControl:    params.VersionControl,
 	}
 
 	txValidator, err := configureTransactionValidator(params.State, params.ChainID, params.ScriptExecutor, params.CheckPayerBalance)
@@ -344,17 +344,30 @@ func (b *Backend) Ping(ctx context.Context) error {
 
 // GetNodeVersionInfo returns node version information such as semver, commit, sporkID, protocolVersion, etc
 func (b *Backend) GetNodeVersionInfo(_ context.Context) (*access.NodeVersionInfo, error) {
-	return b.nodeInfo, nil
+	return b.getNodeVersionInfo(), nil
 }
 
 // getNodeVersionInfo returns the NodeVersionInfo for the node.
-// Since these values are static while the node is running, it is safe to cache.
-func getNodeVersionInfo(stateParams protocol.Params) *access.NodeVersionInfo {
-	sporkID := stateParams.SporkID()
-	protocolVersion := stateParams.ProtocolVersion()
-	sporkRootBlockHeight := stateParams.SporkRootBlockHeight()
+func (b *Backend) getNodeVersionInfo() *access.NodeVersionInfo {
+	sporkID := b.stateParams.SporkID()
+	protocolVersion := b.stateParams.ProtocolVersion()
+	sporkRootBlockHeight := b.stateParams.SporkRootBlockHeight()
+
+	nodeRootBlockHeader := b.stateParams.SealedRoot()
+
+	var startHeight uint64
+	var endHeight uint64
 
-	nodeRootBlockHeader := stateParams.SealedRoot()
+	// Version control feature could be disabled
+	if b.versionControl != nil {
+		startHeight = b.versionControl.StartHeight()
+		endHeight = b.versionControl.EndHeight()
+	}
+
+	// startHeight is the root block if there is no start boundary in the current spork
+	if startHeight == version.NoHeight {
+		startHeight = nodeRootBlockHeader.Height
+	}
 
 	nodeInfo := &access.NodeVersionInfo{
 		Semver:               build.Version(),
@@ -363,6 +376,8 @@ func getNodeVersionInfo(stateParams protocol.Params) *access.NodeVersionInfo {
 		ProtocolVersion:      uint64(protocolVersion),
 		SporkRootBlockHeight: sporkRootBlockHeight,
 		NodeRootBlockHeight:  nodeRootBlockHeader.Height,
+		StartHeight:          startHeight,
+		EndHeight:            endHeight,
 	}
 
 	return nodeInfo

engine/access/rpc/backend/backend_stream_transactions_test.go

@@ -98,13 +98,7 @@ func (s *TransactionStatusSuite) SetupTest() {
 	s.tempSnapshot = &protocol.Snapshot{}
 	s.db, s.dbDir = unittest.TempBadgerDB(s.T())
 
-	header := unittest.BlockHeaderFixture()
-
 	params := protocol.NewParams(s.T())
-	params.On("SporkID").Return(unittest.IdentifierFixture(), nil)
-	params.On("ProtocolVersion").Return(uint(unittest.Uint64InRange(10, 30)), nil)
-	params.On("SporkRootBlockHeight").Return(header.Height, nil)
-	params.On("SealedRoot").Return(header, nil)
 	s.state.On("Params").Return(params)
 
 	s.blocks = storagemock.NewBlocks(s.T())