Add SE_VIDEO_MIN_RECORDING_DURATION to ensure file is not corrupted

Signed-off-by: Viet Nguyen Duc <[email protected]>

Author: VietND96

Video/video.sh

@@ -19,6 +19,7 @@ max_attempts=${SE_VIDEO_WAIT_ATTEMPTS:-50}
 file_ready_max_attempts=${SE_VIDEO_FILE_READY_WAIT_ATTEMPTS:-5}
 wait_uploader_shutdown_max_attempts=${SE_VIDEO_WAIT_UPLOADER_SHUTDOWN_ATTEMPTS:-5}
 graceful_stop_delay=${SE_VIDEO_GRACEFUL_STOP_DELAY:-5}
+min_recording_duration=${SE_VIDEO_MIN_RECORDING_DURATION:-5}
 ts_format=${SE_LOG_TIMESTAMP_FORMAT:-"%Y-%m-%d %H:%M:%S,%3N"}
 process_name="video.recorder"
 
@@ -243,9 +244,32 @@ function stop_ffmpeg_graceful_async() {
   echo "$(date -u +"${ts_format}") [${process_name}] - [Session: ${session_id_param}] FFmpeg graceful stop initiated in background (PID: ${bg_pid}) for file: ${video_file_name_param}"
 }
 
+function ensure_minimum_recording_duration() {
+  # Ensure recording has run for minimum duration to avoid corrupted files
+  # IMPORTANT: recording_started must remain "true" during this function
+  # to prevent new sessions from starting (checked at line ~406)
+
+  if [[ -n "${recording_start_time}" ]]; then
+    local current_time=$(date +%s)
+    local recording_duration=$((current_time - recording_start_time))
+
+    if [[ ${recording_duration} -lt ${min_recording_duration} ]]; then
+      local wait_time=$((min_recording_duration - recording_duration))
+      echo "$(date -u +"${ts_format}") [${process_name}] - [Session: ${prev_session_id}] Recording duration ${recording_duration}s is less than minimum ${min_recording_duration}s, waiting ${wait_time}s more (new sessions blocked)"
+      sleep ${wait_time}
+      echo "$(date -u +"${ts_format}") [${process_name}] - [Session: ${prev_session_id}] Minimum recording duration ${min_recording_duration}s reached, new sessions can start"
+    else
+      echo "$(date -u +"${ts_format}") [${process_name}] - [Session: ${prev_session_id}] Recording duration ${recording_duration}s meets minimum ${min_recording_duration}s requirement"
+    fi
+  fi
+}
+
 function stop_recording() {
   local use_async=${1:-true}
 
+  # Ensure minimum recording duration before stopping
+  ensure_minimum_recording_duration
+
   if [[ "${use_async}" = "true" ]]; then
     # Async stop - allows immediate start of new recording
     # Upload will be triggered AFTER FFmpeg finalization in the background
@@ -276,6 +300,7 @@ function stop_recording() {
 
   recorded_count=$((recorded_count + 1))
   recording_started="false"
+  recording_start_time=""
 }
 
 function check_if_ffmpeg_running() {
@@ -373,6 +398,7 @@ else
   video_file_name=""
   video_file=""
   prev_session_id=""
+  recording_start_time=""
   attempts=0
   max_recorded_count=${SE_DRAIN_AFTER_SESSION_COUNT:-0}
   recorded_count=0
@@ -402,6 +428,7 @@ else
         if ps -p $FFMPEG_PID >/dev/null; then
           recording_started="true"
           prev_session_id=$session_id
+          recording_start_time=$(date +%s)
         fi
         echo "$(date -u +"${ts_format}") [${process_name}] - [Session: ${session_id}] Video recording started (FFmpeg PID: ${FFMPEG_PID})"
         sleep ${poll_interval}