From 8643c8f990850ff8a4071546ccdd3a38a8612bed Mon Sep 17 00:00:00 2001
From: ila <2+ila@noreply.git.ilapage.cn>
Date: Thu, 13 Aug 2026 22:05:28 +0800
Subject: [PATCH] fix: restore desired media paths on startup (#54)

---
 Sense/server/app/sense/media/service.go | 35 ++++++++++++++++++++++++-
 1 file changed, 34 insertions(+), 1 deletion(-)

diff --git a/Sense/server/app/sense/media/service.go b/Sense/server/app/sense/media/service.go
index 839fa03..89bd57e 100644
--- a/Sense/server/app/sense/media/service.go
+++ b/Sense/server/app/sense/media/service.go
@@ -24,6 +24,32 @@ func NewService(store Store, process mediamtx.Process, controller mediamtx.Contr
 	return &Service{store: store, process: process, controller: controller, profile: admission.VerifiedProfile, credential: device.ReadRTSPCredential, now: time.Now}
 }
 
+// Restore recreates desired routes after MediaMTX starts with its base config.
+// Individual route failures are persisted as safe business states and do not
+// prevent the Sense management plane from starting.
+func (s *Service) Restore(ctx context.Context) error {
+	items, err := s.store.List(ctx)
+	if err != nil {
+		return err
+	}
+	for _, route := range items {
+		if route.Desired != "running" {
+			continue
+		}
+		if _, reconcileErr := s.Reconcile(ctx, identity.Principal{}, route.ID); reconcileErr != nil {
+			route.Actual = "apply_failed"
+			route.Detail = "媒体路径恢复失败，请检查视频服务"
+			route.Readers = 0
+			route.Version++
+			route.UpdatedAt = s.now().UTC()
+			if saveErr := s.store.Save(ctx, route); saveErr != nil {
+				return saveErr
+			}
+		}
+	}
+	return nil
+}
+
 func (s *Service) ConfigureProfiles(ctx context.Context, actor identity.Principal, result admission.Result) admission.MediaOutcome {
 	configured := 0
 	ready := 0
@@ -108,6 +134,10 @@ func (s *Service) Reconcile(ctx context.Context, actor identity.Principal, id st
 	if err != nil {
 		route.Actual = "unconverged"
 		route.Detail = "尚未取得媒体状态"
+	} else if !status.Exists {
+		route.Actual = "apply_failed"
+		route.Detail = "媒体路径不存在，请重新对账"
+		route.Readers = 0
 	} else if status.Ready {
 		route.Actual = "ready"
 		route.Detail = "上游拉流正常"
@@ -142,7 +172,10 @@ func (s *Service) Refresh(ctx context.Context, id string) (Route, error) {
 	}
 	actual := "waiting"
 	detail := "等待播放器连接并按需拉流"
-	if status.Ready {
+	if !status.Exists {
+		actual = "apply_failed"
+		detail = "媒体路径不存在，请重新对账"
+	} else if status.Ready {
 		actual = "ready"
 		detail = "上游拉流正常"
 	}