changes

src/lib/ffmpeg.ts

@@ -39,8 +39,8 @@ hw_encoder =
 
 console.log(`🚀 Using hardware encoder: ${hw_encoder}`);
 
-const TIMEOUT_MS = 30_000; // probe + transcode timeout
-const PROBE_TIMEOUT_MS = 40_000; // probe + transcode timeout
+const TIMEOUT_MS = 20_000; // probe + transcode timeout
+const PROBE_TIMEOUT_MS = 30_000; // probe + transcode timeout
 
 function get_hardware_encoder() {
   return new Promise((resolve) => {
@@ -223,12 +223,17 @@ async function F_probe_v2(arg0: {
   playback_url: URL;
   playback_type?: string;
   context?: Context;
+  _log?: boolean;
   file_mode?: {
     path: string;
   };
 }) {
   const { playback_url, context, file_mode } = arg0;
-  let { playback_headers } = arg0;
+  let { playback_headers, _log } = arg0;
+
+  if (typeof _log !== "boolean") {
+    _log = true;
+  }
 
   if (!playback_headers) {
     playback_headers = {};
@@ -369,7 +374,7 @@ async function F_probe_v2(arg0: {
   // add the input flag and URL
   command.push("-i", file_mode?.path || playback_url.href);
 
-  console.log("[PROBE CMD]", command, "\n");
+  if (_log) console.log("[PROBE CMD]", command, "\n");
 
   const proc = Bun.spawn(command, {
     stdout: "pipe",
@@ -1064,14 +1069,7 @@ async function F_build_ffmpeg_command_v3(arg0: {
 
     // command.push("-rw_timeout", timeoutVal, "-timeout", timeoutVal);
     // command.push("-rw_timeout", timeoutVal);
-    command.push(
-      "-rw_timeout",
-      timeoutVal,
-      "-timeout",
-      timeoutVal,
-      "-stimeout",
-      timeoutVal
-    );
+    command.push("-rw_timeout", timeoutVal, "-timeout", timeoutVal);
 
     if (has_tcp_progress) {
       command.push("-multiple_requests", "1");

src/sub-router/showtime.ts

@@ -556,6 +556,8 @@ async function F_handle_process(arg0: {
     } else if (last_failed) {
       throw new Error("Something went wrong: with last try");
     } else {
+      console.log("🪣 CHECKING BUCKET DB ...", "\n");
+
       // CHECK DOCUMENTED FILES
       const _file_data = await check_documented_file();
 
@@ -635,10 +637,13 @@ async function F_handle_process(arg0: {
       promise: NS_ffmpeg.F_probe_v2({
         playback_url: new URL(playback_url),
         context: ctx as any,
-        playback_headers
+        playback_headers,
+        _log: false
       })
     });
 
+    console.log("410 PROBE: ", { E_ }, { R_ });
+
     if (E_ || !R_ || !R_.probe_data) {
       const { status, message } = NS_error.F_collect_error_status_n_message({
         ERR: E_
@@ -1579,8 +1584,6 @@ async function F_handle_process(arg0: {
             console.log("\n");
             console.log(
               `FFMPEG finished -> ${schemed_data?.current_filesize} ${tmp_download_path}`,
-              "\n",
-              bun_proc.resourceUsage(),
               "\n"
             );
             break;