-
Notifications
You must be signed in to change notification settings - Fork 15
/
transactions.go
122 lines (102 loc) · 3.18 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
/*
This work is licensed and released under GNU GPL v3 or any other later versions.
The full text of the license is below/ found at <http://www.gnu.org/licenses/>
(c) 2023 Rocket Pool Pty Ltd. Modified under GNU GPL v3. [1.5.0]
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
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/stader-labs/stader-node/stader-lib/stader"
)
// Estimate the gas of SendTransaction
func EstimateSendTransactionGas(client stader.ExecutionClient, toAddress common.Address, opts *bind.TransactOpts) (stader.GasInfo, error) {
// User-defined settings
response := stader.GasInfo{}
// Set default value
value := opts.Value
if value == nil {
value = big.NewInt(0)
}
// 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
Value: value,
})
if err != nil {
return stader.GasInfo{}, err
}
response.EstGasLimit = gasLimit
response.SafeGasLimit = gasLimit
return response, err
}
// Send a transaction to an address
func SendTransaction(client stader.ExecutionClient, toAddress common.Address, chainID *big.Int, 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)
}
// 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
Value: value,
})
if err != nil {
return common.Hash{}, err
}
}
// Initialize transaction
tx := types.NewTx(&types.DynamicFeeTx{
ChainID: chainID,
Nonce: nonce,
GasTipCap: opts.GasTipCap,
GasFeeCap: opts.GasFeeCap,
Gas: gasLimit,
To: &toAddress,
Value: value,
Data: []byte{},
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
}