From c144376e6cf2d7f5f842e5302d48f9402e53eaff Mon Sep 17 00:00:00 2001
From: Warren Lo <warren@accusys.com.tw>
Date: Thu, 19 Mar 2026 00:32:26 +0800
Subject: [PATCH] Add progress.rs for monitoring

---
 src/api/progress.rs | 75 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 75 insertions(+)
 create mode 100644 src/api/progress.rs

diff --git a/src/api/progress.rs b/src/api/progress.rs
new file mode 100644
index 0000000..507ff16
--- /dev/null
+++ b/src/api/progress.rs
@@ -0,0 +1,75 @@
+//! 處理進度監控
+
+use anyhow::Result;
+use serde::{Deserialize, Serialize};
+
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct ProcessorProgress {
+    pub name: String,
+    pub status: ProcessorStatus,
+    pub progress: f32,
+    pub message: Option<String>,
+}
+
+#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
+#[serde(rename_all = "lowercase")]
+pub enum ProcessorStatus {
+    Pending,
+    Running,
+    Complete,
+    Error,
+}
+
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct VideoProgress {
+    pub uuid: String,
+    pub processors: Vec<ProcessorProgress>,
+}
+
+impl VideoProgress {
+    pub fn new(uuid: &str) -> Self {
+        Self {
+            uuid: uuid.to_string(),
+            processors: Vec::new(),
+        }
+    }
+
+    pub fn update_processor(&mut self, name: &str, status: ProcessorStatus, progress: f32) {
+        if let Some(p) = self.processors.iter_mut().find(|p| p.name == name) {
+            p.status = status;
+            p.progress = progress;
+        } else {
+            self.processors.push(ProcessorProgress {
+                name: name.to_string(),
+                status,
+                progress,
+                message: None,
+            });
+        }
+    }
+
+    pub fn get_overall_progress(&self) -> f32 {
+        if self.processors.is_empty() {
+            return 0.0;
+        }
+        let total: f32 = self.processors.iter().map(|p| p.progress).sum();
+        total / self.processors.len() as f32
+    }
+
+    pub fn is_complete(&self) -> bool {
+        self.processors.iter().all(|p| p.status == ProcessorStatus::Complete)
+    }
+}
+
+pub fn get_known_processors() -> Vec<&'static str> {
+    vec![
+        "asr",
+        "asrx",
+        "yolo",
+        "ocr",
+        "face",
+        "pose",
+        "cut",
+        "trace",
+    ]
+}