fix: miners mode upgrade checks

Author: gmlexx

scheduler/config.go

@@ -40,8 +40,9 @@ type Config struct {
 	HealthCheckPort int `json:"health_check_port"` // Port for health check endpoint (0 = disabled)
 
 	// FanR thresholds for work mode switching
-	FanRHighThreshold int `json:"fanr_high_threshold"` // FanR threshold to decrease work mode
-	FanRLowThreshold  int `json:"fanr_low_threshold"`  // FanR threshold to increase work mode
+	FanRHighThreshold          int `json:"fanr_high_threshold"`           // FanR threshold to decrease work mode
+	FanRLowThreshold           int `json:"fanr_low_threshold"`            // FanR threshold to increase work mode
+	MinerWorkModeUpgradeChecks int `json:"miner_work_mode_upgrade_checks"` // Number of consecutive checks at current work mode required before upgrading
 
 	// Power consumption settings (in kilowatts)
 	MinersPowerLimit         float64 `json:"miners_power_limit"`           // Maximum total power limit for miners in kW
@@ -135,6 +136,7 @@ func DefaultConfig() *Config {
 		ImportPriceOperatorFee:           8.5,     // 8.5 EUR/MWh from Operator
 		ImportPriceDeliveryFee:           40.0,    // 40 EUR/MWh for delivery
 		ExportPriceOperatorFee:           17.0,    // 17 EUR/MWh from Operator
+		MinerWorkModeUpgradeChecks:       5,       // 5 consecutive checks required before upgrading work mode
 		MinersPowerLimit:                 30.0,    // 30 kW total power limit for miners
 		MinerPowerStandby:                0.05,    // 0.05 kW (50 W) in standby
 		MinerPowerEco:                    0.8,     // 0.8 kW (800 W) in eco mode
@@ -236,6 +238,10 @@ func (c *Config) Validate() error {
 		return fmt.Errorf("miner_max_consecutive_errors must be greater than 0, got: %d", c.MinerMaxConsecutiveErrors)
 	}
 
+	if c.MinerWorkModeUpgradeChecks <= 0 {
+		return fmt.Errorf("miner_work_mode_upgrade_checks must be greater than 0, got: %d", c.MinerWorkModeUpgradeChecks)
+	}
+
 	if c.APITimeout <= 0 {
 		return fmt.Errorf("api_timeout must be greater than 0, got: %s", c.APITimeout)
 	}

scheduler/miners.go

@@ -309,12 +309,14 @@ func (s *MinerScheduler) controlMiner(m *miners.AvalonQHost, totalPower float64,
 		}
 		return currentState, newWorkMode
 	} else if fanR < s.config.FanRLowThreshold && totalPower <= effectiveLimit {
-		// Increase work mode only if all LiteStatsHistory fanR values match criteria
-		if len(m.LiteStatsHistory) < 5 || currentWorkMode == miners.AvalonSuperMode {
+		// Increase work mode only if the last N consecutive checks all passed at the current work mode
+		requiredChecks := s.config.MinerWorkModeUpgradeChecks
+		if len(m.LiteStatsHistory) < requiredChecks || currentWorkMode == miners.AvalonSuperMode {
 			return currentState, currentWorkMode
 		}
-		for _, stat := range m.LiteStatsHistory {
-			if stat.FanR >= s.config.FanRLowThreshold {
+		recentHistory := m.LiteStatsHistory[len(m.LiteStatsHistory)-requiredChecks:]
+		for _, stat := range recentHistory {
+			if stat.FanR >= s.config.FanRLowThreshold || stat.WorkMode != currentWorkMode {
 				return currentState, currentWorkMode
 			}
 		}

scheduler/miners_test.go

@@ -30,13 +30,14 @@ import (
 func newTestScheduler(cfg *Config) *MinerScheduler {
 	if cfg == nil {
 		cfg = &Config{
-			FanRHighThreshold:  80,
-			FanRLowThreshold:   50,
-			MinerPowerStandby:  0.1,
-			MinerPowerEco:      1.0,
-			MinerPowerStandard: 1.5,
-			MinerPowerSuper:    2.0,
-			MinersPowerLimit:   10.0,
+			FanRHighThreshold:          80,
+			FanRLowThreshold:           50,
+			MinerPowerStandby:          0.1,
+			MinerPowerEco:              1.0,
+			MinerPowerStandard:         1.5,
+			MinerPowerSuper:            2.0,
+			MinersPowerLimit:           10.0,
+			MinerWorkModeUpgradeChecks: 5,
 		}
 	}
 	return NewMinerScheduler(cfg, log.New(os.Stdout, "TEST: ", log.LstdFlags))
@@ -404,13 +405,14 @@ func TestControlMiner_DecreaseWhenNewPowerWouldStillExceedLimit(t *testing.T) {
 func TestControlMiner_CustomThresholds(t *testing.T) {
 	// Test with custom FanR thresholds
 	cfg := &Config{
-		FanRHighThreshold:  70,
-		FanRLowThreshold:   40,
-		MinerPowerStandby:  0.1,
-		MinerPowerEco:      1.0,
-		MinerPowerStandard: 1.5,
-		MinerPowerSuper:    2.0,
-		MinersPowerLimit:   10.0,
+		FanRHighThreshold:          70,
+		FanRLowThreshold:           40,
+		MinerPowerStandby:          0.1,
+		MinerPowerEco:              1.0,
+		MinerPowerStandard:         1.5,
+		MinerPowerSuper:            2.0,
+		MinersPowerLimit:           10.0,
+		MinerWorkModeUpgradeChecks: 5,
 	}
 	scheduler := newTestScheduler(cfg)
 
@@ -615,13 +617,14 @@ func TestValidate_MinerMaxConsecutiveErrors(t *testing.T) {
 
 func TestControlMiner_PowerCalculation(t *testing.T) {
 	cfg := &Config{
-		FanRHighThreshold:  80,
-		FanRLowThreshold:   50,
-		MinerPowerStandby:  0.2,
-		MinerPowerEco:      1.2,
-		MinerPowerStandard: 1.8,
-		MinerPowerSuper:    2.5,
-		MinersPowerLimit:   10.0,
+		FanRHighThreshold:          80,
+		FanRLowThreshold:           50,
+		MinerPowerStandby:          0.2,
+		MinerPowerEco:              1.2,
+		MinerPowerStandard:         1.8,
+		MinerPowerSuper:            2.5,
+		MinersPowerLimit:           10.0,
+		MinerWorkModeUpgradeChecks: 5,
 	}
 	scheduler := newTestScheduler(cfg)
 

web/src/components/ConfigMenu.tsx

@@ -165,6 +165,13 @@ const SECTIONS: Section[] = [
         unit: "%",
         hint: "Increase work mode below this FanR",
       },
+      {
+        key: "miner_work_mode_upgrade_checks",
+        label: "Work Mode Upgrade Checks",
+        type: "number",
+        min: 1,
+        hint: "Consecutive checks at current work mode required before upgrading",
+      },
       {
         key: "miners_power_limit",
         label: "Total Power Limit",

web/src/types/api.ts

@@ -16,6 +16,7 @@ export interface EmsConfig {
   health_check_port: number;
   fanr_high_threshold: number;
   fanr_low_threshold: number;
+  miner_work_mode_upgrade_checks: number;
   miners_power_limit: number;
   miner_power_standby: number;
   miner_power_eco: number;