120 lines
3.7 KiB
Go
120 lines
3.7 KiB
Go
package network
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/nspcc-dev/neo-go/pkg/config"
|
|
"github.com/nspcc-dev/neo-go/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
|
|
|
|
// Address. Example: "127.0.0.1".
|
|
Address string
|
|
|
|
// AnnouncedPort is an announced node port for P2P version exchange.
|
|
AnnouncedPort uint16
|
|
|
|
// Port is the actual node port it is bound to. Example: 20332.
|
|
Port uint16
|
|
|
|
// 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
|
|
|
|
// 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
|
|
|
|
// Wallet is a wallet configuration.
|
|
Wallet *config.Wallet
|
|
|
|
// TimePerBlock is an interval which should pass between two successive blocks.
|
|
TimePerBlock time.Duration
|
|
|
|
// 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
|
|
}
|
|
)
|
|
|
|
// NewServerConfig creates a new ServerConfig struct
|
|
// using the main applications config.
|
|
func NewServerConfig(cfg config.Config) ServerConfig {
|
|
appConfig := cfg.ApplicationConfiguration
|
|
protoConfig := cfg.ProtocolConfiguration
|
|
|
|
var wc *config.Wallet
|
|
if appConfig.UnlockWallet.Path != "" {
|
|
wc = &appConfig.UnlockWallet
|
|
}
|
|
|
|
return ServerConfig{
|
|
UserAgent: cfg.GenerateUserAgent(),
|
|
Address: appConfig.Address,
|
|
AnnouncedPort: appConfig.AnnouncedNodePort,
|
|
Port: appConfig.NodePort,
|
|
Net: protoConfig.Magic,
|
|
Relay: appConfig.Relay,
|
|
Seeds: protoConfig.SeedList,
|
|
DialTimeout: time.Duration(appConfig.DialTimeout) * time.Second,
|
|
ProtoTickInterval: time.Duration(appConfig.ProtoTickInterval) * time.Second,
|
|
PingInterval: time.Duration(appConfig.PingInterval) * time.Second,
|
|
PingTimeout: time.Duration(appConfig.PingTimeout) * time.Second,
|
|
MaxPeers: appConfig.MaxPeers,
|
|
AttemptConnPeers: appConfig.AttemptConnPeers,
|
|
MinPeers: appConfig.MinPeers,
|
|
Wallet: wc,
|
|
TimePerBlock: time.Duration(protoConfig.SecondsPerBlock) * time.Second,
|
|
OracleCfg: appConfig.Oracle,
|
|
P2PNotaryCfg: appConfig.P2PNotary,
|
|
StateRootCfg: appConfig.StateRoot,
|
|
ExtensiblePoolSize: appConfig.ExtensiblePoolSize,
|
|
}
|
|
}
|