diff options
author | Wei-Ning Huang <w@dexon.org> | 2018-11-23 12:12:10 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@dexon.org> | 2019-04-09 21:32:54 +0800 |
commit | e79dcc385d37eefb121f675d3800dbfe59b515c7 (patch) | |
tree | 220cd446864dcca990d1adeafd23fe7e301ced7e /internal/ethapi/api.go | |
parent | c51c2a240cd3f01bf8bdb6a1644a902b2335b2aa (diff) | |
download | dexon-e79dcc385d37eefb121f675d3800dbfe59b515c7.tar dexon-e79dcc385d37eefb121f675d3800dbfe59b515c7.tar.gz dexon-e79dcc385d37eefb121f675d3800dbfe59b515c7.tar.bz2 dexon-e79dcc385d37eefb121f675d3800dbfe59b515c7.tar.lz dexon-e79dcc385d37eefb121f675d3800dbfe59b515c7.tar.xz dexon-e79dcc385d37eefb121f675d3800dbfe59b515c7.tar.zst dexon-e79dcc385d37eefb121f675d3800dbfe59b515c7.zip |
api: allow sending batch of raw transactions
Diffstat (limited to 'internal/ethapi/api.go')
-rw-r--r-- | internal/ethapi/api.go | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/internal/ethapi/api.go b/internal/ethapi/api.go index 8c950d5cf..3dec0b114 100644 --- a/internal/ethapi/api.go +++ b/internal/ethapi/api.go @@ -1288,6 +1288,31 @@ func submitTransaction(ctx context.Context, b Backend, tx *types.Transaction) (c return tx.Hash(), nil } +// submitTransactions is a helper function that submits batch of tx to txPool and logs a message. +func submitTransactions(ctx context.Context, b Backend, txs []*types.Transaction) ([]common.Hash, error) { + errs := b.SendTxs(ctx, txs) + var hashes []common.Hash + for i, err := range errs { + if err != nil { + return nil, err + } + tx := txs[i] + if tx.To() == nil { + signer := types.MakeSigner(b.ChainConfig(), b.CurrentBlock().Number()) + from, err := types.Sender(signer, tx) + if err != nil { + return nil, err + } + addr := crypto.CreateAddress(from, tx.Nonce()) + log.Info("Submitted contract creation", "fullhash", tx.Hash().Hex(), "contract", addr.Hex()) + } else { + log.Info("Submitted transaction", "fullhash", tx.Hash().Hex(), "recipient", tx.To()) + } + hashes = append(hashes, tx.Hash()) + } + return hashes, nil +} + // SendTransaction creates a transaction for the given argument, sign it and submit it to the // transaction pool. func (s *PublicTransactionPoolAPI) SendTransaction(ctx context.Context, args SendTxArgs) (common.Hash, error) { @@ -1335,6 +1360,20 @@ func (s *PublicTransactionPoolAPI) SendRawTransaction(ctx context.Context, encod return submitTransaction(ctx, s.b, tx) } +// SendRawTransactions will add the signed transaction to the transaction pool. +// The sender is responsible for signing the transaction and using the correct nonce. +func (s *PublicTransactionPoolAPI) SendRawTransactions(ctx context.Context, encodedTxs []hexutil.Bytes) ([]common.Hash, error) { + var txs []*types.Transaction + for _, encodedTx := range encodedTxs { + tx := new(types.Transaction) + if err := rlp.DecodeBytes(encodedTx, tx); err != nil { + return nil, err + } + txs = append(txs, tx) + } + return submitTransactions(ctx, s.b, txs) +} + // Sign calculates an ECDSA signature for: // keccack256("\x19Ethereum Signed Message:\n" + len(message) + message). // |