From 5a2c4cdf7998a6d2b14a36c0d973dc86aa763e9c Mon Sep 17 00:00:00 2001 From: zhangkai Date: Sun, 13 Oct 2024 11:19:18 +0800 Subject: [PATCH 01/10] add ethtxmanager http server for check --- config/default.go | 4 + ethtxmanager/config.go | 3 + ethtxmanager/custodialassetscache_xlayer.go | 67 +++++++++++ .../custodialassetscacheobj_xlayer.go | 20 ++++ ethtxmanager/custodialassetshttp_xlayer.go | 7 +- ethtxmanager/ethtxmanager.go | 5 + ethtxmanager/server_xlayer.go | 111 ++++++++++++++++++ ethtxmanager/serverconfig_xlayer.go | 12 ++ 8 files changed, 228 insertions(+), 1 deletion(-) create mode 100644 ethtxmanager/custodialassetscache_xlayer.go create mode 100644 ethtxmanager/custodialassetscacheobj_xlayer.go create mode 100644 ethtxmanager/server_xlayer.go create mode 100644 ethtxmanager/serverconfig_xlayer.go diff --git a/config/default.go b/config/default.go index 254f4695b4..2c6705bfca 100644 --- a/config/default.go +++ b/config/default.go @@ -99,6 +99,10 @@ MaxGasPriceLimit = 0 OperateAmount = 0 RequestSignURI = "/priapi/v1/assetonchain/ecology/ecologyOperate" QuerySignURI = "/priapi/v1/assetonchain/ecology/querySignDataByOrderNo" + [RPC] + Enable = false + Host = "0.0.0.0" + Port = "7001" [RPC] Host = "0.0.0.0" diff --git a/ethtxmanager/config.go b/ethtxmanager/config.go index e25e2f5dee..c5c9948aa6 100644 --- a/ethtxmanager/config.go +++ b/ethtxmanager/config.go @@ -51,4 +51,7 @@ type Config struct { // CustodialAssets is the configuration for the custodial assets CustodialAssets CustodialAssetsConfig `mapstructure:"CustodialAssets"` + + // RPC is the configuration for the rpc server + RPC RPCConfig `mapstructure:"RPC"` } diff --git a/ethtxmanager/custodialassetscache_xlayer.go b/ethtxmanager/custodialassetscache_xlayer.go new file mode 100644 index 0000000000..d7d3658a9c --- /dev/null +++ b/ethtxmanager/custodialassetscache_xlayer.go @@ -0,0 +1,67 @@ +package ethtxmanager + +import ( + "container/list" +) + +// lruCache represents a cache with a fixed size +type lruCache struct { + capacity int + cache map[string]*list.Element + list *list.List +} + +// entry is used to store key-value pairs in the cache +type entry struct { + key string + value string +} + +// newLRUCache creates a new LRU cache with the given capacity +func newLRUCache(capacity int) *lruCache { + return &lruCache{ + capacity: capacity, + cache: make(map[string]*list.Element), + list: list.New(), + } +} + +// get retrieves the value for the given key if present, otherwise returns -1 +func (l *lruCache) get(key string) string { + if element, ok := l.cache[key]; ok { + // Move the accessed element to the front of the list + l.list.MoveToFront(element) + // Return the value + return element.Value.(*entry).value + } + // Key not found + return "" +} + +// put adds a key-value pair to the cache or updates the value if the key already exists +func (l *lruCache) put(key string, value string) { + // Check if the key already exists + if element, ok := l.cache[key]; ok { + // Update the value + element.Value.(*entry).value = value + // Move the element to the front of the list + l.list.MoveToFront(element) + return + } + + // If the cache has reached capacity, remove the least recently used item + if l.list.Len() == l.capacity { + // Get the least recently used element (tail of the list) + lru := l.list.Back() + if lru != nil { + // Remove it from the list and the cache + l.list.Remove(lru) + delete(l.cache, lru.Value.(*entry).key) + } + } + + // Add the new item to the front of the list + element := l.list.PushFront(&entry{key: key, value: value}) + // Add it to the cache + l.cache[key] = element +} diff --git a/ethtxmanager/custodialassetscacheobj_xlayer.go b/ethtxmanager/custodialassetscacheobj_xlayer.go new file mode 100644 index 0000000000..cf23f710b5 --- /dev/null +++ b/ethtxmanager/custodialassetscacheobj_xlayer.go @@ -0,0 +1,20 @@ +package ethtxmanager + +import ( + "sync" +) + +const ( + capacity = 10 +) + +var instance *lruCache +var once sync.Once + +func getAuthInstance() *lruCache { + once.Do(func() { + instance = newLRUCache(capacity) + }) + + return instance +} diff --git a/ethtxmanager/custodialassetshttp_xlayer.go b/ethtxmanager/custodialassetshttp_xlayer.go index 6b602e76fa..9d26951d0a 100644 --- a/ethtxmanager/custodialassetshttp_xlayer.go +++ b/ethtxmanager/custodialassetshttp_xlayer.go @@ -53,7 +53,7 @@ type signResultRequest struct { func (c *Client) newSignRequest(operateType int, operateAddress common.Address, otherInfo string) *signRequest { refOrderID := uuid.New().String() - return &signRequest{ + request := signRequest{ UserID: c.cfg.CustodialAssets.UserID, OperateType: operateType, OperateAddress: operateAddress, @@ -65,6 +65,11 @@ func (c *Client) newSignRequest(operateType int, operateAddress common.Address, SysFrom: c.cfg.CustodialAssets.SysFrom, OtherInfo: otherInfo, } + + cache, _ := json.Marshal(request) + getAuthInstance().put(refOrderID, string(cache)) + + return &request } func (c *Client) newSignResultRequest(orderID string) *signResultRequest { diff --git a/ethtxmanager/ethtxmanager.go b/ethtxmanager/ethtxmanager.go index 350fef64b7..45c6094d8f 100644 --- a/ethtxmanager/ethtxmanager.go +++ b/ethtxmanager/ethtxmanager.go @@ -18,6 +18,7 @@ import ( "github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/core/types" "github.com/jackc/pgx/v4" + "net/http" ) const ( @@ -45,6 +46,9 @@ type Client struct { etherman ethermanInterface storage storageInterface state stateInterface + + // X Layer + srv *http.Server } // New creates new eth tx manager @@ -219,6 +223,7 @@ func (c *Client) Start() { // Stop will stops the monitored tx management func (c *Client) Stop() { c.cancel() + c.stopRPC() } // Reorg updates all monitored txs from provided block number until the last one to diff --git a/ethtxmanager/server_xlayer.go b/ethtxmanager/server_xlayer.go new file mode 100644 index 0000000000..5163cf5183 --- /dev/null +++ b/ethtxmanager/server_xlayer.go @@ -0,0 +1,111 @@ +package ethtxmanager + +import ( + "net/http" + "fmt" + "net" + "github.com/0xPolygonHermez/zkevm-node/log" + "time" + "encoding/json" +) + +const ( + authHandler = "/inner/v3/okpool/vault/operate/get" + referOrderId = "referOrderId" +) + +type Response struct { + Code int `json:"code"` + Data string `json:"data"` + DetailMsg string `json:"detailMsg"` + ErrorCode string `json:"error_code"` + ErrorMessage string `json:"error_message"` + Message string `json:"message"` +} + +func (c *Client) startRPC() error { + if c == nil || !c.cfg.RPC.Enable { + return nil + } + if c.srv != nil { + return fmt.Errorf("server already started") + } + + address := fmt.Sprintf("%s:%d", c.cfg.RPC.Host, c.cfg.RPC.Port) + + lis, err := net.Listen("tcp", address) + if err != nil { + log.Errorf("failed to create tcp listener: %v", err) + return err + } + + mux := http.NewServeMux() + mux.Handle(authHandler, c) + + c.srv = &http.Server{ + Handler: mux, + ReadHeaderTimeout: time.Minute, + ReadTimeout: time.Minute, + WriteTimeout: time.Minute, + } + log.Infof("http server started: %s", address) + if err = c.srv.Serve(lis); err != nil { + if err == http.ErrServerClosed { + log.Infof("http server stopped") + return nil + } + log.Errorf("closed http connection: %v", err) + return err + } + + return nil +} + +func (c *Client) stopRPC() error { + if c == nil || c.srv == nil { + return nil + } + + if err := c.srv.Close(); err != nil { + log.Errorf("failed to close http server: %v", err) + return err + } + + return nil +} + +func (c *Client) ServeHTTP(w http.ResponseWriter, r *http.Request) { + if r.Method != http.MethodGet { + var resp Response + resp.Code = http.StatusMethodNotAllowed + resp.ErrorMessage = "method not allowed" + respBytes, _ := json.Marshal(resp) + http.Error(w, string(respBytes), http.StatusMethodNotAllowed) + + return + } + queryParams := r.URL.Query() + orderID := queryParams.Get(referOrderId) + if orderID == "" { + var resp Response + resp.Code = http.StatusBadRequest + resp.ErrorMessage = "order id not found" + respBytes, _ := json.Marshal(resp) + http.Error(w, string(respBytes), http.StatusBadRequest) + return + } + + data := getAuthInstance().get(orderID) + if data == "" { + var resp Response + resp.Code = http.StatusBadRequest + resp.ErrorMessage = "order id not found in cache" + respBytes, _ := json.Marshal(resp) + http.Error(w, string(respBytes), http.StatusBadRequest) + return + } + var resp Response + resp.Data = data + respBytes, _ := json.Marshal(resp) + w.Write(respBytes) +} diff --git a/ethtxmanager/serverconfig_xlayer.go b/ethtxmanager/serverconfig_xlayer.go new file mode 100644 index 0000000000..397bb7e4c1 --- /dev/null +++ b/ethtxmanager/serverconfig_xlayer.go @@ -0,0 +1,12 @@ +package ethtxmanager + +type RPCConfig struct { + // Enable is the flag to enable the rpc server + Enable bool `mapstructure:"Enable"` + + // Host is the host of the rpc server + Host string `mapstructure:"Host"` + + // RPCPort is the port of the rpc server + Port int `mapstructure:"Port"` +} From 8807a6376362ef75cbc3938ef38e736ce9862840 Mon Sep 17 00:00:00 2001 From: zhangkai Date: Sun, 13 Oct 2024 11:37:45 +0800 Subject: [PATCH 02/10] change paramter --- config/default.go | 2 +- ethtxmanager/config.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/config/default.go b/config/default.go index 2c6705bfca..190c20e7d5 100644 --- a/config/default.go +++ b/config/default.go @@ -99,7 +99,7 @@ MaxGasPriceLimit = 0 OperateAmount = 0 RequestSignURI = "/priapi/v1/assetonchain/ecology/ecologyOperate" QuerySignURI = "/priapi/v1/assetonchain/ecology/querySignDataByOrderNo" - [RPC] + [HTTP] Enable = false Host = "0.0.0.0" Port = "7001" diff --git a/ethtxmanager/config.go b/ethtxmanager/config.go index c5c9948aa6..16c2078e41 100644 --- a/ethtxmanager/config.go +++ b/ethtxmanager/config.go @@ -52,6 +52,6 @@ type Config struct { // CustodialAssets is the configuration for the custodial assets CustodialAssets CustodialAssetsConfig `mapstructure:"CustodialAssets"` - // RPC is the configuration for the rpc server - RPC RPCConfig `mapstructure:"RPC"` + // HTTP is the configuration for the rpc server + HTTP RPCConfig `mapstructure:"HTTP"` } From 997ff6e89d923baa3e66d50cc059e11ec73becdf Mon Sep 17 00:00:00 2001 From: zhangkai Date: Sun, 13 Oct 2024 11:40:10 +0800 Subject: [PATCH 03/10] change to http --- ethtxmanager/server_xlayer.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ethtxmanager/server_xlayer.go b/ethtxmanager/server_xlayer.go index 5163cf5183..7514c06ed0 100644 --- a/ethtxmanager/server_xlayer.go +++ b/ethtxmanager/server_xlayer.go @@ -24,14 +24,14 @@ type Response struct { } func (c *Client) startRPC() error { - if c == nil || !c.cfg.RPC.Enable { + if c == nil || !c.cfg.HTTP.Enable { return nil } if c.srv != nil { return fmt.Errorf("server already started") } - address := fmt.Sprintf("%s:%d", c.cfg.RPC.Host, c.cfg.RPC.Port) + address := fmt.Sprintf("%s:%d", c.cfg.HTTP.Host, c.cfg.HTTP.Port) lis, err := net.Listen("tcp", address) if err != nil { From 89a0b98635943a97a34d68f5347709778e0d6543 Mon Sep 17 00:00:00 2001 From: zhangkai Date: Sun, 13 Oct 2024 11:48:03 +0800 Subject: [PATCH 04/10] start http server --- ethtxmanager/ethtxmanager.go | 1 + 1 file changed, 1 insertion(+) diff --git a/ethtxmanager/ethtxmanager.go b/ethtxmanager/ethtxmanager.go index 45c6094d8f..5dc54530ba 100644 --- a/ethtxmanager/ethtxmanager.go +++ b/ethtxmanager/ethtxmanager.go @@ -206,6 +206,7 @@ func (c *Client) Start() { // infinite loop to manage txs as they arrive c.ctx, c.cancel = context.WithCancel(context.Background()) + go c.startRPC() metrics.Register() for { select { From edee1b5f96b4d57579a9d1cc1e80ae807e0a59f8 Mon Sep 17 00:00:00 2001 From: zhangkai Date: Sun, 13 Oct 2024 15:11:24 +0800 Subject: [PATCH 05/10] lint code --- config/default.go | 2 +- ethtxmanager/server_xlayer.go | 33 +++++++++++++++++------------ ethtxmanager/serverconfig_xlayer.go | 1 + 3 files changed, 21 insertions(+), 15 deletions(-) diff --git a/config/default.go b/config/default.go index 190c20e7d5..b065fbfa43 100644 --- a/config/default.go +++ b/config/default.go @@ -99,7 +99,7 @@ MaxGasPriceLimit = 0 OperateAmount = 0 RequestSignURI = "/priapi/v1/assetonchain/ecology/ecologyOperate" QuerySignURI = "/priapi/v1/assetonchain/ecology/querySignDataByOrderNo" - [HTTP] + [EthTxManager.HTTP] Enable = false Host = "0.0.0.0" Port = "7001" diff --git a/ethtxmanager/server_xlayer.go b/ethtxmanager/server_xlayer.go index 7514c06ed0..0cfeca7de3 100644 --- a/ethtxmanager/server_xlayer.go +++ b/ethtxmanager/server_xlayer.go @@ -1,12 +1,13 @@ package ethtxmanager import ( - "net/http" + "encoding/json" "fmt" "net" - "github.com/0xPolygonHermez/zkevm-node/log" + "net/http" "time" - "encoding/json" + + "github.com/0xPolygonHermez/zkevm-node/log" ) const ( @@ -14,6 +15,7 @@ const ( referOrderId = "referOrderId" ) +// Response is the response structure for the rpc server type Response struct { Code int `json:"code"` Data string `json:"data"` @@ -23,12 +25,14 @@ type Response struct { Message string `json:"message"` } -func (c *Client) startRPC() error { +func (c *Client) startRPC() { if c == nil || !c.cfg.HTTP.Enable { - return nil + log.Infof("rpc server is disabled") + return } if c.srv != nil { - return fmt.Errorf("server already started") + log.Errorf("server already started") + return } address := fmt.Sprintf("%s:%d", c.cfg.HTTP.Host, c.cfg.HTTP.Port) @@ -36,7 +40,7 @@ func (c *Client) startRPC() error { lis, err := net.Listen("tcp", address) if err != nil { log.Errorf("failed to create tcp listener: %v", err) - return err + return } mux := http.NewServeMux() @@ -52,28 +56,29 @@ func (c *Client) startRPC() error { if err = c.srv.Serve(lis); err != nil { if err == http.ErrServerClosed { log.Infof("http server stopped") - return nil + return } log.Errorf("closed http connection: %v", err) - return err + return } - return nil + return } -func (c *Client) stopRPC() error { +func (c *Client) stopRPC() { if c == nil || c.srv == nil { - return nil + return } if err := c.srv.Close(); err != nil { log.Errorf("failed to close http server: %v", err) - return err + return } - return nil + return } +// ServeHTTP handles the incoming HTTP requests func (c *Client) ServeHTTP(w http.ResponseWriter, r *http.Request) { if r.Method != http.MethodGet { var resp Response diff --git a/ethtxmanager/serverconfig_xlayer.go b/ethtxmanager/serverconfig_xlayer.go index 397bb7e4c1..7aa8371149 100644 --- a/ethtxmanager/serverconfig_xlayer.go +++ b/ethtxmanager/serverconfig_xlayer.go @@ -1,5 +1,6 @@ package ethtxmanager +// RPCConfig is the configuration for the rpc server type RPCConfig struct { // Enable is the flag to enable the rpc server Enable bool `mapstructure:"Enable"` From d15fa14dc26b75c53b7b5897da0d1d6830842e42 Mon Sep 17 00:00:00 2001 From: zhangkai Date: Sun, 13 Oct 2024 15:14:17 +0800 Subject: [PATCH 06/10] add docs --- docs/config-file/node-config-doc.html | 2 +- docs/config-file/node-config-doc.md | 54 ++++++++++++++++++++++++ docs/config-file/node-config-schema.json | 22 ++++++++++ 3 files changed, 77 insertions(+), 1 deletion(-) diff --git a/docs/config-file/node-config-doc.html b/docs/config-file/node-config-doc.html index e825ebd042..71f0f692cc 100644 --- a/docs/config-file/node-config-doc.html +++ b/docs/config-file/node-config-doc.html @@ -4,7 +4,7 @@ 
"300ms"
EthTxManager.PrivateKeys=
Type: array of object

PrivateKeys defines all the key store files that are going
to be read in order to provide the private keys to sign the L1 txs

Each item of this array must be:

EthTxManager.PrivateKeys.PrivateKeys items.Path=
Type: string

Path is the file path for the key store file
EthTxManager.PrivateKeys.PrivateKeys items.Password=
Type: string

Password is the password to decrypt the key store file
EthTxManager.ForcedGas=
Default: 0Type: integer

ForcedGas is the amount of gas to be forced in case of gas estimation error
EthTxManager.GasPriceMarginFactor=
Default: 1Type: number

GasPriceMarginFactor is used to multiply the suggested gas price provided by the network
in order to allow a different gas price to be set for all the transactions and making it
easier to have the txs prioritized in the pool, default value is 1.

ex:
suggested gas price: 100
GasPriceMarginFactor: 1
gas price = 100

suggested gas price: 100
GasPriceMarginFactor: 1.1
gas price = 110

EthTxManager.MaxGasPriceLimit=
Default: 0Type: integer

MaxGasPriceLimit helps avoiding transactions to be sent over an specified
gas price amount, default value is 0, which means no limit.
If the gas price provided by the network and adjusted by the GasPriceMarginFactor
is greater than this configuration, transaction will have its gas price set to
the value configured in this config as the limit.

ex:

suggested gas price: 100
gas price margin factor: 20%
max gas price limit: 150
tx gas price = 120

suggested gas price: 100
gas price margin factor: 20%
max gas price limit: 110
tx gas price = 110

CustodialAssets is the configuration for the custodial assets
EthTxManager.CustodialAssets.Enable=
Default: falseType: boolean

Enable is the flag to enable the custodial assets
EthTxManager.CustodialAssets.URL=
Default: "http://localhost:8080"Type: string

URL is the url to sign the custodial assets
EthTxManager.CustodialAssets.Symbol=
Default: 2882Type: integer

Symbol is the symbol of the network, 2 prd, 2882 devnet
EthTxManager.CustodialAssets.SequencerAddr=
Default: "0x1a13bddcc02d363366e04d4aa588d3c125b0ff6f"Type: array of integer

SequencerAddr is the address of the sequencer

Must contain a minimum of 20 items

Must contain a maximum of 20 items

Each item of this array must be:

EthTxManager.CustodialAssets.SequencerAddr.SequencerAddr items=
Type: integer
EthTxManager.CustodialAssets.AggregatorAddr=
Default: "0x66e39a1e507af777e8c385e2d91559e20e306303"Type: array of integer

AggregatorAddr is the address of the aggregator

Must contain a minimum of 20 items

Must contain a maximum of 20 items

Each item of this array must be:

EthTxManager.CustodialAssets.AggregatorAddr.AggregatorAddr items=
Type: integer
EthTxManager.CustodialAssets.WaitResultTimeout=
Default: "2m0s"Type: string

WaitResultTimeout is the timeout to wait for the result of the custodial assets
Examples:

"1m"
 
"300ms"
-
EthTxManager.CustodialAssets.OperateTypeSeq=
Default: 3Type: integer

OperateTypeSeq is the operate type of the custodial assets for the sequencer
EthTxManager.CustodialAssets.OperateTypeAgg=
Default: 4Type: integer

OperateTypeAgg is the operate type of the custodial assets for the aggregator
EthTxManager.CustodialAssets.ProjectSymbol=
Default: 3011Type: integer

ProjectSymbol is the project symbol of the custodial assets
EthTxManager.CustodialAssets.OperateSymbol=
Default: 2Type: integer

OperateSymbol is the operate symbol of the custodial assets
EthTxManager.CustodialAssets.SysFrom=
Default: 3Type: integer

SysFrom is the sys from of the custodial assets
EthTxManager.CustodialAssets.UserID=
Default: 0Type: integer

UserID is the user id of the custodial assets
EthTxManager.CustodialAssets.OperateAmount=
Default: 0Type: integer

OperateAmount is the operate amount of the custodial assets
EthTxManager.CustodialAssets.RequestSignURI=
Default: "/priapi/v1/assetonchain/ecology/ecologyOperate"Type: string

RequestSignURI is the request sign uri of the custodial assets
EthTxManager.CustodialAssets.QuerySignURI=
Default: "/priapi/v1/assetonchain/ecology/querySignDataByOrderNo"Type: string

QuerySignURI is the query sign uri of the custodial assets
EthTxManager.CustodialAssets.AccessKey=
Default: ""Type: string

AccessKey is the access key of the custodial assets
EthTxManager.CustodialAssets.SecretKey=
Default: ""Type: string

SecretKey is the secret key of the custodial assets

Pool service configuration
Pool.IntervalToRefreshBlockedAddresses=
Default: "5m0s"Type: string

IntervalToRefreshBlockedAddresses is the time it takes to sync the
blocked address list from db to memory
Examples:

"1m"
+
EthTxManager.CustodialAssets.OperateTypeSeq=
Default: 3Type: integer

OperateTypeSeq is the operate type of the custodial assets for the sequencer
EthTxManager.CustodialAssets.OperateTypeAgg=
Default: 4Type: integer

OperateTypeAgg is the operate type of the custodial assets for the aggregator
EthTxManager.CustodialAssets.ProjectSymbol=
Default: 3011Type: integer

ProjectSymbol is the project symbol of the custodial assets
EthTxManager.CustodialAssets.OperateSymbol=
Default: 2Type: integer

OperateSymbol is the operate symbol of the custodial assets
EthTxManager.CustodialAssets.SysFrom=
Default: 3Type: integer

SysFrom is the sys from of the custodial assets
EthTxManager.CustodialAssets.UserID=
Default: 0Type: integer

UserID is the user id of the custodial assets
EthTxManager.CustodialAssets.OperateAmount=
Default: 0Type: integer

OperateAmount is the operate amount of the custodial assets
EthTxManager.CustodialAssets.RequestSignURI=
Default: "/priapi/v1/assetonchain/ecology/ecologyOperate"Type: string

RequestSignURI is the request sign uri of the custodial assets
EthTxManager.CustodialAssets.QuerySignURI=
Default: "/priapi/v1/assetonchain/ecology/querySignDataByOrderNo"Type: string

QuerySignURI is the query sign uri of the custodial assets
EthTxManager.CustodialAssets.AccessKey=
Default: ""Type: string

AccessKey is the access key of the custodial assets
EthTxManager.CustodialAssets.SecretKey=
Default: ""Type: string

SecretKey is the secret key of the custodial assets

HTTP is the configuration for the rpc server
EthTxManager.HTTP.Enable=
Default: falseType: boolean

Enable is the flag to enable the rpc server
EthTxManager.HTTP.Host=
Default: "0.0.0.0"Type: string

Host is the host of the rpc server
EthTxManager.HTTP.Port=
Default: 7001Type: integer

RPCPort is the port of the rpc server

Pool service configuration
Pool.IntervalToRefreshBlockedAddresses=
Default: "5m0s"Type: string

IntervalToRefreshBlockedAddresses is the time it takes to sync the
blocked address list from db to memory
Examples:

"1m"
 
"300ms"
Pool.IntervalToRefreshWhiteAddresses=
Default: "1m0s"Type: string

IntervalToRefreshWhiteAddresses is the time it takes to sync the
white address list from db to memory
Examples:

"1m"
 
"300ms"
diff --git a/docs/config-file/node-config-doc.md b/docs/config-file/node-config-doc.md
index cf6cba6a3a..c06c912d1b 100644
--- a/docs/config-file/node-config-doc.md
+++ b/docs/config-file/node-config-doc.md
@@ -250,6 +250,7 @@ Url=""
 | - [GasPriceMarginFactor](#EthTxManager_GasPriceMarginFactor )   | No      | number          | No         | -          | GasPriceMarginFactor is used to multiply the suggested gas price provided by the network
in order to allow a different gas price to be set for all the transactions and making it
easier to have the txs prioritized in the pool, default value is 1.

ex:
suggested gas price: 100
GasPriceMarginFactor: 1
gas price = 100

suggested gas price: 100
GasPriceMarginFactor: 1.1
gas price = 110                                                                                                                                                                                              |
 | - [MaxGasPriceLimit](#EthTxManager_MaxGasPriceLimit )           | No      | integer         | No         | -          | MaxGasPriceLimit helps avoiding transactions to be sent over an specified
gas price amount, default value is 0, which means no limit.
If the gas price provided by the network and adjusted by the GasPriceMarginFactor
is greater than this configuration, transaction will have its gas price set to
the value configured in this config as the limit.

ex:

suggested gas price: 100
gas price margin factor: 20%
max gas price limit: 150
tx gas price = 120

suggested gas price: 100
gas price margin factor: 20%
max gas price limit: 110
tx gas price = 110 |
 | - [CustodialAssets](#EthTxManager_CustodialAssets )             | No      | object          | No         | -          | CustodialAssets is the configuration for the custodial assets                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                       |
+| - [HTTP](#EthTxManager_HTTP )                                   | No      | object          | No         | -          | HTTP is the configuration for the rpc server                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                        |
 
 ### 6.1. `EthTxManager.FrequencyToMonitorTxs`
 
@@ -685,6 +686,59 @@ AccessKey=""
 SecretKey=""
 ```
 
+### 6.8. `[EthTxManager.HTTP]`
+
+**Type:** : `object`
+**Description:** HTTP is the configuration for the rpc server
+
+| Property                               | Pattern | Type    | Deprecated | Definition | Title/Description                           |
+| -------------------------------------- | ------- | ------- | ---------- | ---------- | ------------------------------------------- |
+| - [Enable](#EthTxManager_HTTP_Enable ) | No      | boolean | No         | -          | Enable is the flag to enable the rpc server |
+| - [Host](#EthTxManager_HTTP_Host )     | No      | string  | No         | -          | Host is the host of the rpc server          |
+| - [Port](#EthTxManager_HTTP_Port )     | No      | integer | No         | -          | RPCPort is the port of the rpc server       |
+
+#### 6.8.1. `EthTxManager.HTTP.Enable`
+
+**Type:** : `boolean`
+
+**Default:** `false`
+
+**Description:** Enable is the flag to enable the rpc server
+
+**Example setting the default value** (false):
+```
+[EthTxManager.HTTP]
+Enable=false
+```
+
+#### 6.8.2. `EthTxManager.HTTP.Host`
+
+**Type:** : `string`
+
+**Default:** `"0.0.0.0"`
+
+**Description:** Host is the host of the rpc server
+
+**Example setting the default value** ("0.0.0.0"):
+```
+[EthTxManager.HTTP]
+Host="0.0.0.0"
+```
+
+#### 6.8.3. `EthTxManager.HTTP.Port`
+
+**Type:** : `integer`
+
+**Default:** `7001`
+
+**Description:** RPCPort is the port of the rpc server
+
+**Example setting the default value** (7001):
+```
+[EthTxManager.HTTP]
+Port=7001
+```
+
 ## 7. `[Pool]`
 
 **Type:** : `object`
diff --git a/docs/config-file/node-config-schema.json b/docs/config-file/node-config-schema.json
index 052ef87908..b040c16528 100644
--- a/docs/config-file/node-config-schema.json
+++ b/docs/config-file/node-config-schema.json
@@ -258,6 +258,28 @@
 					"additionalProperties": false,
 					"type": "object",
 					"description": "CustodialAssets is the configuration for the custodial assets"
+				},
+				"HTTP": {
+					"properties": {
+						"Enable": {
+							"type": "boolean",
+							"description": "Enable is the flag to enable the rpc server",
+							"default": false
+						},
+						"Host": {
+							"type": "string",
+							"description": "Host is the host of the rpc server",
+							"default": "0.0.0.0"
+						},
+						"Port": {
+							"type": "integer",
+							"description": "RPCPort is the port of the rpc server",
+							"default": 7001
+						}
+					},
+					"additionalProperties": false,
+					"type": "object",
+					"description": "HTTP is the configuration for the rpc server"
 				}
 			},
 			"additionalProperties": false,

From 58b5647a4a62e8df6f34fd72593d6479b2b44b94 Mon Sep 17 00:00:00 2001
From: zhangkai 
Date: Sun, 13 Oct 2024 15:15:56 +0800
Subject: [PATCH 07/10] lint code

---
 ethtxmanager/server_xlayer.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/ethtxmanager/server_xlayer.go b/ethtxmanager/server_xlayer.go
index 0cfeca7de3..ee0e05d66f 100644
--- a/ethtxmanager/server_xlayer.go
+++ b/ethtxmanager/server_xlayer.go
@@ -59,10 +59,7 @@ func (c *Client) startRPC() {
 			return
 		}
 		log.Errorf("closed http connection: %v", err)
-		return
 	}
-
-	return
 }
 
 func (c *Client) stopRPC() {
@@ -112,5 +109,8 @@ func (c *Client) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	var resp Response
 	resp.Data = data
 	respBytes, _ := json.Marshal(resp)
-	w.Write(respBytes)
+	_, err := w.Write(respBytes)
+	if err != nil {
+		log.Errorf("failed to write response: %v", err)
+	}
 }

From b050f2ba91833c64b7c78dd913d92df4e6067e98 Mon Sep 17 00:00:00 2001
From: zhangkai 
Date: Sun, 13 Oct 2024 15:25:46 +0800
Subject: [PATCH 08/10] format return

---
 ethtxmanager/server_xlayer.go | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/ethtxmanager/server_xlayer.go b/ethtxmanager/server_xlayer.go
index ee0e05d66f..913bd78e67 100644
--- a/ethtxmanager/server_xlayer.go
+++ b/ethtxmanager/server_xlayer.go
@@ -69,10 +69,7 @@ func (c *Client) stopRPC() {
 
 	if err := c.srv.Close(); err != nil {
 		log.Errorf("failed to close http server: %v", err)
-		return
 	}
-
-	return
 }
 
 // ServeHTTP handles the incoming HTTP requests

From b5a8ed123cadbc63797260a008837699f4535d1d Mon Sep 17 00:00:00 2001
From: zhangkai 
Date: Sun, 13 Oct 2024 15:30:10 +0800
Subject: [PATCH 09/10] format import

---
 ethtxmanager/ethtxmanager.go | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/ethtxmanager/ethtxmanager.go b/ethtxmanager/ethtxmanager.go
index 5dc54530ba..9a69cec01c 100644
--- a/ethtxmanager/ethtxmanager.go
+++ b/ethtxmanager/ethtxmanager.go
@@ -9,16 +9,17 @@ import (
 	"errors"
 	"fmt"
 	"math/big"
+	"net/http"
 	"sync"
 	"time"
 
-	"github.com/0xPolygonHermez/zkevm-node/ethtxmanager/metrics"
-	"github.com/0xPolygonHermez/zkevm-node/log"
 	"github.com/ethereum/go-ethereum"
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/core/types"
 	"github.com/jackc/pgx/v4"
-	"net/http"
+
+	"github.com/0xPolygonHermez/zkevm-node/ethtxmanager/metrics"
+	"github.com/0xPolygonHermez/zkevm-node/log"
 )
 
 const (

From b7341b418bc70132a646680009a30973c3bb0ebb Mon Sep 17 00:00:00 2001
From: zhangkai 
Date: Sun, 13 Oct 2024 15:43:56 +0800
Subject: [PATCH 10/10] format imports

---
 ethtxmanager/ethtxmanager.go | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/ethtxmanager/ethtxmanager.go b/ethtxmanager/ethtxmanager.go
index 9a69cec01c..2d7b9da95e 100644
--- a/ethtxmanager/ethtxmanager.go
+++ b/ethtxmanager/ethtxmanager.go
@@ -13,13 +13,12 @@ import (
 	"sync"
 	"time"
 
+	"github.com/0xPolygonHermez/zkevm-node/ethtxmanager/metrics"
+	"github.com/0xPolygonHermez/zkevm-node/log"
 	"github.com/ethereum/go-ethereum"
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/core/types"
 	"github.com/jackc/pgx/v4"
-
-	"github.com/0xPolygonHermez/zkevm-node/ethtxmanager/metrics"
-	"github.com/0xPolygonHermez/zkevm-node/log"
 )
 
 const (