From 2be97d719063b5ac10a29380a74641972113a5b0 Mon Sep 17 00:00:00 2001
From: Chris Lu <chris.lu@gmail.com>
Date: Tue, 17 Feb 2026 02:06:13 -0800
Subject: [PATCH] feat(plugin): Add history management to plugin manager

---
 weed/admin/plugin/manager.go | 76 ++++++++++++++++++++++++++++++++++++
 1 file changed, 76 insertions(+)

diff --git a/weed/admin/plugin/manager.go b/weed/admin/plugin/manager.go
index 7095a8a1a..d308be1ae 100644
--- a/weed/admin/plugin/manager.go
+++ b/weed/admin/plugin/manager.go
@@ -420,3 +420,79 @@ func (m *Manager) GetDispatcher() *Dispatcher {
 func (m *Manager) GetGRPCServer() *GRPCServer {
 	return m.grpcServer
 }
+
+// GetDetectionHistory returns detection history for a job type
+func (m *Manager) GetDetectionHistory(jobType string) []DetectionRecord {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
+
+	configs := m.configMgr.ListConfigs()
+	for _, cfg := range configs {
+		if jobCfg, ok := cfg.GetJobTypeConfig(jobType); ok {
+			cfg.mu.RLock()
+			defer cfg.mu.RUnlock()
+			history := make([]DetectionRecord, len(jobCfg.DetectionHistory))
+			copy(history, jobCfg.DetectionHistory)
+			return history
+		}
+	}
+	return []DetectionRecord{}
+}
+
+// GetExecutionHistory returns execution history for a job type
+func (m *Manager) GetExecutionHistory(jobType string) []ExecutionRecord {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
+
+	configs := m.configMgr.ListConfigs()
+	for _, cfg := range configs {
+		if jobCfg, ok := cfg.GetJobTypeConfig(jobType); ok {
+			cfg.mu.RLock()
+			defer cfg.mu.RUnlock()
+			history := make([]ExecutionRecord, len(jobCfg.ExecutionHistory))
+			copy(history, jobCfg.ExecutionHistory)
+			return history
+		}
+	}
+	return []ExecutionRecord{}
+}
+
+// RecordDetection adds a detection record to history
+func (m *Manager) RecordDetection(jobType string, record *DetectionRecord) {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
+
+	configs := m.configMgr.ListConfigs()
+	for _, cfg := range configs {
+		if jobCfg, ok := cfg.GetJobTypeConfig(jobType); ok {
+			cfg.mu.Lock()
+			maxSize := 50
+			jobCfg.DetectionHistory = append([]DetectionRecord{*record}, jobCfg.DetectionHistory...)
+			if len(jobCfg.DetectionHistory) > maxSize {
+				jobCfg.DetectionHistory = jobCfg.DetectionHistory[:maxSize]
+			}
+			cfg.mu.Unlock()
+			break
+		}
+	}
+}
+
+// RecordExecution adds an execution record to history
+func (m *Manager) RecordExecution(jobType string, record *ExecutionRecord) {
+	m.mu.RLock()
+	defer m.mu.RUnlock()
+
+	configs := m.configMgr.ListConfigs()
+	for _, cfg := range configs {
+		if jobCfg, ok := cfg.GetJobTypeConfig(jobType); ok {
+			cfg.mu.Lock()
+			maxSize := 100
+			jobCfg.ExecutionHistory = append([]ExecutionRecord{*record}, jobCfg.ExecutionHistory...)
+			if len(jobCfg.ExecutionHistory) > maxSize {
+				jobCfg.ExecutionHistory = jobCfg.ExecutionHistory[:maxSize]
+			}
+			cfg.mu.Unlock()
+			break
+		}
+	}
+}