-
Notifications
You must be signed in to change notification settings - Fork 184
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* add txpool API * add GetAddressList * fix bug of make(txlen) * change version to v0.18.9 Co-authored-by: MengXiangJian <[email protected]>
- Loading branch information
1 parent
1400ee0
commit cafa364
Showing
5 changed files
with
128 additions
and
10 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,102 @@ | ||
| package txpool | ||
|
|
||
| import ( | ||
| "fmt" | ||
| clientcontext "github.com/cosmos/cosmos-sdk/client/context" | ||
| "github.com/ethereum/go-ethereum/common/hexutil" | ||
| rpctypes "github.com/okex/exchain/app/rpc/types" | ||
|
|
||
| "github.com/okex/exchain/app/rpc/backend" | ||
| "github.com/tendermint/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]*rpctypes.Transaction { | ||
| addressList, err := s.backend.PendingAddressList() | ||
| if err != nil { | ||
| s.logger.Error("txpool.Content addressList err: ", err) | ||
| } | ||
| content := map[string]map[string]map[string]*rpctypes.Transaction{ | ||
| "queued": make(map[string]map[string]*rpctypes.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]*rpctypes.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 *rpctypes.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 | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters