Update predictive-maintenance/mapper/pkg/inference/detector.go

Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>

Author: darshankerkar

predictive-maintenance/mapper/pkg/inference/detector.go

@@ -70,15 +70,8 @@ func (d *Detector) Analyze(reading driver.SensorReading) AnomalyResult {
 	d.mu.Lock()
 	defer d.mu.Unlock()
 
-	if len(d.window) >= d.windowSize {
-		copy(d.window, d.window[1:])
-		d.window[d.windowSize-1] = reading
-	} else {
-		d.window = append(d.window, reading)
-	}
-
-	// need 5+ readings to start
 	if len(d.window) < 5 {
+		d.window = append(d.window, reading)
 		return AnomalyResult{}
 	}
 
@@ -89,6 +82,14 @@ func (d *Detector) Analyze(reading driver.SensorReading) AnomalyResult {
 	tempZ := zScore(reading.Temperature, tempMean, tempStd)
 	maxZ := math.Max(math.Abs(vibZ), math.Abs(tempZ))
 
+	// Update window after analysis to avoid masking effect
+	if len(d.window) >= d.windowSize {
+		copy(d.window, d.window[1:])
+		d.window[d.windowSize-1] = reading
+	} else {
+		d.window = append(d.window, reading)
+	}
+
 	isAnomaly := maxZ > d.zScoreThreshold
 	confidence := math.Min(1.0, maxZ/d.zScoreThreshold/2)