From 47521509c4fcb1a34ad0ec125bd960e74f1bae21 Mon Sep 17 00:00:00 2001
From: Nandor Pal <nandor.pal@acetech.dev>
Date: Mon, 12 Aug 2024 18:51:08 +0300
Subject: [PATCH] fix(video uploader): upload pipe detection (#2352)

---
 Video/upload.sh | 48 ++++++++++++++++++++++++++++++++++++++++++------
 1 file changed, 42 insertions(+), 6 deletions(-)

diff --git a/Video/upload.sh b/Video/upload.sh
index 345894971..e294894a4 100755
--- a/Video/upload.sh
+++ b/Video/upload.sh
@@ -53,10 +53,46 @@ function graceful_exit() {
 }
 trap graceful_exit SIGTERM SIGINT EXIT
 
-while [ ! -p ${UPLOAD_PIPE_FILE} ];
-do
-      echo "Waiting for ${UPLOAD_PIPE_FILE} to be created"
-      sleep 1
+# Function to create the named pipe if it doesn't exist
+function create_named_pipe() {
+    if [ ! -p "${UPLOAD_PIPE_FILE}" ];
+    then
+        if [ -e "${UPLOAD_PIPE_FILE}" ];
+        then
+            rm -f "${UPLOAD_PIPE_FILE}"
+        fi
+        mkfifo "${UPLOAD_PIPE_FILE}"
+        echo "Created named pipe ${UPLOAD_PIPE_FILE}"
+    fi
+}
+
+TIMEOUT=300 # Timeout in seconds (5 minutes)
+START_TIME=$(date +%s)
+
+while true; do
+    if [ -e "${UPLOAD_PIPE_FILE}" ];
+    then
+        if [ -p "${UPLOAD_PIPE_FILE}" ];
+        then
+            break
+        else
+            echo "${UPLOAD_PIPE_FILE} exists but is not a named pipe"
+            create_named_pipe
+        fi
+    else
+        create_named_pipe
+    fi
+
+    CURRENT_TIME=$(date +%s)
+    ELAPSED_TIME=$((CURRENT_TIME - START_TIME))
+    if [ ${ELAPSED_TIME} -ge ${TIMEOUT} ];
+    then
+        echo "Timeout waiting for ${UPLOAD_PIPE_FILE} to be created"
+        exit 1
+    fi
+
+    echo "Waiting for ${UPLOAD_PIPE_FILE} to be created"
+    sleep 1
 done
 
 echo "Waiting for video files put into pipe for proceeding to upload"
@@ -64,7 +100,7 @@ echo "Waiting for video files put into pipe for proceeding to upload"
 rename_rclone_env
 
 list_rclone_pid=()
-while read FILE DESTINATION < ${UPLOAD_PIPE_FILE}
+while read FILE DESTINATION < ${UPLOAD_PIPE_FILE};
 do
     if [ "${FILE}" = "exit" ];
     then
@@ -76,7 +112,7 @@ do
         list_rclone_pid+=($!)
     else
         # Wait for a batch rclone processes to finish
-        if [ ${#list_rclone_pid[@]} -eq ${SE_VIDEO_UPLOAD_BATCH_CHECK} ]
+        if [ ${#list_rclone_pid[@]} -eq ${SE_VIDEO_UPLOAD_BATCH_CHECK} ];
         then
             for pid in "${list_rclone_pid[@]}";
             do