Skip to content

Add NetworkStateProvider #1056

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
0xfornax wants to merge 3 commits into
base: master
Choose a base branch
from
Draft

Add NetworkStateProvider #1056

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
a845791
Add NetworkStateProvider
0xfornax Apr 15, 2026
516613a
Createa a networkTreeProvider and add tests to challenge proposals
0xfornax Apr 15, 2026
badc2b3
Widen the EC/CC static provider
0xfornax Apr 21, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 13 additions & 3 deletions rocketpool/node/node.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -145,8 +145,18 @@ func run(c *cli.Command) error {
errorLog := log.NewColorLogger(ErrorColor)
updateLog := log.NewColorLogger(UpdateColor)

// Create the state manager
m := state.NewNetworkStateManager(rp, cfg.Smartnode.GetStateManagerContracts(), bc, &updateLog)
// Create the state provider. In live mode this is a NetworkStateManager
// backed by the real EC/BC; in --network-state mode it is a
// StaticNetworkStateProvider that serves from the pre-loaded snapshot.
var m state.NetworkStateProvider
if services.IsStaticStateMode(c) {
m, err = services.GetNetworkStateProvider(c)
if err != nil {
return fmt.Errorf("error getting network state provider: %w", err)
}
} else {
m = state.NewNetworkStateManager(rp, cfg.Smartnode.GetStateManagerContracts(), bc, &updateLog)
}
stateLocker := collectors.NewStateLocker()

// Initialize tasks
Expand Down Expand Up @@ -497,7 +507,7 @@ func removeLegacyFeeRecipientFiles(c *cli.Command) error {
}

// Update the latest network state at each cycle
func updateNetworkState(m *state.NetworkStateManager, log *log.ColorLogger, nodeAddress common.Address) (*state.NetworkState, error) {
func updateNetworkState(m state.NetworkStateProvider, log *log.ColorLogger, nodeAddress common.Address) (*state.NetworkState, error) {
// Get the state of the network
state, err := m.GetHeadStateForNode(nodeAddress)
if err != nil {
Expand Down
Loading
Loading