diff --git a/cmd/networkcmd/helpers.go b/cmd/networkcmd/helpers.go index 9bf679888..f0341ee6c 100644 --- a/cmd/networkcmd/helpers.go +++ b/cmd/networkcmd/helpers.go @@ -12,7 +12,6 @@ import ( "github.com/ava-labs/avalanche-cli/pkg/binutils" "github.com/ava-labs/avalanche-cli/pkg/constants" - "github.com/ava-labs/avalanche-cli/pkg/evm" "github.com/ava-labs/avalanche-cli/pkg/models" "github.com/ava-labs/avalanche-cli/pkg/utils" "github.com/ava-labs/avalanche-cli/pkg/ux" @@ -170,16 +169,10 @@ func TrackSubnet( } networkInfo.RPCEndpoints = rpcEndpoints.List() networkInfo.WSEndpoints = wsEndpoints.List() - for _, rpcURL := range networkInfo.RPCEndpoints { - ux.Logger.PrintToUser("Waiting for %s to be available", rpcURL) - if err := evm.WaitForRPC(ctx, rpcURL); err != nil { - return err - } - } - if err := IsBootstrapped(cli, blockchainID.String()); err != nil { + if err := WaitBootstrapped(cli, blockchainID.String()); err != nil { return err } - if err := IsBootstrapped(cli, "P"); err != nil { + if err := WaitBootstrapped(cli, "P"); err != nil { return err } if _, err := cli.UpdateStatus(ctx); err != nil { @@ -204,7 +197,7 @@ func TrackSubnet( return nil } -func IsBootstrapped(cli client.Client, blockchainID string) error { +func WaitBootstrapped(cli client.Client, blockchainID string) error { blockchainBootstrapCheckFrequency := time.Second ctx, cancel := utils.GetANRContext() defer cancel() diff --git a/pkg/node/local.go b/pkg/node/local.go index 0e1e6e1e5..53c3cc5f5 100644 --- a/pkg/node/local.go +++ b/pkg/node/local.go @@ -16,7 +16,6 @@ import ( "github.com/ava-labs/avalanche-cli/pkg/application" "github.com/ava-labs/avalanche-cli/pkg/binutils" "github.com/ava-labs/avalanche-cli/pkg/constants" - "github.com/ava-labs/avalanche-cli/pkg/evm" "github.com/ava-labs/avalanche-cli/pkg/localnet" "github.com/ava-labs/avalanche-cli/pkg/models" "github.com/ava-labs/avalanche-cli/pkg/networkoptions" @@ -100,8 +99,6 @@ func TrackSubnetWithLocalMachine( if err != nil { return err } - networkInfo := sc.Networks[network.Name()] - rpcEndpoints := []string{} for _, nodeInfo := range status.ClusterInfo.NodeInfos { ux.Logger.PrintToUser("Restarting node %s to track newly deployed network", nodeInfo.Name) if err := LocalNodeTrackSubnet( @@ -120,18 +117,11 @@ func TrackSubnetWithLocalMachine( if err := AddNodeInfoToSidecar(&sc, nodeInfo, network); err != nil { return fmt.Errorf("failed to update sidecar with new node info: %w", err) } - rpcEndpoints = append(rpcEndpoints, models.GetRPCEndpoint(nodeInfo.Uri, networkInfo.BlockchainID.String())) } ux.Logger.PrintToUser("Waiting for blockchain %s to be bootstrapped", blockchainName) if err := WaitBootstrapped(ctx, cli, blockchainID.String()); err != nil { return fmt.Errorf("failure waiting for local cluster %s bootstrapping: %w", blockchainName, err) } - for _, rpcURL := range rpcEndpoints { - ux.Logger.PrintToUser("Waiting for rpc %s to be available", rpcURL) - if err := evm.WaitForRPC(ctx, rpcURL); err != nil { - return err - } - } if err := app.UpdateSidecar(&sc); err != nil { return err }