ax(mining): rename cfg to minersConfiguration in manager.go (AX Principle 1)
Co-Authored-By: Charon <charon@lethean.io>
This commit is contained in:
parent
31ef201ff4
commit
daf3c2fff9
1 changed files with 9 additions and 9 deletions
|
|
@ -91,14 +91,14 @@ func NewManagerForSimulation() *Manager {
|
|||
|
||||
// initDatabase initializes the SQLite database based on config.
|
||||
func (m *Manager) initDatabase() {
|
||||
cfg, err := LoadMinersConfig()
|
||||
minersConfiguration, err := LoadMinersConfig()
|
||||
if err != nil {
|
||||
logging.Warn("could not load config for database init", logging.Fields{"error": err})
|
||||
return
|
||||
}
|
||||
|
||||
m.databaseEnabled = cfg.Database.Enabled
|
||||
m.databaseRetention = cfg.Database.RetentionDays
|
||||
m.databaseEnabled = minersConfiguration.Database.Enabled
|
||||
m.databaseRetention = minersConfiguration.Database.RetentionDays
|
||||
if m.databaseRetention == 0 {
|
||||
m.databaseRetention = 30
|
||||
}
|
||||
|
|
@ -159,7 +159,7 @@ func (m *Manager) startDBCleanup() {
|
|||
|
||||
// syncMinersConfig ensures the miners.json config file has entries for all available miners.
|
||||
func (m *Manager) syncMinersConfig() {
|
||||
cfg, err := LoadMinersConfig()
|
||||
minersConfiguration, err := LoadMinersConfig()
|
||||
if err != nil {
|
||||
logging.Warn("could not load miners config for sync", logging.Fields{"error": err})
|
||||
return
|
||||
|
|
@ -170,14 +170,14 @@ func (m *Manager) syncMinersConfig() {
|
|||
|
||||
for _, availableMiner := range availableMiners {
|
||||
found := false
|
||||
for _, configuredMiner := range cfg.Miners {
|
||||
for _, configuredMiner := range minersConfiguration.Miners {
|
||||
if strings.EqualFold(configuredMiner.MinerType, availableMiner.Name) {
|
||||
found = true
|
||||
break
|
||||
}
|
||||
}
|
||||
if !found {
|
||||
cfg.Miners = append(cfg.Miners, MinerAutostartConfig{
|
||||
minersConfiguration.Miners = append(minersConfiguration.Miners, MinerAutostartConfig{
|
||||
MinerType: availableMiner.Name,
|
||||
Autostart: false,
|
||||
Config: nil, // No default config
|
||||
|
|
@ -188,7 +188,7 @@ func (m *Manager) syncMinersConfig() {
|
|||
}
|
||||
|
||||
if configUpdated {
|
||||
if err := SaveMinersConfig(cfg); err != nil {
|
||||
if err := SaveMinersConfig(minersConfiguration); err != nil {
|
||||
logging.Warn("failed to save updated miners config", logging.Fields{"error": err})
|
||||
}
|
||||
}
|
||||
|
|
@ -196,13 +196,13 @@ func (m *Manager) syncMinersConfig() {
|
|||
|
||||
// autostartMiners loads the miners config and starts any miners marked for autostart.
|
||||
func (m *Manager) autostartMiners() {
|
||||
cfg, err := LoadMinersConfig()
|
||||
minersConfiguration, err := LoadMinersConfig()
|
||||
if err != nil {
|
||||
logging.Warn("could not load miners config for autostart", logging.Fields{"error": err})
|
||||
return
|
||||
}
|
||||
|
||||
for _, autostartEntry := range cfg.Miners {
|
||||
for _, autostartEntry := range minersConfiguration.Miners {
|
||||
if autostartEntry.Autostart && autostartEntry.Config != nil {
|
||||
logging.Info("autostarting miner", logging.Fields{"type": autostartEntry.MinerType})
|
||||
if _, err := m.StartMiner(context.Background(), autostartEntry.MinerType, autostartEntry.Config); err != nil {
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue