fix: integration-tests

Author: Patricio Tourne Passarino

integration-tests/deployment/ccip/cs_add_lanes_test.go

@@ -11,9 +11,10 @@ import (
 
 	"github.com/Masterminds/semver/v3"
 	chainselectors "github.com/smartcontractkit/chain-selectors"
+	"github.com/stretchr/testify/require"
+
 	"github.com/smartcontractkit/chainlink-ccip/deployment/utils/mcms"
 	commonchangeset "github.com/smartcontractkit/chainlink/deployment/common/changeset"
-	"github.com/stretchr/testify/require"
 
 	"github.com/smartcontractkit/chainlink-ton/deployment/utils/sequence"
 
@@ -75,7 +76,7 @@ func TestAddLanes(t *testing.T) {
 		},
 	})
 	require.NoError(t, err, "Failed to apply DeployChainContracts changeset")
-	_ = out.DataStore.Merge(env.DataStore)
+	require.NoError(t, out.DataStore.Merge(env.DataStore))
 	env.DataStore = out.DataStore.Seal()
 
 	// Get OnRamp Address from EVM

integration-tests/deployment/ccip/cs_fast_curse_test.go

@@ -7,9 +7,10 @@ import (
 
 	"github.com/Masterminds/semver/v3"
 	chainselectors "github.com/smartcontractkit/chain-selectors"
+	"github.com/stretchr/testify/require"
+
 	"github.com/smartcontractkit/chainlink-ccip/deployment/utils/mcms"
 	commonchangeset "github.com/smartcontractkit/chainlink/deployment/common/changeset"
-	"github.com/stretchr/testify/require"
 
 	"github.com/smartcontractkit/chainlink-ton/deployment/utils/sequence"
 
@@ -70,7 +71,7 @@ func TestFastCurseTON(t *testing.T) {
 		},
 	})
 	require.NoError(t, err, "Failed to apply DeployChainContracts changeset")
-	_ = out.DataStore.Merge(env.DataStore)
+	require.NoError(t, out.DataStore.Merge(env.DataStore))
 	env.DataStore = out.DataStore.Seal()
 	// </deploy-evm>
 

integration-tests/monitor/balance_test.go

@@ -150,7 +150,7 @@ func TestBalanceMonitor_Polling(t *testing.T) {
 	err = balanceMonitor.Start(t.Context())
 	require.NoError(t, err)
 	defer func() {
-		_ = balanceMonitor.Close()
+		require.NoError(t, balanceMonitor.Close())
 	}()
 
 	// Wait a bit to allow the monitor to poll at least once

integration-tests/smoke/chainaccessor/accessor_test.go

@@ -147,6 +147,7 @@ func Test_TonAccessor_MsgsBetweenSeqNums(t *testing.T) {
 func Test_TonAccessorCommitEventQueries(t *testing.T) {
 	// Note: we don't test the API client interaction here, so we return empty client
 	clientProvider := func(ctx context.Context) (ton.APIClientWrapped, error) {
+		//nolint:nilnil // mock
 		return nil, nil
 	}
 
@@ -639,7 +640,8 @@ func testCommitReportsBasicHelper(t *testing.T, lp logpoller.Service, logStore l
 	require.Equal(t, ccipocr3.SeqNum(1), merkleRoot.SeqNumsRange.Start(), "MinSeqNr should be 1")
 	require.Equal(t, ccipocr3.SeqNum(1), merkleRoot.SeqNumsRange.End(), "MaxSeqNr should be 1")
 
-	expectedMerkleRootBytes, _ := hex.DecodeString("bea275bb6614f85036536bc670e540bc748118e90537b8441c950672f74607d5")
+	expectedMerkleRootBytes, err := hex.DecodeString("bea275bb6614f85036536bc670e540bc748118e90537b8441c950672f74607d5")
+	require.NoError(t, err)
 	require.Equal(t, expectedMerkleRootBytes, merkleRoot.MerkleRoot[:], "MerkleRoot should match")
 
 	// Validate PriceUpdates should be empty for this test (since we used merkleRootOnlyCell)
@@ -695,11 +697,6 @@ func Test_TonAccessorExecutionStateChangedEventQueries(t *testing.T) {
 }
 
 func Test_TonAccessorExecutedMessages(t *testing.T) {
-	// Note: we don't test the API client interaction here, so we return empty client
-	clientProvider := func(ctx context.Context) (ton.APIClientWrapped, error) {
-		return nil, nil
-	}
-
 	// Setup in-memory store
 	lggr := logger.Test(t)
 	opts := &logpoller.ServiceOptions{
@@ -711,7 +708,8 @@ func Test_TonAccessorExecutedMessages(t *testing.T) {
 	lp, err := logpoller.NewService(
 		lggr,
 		"test-chain",
-		clientProvider,
+		// Note: we don't test the API client interaction here, so we return empty client
+		mockClientProvider,
 		opts,
 	)
 	require.NoError(t, err)
@@ -720,15 +718,15 @@ func Test_TonAccessorExecutedMessages(t *testing.T) {
 	testExecutedMessagesHelper(t, lp, opts.LogStore, 1)
 }
 
+func mockClientProvider(ctx context.Context) (ton.APIClientWrapped, error) {
+	//nolint:nilnil // mock
+	return nil, nil
+}
+
 // Test validation for MsgsBetweenSeqNums sequence number range
 func Test_TonAccessor_MsgsBetweenSeqNums_SequenceRangeValidation(t *testing.T) {
 	lggr := logger.Test(t)
 
-	// Note: we don't test the API client interaction here, so we return empty client
-	clientProvider := func(ctx context.Context) (ton.APIClientWrapped, error) {
-		return nil, nil
-	}
-
 	opts := &logpoller.ServiceOptions{
 		Config:      logpoller.DefaultConfigSet,
 		FilterStore: inmemorystore.NewFilterStore("test-chain", lggr),
@@ -738,7 +736,8 @@ func Test_TonAccessor_MsgsBetweenSeqNums_SequenceRangeValidation(t *testing.T) {
 	lp, err := logpoller.NewService(
 		lggr,
 		"test-chain",
-		clientProvider,
+		// Note: we don't test the API client interaction here, so we return empty client
+		mockClientProvider,
 		opts,
 	)
 	require.NoError(t, err)
@@ -788,11 +787,6 @@ func Test_TonAccessorExecutedMessages_WithPostgresStore(t *testing.T) {
 		t.Skip("Skipping postgres test in short mode")
 	}
 
-	// Note: we don't test the API client interaction here, so we return empty client
-	clientProvider := func(ctx context.Context) (ton.APIClientWrapped, error) {
-		return nil, nil
-	}
-
 	// Setup postgres store using testcontainers
 	lggr := logger.Test(t)
 	ds := pgtest.SetupTestDB(t)
@@ -814,7 +808,8 @@ func Test_TonAccessorExecutedMessages_WithPostgresStore(t *testing.T) {
 	lp, err := logpoller.NewService(
 		lggr,
 		"test-chain",
-		clientProvider,
+		// Note: we don't test the API client interaction here, so we return empty client
+		mockClientProvider,
 		opts,
 	)
 	require.NoError(t, err)

integration-tests/smoke/logpoller/log_poller_test.go

@@ -107,7 +107,8 @@ func Test_LogPoller(t *testing.T) {
 
 			indexedCells := make([]*cell.Cell, 0, len(txs))
 			for _, tx := range txs {
-				msgs, _ := tx.Transaction.IO.Out.ToSlice()
+				msgs, serr := tx.Transaction.IO.Out.ToSlice()
+				require.NoError(t, serr)
 				for _, msg := range msgs {
 					// test contract only emits ExternalMessageOut
 					if msg.MsgType == tlb.MsgTypeExternalOut {
@@ -152,7 +153,8 @@ func Test_LogPoller(t *testing.T) {
 
 				// Extract messages from the loaded transactions
 				for _, tx := range txs {
-					msgs, _ := tx.Transaction.IO.Out.ToSlice()
+					msgs, serr := tx.Transaction.IO.Out.ToSlice()
+					require.NoError(t, serr)
 					for _, msg := range msgs {
 						if msg.MsgType == tlb.MsgTypeExternalOut {
 							if extOut := msg.AsExternalOut(); extOut != nil {
@@ -894,7 +896,8 @@ func Test_LogPoller(t *testing.T) {
 			return counterValue == preReplayEvents
 		}, 30*time.Second, 1*time.Second, "counter should reach expected value")
 
-		counterValue, _ := counter.GetValue(t.Context(), tonChain.Client, emitter.ContractAddress())
+		counterValue, err := counter.GetValue(t.Context(), tonChain.Client, emitter.ContractAddress())
+		require.NoError(t, err)
 		require.Equal(t, preReplayEvents, int(counterValue))
 
 		// 3. Start LogPoller (with in-memory stores)
@@ -922,10 +925,11 @@ func Test_LogPoller(t *testing.T) {
 		defer func() { require.NoError(t, lp.Close()) }()
 
 		// 5. Verify no logs before replay
-		logs, _, _, _ := lp.NewQuery().
+		logs, _, _, err := lp.NewQuery().
 			WithSource(emitter.ContractAddress()).
 			WithEventSig(counter.TopicCountIncreased).
 			Execute(t.Context())
+		require.NoError(t, err)
 		require.Empty(t, logs, "should have no logs before replay")
 
 		// 6. Request replay from block before events were emitted
@@ -956,7 +960,8 @@ func Test_LogPoller(t *testing.T) {
 				return false
 			}
 
-			result, _ := query.DecodedLogs[counter.CountIncreased](logs)
+			result, serr := query.DecodedLogs[counter.CountIncreased](logs)
+			require.NoError(t, serr)
 			t.Logf("found %d logs after replay", len(result))
 			return len(result) == preReplayEvents
 		}, 60*time.Second, 2*time.Second, "replay should complete and index all events")
@@ -969,11 +974,13 @@ func Test_LogPoller(t *testing.T) {
 		}
 
 		require.Eventually(t, func() bool {
-			logs, _, _, _ := lp.NewQuery().
+			logs, _, _, err := lp.NewQuery().
 				WithSource(emitter.ContractAddress()).
 				WithEventSig(counter.TopicCountIncreased).
 				Execute(t.Context())
-			result, _ := query.DecodedLogs[counter.CountIncreased](logs)
+			require.NoError(t, err)
+			result, err := query.DecodedLogs[counter.CountIncreased](logs)
+			require.NoError(t, err)
 			return len(result) == preReplayEvents+postReplayEvents
 		}, 30*time.Second, 2*time.Second, "should index new events after replay")
 	})