Update chaos examples (#1658)

update chaos examples, havoc fixes

Author: skudasov

book/src/framework/chaos/chaos.md

@@ -56,7 +56,7 @@ We also offer a set of blockchain-specific experiments, which typically involve
 
 - Utilizing developer APIs (e.g., Anvil)
 
-Check [gas](https://github.com/smartcontractkit/chainlink-testing-framework/blob/main/framework/examples/myproject/chaos/chaos_blockchain_evm_gas_test.go) and [reorg](https://github.com/smartcontractkit/chainlink-testing-framework/blob/main/framework/examples/myproject/chaos/chaos_blockchain_evm_reorg_test.go) examples.
+Check [gas](https://github.com/smartcontractkit/chainlink-testing-framework/blob/main/framework/examples/myproject/chaos/chaos_blockchain_evm_gas_test.go) and [reorg](https://github.com/smartcontractkit/chainlink-testing-framework/blob/main/framework/examples/myproject/chaos/chaos_blockchain_evm_reorg_test.go) examples, the same example work for [K8s](https://github.com/smartcontractkit/chainlink-testing-framework/blob/main/framework/examples/myproject/chaos/chaos_k8s_test.go).
 
 ## Debugging
 

framework/.changeset/v0.5.8.md

@@ -0,0 +1 @@
+- All-in-one chaos examples for K8s based on CCIPv2

framework/config.go

@@ -235,3 +235,11 @@ func (d *JSONStrDuration) UnmarshalJSON(b []byte) error {
 		return errors.New("invalid duration")
 	}
 }
+
+func MustParseDuration(s string) time.Duration {
+	d, err := time.ParseDuration(s)
+	if err != nil {
+		L.Fatal().Msg("cannot parse duration, should be Go format 1h2m3s")
+	}
+	return d
+}

framework/examples/myproject/chaos/chaos_blockchain_evm_gas_test.go

@@ -1,9 +1,7 @@
 package chaos
 
 import (
-	"context"
-	"github.com/ethereum/go-ethereum/ethclient"
-	"github.com/smartcontractkit/chainlink-testing-framework/framework"
+	f "github.com/smartcontractkit/chainlink-testing-framework/framework"
 	"github.com/smartcontractkit/chainlink-testing-framework/framework/clclient"
 	"github.com/smartcontractkit/chainlink-testing-framework/framework/components/blockchain"
 	"github.com/smartcontractkit/chainlink-testing-framework/framework/components/fake"
@@ -15,24 +13,14 @@ import (
 	"time"
 )
 
-func printBlockBaseFee(t *testing.T, url string) {
-	ec, err := ethclient.Dial(url)
-	require.NoError(t, err)
-	bn, err := ec.BlockNumber(context.Background())
-	require.NoError(t, err)
-	b, err := ec.BlockByNumber(context.Background(), big.NewInt(int64(bn)))
-	require.NoError(t, err)
-	t.Logf("Current block base fee: %d", b.BaseFee())
-}
-
 type CfgGas struct {
 	BlockchainA        *blockchain.Input `toml:"blockchain_a" validate:"required"`
 	MockerDataProvider *fake.Input       `toml:"data_provider" validate:"required"`
 	NodeSet            *ns.Input         `toml:"nodeset" validate:"required"`
 }
 
 func TestBlockchainGasChaos(t *testing.T) {
-	in, err := framework.Load[CfgGas](t)
+	in, err := f.Load[CfgGas](t)
 	require.NoError(t, err)
 
 	// Can replace deployments with CRIB here
@@ -51,28 +39,31 @@ func TestBlockchainGasChaos(t *testing.T) {
 	blockEvery := 1 * time.Second
 	waitBetweenTests := 1 * time.Minute
 
-	gasControlFunc := func(t *testing.T, r *rpc.RPCClient, url string) {
+	gasControlFunc := func(t *testing.T, r *rpc.RPCClient) {
 		startGasPrice := big.NewInt(2e9)
 		// ramp
 		for i := 0; i < 10; i++ {
-			printBlockBaseFee(t, url)
+			err := r.PrintBlockBaseFee()
+			require.NoError(t, err)
 			t.Logf("Setting block base fee: %d", startGasPrice)
-			err := r.AnvilSetNextBlockBaseFeePerGas(startGasPrice)
+			err = r.AnvilSetNextBlockBaseFeePerGas(startGasPrice)
 			require.NoError(t, err)
 			startGasPrice = startGasPrice.Add(startGasPrice, big.NewInt(1e9))
 			time.Sleep(blockEvery)
 		}
 		// hold
 		for i := 0; i < 10; i++ {
-			printBlockBaseFee(t, url)
+			err := r.PrintBlockBaseFee()
+			require.NoError(t, err)
 			time.Sleep(blockEvery)
 			t.Logf("Setting block base fee: %d", startGasPrice)
-			err := r.AnvilSetNextBlockBaseFeePerGas(startGasPrice)
+			err = r.AnvilSetNextBlockBaseFeePerGas(startGasPrice)
 			require.NoError(t, err)
 		}
 		// release
 		for i := 0; i < 10; i++ {
-			printBlockBaseFee(t, url)
+			err := r.PrintBlockBaseFee()
+			require.NoError(t, err)
 			time.Sleep(blockEvery)
 		}
 	}
@@ -82,7 +73,7 @@ func TestBlockchainGasChaos(t *testing.T) {
 		chainURL         string
 		increase         *big.Int
 		waitBetweenTests time.Duration
-		gasFunc          func(t *testing.T, r *rpc.RPCClient, url string)
+		gasFunc          func(t *testing.T, r *rpc.RPCClient)
 		validate         func(t *testing.T, c []*clclient.ChainlinkClient)
 	}{
 		{
@@ -114,9 +105,8 @@ func TestBlockchainGasChaos(t *testing.T) {
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
 			t.Log(tc.name)
-			printBlockBaseFee(t, tc.chainURL)
 			r := rpc.New(tc.chainURL, nil)
-			tc.gasFunc(t, r, tc.chainURL)
+			tc.gasFunc(t, r)
 			tc.validate(t, c)
 			time.Sleep(waitBetweenTests)
 		})

framework/examples/myproject/chaos/chaos_k8s.toml

@@ -0,0 +1,12 @@
+[chaos]
+wait_before_start = "10s"
+namespace = "default"
+dashboard_uuids = ["WaspDebug"]
+experiment_duration = "20s"
+experiment_injection_duration = "10s"
+remove_k8s_chaos = true
+
+blockchain_http_urls = ["http://localhost:8545", "http://localhost:8550"]
+reorg_below_finality_threshold = 5
+reorg_above_finality_threshold = 10
+block_every = "1s"