parallel tests

cosmos · Jun 19, 2023 · 69933c3 · 69933c3
1 parent e857029
commit 69933c3
Show file tree

Hide file tree

Showing 78 changed files with 161 additions and 0 deletions.
diff --git a/.golangci.yml b/.golangci.yml
@@ -18,7 +18,9 @@ linters:
     - ineffassign
     - misspell
     - nakedret
+    - paralleltest
     - staticcheck
+    - tparallel
     - thelper
     - stylecheck
     - revive

diff --git a/cmd/build_test_matrix/main_test.go b/cmd/build_test_matrix/main_test.go
@@ -17,13 +17,16 @@ const (
 )
 
 func TestGetGithubActionMatrixForTests(t *testing.T) {
+	t.Parallel()
 	t.Run("empty dir does not fail", func(t *testing.T) {
+		t.Parallel()
 		testingDir := t.TempDir()
 		_, err := getGithubActionMatrixForTests(testingDir, "", "", nil)
 		assert.NoError(t, err)
 	})
 
 	t.Run("only test functions are picked up", func(t *testing.T) {
+		t.Parallel()
 		testingDir := t.TempDir()
 		createFileWithTestSuiteAndTests(t, "FeeMiddlewareTestSuite", "TestA", "TestB", testingDir, goTestFileNameOne)
 
@@ -46,6 +49,7 @@ func TestGetGithubActionMatrixForTests(t *testing.T) {
 	})
 
 	t.Run("all files are picked up", func(t *testing.T) {
+		t.Parallel()
 		testingDir := t.TempDir()
 		createFileWithTestSuiteAndTests(t, "FeeMiddlewareTestSuite", "TestA", "TestB", testingDir, goTestFileNameOne)
 		createFileWithTestSuiteAndTests(t, "TransferTestSuite", "TestC", "TestD", testingDir, goTestFileNameTwo)
@@ -78,6 +82,7 @@ func TestGetGithubActionMatrixForTests(t *testing.T) {
 	})
 
 	t.Run("single test can be specified", func(t *testing.T) {
+		t.Parallel()
 		testingDir := t.TempDir()
 		createFileWithTestSuiteAndTests(t, "FeeMiddlewareTestSuite", "TestA", "TestB", testingDir, goTestFileNameOne)
 		createFileWithTestSuiteAndTests(t, "TransferTestSuite", "TestC", "TestD", testingDir, goTestFileNameTwo)
@@ -98,6 +103,7 @@ func TestGetGithubActionMatrixForTests(t *testing.T) {
 	})
 
 	t.Run("error if single test doesn't exist", func(t *testing.T) {
+		t.Parallel()
 		testingDir := t.TempDir()
 		createFileWithTestSuiteAndTests(t, "FeeMiddlewareTestSuite", "TestA", "TestB", testingDir, goTestFileNameOne)
 
@@ -106,6 +112,7 @@ func TestGetGithubActionMatrixForTests(t *testing.T) {
 	})
 
 	t.Run("non test files are not picked up", func(t *testing.T) {
+		t.Parallel()
 		testingDir := t.TempDir()
 		createFileWithTestSuiteAndTests(t, "FeeMiddlewareTestSuite", "TestA", "TestB", testingDir, nonTestFile)
 
@@ -115,6 +122,7 @@ func TestGetGithubActionMatrixForTests(t *testing.T) {
 	})
 
 	t.Run("fails when there are multiple suite runs", func(t *testing.T) {
+		t.Parallel()
 		testingDir := t.TempDir()
 		createFileWithTestSuiteAndTests(t, "FeeMiddlewareTestSuite", "TestA", "TestB", testingDir, nonTestFile)
 

diff --git a/internal/collections/collections_test.go b/internal/collections/collections_test.go
@@ -8,6 +8,7 @@ import (
 )
 
 func TestContainsString(t *testing.T) {
+	t.Parallel()
 	testCases := []struct {
 		name     string
 		haystack []string
@@ -26,6 +27,7 @@ func TestContainsString(t *testing.T) {
 }
 
 func TestContainsInt(t *testing.T) {
+	t.Parallel()
 	testCases := []struct {
 		name     string
 		haystack []int

diff --git a/modules/apps/27-interchain-accounts/controller/ibc_middleware_test.go b/modules/apps/27-interchain-accounts/controller/ibc_middleware_test.go
@@ -48,6 +48,7 @@ type InterchainAccountsTestSuite struct {
 }
 
 func TestICATestSuite(t *testing.T) {
+	t.Parallel()
 	suite.Run(t, new(InterchainAccountsTestSuite))
 }
 

diff --git a/modules/apps/27-interchain-accounts/controller/keeper/keeper_test.go b/modules/apps/27-interchain-accounts/controller/keeper/keeper_test.go
@@ -99,6 +99,7 @@ func RegisterInterchainAccount(endpoint *ibctesting.Endpoint, owner string) erro
 }
 
 func TestKeeperTestSuite(t *testing.T) {
+	t.Parallel()
 	suite.Run(t, new(KeeperTestSuite))
 }
 

diff --git a/modules/apps/27-interchain-accounts/controller/migrations/v6/migrations_test.go b/modules/apps/27-interchain-accounts/controller/migrations/v6/migrations_test.go
@@ -80,6 +80,7 @@ func (suite *MigrationsTestSuite) RegisterInterchainAccount(endpoint *ibctesting
 }
 
 func TestKeeperTestSuite(t *testing.T) {
+	t.Parallel()
 	suite.Run(t, new(MigrationsTestSuite))
 }
 

diff --git a/modules/apps/27-interchain-accounts/controller/types/msgs_test.go b/modules/apps/27-interchain-accounts/controller/types/msgs_test.go
@@ -20,6 +20,7 @@ import (
 )
 
 func TestMsgRegisterInterchainAccountValidateBasic(t *testing.T) {
+	t.Parallel()
 	var msg *types.MsgRegisterInterchainAccount
 
 	testCases := []struct {
@@ -88,6 +89,7 @@ func TestMsgRegisterInterchainAccountValidateBasic(t *testing.T) {
 }
 
 func TestMsgRegisterInterchainAccountGetSigners(t *testing.T) {
+	t.Parallel()
 	expSigner, err := sdk.AccAddressFromBech32(ibctesting.TestAccAddress)
 	require.NoError(t, err)
 
@@ -96,6 +98,7 @@ func TestMsgRegisterInterchainAccountGetSigners(t *testing.T) {
 }
 
 func TestMsgSendTxValidateBasic(t *testing.T) {
+	t.Parallel()
 	var msg *types.MsgSendTx
 
 	testCases := []struct {
@@ -181,6 +184,7 @@ func TestMsgSendTxValidateBasic(t *testing.T) {
 }
 
 func TestMsgSendTxGetSigners(t *testing.T) {
+	t.Parallel()
 	expSigner, err := sdk.AccAddressFromBech32(ibctesting.TestAccAddress)
 	require.NoError(t, err)
 

diff --git a/modules/apps/27-interchain-accounts/host/client/cli/tx_test.go b/modules/apps/27-interchain-accounts/host/client/cli/tx_test.go
@@ -39,6 +39,7 @@ const bankSendMessage = `{
 var multiMsg = fmt.Sprintf("[ %s, %s ]", msgDelegateMessage, bankSendMessage)
 
 func TestGeneratePacketData(t *testing.T) {
+	t.Parallel()
 	t.Helper()
 	tests := []struct {
 		name                string
@@ -110,6 +111,7 @@ func TestGeneratePacketData(t *testing.T) {
 		cdc := codec.NewProtoCodec(ir)
 
 		t.Run(tc.name, func(t *testing.T) {
+			t.Parallel()
 			bz, err := generatePacketData(cdc, []byte(tc.message), tc.memo)
 
 			if tc.expectedPass {

diff --git a/modules/apps/27-interchain-accounts/host/ibc_module_test.go b/modules/apps/27-interchain-accounts/host/ibc_module_test.go
@@ -49,6 +49,7 @@ type InterchainAccountsTestSuite struct {
 }
 
 func TestICATestSuite(t *testing.T) {
+	t.Parallel()
 	suite.Run(t, new(InterchainAccountsTestSuite))
 }
 

diff --git a/modules/apps/27-interchain-accounts/host/keeper/keeper_test.go b/modules/apps/27-interchain-accounts/host/keeper/keeper_test.go
@@ -100,6 +100,7 @@ func RegisterInterchainAccount(endpoint *ibctesting.Endpoint, owner string) erro
 }
 
 func TestKeeperTestSuite(t *testing.T) {
+	t.Parallel()
 	suite.Run(t, new(KeeperTestSuite))
 }
 

diff --git a/modules/apps/27-interchain-accounts/host/types/msgs_test.go b/modules/apps/27-interchain-accounts/host/types/msgs_test.go
@@ -9,6 +9,7 @@ import (
 )
 
 func TestMsgUpdateParamsValidateBasic(t *testing.T) {
+	t.Parallel()
 	var msg *types.MsgUpdateParams
 
 	testCases := []struct {
@@ -50,7 +51,9 @@ func TestMsgUpdateParamsValidateBasic(t *testing.T) {
 	}
 
 	for _, tc := range testCases {
+		tc := tc
 		t.Run(tc.name, func(t *testing.T) {
+			t.Parallel()
 			tc.malleate()
 
 			err := msg.ValidateBasic()
@@ -64,6 +67,7 @@ func TestMsgUpdateParamsValidateBasic(t *testing.T) {
 }
 
 func TestMsgUpdateParamsGetSigners(t *testing.T) {
+	t.Parallel()
 	authority := sdk.AccAddress("authority")
 	msg := types.MsgUpdateParams{
 		Authority: authority.String(),

diff --git a/modules/apps/27-interchain-accounts/host/types/params_test.go b/modules/apps/27-interchain-accounts/host/types/params_test.go
@@ -9,6 +9,7 @@ import (
 )
 
 func TestValidateParams(t *testing.T) {
+	t.Parallel()
 	require.NoError(t, types.DefaultParams().Validate())
 	require.NoError(t, types.NewParams(false, []string{}).Validate())
 	require.Error(t, types.NewParams(true, []string{""}).Validate())

diff --git a/modules/apps/27-interchain-accounts/module_test.go b/modules/apps/27-interchain-accounts/module_test.go
@@ -24,6 +24,7 @@ type InterchainAccountsTestSuite struct {
 }
 
 func TestICATestSuite(t *testing.T) {
+	t.Parallel()
 	suite.Run(t, new(InterchainAccountsTestSuite))
 }
 

diff --git a/modules/apps/27-interchain-accounts/simulation/decoder_test.go b/modules/apps/27-interchain-accounts/simulation/decoder_test.go
@@ -13,6 +13,7 @@ import (
 )
 
 func TestDecodeStore(t *testing.T) {
+	t.Parallel()
 	var (
 		owner     = "owner"
 		channelID = ibctesting.FirstChannelID
@@ -54,6 +55,7 @@ func TestDecodeStore(t *testing.T) {
 	for i, tt := range tests {
 		i, tt := i, tt
 		t.Run(tt.name, func(t *testing.T) {
+			t.Parallel()
 			if i == len(tests)-1 {
 				require.Panics(t, func() { dec(kvPairs.Pairs[i], kvPairs.Pairs[i]) }, tt.name)
 			} else {

diff --git a/modules/apps/27-interchain-accounts/simulation/genesis_test.go b/modules/apps/27-interchain-accounts/simulation/genesis_test.go
@@ -21,6 +21,7 @@ import (
 // TestRandomizedGenState tests the normal scenario of applying RandomizedGenState.
 // Abonormal scenarios are not tested here.
 func TestRandomizedGenState(t *testing.T) {
+	t.Parallel()
 	interfaceRegistry := codectypes.NewInterfaceRegistry()
 	cryptocodec.RegisterInterfaces(interfaceRegistry)
 	cdc := codec.NewProtoCodec(interfaceRegistry)

diff --git a/modules/apps/27-interchain-accounts/types/account_test.go b/modules/apps/27-interchain-accounts/types/account_test.go
@@ -39,6 +39,7 @@ func (suite *TypesTestSuite) SetupTest() {
 }
 
 func TestTypesTestSuite(t *testing.T) {
+	t.Parallel()
 	suite.Run(t, new(TypesTestSuite))
 }
 

diff --git a/modules/apps/29-fee/fee_test.go b/modules/apps/29-fee/fee_test.go
@@ -48,6 +48,7 @@ func (suite *FeeTestSuite) SetupTest() {
 }
 
 func TestIBCFeeTestSuite(t *testing.T) {
+	t.Parallel()
 	suite.Run(t, new(FeeTestSuite))
 }
 

diff --git a/modules/apps/29-fee/keeper/keeper_test.go b/modules/apps/29-fee/keeper/keeper_test.go
@@ -57,6 +57,7 @@ func (suite *KeeperTestSuite) SetupTest() {
 }
 
 func TestKeeperTestSuite(t *testing.T) {
+	t.Parallel()
 	suite.Run(t, new(KeeperTestSuite))
 }
 

diff --git a/modules/apps/29-fee/types/fee_test.go b/modules/apps/29-fee/types/fee_test.go
@@ -30,13 +30,15 @@ var (
 const invalidAddress = "invalid-address"
 
 func TestFeeTotal(t *testing.T) {
+	t.Parallel()
 	fee := types.NewFee(defaultRecvFee, defaultAckFee, defaultTimeoutFee)
 
 	total := fee.Total()
 	require.Equal(t, sdk.NewInt(600), total.AmountOf(sdk.DefaultBondDenom))
 }
 
 func TestPacketFeeValidation(t *testing.T) {
+	t.Parallel()
 	var packetFee types.PacketFee
 
 	testCases := []struct {

diff --git a/modules/apps/29-fee/types/genesis_test.go b/modules/apps/29-fee/types/genesis_test.go
@@ -13,11 +13,13 @@ import (
 )
 
 func TestValidateDefaultGenesis(t *testing.T) {
+	t.Parallel()
 	err := types.DefaultGenesisState().Validate()
 	require.NoError(t, err)
 }
 
 func TestValidateGenesis(t *testing.T) {
+	t.Parallel()
 	var genState *types.GenesisState
 
 	testCases := []struct {

diff --git a/modules/apps/29-fee/types/keys_test.go b/modules/apps/29-fee/types/keys_test.go
@@ -14,11 +14,13 @@ import (
 var validPacketID = channeltypes.NewPacketID(ibctesting.MockFeePort, ibctesting.FirstChannelID, 1)
 
 func TestKeyPayee(t *testing.T) {
+	t.Parallel()
 	key := types.KeyPayee("relayer-address", ibctesting.FirstChannelID)
 	require.Equal(t, string(key), fmt.Sprintf("%s/%s/%s", types.PayeeKeyPrefix, "relayer-address", ibctesting.FirstChannelID))
 }
 
 func TestParseKeyPayee(t *testing.T) {
+	t.Parallel()
 	testCases := []struct {
 		name    string
 		key     string
@@ -50,6 +52,7 @@ func TestParseKeyPayee(t *testing.T) {
 }
 
 func TestKeyCounterpartyPayee(t *testing.T) {
+	t.Parallel()
 	var (
 		relayerAddress = "relayer_address"
 		channelID      = "channel-0"
@@ -60,11 +63,13 @@ func TestKeyCounterpartyPayee(t *testing.T) {
 }
 
 func TestKeyFeesInEscrow(t *testing.T) {
+	t.Parallel()
 	key := types.KeyFeesInEscrow(validPacketID)
 	require.Equal(t, string(key), fmt.Sprintf("%s/%s/%s/%d", types.FeesInEscrowPrefix, ibctesting.MockFeePort, ibctesting.FirstChannelID, 1))
 }
 
 func TestParseKeyFeeEnabled(t *testing.T) {
+	t.Parallel()
 	testCases := []struct {
 		name    string
 		key     string
@@ -103,6 +108,7 @@ func TestParseKeyFeeEnabled(t *testing.T) {
 }
 
 func TestParseKeyFeesInEscrow(t *testing.T) {
+	t.Parallel()
 	testCases := []struct {
 		name    string
 		key     string
@@ -138,6 +144,7 @@ func TestParseKeyFeesInEscrow(t *testing.T) {
 }
 
 func TestParseKeyForwardRelayerAddress(t *testing.T) {
+	t.Parallel()
 	testCases := []struct {
 		name    string
 		key     string
@@ -173,6 +180,7 @@ func TestParseKeyForwardRelayerAddress(t *testing.T) {
 }
 
 func TestParseKeyCounterpartyPayee(t *testing.T) {
+	t.Parallel()
 	relayerAddress := "relayer_address"
 
 	testCases := []struct {