/
transactions.go
125 lines (105 loc) · 2.94 KB
/
transactions.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
package eth
import (
"context"
"math/big"
"github.com/ethereum/go-ethereum"
"github.com/ethereum/go-ethereum/accounts/abi/bind"
"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/core/types"
"github.com/rocket-pool/rocketpool-go/rocketpool"
)
// Estimate the gas of SendTransaction
func EstimateSendTransactionGas(client rocketpool.ExecutionClient, toAddress common.Address, data []byte, useSafeGasLimit bool, opts *bind.TransactOpts) (rocketpool.GasInfo, error) {
// User-defined settings
response := rocketpool.GasInfo{}
// Set default value
value := opts.Value
if value == nil {
value = big.NewInt(0)
}
// Set default data
if data == nil {
data = []byte{}
}
// Estimate gas limit
gasLimit, err := client.EstimateGas(context.Background(), ethereum.CallMsg{
From: opts.From,
To: &toAddress,
GasPrice: big.NewInt(0), // set to 0 for simulation
Data: data,
Value: value,
})
if err != nil {
return rocketpool.GasInfo{}, err
}
response.EstGasLimit = gasLimit
if useSafeGasLimit {
response.SafeGasLimit = uint64(float64(gasLimit) * rocketpool.GasLimitMultiplier)
} else {
response.SafeGasLimit = gasLimit
}
return response, err
}
// Send a transaction to an address
// useSafeGasLimit will amplify the estimated gas limit to by 50% for safety (no effect if the gas limit in opts is already set).
func SendTransaction(client rocketpool.ExecutionClient, toAddress common.Address, chainID *big.Int, data []byte, useSafeGasLimit bool, opts *bind.TransactOpts) (common.Hash, error) {
var err error
// Get from address nonce
var nonce uint64
if opts.Nonce == nil {
nonce, err = client.PendingNonceAt(context.Background(), opts.From)
if err != nil {
return common.Hash{}, err
}
} else {
nonce = opts.Nonce.Uint64()
}
// Set default value
value := opts.Value
if value == nil {
value = big.NewInt(0)
}
// Set default data
if data == nil {
data = []byte{}
}
// Estimate gas limit
gasLimit := opts.GasLimit
if gasLimit == 0 {
gasLimit, err = client.EstimateGas(context.Background(), ethereum.CallMsg{
From: opts.From,
To: &toAddress,
GasPrice: big.NewInt(0), // use 0 gwei for simulation
Data: data,
Value: value,
})
if err != nil {
return common.Hash{}, err
}
if useSafeGasLimit {
gasLimit = uint64(float64(gasLimit) * rocketpool.GasLimitMultiplier)
}
}
// Initialize transaction
tx := types.NewTx(&types.DynamicFeeTx{
ChainID: chainID,
Nonce: nonce,
GasTipCap: opts.GasTipCap,
GasFeeCap: opts.GasFeeCap,
Gas: gasLimit,
To: &toAddress,
Value: value,
Data: data,
AccessList: []types.AccessTuple{},
})
// Sign transaction
signedTx, err := opts.Signer(opts.From, tx)
if err != nil {
return common.Hash{}, err
}
// Send transaction
if err = client.SendTransaction(context.Background(), signedTx); err != nil {
return common.Hash{}, err
}
return signedTx.Hash(), nil
}