Add multinode to txm

smartcontractkit · Oct 2, 2024 · b5c3891 · b5c3891
1 parent 83dced8
commit b5c3891
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/pkg/solana/txm/txm_internal_test.go b/pkg/solana/txm/txm_internal_test.go
@@ -112,7 +112,7 @@ func TestTxm(t *testing.T) {
 
 			txm := NewTxm(id, func() (client.ReaderWriter, error) {
 				return mc, nil
-			}, cfg, mkey, lggr)
+			}, cfg, nil, mkey, lggr)
 			require.NoError(t, txm.Start(ctx))
 
 			// tracking prom metrics
@@ -718,7 +718,7 @@ func TestTxm_Enqueue(t *testing.T) {
 
 	txm := NewTxm("enqueue_test", func() (client.ReaderWriter, error) {
 		return mc, nil
-	}, cfg, mkey, lggr)
+	}, cfg, nil, mkey, lggr)
 
 	require.ErrorContains(t, txm.Enqueue("txmUnstarted", &solana.Transaction{}), "not started")
 	require.NoError(t, txm.Start(ctx))

diff --git a/pkg/solana/txm/txm_race_test.go b/pkg/solana/txm/txm_race_test.go
@@ -65,7 +65,7 @@ func TestTxm_SendWithRetry_Race(t *testing.T) {
 		}
 
 		// build minimal txm
-		txm := NewTxm("retry_race", getClient, cfg, ks, lggr)
+		txm := NewTxm("retry_race", getClient, cfg, nil, ks, lggr)
 		txm.fee = fee
 
 		_, _, _, err := txm.sendWithRetry(

diff --git a/pkg/solana/txm/txm_test.go b/pkg/solana/txm/txm_test.go
@@ -72,7 +72,7 @@ func TestTxm_Integration(t *testing.T) {
 			getClient := func() (solanaClient.ReaderWriter, error) {
 				return client, nil
 			}
-			txm := txm.NewTxm("localnet", getClient, cfg, mkey, lggr)
+			txm := txm.NewTxm("localnet", getClient, cfg, nil, mkey, lggr)
 
 			// track initial balance
 			initBal, err := client.Balance(pubKey)