Merge pull request #2386 from jorgemmsilva/fix/spam-test

tests: minor on-ledger spam cluster test fix

tools/cluster/tests/inccounter_test.go

@@ -267,11 +267,11 @@ func testIncCounterTimelock(t *testing.T, env *ChainEnv) {
 	e.checkWasmContractCounter(1)
 
 	e.postRequest(incHname, isc.Hn("incrementWithDelay"), 0, map[string]interface{}{
-		varDelay: int32(5), // 5s delay()
+		varDelay: int32(50), // 50s delay()
 	})
 
-	time.Sleep(300 * time.Millisecond) // equivalent of 3s
+	time.Sleep(3000 * time.Millisecond) // equivalent of 30s
 	e.checkWasmContractCounter(1)
-	time.Sleep(300 * time.Millisecond) // equivalent of 3s
+	time.Sleep(3000 * time.Millisecond) // equivalent of 30s
 	e.checkWasmContractCounter(2)
 }

tools/cluster/tests/spam_test.go

@@ -35,7 +35,7 @@ func testSpamOnledger(t *testing.T, env *ChainEnv) {
 	const numRequests = 10_000
 
 	// send requests from many different wallets to speed things up
-	numAccounts := 1000
+	numAccounts := numRequests / 10
 	numRequestsPerAccount := numRequests / numAccounts
 	errCh := make(chan error, numRequests)
 	txCh := make(chan iotago.Transaction, numRequests)
@@ -52,33 +52,33 @@ func testSpamOnledger(t *testing.T, env *ChainEnv) {
 				}
 				// wait and re-try
 				createWalletRetries++
-				i--
-				time.Sleep(1 * time.Second)
+				time.Sleep(200 * time.Millisecond)
 				continue
 			}
 
 			break
 		}
 		go func() {
 			chainClient := env.Chain.SCClient(isc.Hn(nativeIncCounterSCName), keyPair)
-			retries := 0
 			for i := 0; i < numRequestsPerAccount; i++ {
-				tx, err := chainClient.PostRequest(inccounter.FuncIncCounter.Name)
-				if err != nil {
-					if retries >= 5 {
-						errCh <- fmt.Errorf("failed to issue tx, an error 5 times, %w", err)
-						break
+				retries := 0
+				for {
+					tx, err := chainClient.PostRequest(inccounter.FuncIncCounter.Name)
+					if err != nil {
+						if retries >= 5 {
+							errCh <- fmt.Errorf("failed to issue tx, an error 5 times, %w", err)
+							break
+						}
+						// wait and retry the tx
+						retries++
+						time.Sleep(200 * time.Millisecond)
+						continue
 					}
-					// wait and re-try the tx
-					retries++
-					i--
-					time.Sleep(1 * time.Second)
-					continue
+					errCh <- err
+					txCh <- *tx
+					break
 				}
-				retries = 0
-				errCh <- err
-				txCh <- *tx
-				time.Sleep(1 * time.Second) // give time for the indexer to get the new UTXOs (so we don't issue conflicting txs)
+				time.Sleep(200 * time.Millisecond) // give time for the indexer to get the new UTXOs (so we don't issue conflicting txs)
 			}
 		}()
 	}
@@ -102,7 +102,7 @@ func testSpamOnledger(t *testing.T, env *ChainEnv) {
 	res, _, err := env.Chain.Cluster.WaspClient(0).CorecontractsApi.BlocklogGetEventsOfLatestBlock(context.Background(), env.Chain.ChainID.String()).Execute()
 	require.NoError(t, err)
 
-	println(res.Events)
+	require.Contains(t, res.Events[len(res.Events)-1], fmt.Sprintf("counter = %d", numRequests))
 }
 
 // executed in cluster_test.go