You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

78 lines
2.6 KiB

Redo coordinator structure, connect API to node - API: - Modify the constructor so that hardcoded rollup constants don't need to be passed (introduce a `Config` and use `configAPI` internally) - Common: - Update rollup constants with proper *big.Int when required - Add BidCoordinator and Slot structs used by the HistoryDB and Synchronizer. - Add helper methods to AuctionConstants - AuctionVariables: Add column `DefaultSlotSetBidSlotNum` (in the SQL table: `default_slot_set_bid_slot_num`), which indicates at which slotNum does the `DefaultSlotSetBid` specified starts applying. - Config: - Move coordinator exclusive configuration from the node config to the coordinator config - Coordinator: - Reorganize the code towards having the goroutines started and stopped from the coordinator itself instead of the node. - Remove all stop and stopped channels, and use context.Context and sync.WaitGroup instead. - Remove BatchInfo setters and assing variables directly - In ServerProof and ServerProofPool use context instead stop channel. - Use message passing to notify the coordinator about sync updates and reorgs - Introduce the Pipeline, which can be started and stopped by the Coordinator - Introduce the TxManager, which manages ethereum transactions (the TxManager is also in charge of making the forge call to the rollup smart contract). The TxManager keeps ethereum transactions and: 1. Waits for the transaction to be accepted 2. Waits for the transaction to be confirmed for N blocks - In forge logic, first prepare a batch and then wait for an available server proof to have all work ready once the proof server is ready. - Remove the `isForgeSequence` method which was querying the smart contract, and instead use notifications sent by the Synchronizer to figure out if it's forging time. - Update test (which is a minimal test to manually see if the coordinator starts) - HistoryDB: - Add method to get the number of batches in a slot (used to detect when a slot has passed the bid winner forging deadline) - Add method to get the best bid and associated coordinator of a slot (used to detect the forgerAddress that can forge the slot) - General: - Rename some instances of `currentBlock` to `lastBlock` to be more clear. - Node: - Connect the API to the node and call the methods to update cached state when the sync advances blocks. - Call methods to update Coordinator state when the sync advances blocks and finds reorgs. - Synchronizer: - Add Auction field in the Stats, which contain the current slot with info about highest bidder and other related info required to know who can forge in the current block. - Better organization of cached state: - On Sync, update the internal cached state - On Init or Reorg, load the state from HistoryDB into the internal cached state.
3 years ago
  1. package common
  2. import (
  3. "bytes"
  4. "encoding/hex"
  5. "math/big"
  6. ethCommon "github.com/ethereum/go-ethereum/common"
  7. "github.com/hermeznetwork/tracerr"
  8. "github.com/iden3/go-iden3-crypto/babyjub"
  9. "github.com/iden3/go-merkletree"
  10. )
  11. // SwapEndianness swaps the order of the bytes in the slice.
  12. func SwapEndianness(b []byte) []byte {
  13. o := make([]byte, len(b))
  14. for i := range b {
  15. o[len(b)-1-i] = b[i]
  16. }
  17. return o
  18. }
  19. // EthAddrToBigInt returns a *big.Int from a given ethereum common.Address.
  20. func EthAddrToBigInt(a ethCommon.Address) *big.Int {
  21. return new(big.Int).SetBytes(a.Bytes())
  22. }
  23. // BJJFromStringWithChecksum parses a hex string in Hermez format (which has
  24. // the Hermez checksum at the last byte, and is encoded in BigEndian) and
  25. // returns the corresponding *babyjub.PublicKey. This method is not part of the
  26. // spec, is used for importing javascript test vectors data.
  27. func BJJFromStringWithChecksum(s string) (babyjub.PublicKeyComp, error) {
  28. b, err := hex.DecodeString(s)
  29. if err != nil {
  30. return EmptyBJJComp, tracerr.Wrap(err)
  31. }
  32. pkBytes := SwapEndianness(b)
  33. var pkComp babyjub.PublicKeyComp
  34. copy(pkComp[:], pkBytes[:])
  35. return pkComp, nil
  36. }
  37. // CopyBigInt returns a copy of the big int
  38. func CopyBigInt(a *big.Int) *big.Int {
  39. return new(big.Int).SetBytes(a.Bytes())
  40. }
  41. // RmEndingZeroes is used to convert the Siblings from a CircomProof into
  42. // Siblings of a merkletree Proof compatible with the js version. This method
  43. // should be used only if it exist an already generated CircomProof compatible
  44. // with circom circuits and a CircomProof compatible with SmartContracts is
  45. // needed. If the proof is not generated yet, this method should not be needed
  46. // and should be used mt.GenerateSCVerifierProof to directly generate the
  47. // CircomProof for the SmartContracts.
  48. func RmEndingZeroes(siblings []*merkletree.Hash) []*merkletree.Hash {
  49. pos := 0
  50. for i := len(siblings) - 1; i >= 0; i-- {
  51. if !bytes.Equal(siblings[i].Bytes(), merkletree.HashZero.Bytes()) {
  52. pos = i + 1
  53. break
  54. }
  55. }
  56. return siblings[:pos]
  57. }
  58. // TokensToUSD is a helper function to calculate the USD value of a certain
  59. // amount of tokens considering the normalized token price (which is the price
  60. // commonly reported by exhanges)
  61. func TokensToUSD(amount *big.Int, decimals uint64, valueUSD float64) float64 {
  62. amountF := new(big.Float).SetInt(amount)
  63. // Divide by 10^decimals to normalize the amount
  64. baseF := new(big.Float).SetInt(new(big.Int).Exp(
  65. big.NewInt(10), big.NewInt(int64(decimals)), nil)) //nolint:gomnd
  66. amountF.Mul(amountF, big.NewFloat(valueUSD))
  67. amountF.Quo(amountF, baseF)
  68. amountUSD, _ := amountF.Float64()
  69. return amountUSD
  70. }