Uptime tracking

go.mod

@@ -5,7 +5,7 @@ go 1.22.8
 require (
 	github.com/VictoriaMetrics/fastcache v1.12.1
 	github.com/antithesishq/antithesis-sdk-go v0.3.8
-	github.com/ava-labs/avalanchego v1.11.13-0.20241026214739-acb3d7d102a0
+	github.com/ava-labs/avalanchego v1.11.13-0.20241029131257-e05aa37abaf9
 	github.com/cespare/cp v0.1.0
 	github.com/crate-crypto/go-ipa v0.0.0-20231025140028-3c0104f4b233
 	github.com/davecgh/go-spew v1.1.1

go.sum

@@ -60,6 +60,8 @@ github.com/antithesishq/antithesis-sdk-go v0.3.8/go.mod h1:IUpT2DPAKh6i/YhSbt6Gl
 github.com/armon/consul-api v0.0.0-20180202201655-eb2c6b5be1b6/go.mod h1:grANhF5doyWs3UAsr3K4I6qtAmlQcZDesFNEHPZAzj8=
 github.com/ava-labs/avalanchego v1.11.13-0.20241026214739-acb3d7d102a0 h1:1T9OnvZP6XZ62EVWlfmrI8rrudyE6bM2Zt51pCHfS5o=
 github.com/ava-labs/avalanchego v1.11.13-0.20241026214739-acb3d7d102a0/go.mod h1:gYlTU42Q4b29hzhUN22yclym5qwB3Si0jh4+LTn7DZM=
+github.com/ava-labs/avalanchego v1.11.13-0.20241029131257-e05aa37abaf9 h1:rX5Xn5WBPppyvvZXp8wwx9dX+4fBY2/XeNIEm18ifzk=
+github.com/ava-labs/avalanchego v1.11.13-0.20241029131257-e05aa37abaf9/go.mod h1:gYlTU42Q4b29hzhUN22yclym5qwB3Si0jh4+LTn7DZM=
 github.com/ava-labs/coreth v0.13.8 h1:f14X3KgwHl9LwzfxlN6S4bbn5VA2rhEsNnHaRLSTo/8=
 github.com/ava-labs/coreth v0.13.8/go.mod h1:t3BSv/eQv0AlDPMfEDCMMoD/jq1RkUsbFzQAFg5qBcE=
 github.com/aymerick/raymond v2.0.3-0.20180322193309-b565731e1464+incompatible/go.mod h1:osfaiScAUVup+UC9Nfq76eWqDhXlp+4UYaA8uhTBO6g=

plugin/evm/block.go

@@ -215,7 +215,7 @@ func (b *Block) verify(predicateContext *precompileconfig.PredicateContext, writ
 	// If the chain is still bootstrapping, we can assume that all blocks we are verifying have
 	// been accepted by the network (so the predicate was validated by the network when the
 	// block was originally verified).
-	if b.vm.bootstrapped {
+	if b.vm.bootstrapped.Get() {
 		if err := b.verifyPredicates(predicateContext); err != nil {
 			return fmt.Errorf("failed to verify predicates: %w", err)
 		}

plugin/evm/syncervm_test.go

@@ -494,7 +494,7 @@ func testSyncerVM(t *testing.T, vmSetup *syncVMSetup, test syncTest) {
 
 	// check we can transition to [NormalOp] state and continue to process blocks.
 	require.NoError(syncerVM.SetState(context.Background(), snow.NormalOp))
-	require.True(syncerVM.bootstrapped)
+	require.True(syncerVM.bootstrapped.Get())
 
 	// Generate blocks after we have entered normal consensus as well
 	generateAndAcceptBlocks(t, syncerVM, blocksToBuild, func(_ int, gen *core.BlockGen) {

plugin/evm/tx_gossip_test.go

@@ -37,7 +37,7 @@ func TestEthTxGossip(t *testing.T) {
 	require := require.New(t)
 	ctx := context.Background()
 	snowCtx := utils.TestSnowContext()
-	validatorState := &validatorstest.State{}
+	validatorState := utils.NewTestValidatorState()
 	snowCtx.ValidatorState = validatorState
 
 	responseSender := &enginetest.SenderStub{

plugin/evm/validators/interfaces/interface.go

@@ -4,6 +4,8 @@
 package interfaces
 
 import (
+	"time"
+
 	"github.com/ava-labs/avalanchego/ids"
 	"github.com/ava-labs/avalanchego/snow/uptime"
 	"github.com/ava-labs/avalanchego/utils/set"
@@ -27,6 +29,8 @@ type State interface {
 	GetValidationIDs() set.Set[ids.ID]
 	// GetValidatorIDs returns the validator node IDs in the state
 	GetValidatorIDs() set.Set[ids.NodeID]
+	// GetValidator returns the validator data for the given nodeID
+	GetValidator(nodeID ids.NodeID) (*ValidatorOutput, error)
 
 	// RegisterListener registers a listener to the state
 	RegisterListener(StateCallbackListener)
@@ -41,3 +45,10 @@ type StateCallbackListener interface {
 	// OnValidatorStatusUpdated is called when a validator status is updated
 	OnValidatorStatusUpdated(vID ids.ID, nodeID ids.NodeID, isActive bool)
 }
+
+type ValidatorOutput struct {
+	ValidationID ids.ID     `json:"validationID"`
+	NodeID       ids.NodeID `json:"nodeID"`
+	StartTime    time.Time  `json:"startTime"`
+	IsActive     bool       `json:"isActive"`
+}

plugin/evm/validators/state.go

@@ -209,6 +209,20 @@ func (s *state) GetValidatorIDs() set.Set[ids.NodeID] {
 	return ids
 }
 
+// GetValidator returns the validator data for the given nodeID
+func (s *state) GetValidator(nodeID ids.NodeID) (*interfaces.ValidatorOutput, error) {
+	data, err := s.getData(nodeID)
+	if err != nil {
+		return nil, err
+	}
+	return &interfaces.ValidatorOutput{
+		ValidationID: data.validationID,
+		NodeID:       data.NodeID,
+		StartTime:    data.getStartTime(),
+		IsActive:     data.IsActive,
+	}, nil
+}
+
 // RegisterListener registers a listener to the state
 // OnValidatorAdded is called for all current validators on the provided listener before this function returns
 func (s *state) RegisterListener(listener interfaces.StateCallbackListener) {