[Access] Add compatible range to Node Version Info endpoint

access/api.go

@@ -15,7 +15,7 @@ import (
 type API interface {
 	Ping(ctx context.Context) error
 	GetNetworkParameters(ctx context.Context) NetworkParameters
-	GetNodeVersionInfo(ctx context.Context) (*NodeVersionInfo, error)
+	GetNodeVersionInfo(ctx context.Context) (*flow.NodeVersionInfo, error)
 
 	GetLatestBlockHeader(ctx context.Context, isSealed bool) (*flow.Header, flow.BlockStatus, error)
 	GetBlockHeaderByHeight(ctx context.Context, height uint64) (*flow.Header, flow.BlockStatus, error)
@@ -263,13 +263,3 @@ func MessageToTransactionResult(message *access.TransactionResultResponse) *Tran
 type NetworkParameters struct {
 	ChainID flow.ChainID
 }
-
-// NodeVersionInfo contains information about node, such as semver, commit, sporkID, protocolVersion, etc
-type NodeVersionInfo struct {
-	Semver               string
-	Commit               string
-	SporkId              flow.Identifier
-	ProtocolVersion      uint64
-	SporkRootBlockHeight uint64
-	NodeRootBlockHeight  uint64
-}

access/handler.go

@@ -100,6 +100,7 @@ func (h *Handler) GetNodeVersionInfo(
 			ProtocolVersion:      nodeVersionInfo.ProtocolVersion,
 			SporkRootBlockHeight: nodeVersionInfo.SporkRootBlockHeight,
 			NodeRootBlockHeight:  nodeVersionInfo.NodeRootBlockHeight,
+			CompatibleRange:      convert.CompatibleRangeToMessage(nodeVersionInfo.CompatibleRange),
 		},
 	}, 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_compatible_range.go

@@ -0,0 +1,15 @@
+/*
+ * Access API
+ *
+ * No description provided (generated by Swagger Codegen https://github.com/swagger-api/swagger-codegen)
+ *
+ * API version: 1.0.0
+ * Generated by: Swagger Codegen (https://github.com/swagger-api/swagger-codegen.git)
+ */
+package models
+
+// A compatible version range.
+type CompatibleRange struct {
+	StartHeight string `json:"start_height"`
+	EndHeight   string `json:"end_height"`
+}

engine/access/rest/models/model_node_version_info.go

@@ -9,10 +9,11 @@
 package models
 
 type NodeVersionInfo struct {
-	Semver               string `json:"semver"`
-	Commit               string `json:"commit"`
-	SporkId              string `json:"spork_id"`
-	ProtocolVersion      string `json:"protocol_version"`
-	SporkRootBlockHeight string `json:"spork_root_block_height"`
-	NodeRootBlockHeight  string `json:"node_root_block_height"`
+	Semver               string           `json:"semver"`
+	Commit               string           `json:"commit"`
+	SporkId              string           `json:"spork_id"`
+	ProtocolVersion      string           `json:"protocol_version"`
+	SporkRootBlockHeight string           `json:"spork_root_block_height"`
+	NodeRootBlockHeight  string           `json:"node_root_block_height"`
+	CompatibleRange      *CompatibleRange `json:"compatible_range,omitempty"`
 }

engine/access/rest/models/node_version_info.go

@@ -1,15 +1,22 @@
 package models
 
 import (
-	"github.com/onflow/flow-go/access"
 	"github.com/onflow/flow-go/engine/access/rest/util"
+	"github.com/onflow/flow-go/model/flow"
 )
 
-func (t *NodeVersionInfo) Build(params *access.NodeVersionInfo) {
+func (t *NodeVersionInfo) Build(params *flow.NodeVersionInfo) {
 	t.Semver = params.Semver
 	t.Commit = params.Commit
 	t.SporkId = params.SporkId.String()
 	t.ProtocolVersion = util.FromUint(params.ProtocolVersion)
 	t.SporkRootBlockHeight = util.FromUint(params.SporkRootBlockHeight)
 	t.NodeRootBlockHeight = util.FromUint(params.NodeRootBlockHeight)
+
+	if params.CompatibleRange != nil {
+		t.CompatibleRange = &CompatibleRange{
+			StartHeight: util.FromUint(params.CompatibleRange.StartHeight),
+			EndHeight:   util.FromUint(params.CompatibleRange.EndHeight),
+		}
+	}
 }

engine/access/rest/routes/node_version_info_test.go

@@ -9,9 +9,9 @@ import (
 	mocktestify "github.com/stretchr/testify/mock"
 	"github.com/stretchr/testify/require"
 
-	"github.com/onflow/flow-go/access"
 	"github.com/onflow/flow-go/access/mock"
 	"github.com/onflow/flow-go/cmd/build"
+	"github.com/onflow/flow-go/model/flow"
 	"github.com/onflow/flow-go/utils/unittest"
 )
 
@@ -28,13 +28,19 @@ func TestGetNodeVersionInfo(t *testing.T) {
 	t.Run("get node version info", func(t *testing.T) {
 		req := getNodeVersionInfoRequest(t)
 
-		params := &access.NodeVersionInfo{
+		nodeRootBlockHeight := unittest.Uint64InRange(10_000, 100_000)
+
+		params := &flow.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,
+			CompatibleRange: &flow.CompatibleRange{
+				StartHeight: nodeRootBlockHeight,
+				EndHeight:   uint64(0),
+			},
 		}
 
 		backend.Mock.
@@ -48,21 +54,31 @@ func TestGetNodeVersionInfo(t *testing.T) {
 	})
 }
 
-func nodeVersionInfoExpectedStr(nodeVersionInfo *access.NodeVersionInfo) string {
+func nodeVersionInfoExpectedStr(nodeVersionInfo *flow.NodeVersionInfo) string {
+	compatibleRange := fmt.Sprintf(`"compatible_range": {
+		"start_height": "%d",
+		"end_height": "%d"
+	}`,
+		nodeVersionInfo.CompatibleRange.StartHeight,
+		nodeVersionInfo.CompatibleRange.EndHeight,
+	)
+
 	return fmt.Sprintf(`{
 			"semver": "%s",
 			"commit": "%s",
 			"spork_id": "%s",
             "protocol_version": "%d",
             "spork_root_block_height": "%d",
-            "node_root_block_height": "%d"
+            "node_root_block_height": "%d",
+            %s
 		}`,
 		nodeVersionInfo.Semver,
 		nodeVersionInfo.Commit,
 		nodeVersionInfo.SporkId.String(),
 		nodeVersionInfo.ProtocolVersion,
 		nodeVersionInfo.SporkRootBlockHeight,
 		nodeVersionInfo.NodeRootBlockHeight,
+		compatibleRange,
 	)
 }
 

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)
@@ -343,26 +343,41 @@ 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
+func (b *Backend) GetNodeVersionInfo(_ context.Context) (*flow.NodeVersionInfo, error) {
+	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() *flow.NodeVersionInfo {
+	sporkID := b.stateParams.SporkID()
+	protocolVersion := b.stateParams.ProtocolVersion()
+	sporkRootBlockHeight := b.stateParams.SporkRootBlockHeight()
+
+	nodeRootBlockHeader := b.stateParams.SealedRoot()
 
-	nodeRootBlockHeader := stateParams.SealedRoot()
+	var compatibleRange *flow.CompatibleRange
+
+	// Version control feature could be disabled
+	if b.versionControl != nil {
+		compatibleRange = &flow.CompatibleRange{
+			StartHeight: b.versionControl.StartHeight(),
+			EndHeight:   b.versionControl.EndHeight(),
+		}
+
+		// StartHeight is the root block if there is no start boundary in the current spork
+		if compatibleRange.StartHeight == version.NoHeight {
+			compatibleRange.StartHeight = nodeRootBlockHeader.Height
+		}
+	}
 
-	nodeInfo := &access.NodeVersionInfo{
+	nodeInfo := &flow.NodeVersionInfo{
 		Semver:               build.Version(),
 		Commit:               build.Commit(),
 		SporkId:              sporkID,
 		ProtocolVersion:      uint64(protocolVersion),
 		SporkRootBlockHeight: sporkRootBlockHeight,
 		NodeRootBlockHeight:  nodeRootBlockHeader.Height,
+		CompatibleRange:      compatibleRange,
 	}
 
 	return nodeInfo

engine/access/rpc/backend/backend_network.go

@@ -51,12 +51,12 @@ func (b *backendNetwork) GetNetworkParameters(_ context.Context) access.NetworkP
 	}
 }
 
-func (b *backendNetwork) GetNodeVersionInfo(_ context.Context) (*access.NodeVersionInfo, error) {
+func (b *backendNetwork) GetNodeVersionInfo(_ context.Context) (*flow.NodeVersionInfo, error) {
 	stateParams := b.state.Params()
 	sporkId := stateParams.SporkID()
 	protocolVersion := stateParams.ProtocolVersion()
 
-	return &access.NodeVersionInfo{
+	return &flow.NodeVersionInfo{
 		Semver:          build.Version(),
 		Commit:          build.Commit(),
 		SporkId:         sporkId,