From f9ea0fbb5a009c33c656b7e5570d1aa0f2a06a62 Mon Sep 17 00:00:00 2001
From: rcourtman <courtmanr@gmail.com>
Date: Fri, 2 Jan 2026 14:01:32 +0000
Subject: [PATCH] fix(pro): add error tracking to patrol history store

- Add lastSaveError, lastSaveTime, onSaveError fields to PatrolRunHistoryStore
- Add GetPersistenceStatus() and SetOnSaveError() methods
- Consistent with findings store and cost store error handling
---
 internal/ai/patrol_history_persistence.go | 30 +++++++++++++++++++++++
 1 file changed, 30 insertions(+)

diff --git a/internal/ai/patrol_history_persistence.go b/internal/ai/patrol_history_persistence.go
index 359b4ec2a..f00304126 100644
--- a/internal/ai/patrol_history_persistence.go
+++ b/internal/ai/patrol_history_persistence.go
@@ -110,6 +110,11 @@ type PatrolRunHistoryStore struct {
 	saveTimer    *time.Timer
 	savePending  bool
 	saveDebounce time.Duration
+
+	// Error tracking for persistence
+	lastSaveError error
+	lastSaveTime  time.Time
+	onSaveError   func(err error)
 }
 
 // NewPatrolRunHistoryStore creates a new patrol run history store
@@ -228,11 +233,36 @@ func (s *PatrolRunHistoryStore) scheduleSaveLocked() {
 		if persistence != nil {
 			if err := persistence.SavePatrolRunHistory(runs); err != nil {
 				log.Error().Err(err).Msg("Failed to save patrol run history")
+				s.mu.Lock()
+				s.lastSaveError = err
+				s.mu.Unlock()
+				if onErr := s.onSaveError; onErr != nil {
+					onErr(err)
+				}
+			} else {
+				s.mu.Lock()
+				s.lastSaveError = nil
+				s.lastSaveTime = time.Now()
+				s.mu.Unlock()
 			}
 		}
 	})
 }
 
+// SetOnSaveError sets a callback that is called when persistence fails.
+func (s *PatrolRunHistoryStore) SetOnSaveError(fn func(err error)) {
+	s.mu.Lock()
+	defer s.mu.Unlock()
+	s.onSaveError = fn
+}
+
+// GetPersistenceStatus returns the last save error, last save time, and whether persistence is configured.
+func (s *PatrolRunHistoryStore) GetPersistenceStatus() (lastError error, lastSaveTime time.Time, hasPersistence bool) {
+	s.mu.RLock()
+	defer s.mu.RUnlock()
+	return s.lastSaveError, s.lastSaveTime, s.persistence != nil
+}
+
 // FlushPersistence immediately saves any pending changes
 func (s *PatrolRunHistoryStore) FlushPersistence() error {
 	s.mu.Lock()