From 08423e35828704b2a5a1897bb00c488fbd3f9f90 Mon Sep 17 00:00:00 2001 From: Jesse Lee Date: Wed, 28 Jun 2023 17:12:13 -0400 Subject: [PATCH] just use transact opts --- cmd/loadtest/loadtest.go | 29 ++++++++--------------------- 1 file changed, 8 insertions(+), 21 deletions(-) diff --git a/cmd/loadtest/loadtest.go b/cmd/loadtest/loadtest.go index f165d710..8bd8e630 100644 --- a/cmd/loadtest/loadtest.go +++ b/cmd/loadtest/loadtest.go @@ -818,11 +818,9 @@ func mainLoop(ctx context.Context, c *ethclient.Client, rpc *ethrpc.Client) erro if localMode == loadTestModeRandom { localMode = validLoadTestModes[int(i+j)%(len(validLoadTestModes)-1)] } - - header, err := c.HeaderByNumber(ctx, nil) switch localMode { case loadTestModeTransaction: - startReq, endReq, err = loadtestTransaction(ctx, c, myNonceValue, header) + startReq, endReq, err = loadtestTransaction(ctx, c, myNonceValue) case loadTestModeDeploy: startReq, endReq, err = loadtestDeploy(ctx, c, myNonceValue) case loadTestModeCall: @@ -958,7 +956,7 @@ func blockUntilSuccessful(ctx context.Context, c *ethclient.Client, f func() err } } -func loadtestTransaction(ctx context.Context, c *ethclient.Client, nonce uint64, head *ethtypes.Header) (t1 time.Time, t2 time.Time, err error) { +func loadtestTransaction(ctx context.Context, c *ethclient.Client, nonce uint64) (t1 time.Time, t2 time.Time, err error) { ltp := inputLoadTestParams gasPrice := ltp.CurrentGas @@ -974,24 +972,13 @@ func loadtestTransaction(ctx context.Context, c *ethclient.Client, nonce uint64, gasLimit := uint64(21000) var tx *ethtypes.Transaction - if *ltp.LegacyTransactionMode { - tx = ethtypes.NewTransaction(nonce, *to, amount, gasLimit, gasPrice, nil) - } else { - gasTipCap := ltp.CurrentGasTipCap - gasFeeCap := new(big.Int).Add(gasTipCap, head.BaseFee) - dynamicFeeTx := ðtypes.DynamicFeeTx{ - ChainID: chainID, - Nonce: nonce, - To: to, - Gas: gasLimit, - GasFeeCap: gasFeeCap, - GasTipCap: gasTipCap, - Data: nil, - Value: amount, - } - tx = ethtypes.NewTx(dynamicFeeTx) + if err != nil { + log.Error().Err(err).Msg("Unable to get head") + return } + tx = ethtypes.NewTransaction(nonce, *to, amount, gasLimit, gasPrice, nil) + tops, err := bind.NewKeyedTransactorWithChainID(privateKey, chainID) if err != nil { log.Error().Err(err).Msg("Unable create transaction signer") @@ -999,7 +986,7 @@ func loadtestTransaction(ctx context.Context, c *ethclient.Client, nonce uint64, } tops = configureTransactOpts(tops) - stx, err := tops.Signer(*to, tx) + stx, err := tops.Signer(*ltp.FromETHAddress, tx) if err != nil { log.Error().Err(err).Msg("Unable to sign transaction") return