129 lines
4.2 KiB
Go
Executable File
129 lines
4.2 KiB
Go
Executable File
package network
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"git.marketally.com/tutus-one/tutus-chain/pkg/config"
|
|
"git.marketally.com/tutus-one/tutus-chain/pkg/config/netmode"
|
|
"go.uber.org/zap/zapcore"
|
|
)
|
|
|
|
type (
|
|
// ServerConfig holds the server configuration.
|
|
ServerConfig struct {
|
|
// MinPeers is the minimum number of peers for normal operation.
|
|
// When a node has less than this number of peers, it tries to
|
|
// connect with some new ones.
|
|
MinPeers int
|
|
|
|
// AttemptConnPeers is the number of connection to try to
|
|
// establish when the connection count drops below the MinPeers
|
|
// value.
|
|
AttemptConnPeers int
|
|
|
|
// MaxPeers is the maximum number of peers that can
|
|
// be connected to the server.
|
|
MaxPeers int
|
|
|
|
// The user agent of the server.
|
|
UserAgent string
|
|
|
|
// Addresses stores the list of bind addresses for the node.
|
|
Addresses []config.AnnounceableAddress
|
|
|
|
// The network mode the server will operate on.
|
|
// ModePrivNet docker private network.
|
|
// ModeTestNet Neo test network.
|
|
// ModeMainNet Neo main network.
|
|
Net netmode.Magic
|
|
|
|
// Relay determines whether the server is forwarding its inventory.
|
|
Relay bool
|
|
|
|
// ArchivalNodesSync determines whether the server is asking for old
|
|
// blocks from archival nodes only (if syncing via P2P).
|
|
ArchivalNodesSync bool
|
|
|
|
// DisableCompression determines whether the server should disable P2P
|
|
// payloads compression.
|
|
DisableCompression bool
|
|
|
|
// Seeds is a list of initial nodes used to establish connectivity.
|
|
Seeds []string
|
|
|
|
// Maximum duration a single dial may take.
|
|
DialTimeout time.Duration
|
|
|
|
// The duration between protocol ticks with each connected peer.
|
|
// When this is 0, the default interval of 5 seconds will be used.
|
|
ProtoTickInterval time.Duration
|
|
|
|
// Interval used in pinging mechanism for syncing blocks.
|
|
PingInterval time.Duration
|
|
// Time to wait for pong(response for sent ping request).
|
|
PingTimeout time.Duration
|
|
|
|
// Level of the internal logger.
|
|
LogLevel zapcore.Level
|
|
|
|
// OracleCfg is oracle module configuration.
|
|
OracleCfg config.OracleConfiguration
|
|
|
|
// P2PNotaryCfg is notary module configuration.
|
|
P2PNotaryCfg config.P2PNotary
|
|
|
|
// StateRootCfg is stateroot module configuration.
|
|
StateRootCfg config.StateRoot
|
|
|
|
// ExtensiblePoolSize is the size of the pool for extensible payloads from a single sender.
|
|
ExtensiblePoolSize int
|
|
|
|
// BroadcastFactor is the factor (0-100) for fan-out optimization.
|
|
BroadcastFactor int
|
|
// BroadcastTxsBatchDelay is a time for txs batch collection before
|
|
// broadcasting them.
|
|
BroadcastTxsBatchDelay time.Duration
|
|
|
|
NeoFSBlockFetcherCfg config.NeoFSBlockFetcher
|
|
// NeoFSStateFetcherCfg is the statefetcher module configuration.
|
|
NeoFSStateFetcherCfg config.NeoFSStateFetcher
|
|
}
|
|
)
|
|
|
|
// NewServerConfig creates a new ServerConfig struct
|
|
// using the main applications config.
|
|
func NewServerConfig(cfg config.Config) (ServerConfig, error) {
|
|
appConfig := cfg.ApplicationConfiguration
|
|
protoConfig := cfg.ProtocolConfiguration
|
|
addrs, err := appConfig.GetAddresses()
|
|
if err != nil {
|
|
return ServerConfig{}, fmt.Errorf("failed to parse addresses: %w", err)
|
|
}
|
|
c := ServerConfig{
|
|
UserAgent: cfg.GenerateUserAgent(),
|
|
Addresses: addrs,
|
|
Net: protoConfig.Magic,
|
|
Relay: appConfig.Relay,
|
|
ArchivalNodesSync: appConfig.ArchivalNodesSync,
|
|
DisableCompression: appConfig.P2P.DisableCompression,
|
|
Seeds: protoConfig.SeedList,
|
|
DialTimeout: appConfig.P2P.DialTimeout,
|
|
ProtoTickInterval: appConfig.P2P.ProtoTickInterval,
|
|
PingInterval: appConfig.P2P.PingInterval,
|
|
PingTimeout: appConfig.P2P.PingTimeout,
|
|
MaxPeers: appConfig.P2P.MaxPeers,
|
|
AttemptConnPeers: appConfig.P2P.AttemptConnPeers,
|
|
MinPeers: appConfig.P2P.MinPeers,
|
|
OracleCfg: appConfig.Oracle,
|
|
P2PNotaryCfg: appConfig.P2PNotary,
|
|
StateRootCfg: appConfig.StateRoot,
|
|
ExtensiblePoolSize: appConfig.P2P.ExtensiblePoolSize,
|
|
BroadcastFactor: appConfig.P2P.BroadcastFactor,
|
|
BroadcastTxsBatchDelay: appConfig.P2P.BroadcastTxsBatchDelay,
|
|
NeoFSBlockFetcherCfg: appConfig.NeoFSBlockFetcher,
|
|
NeoFSStateFetcherCfg: appConfig.NeoFSStateFetcher,
|
|
}
|
|
return c, nil
|
|
}
|