test: cover media restore and missing paths (#54)

Sense/server/app/sense/media/service_test.go

@@ -53,8 +53,9 @@ func (f fakeController) Status(context.Context, string) (mediamtx.PathStatus, er
 		return mediamtx.PathStatus{}, errors.New("timeout")
 	}
 	if !f.status.Ready {
-		return mediamtx.PathStatus{Ready: true, Readers: 2}, nil
+		return mediamtx.PathStatus{Exists: true, Ready: true, Readers: 2}, nil
 	}
+	f.status.Exists = true
 	return f.status, nil
 }
 
@@ -155,7 +156,7 @@ func TestRefreshTracksOnDemandReaderWithoutReapplyingRoute(t *testing.T) {
 	if err := store.Save(context.Background(), route); err != nil {
 		t.Fatal(err)
 	}
-	service := NewService(store, &fakeProcess{}, refreshController{status: mediamtx.PathStatus{Name: route.Path, Ready: true, Readers: 1}})
+	service := NewService(store, &fakeProcess{}, refreshController{status: mediamtx.PathStatus{Name: route.Path, Exists: true, Ready: true, Readers: 1}})
 	result, err := service.Refresh(context.Background(), route.ID)
 	if err != nil || result.Actual != "ready" || result.Readers != 1 || result.Detail != "上游拉流正常" {
 		t.Fatalf("result=%#v err=%v", result, err)
@@ -166,5 +167,30 @@ func TestRefreshTracksOnDemandReaderWithoutReapplyingRoute(t *testing.T) {
 	}
 }
 
+func TestRefreshReportsMissingPathInsteadOfWaiting(t *testing.T) {
+	store := NewMemoryStore()
+	route := Route{ID: "device:main", Path: "sense_device_main", Desired: "running", Actual: "waiting", Version: 1}
+	if err := store.Save(context.Background(), route); err != nil {
+		t.Fatal(err)
+	}
+	service := NewService(store, &fakeProcess{}, refreshController{status: mediamtx.PathStatus{Name: route.Path, Exists: false}})
+	result, err := service.Refresh(context.Background(), route.ID)
+	if err != nil || result.Actual != "apply_failed" || !strings.Contains(result.Detail, "不存在") {
+		t.Fatalf("result=%#v err=%v", result, err)
+	}
+}
+
+func TestRestoreReconcilesDesiredRoutes(t *testing.T) {
+	process := &fakeProcess{}
+	service, route := preparedService(t, process, fakeController{})
+	if err := service.Restore(context.Background()); err != nil {
+		t.Fatal(err)
+	}
+	restored, err := service.store.Get(context.Background(), route.ID)
+	if err != nil || !process.State().Running || restored.Actual != "ready" {
+		t.Fatalf("restored=%#v process=%#v err=%v", restored, process.State(), err)
+	}
+}
+
 func rtspReady() rtsp.Result { return rtsp.Result{Status: "ready"} }