wait for control job to be done

engine/src/api/routes.rs

@@ -869,10 +869,22 @@ pub async fn control_playout(
 ) -> Result<impl Responder, ServiceError> {
     let manager = controllers.lock().unwrap().get(*id).unwrap();
 
-    match control_state(&pool, manager, &control.control).await {
+    if manager.is_processing.load(Ordering::SeqCst) {
+        return Err(ServiceError::Conflict(
+            "A command is already being processed, please wait".to_string(),
+        ));
+    }
+
+    manager.is_processing.store(true, Ordering::SeqCst);
+
+    let resp = match control_state(&pool, &manager, &control.control).await {
         Ok(res) => Ok(web::Json(res)),
         Err(e) => Err(e),
-    }
+    };
+
+    manager.is_processing.store(false, Ordering::SeqCst);
+
+    resp
 }
 
 /// **Get current Clip**

engine/src/utils/control.rs

@@ -132,7 +132,7 @@ pub async fn send_message(
 
 pub async fn control_state(
     conn: &Pool<Sqlite>,
-    manager: ChannelManager,
+    manager: &ChannelManager,
     command: &str,
 ) -> Result<Map<String, Value>, ServiceError> {
     let config = manager.config.lock().unwrap().clone();

frontend/stores/config.ts

@@ -2,7 +2,6 @@ import { cloneDeep } from 'lodash-es'
 import { defineStore } from 'pinia'
 import type { AdvancedConfig } from '~/types/advanced_config'
 
-
 export const useConfig = defineStore('config', {
     state: () => ({
         i: 0,