poanetwork
/
quorum
mirror of https://github.com/poanetwork/quorum.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fix async tx submission

This commit is contained in:
Brian Schroeder 2017-10-19 15:28:10 -04:00
parent 111fa57825
commit c0218f9052
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
internal/ethapi/api.go
View File

@ -1487,7 +1487,7 @@ func (a *Async) send(ctx context.Context, s *PublicTransactionPoolAPI, asyncArgs
} }
b, err := private.P.Send([]byte(args.Data), args.PrivateFrom, args.PrivateFor) b, err := private.P.Send([]byte(args.Data), args.PrivateFrom, args.PrivateFor)
if err != nil { if err != nil {
log.Info("Error running Private.P.Send: %v", err) log.Info("Error running Private.P.Send", "err", err)
res.Error = err.Error() res.Error = err.Error()
return return
} }
@ -1513,12 +1513,13 @@ func (a *Async) save(ctx context.Context, s *PublicTransactionPoolAPI, args Send
} else { } else {
tx = types.NewTransaction((uint64)(*args.Nonce), *args.To, (*big.Int)(args.Value), (*big.Int)(args.Gas), (*big.Int)(args.GasPrice), data) tx = types.NewTransaction((uint64)(*args.Nonce), *args.To, (*big.Int)(args.Value), (*big.Int)(args.Gas), (*big.Int)(args.GasPrice), data)
} }
return common.Hash{}, fmt.Errorf("unimplemented: Async.save %v", tx)
//signature, err := s.b.AccountManager().SignEthereum(args.From, tx.SigHash().Bytes()) signed, err := s.sign(args.From, tx)
//if err != nil { if err != nil {
// return common.Hash{}, err return common.Hash{}, err
//} }
//return submitTransaction(ctx, s.b, tx, signature, len(args.PrivateFor) > 0)
return submitTransaction(ctx, s.b, signed, args.PrivateFor != nil)
} }
func newAsync(n int) *Async { func newAsync(n int) *Async {