mirror of
https://github.com/arnaucube/hermez-node.git
synced 2026-02-07 03:16:45 +01:00
Compare commits
3 Commits
v1.0.0
...
hardcoded-
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
714530e164 | ||
|
|
378ba669b6 | ||
|
|
3865c0a9eb |
@@ -522,11 +522,16 @@ func TestMain(m *testing.M) {
|
|||||||
WithdrawalDelay: uint64(3000),
|
WithdrawalDelay: uint64(3000),
|
||||||
}
|
}
|
||||||
|
|
||||||
stateAPIUpdater = stateapiupdater.NewUpdater(hdb, nodeConfig, &common.SCVariables{
|
stateAPIUpdater, err = stateapiupdater.NewUpdater(hdb, nodeConfig, &common.SCVariables{
|
||||||
Rollup: rollupVars,
|
Rollup: rollupVars,
|
||||||
Auction: auctionVars,
|
Auction: auctionVars,
|
||||||
WDelayer: wdelayerVars,
|
WDelayer: wdelayerVars,
|
||||||
}, constants)
|
}, constants, &stateapiupdater.RecommendedFeePolicy{
|
||||||
|
PolicyType: stateapiupdater.RecommendedFeePolicyTypeAvgLastHour,
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
|
||||||
// Generate test data, as expected to be received/sended from/to the API
|
// Generate test data, as expected to be received/sended from/to the API
|
||||||
testCoords := genTestCoordinators(commonCoords)
|
testCoords := genTestCoordinators(commonCoords)
|
||||||
|
|||||||
@@ -6,6 +6,7 @@ import (
|
|||||||
|
|
||||||
"github.com/hermeznetwork/hermez-node/common"
|
"github.com/hermeznetwork/hermez-node/common"
|
||||||
"github.com/hermeznetwork/hermez-node/db/historydb"
|
"github.com/hermeznetwork/hermez-node/db/historydb"
|
||||||
|
"github.com/hermeznetwork/hermez-node/log"
|
||||||
"github.com/hermeznetwork/tracerr"
|
"github.com/hermeznetwork/tracerr"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -17,11 +18,45 @@ type Updater struct {
|
|||||||
vars common.SCVariablesPtr
|
vars common.SCVariablesPtr
|
||||||
consts historydb.Constants
|
consts historydb.Constants
|
||||||
rw sync.RWMutex
|
rw sync.RWMutex
|
||||||
|
rfp *RecommendedFeePolicy
|
||||||
|
}
|
||||||
|
|
||||||
|
// RecommendedFeePolicy describes how the recommended fee is calculated
|
||||||
|
type RecommendedFeePolicy struct {
|
||||||
|
PolicyType RecommendedFeePolicyType
|
||||||
|
StaticValue float64
|
||||||
|
}
|
||||||
|
|
||||||
|
// RecommendedFeePolicyType describes the different available recommended fee strategies
|
||||||
|
type RecommendedFeePolicyType string
|
||||||
|
|
||||||
|
const (
|
||||||
|
// Always give the same StaticValue as recommended fee
|
||||||
|
RecommendedFeePolicyTypeStatic RecommendedFeePolicyType = "Static"
|
||||||
|
// Set the recommended fee using the average fee of the last hour
|
||||||
|
RecommendedFeePolicyTypeAvgLastHour RecommendedFeePolicyType = "AvgLastHour"
|
||||||
|
)
|
||||||
|
|
||||||
|
func (rfp *RecommendedFeePolicy) valid() bool {
|
||||||
|
switch rfp.PolicyType {
|
||||||
|
case RecommendedFeePolicyTypeStatic:
|
||||||
|
if rfp.StaticValue == 0 {
|
||||||
|
log.Warn("RcommendedFee is set to 0 USD, and the policy is static")
|
||||||
|
}
|
||||||
|
return true
|
||||||
|
case RecommendedFeePolicyTypeAvgLastHour:
|
||||||
|
return true
|
||||||
|
default:
|
||||||
|
return false
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewUpdater creates a new Updater
|
// NewUpdater creates a new Updater
|
||||||
func NewUpdater(hdb *historydb.HistoryDB, config *historydb.NodeConfig, vars *common.SCVariables,
|
func NewUpdater(hdb *historydb.HistoryDB, config *historydb.NodeConfig, vars *common.SCVariables,
|
||||||
consts *historydb.Constants) *Updater {
|
consts *historydb.Constants, rfp *RecommendedFeePolicy) (*Updater, error) {
|
||||||
|
if ok := rfp.valid(); !ok {
|
||||||
|
return nil, tracerr.New("Invalid recommende fee policy")
|
||||||
|
}
|
||||||
u := Updater{
|
u := Updater{
|
||||||
hdb: hdb,
|
hdb: hdb,
|
||||||
config: *config,
|
config: *config,
|
||||||
@@ -31,9 +66,10 @@ func NewUpdater(hdb *historydb.HistoryDB, config *historydb.NodeConfig, vars *co
|
|||||||
ForgeDelay: config.ForgeDelay,
|
ForgeDelay: config.ForgeDelay,
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
rfp: rfp,
|
||||||
}
|
}
|
||||||
u.SetSCVars(vars.AsPtr())
|
u.SetSCVars(vars.AsPtr())
|
||||||
return &u
|
return &u, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Store the State in the HistoryDB
|
// Store the State in the HistoryDB
|
||||||
@@ -65,13 +101,27 @@ func (u *Updater) SetSCVars(vars *common.SCVariablesPtr) {
|
|||||||
|
|
||||||
// UpdateRecommendedFee update Status.RecommendedFee information
|
// UpdateRecommendedFee update Status.RecommendedFee information
|
||||||
func (u *Updater) UpdateRecommendedFee() error {
|
func (u *Updater) UpdateRecommendedFee() error {
|
||||||
recommendedFee, err := u.hdb.GetRecommendedFee(u.config.MinFeeUSD, u.config.MaxFeeUSD)
|
switch u.rfp.PolicyType {
|
||||||
if err != nil {
|
case RecommendedFeePolicyTypeStatic:
|
||||||
return tracerr.Wrap(err)
|
u.rw.Lock()
|
||||||
|
u.state.RecommendedFee = common.RecommendedFee{
|
||||||
|
ExistingAccount: u.rfp.StaticValue,
|
||||||
|
CreatesAccount: u.rfp.StaticValue,
|
||||||
|
CreatesAccountInternal: u.rfp.StaticValue,
|
||||||
|
}
|
||||||
|
u.rw.Unlock()
|
||||||
|
case RecommendedFeePolicyTypeAvgLastHour:
|
||||||
|
recommendedFee, err := u.hdb.GetRecommendedFee(u.config.MinFeeUSD, u.config.MaxFeeUSD)
|
||||||
|
if err != nil {
|
||||||
|
return tracerr.Wrap(err)
|
||||||
|
}
|
||||||
|
u.rw.Lock()
|
||||||
|
u.state.RecommendedFee = *recommendedFee
|
||||||
|
u.rw.Unlock()
|
||||||
|
default:
|
||||||
|
return tracerr.New("Invalid recommende fee policy")
|
||||||
}
|
}
|
||||||
u.rw.Lock()
|
|
||||||
u.state.RecommendedFee = *recommendedFee
|
|
||||||
u.rw.Unlock()
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -59,17 +59,21 @@ externalDocs:
|
|||||||
description: Find out more about Hermez network.
|
description: Find out more about Hermez network.
|
||||||
url: 'https://hermez.io'
|
url: 'https://hermez.io'
|
||||||
servers:
|
servers:
|
||||||
- description: Hosted mock up
|
- description: Hosted mock up, returns fake data useful for development
|
||||||
url: https://apimock.hermez.network/v1
|
url: https://apimock.hermez.network
|
||||||
- description: Localhost mock Up
|
- description: Localhost mock up, returns fake data useful for development
|
||||||
url: http://localhost:4010/v1
|
url: http://localhost:4010
|
||||||
|
- description: Testnet (Rinkeby) server
|
||||||
|
url: https://api.testnet.hermez.io
|
||||||
|
- description: Mainnet (Ethereum) server, use it carefully, specially if attempting to send transactions. You could lose money!
|
||||||
|
url: https://api.hermez.io
|
||||||
tags:
|
tags:
|
||||||
- name: Coordinator
|
- name: Coordinator
|
||||||
description: Endpoints used by the nodes running in coordinator mode. They are used to interact with the network.
|
description: Endpoints used by the nodes running in coordinator mode. They are used to interact with the network.
|
||||||
- name: Explorer
|
- name: Explorer
|
||||||
description: Endpoints used by the nodes running in explorer mode. They are used to get information of the netwrok.
|
description: Endpoints used by the nodes running in explorer mode. They are used to get information of the netwrok.
|
||||||
paths:
|
paths:
|
||||||
'/account-creation-authorization':
|
'/v1/account-creation-authorization':
|
||||||
post:
|
post:
|
||||||
tags:
|
tags:
|
||||||
- Coordinator
|
- Coordinator
|
||||||
@@ -99,7 +103,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/account-creation-authorization/{hezEthereumAddress}':
|
'/v1/account-creation-authorization/{hezEthereumAddress}':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Coordinator
|
- Coordinator
|
||||||
@@ -139,7 +143,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/accounts':
|
'/v1/accounts':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -210,7 +214,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/accounts/{accountIndex}':
|
'/v1/accounts/{accountIndex}':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -249,7 +253,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/exits':
|
'/v1/exits':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -336,7 +340,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/exits/{batchNum}/{accountIndex}':
|
'/v1/exits/{batchNum}/{accountIndex}':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -381,7 +385,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/transactions-pool':
|
'/v1/transactions-pool':
|
||||||
post:
|
post:
|
||||||
tags:
|
tags:
|
||||||
- Coordinator
|
- Coordinator
|
||||||
@@ -415,7 +419,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/transactions-pool/{id}':
|
'/v1/transactions-pool/{id}':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Coordinator
|
- Coordinator
|
||||||
@@ -458,7 +462,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/transactions-history':
|
'/v1/transactions-history':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -548,7 +552,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/transactions-history/{id}':
|
'/v1/transactions-history/{id}':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -588,7 +592,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/batches':
|
'/v1/batches':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -664,7 +668,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/batches/{batchNum}':
|
'/v1/batches/{batchNum}':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -704,7 +708,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/full-batches/{batchNum}':
|
'/v1/full-batches/{batchNum}':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -745,7 +749,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/slots':
|
'/v1/slots':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -821,7 +825,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/slots/{slotNum}':
|
'/v1/slots/{slotNum}':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -861,7 +865,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/bids':
|
'/v1/bids':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -925,7 +929,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/state':
|
'/v1/state':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -951,7 +955,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/config':
|
'/v1/config':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -971,7 +975,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/tokens':
|
'/v1/tokens':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -1044,7 +1048,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/tokens/{id}':
|
'/v1/tokens/{id}':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
@@ -1083,7 +1087,7 @@ paths:
|
|||||||
application/json:
|
application/json:
|
||||||
schema:
|
schema:
|
||||||
$ref: '#/components/schemas/Error500'
|
$ref: '#/components/schemas/Error500'
|
||||||
'/coordinators':
|
'/v1/coordinators':
|
||||||
get:
|
get:
|
||||||
tags:
|
tags:
|
||||||
- Explorer
|
- Explorer
|
||||||
|
|||||||
@@ -145,3 +145,11 @@ Coordinator = true
|
|||||||
BatchPath = "/tmp/iden3-test/hermez/batchesdebug"
|
BatchPath = "/tmp/iden3-test/hermez/batchesdebug"
|
||||||
LightScrypt = true
|
LightScrypt = true
|
||||||
# RollupVerifierIndex = 0
|
# RollupVerifierIndex = 0
|
||||||
|
|
||||||
|
[RecommendedFeePolicy]
|
||||||
|
# Strategy used to calculate the recommended fee that the API will expose.
|
||||||
|
# Available options:
|
||||||
|
# - Static: always return the same value (StaticValue) in USD
|
||||||
|
# - AvgLastHour: calculate using the average fee of the forged transactions during the last hour
|
||||||
|
PolicyType = "Static"
|
||||||
|
StaticValue = 0.99
|
||||||
@@ -365,6 +365,7 @@ func getConfig(c *cli.Context) (*Config, error) {
|
|||||||
}
|
}
|
||||||
case modeCoord:
|
case modeCoord:
|
||||||
cfg.mode = node.ModeCoordinator
|
cfg.mode = node.ModeCoordinator
|
||||||
|
fmt.Println("LOADING CFG")
|
||||||
cfg.node, err = config.LoadNode(nodeCfgPath, true)
|
cfg.node, err = config.LoadNode(nodeCfgPath, true)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, tracerr.Wrap(err)
|
return nil, tracerr.Wrap(err)
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import (
|
|||||||
|
|
||||||
"github.com/BurntSushi/toml"
|
"github.com/BurntSushi/toml"
|
||||||
ethCommon "github.com/ethereum/go-ethereum/common"
|
ethCommon "github.com/ethereum/go-ethereum/common"
|
||||||
|
"github.com/hermeznetwork/hermez-node/api/stateapiupdater"
|
||||||
"github.com/hermeznetwork/hermez-node/common"
|
"github.com/hermeznetwork/hermez-node/common"
|
||||||
"github.com/hermeznetwork/hermez-node/priceupdater"
|
"github.com/hermeznetwork/hermez-node/priceupdater"
|
||||||
"github.com/hermeznetwork/tracerr"
|
"github.com/hermeznetwork/tracerr"
|
||||||
@@ -347,8 +348,9 @@ type Node struct {
|
|||||||
// can wait to stablish a SQL connection
|
// can wait to stablish a SQL connection
|
||||||
SQLConnectionTimeout Duration
|
SQLConnectionTimeout Duration
|
||||||
} `validate:"required"`
|
} `validate:"required"`
|
||||||
Debug NodeDebug `validate:"required"`
|
RecommendedFeePolicy stateapiupdater.RecommendedFeePolicy `validate:"required"`
|
||||||
Coordinator Coordinator `validate:"-"`
|
Debug NodeDebug `validate:"required"`
|
||||||
|
Coordinator Coordinator `validate:"-"`
|
||||||
}
|
}
|
||||||
|
|
||||||
// APIServer is the api server configuration parameters
|
// APIServer is the api server configuration parameters
|
||||||
|
|||||||
11
node/node.go
11
node/node.go
@@ -288,7 +288,16 @@ func NewNode(mode Mode, cfg *config.Node) (*Node, error) {
|
|||||||
return nil, tracerr.Wrap(err)
|
return nil, tracerr.Wrap(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
stateAPIUpdater := stateapiupdater.NewUpdater(historyDB, &hdbNodeCfg, initSCVars, &hdbConsts)
|
stateAPIUpdater, err := stateapiupdater.NewUpdater(
|
||||||
|
historyDB,
|
||||||
|
&hdbNodeCfg,
|
||||||
|
initSCVars,
|
||||||
|
&hdbConsts,
|
||||||
|
&cfg.RecommendedFeePolicy,
|
||||||
|
)
|
||||||
|
if err != nil {
|
||||||
|
return nil, tracerr.Wrap(err)
|
||||||
|
}
|
||||||
|
|
||||||
var coord *coordinator.Coordinator
|
var coord *coordinator.Coordinator
|
||||||
if mode == ModeCoordinator {
|
if mode == ModeCoordinator {
|
||||||
|
|||||||
Reference in New Issue
Block a user