Function New

testutil/network/network.go:233–455

New creates a new Network for integration tests.

(t *testing.T, cfg Config)

// New creates a new Network for integration tests.
func New(t *testing.T, cfg Config) *Network {
	// only one caller/test can create and use a network at a time
	t.Log("acquiring test network lock")
	lock.Lock()

	baseDir, err := os.MkdirTemp(t.TempDir(), cfg.ChainID)
	require.NoError(t, err)
	t.Logf("created temporary directory: %s", baseDir)

	network := &Network{
		T:          t,
		BaseDir:    baseDir,
		Validators: make([]*Validator, cfg.NumValidators),
		Config:     cfg,
	}

	t.Log("preparing test network...")

	monikers := make([]string, cfg.NumValidators)
	nodeIDs := make([]string, cfg.NumValidators)
	valPubKeys := make([]cryptotypes.PubKey, cfg.NumValidators)

	var genAccounts []authtypes.GenesisAccount
	var genBalances []banktypes.Balance
	var genFiles []string

	buf := bufio.NewReader(os.Stdin)

	allocPortsCount := (portsPerValidator * cfg.NumValidators) + 4

	availablePorts, err := GetFreePorts(allocPortsCount)
	require.NoError(t, err)
	require.Equal(t, allocPortsCount, len(availablePorts))

	ports := newFreePorts(availablePorts)

	// generate private keys, node IDs, and initial transactions
	for i := 0; i < cfg.NumValidators; i++ {
		appCfg := srvconfig.DefaultConfig()
		appCfg.Pruning = cfg.PruningStrategy
		appCfg.MinGasPrices = cfg.MinGasPrices
		appCfg.API.Enable = true
		appCfg.API.Swagger = false
		appCfg.Telemetry.Enabled = false
		appCfg.GRPC.Enable = false
		appCfg.GRPCWeb.Enable = false

		ctx := server.NewDefaultContext()
		ctx.Viper.Set(cflags.FlagChainID, cfg.ChainID)

		// Only allow the first validator to expose an RPC, API and gRPC
		// server/client due to Tendermint in-process constraints.
		apiAddr := ""

		tmCfg := ctx.Config
		tmCfg.Consensus.TimeoutCommit = cfg.TimeoutCommit

		tmCfg.RPC.ListenAddress = ""