Skip to content

Commit

Permalink
Merge pull request #2068 from fxfactorial/picks-for-s3
Browse files Browse the repository at this point in the history
Picks for s3
  • Loading branch information
Leo Chen authored Jan 13, 2020
2 parents 9b834c4 + 129a56a commit 917d803
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 17 deletions.
2 changes: 2 additions & 0 deletions internal/hmyapi/harmony.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ type NodeMetadata struct {
ChainID string `json:"chainid"`
IsLeader bool `json:"is-leader"`
ShardID uint32 `json:"shard-id"`
Role string `json:"role"`
}

// GetNodeMetadata produces a NodeMetadata record, data is from the answering RPC node
Expand All @@ -64,6 +65,7 @@ func (s *PublicHarmonyAPI) GetNodeMetadata() NodeMetadata {
s.b.ChainConfig().ChainID.String(),
s.b.IsLeader(),
s.b.GetShardID(),
cfg.Role().String(),
}
}

Expand Down
20 changes: 3 additions & 17 deletions internal/hmyapi/transactionpool.go
Original file line number Diff line number Diff line change
Expand Up @@ -270,28 +270,14 @@ func (s *PublicTransactionPoolAPI) GetTransactionReceipt(ctx context.Context, ha
}

// PendingTransactions returns the transactions that are in the transaction pool
// and have a from address that is one of the accounts this node manages.
func (s *PublicTransactionPoolAPI) PendingTransactions() ([]*RPCTransaction, error) {
pending, err := s.b.GetPoolTransactions()
if err != nil {
return nil, err
}
accounts := make(map[common.Address]struct{})
for _, wallet := range s.b.AccountManager().Wallets() {
for _, account := range wallet.Accounts() {
accounts[account.Address] = struct{}{}
}
}
transactions := make([]*RPCTransaction, 0, len(pending))
for _, tx := range pending {
var signer types.Signer = types.HomesteadSigner{}
if tx.Protected() {
signer = types.NewEIP155Signer(tx.ChainID())
}
from, _ := types.Sender(signer, tx)
if _, exists := accounts[from]; exists {
transactions = append(transactions, newRPCPendingTransaction(tx))
}
transactions := make([]*RPCTransaction, len(pending))
for i := range pending {
transactions[i] = newRPCPendingTransaction(pending[i])
}
return transactions, nil
}
Expand Down

0 comments on commit 917d803

Please sign in to comment.