-
Notifications
You must be signed in to change notification settings - Fork 181
/
api.go
103 lines (89 loc) · 3.13 KB
/
api.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
package txpool
import (
"fmt"
"github.com/ethereum/go-ethereum/common/hexutil"
clientcontext "github.com/okex/exchain/libs/cosmos-sdk/client/context"
"github.com/okex/exchain/x/evm/watcher"
"github.com/okex/exchain/app/rpc/backend"
"github.com/okex/exchain/libs/tendermint/libs/log"
)
// PublicTxPoolAPI offers and API for the transaction pool. It only operates on data that is non confidential.
type PublicTxPoolAPI struct {
clientCtx clientcontext.CLIContext
logger log.Logger
backend backend.Backend
}
// NewPublicTxPoolAPI creates a new tx pool service that gives information about the transaction pool.
func NewAPI(clientCtx clientcontext.CLIContext, log log.Logger, backend backend.Backend) *PublicTxPoolAPI {
api := &PublicTxPoolAPI{
clientCtx: clientCtx,
backend: backend,
logger: log.With("module", "json-rpc", "namespace", "txpool"),
}
return api
}
// Content returns the transactions contained within the transaction pool.
func (s *PublicTxPoolAPI) Content() map[string]map[string]map[string]*watcher.Transaction {
addressList, err := s.backend.PendingAddressList()
if err != nil {
s.logger.Error("txpool.Content addressList err: ", err)
}
content := map[string]map[string]map[string]*watcher.Transaction{
"queued": make(map[string]map[string]*watcher.Transaction),
}
for _, address := range addressList {
txs, err := s.backend.UserPendingTransactions(address, -1)
if err != nil {
s.logger.Error("txpool.Content err: ", err)
}
// Flatten the queued transactions
dump := make(map[string]*watcher.Transaction)
for _, tx := range txs {
dump[fmt.Sprintf("%d", tx.Nonce)] = tx
}
content["queued"][address] = dump
}
return content
}
// Status returns the number of pending and queued transaction in the pool.
func (s *PublicTxPoolAPI) Status() map[string]hexutil.Uint {
numRes, err := s.backend.PendingTransactionCnt()
if err != nil {
s.logger.Error("txpool.Status err: ", err)
return nil
}
return map[string]hexutil.Uint{
"queued": hexutil.Uint(numRes),
}
}
// Inspect retrieves the content of the transaction pool and flattens it into an
// easily inspectable list.
func (s *PublicTxPoolAPI) Inspect() map[string]map[string]map[string]string {
addressList, err := s.backend.PendingAddressList()
if err != nil {
s.logger.Error("txpool.Inspect addressList err: ", err)
}
content := map[string]map[string]map[string]string{
"queued": make(map[string]map[string]string),
}
for _, address := range addressList {
txs, err := s.backend.UserPendingTransactions(address, -1)
if err != nil {
s.logger.Error("txpool.Inspect err: ", err)
}
// Define a formatter to flatten a transaction into a string
var format = func(tx *watcher.Transaction) string {
if to := tx.To; to != nil {
return fmt.Sprintf("%s: %v wei + %v gas × %v wei", tx.To.Hex(), tx.Value, tx.Gas, tx.GasPrice)
}
return fmt.Sprintf("contract creation: %v wei + %v gas × %v wei", tx.Value, tx.Gas, tx.GasPrice)
}
// Flatten the queued transactions
dump := make(map[string]string)
for _, tx := range txs {
dump[fmt.Sprintf("%d", tx.Nonce)] = format(tx)
}
content["queued"][address] = dump
}
return content
}