add /restart_streams route to REST API

src/lib/server/manager.rs

@@ -66,6 +66,7 @@ pub async fn run(server_address: &str) -> Result<(), std::io::Error> {
             .route("/info", web::get().to(pages::info))
             .route("/delete_stream", web::delete().to(pages::remove_stream))
             .route("/reset_settings", web::post().to(pages::reset_settings))
+            .route("/restart_streams", web::post().to(pages::restart_streams))
             .route("/streams", web::get().to(pages::streams))
             .route("/streams", web::post().to(pages::streams_post))
             .route("/v4l", web::get().to(pages::v4l))

src/lib/server/pages.rs

@@ -271,6 +271,22 @@ pub async fn reset_settings(query: web::Query<ResetSettings>) -> Result<HttpResp
     ))
 }
 
+#[api_v2_operation]
+/// Restart streams
+pub async fn restart_streams(query: web::Query<ResetSettings>) -> Result<HttpResponse> {
+    if query.all.unwrap_or_default() {
+        stream_manager::start_default()
+            .await
+            .map_err(|error| Error::Internal(format!("{error:?}")))?;
+
+        return Ok(HttpResponse::Ok().finish());
+    }
+
+    Err(Error::Internal(
+        "Missing argument for restart_streams.".to_string(),
+    ))
+}
+
 #[api_v2_operation]
 /// Provide a list of all streams configured
 pub async fn streams() -> Result<HttpResponse> {