p1

src/lib/ffmpeg-v2.ts

@@ -81,6 +81,7 @@ function check_if_fFmpeg_active() {
 
 export const NS_ffmpeg_v2 = {
   F_probe_t1,
+  F_ping_probe,
   F_build_ffmpeg_flags_t1,
   proc_error_pattern,
   ffmpeg_path,
@@ -1038,3 +1039,25 @@ export function F_estimate_hls_size(arg0: {
     return { ratio: spec_minimum(type), source: "spec_minimum" };
   }
 }
+
+async function F_ping_probe(arg0: {
+  playback: Omit<T_probe_playback, "picture_quality">;
+  context?: Context;
+  just_cmd?: boolean;
+  timeout?: number;
+}) {
+  const { context, playback, timeout, just_cmd } = arg0;
+
+  const [E_, R_] = await NS_promise.F_catch_promise({
+    promise: NS_ffmpeg_v2.F_probe_t1({
+      context,
+      playback,
+      timeout,
+      just_cmd
+    })
+  });
+
+  if (E_) throw E_;
+
+  return R_;
+}

src/sub-router/showtime.ts

@@ -447,13 +447,6 @@ async function process_data(arg0: {
 
   if (!stream_delivery_handler) stream_to_pipe = false;
 
-  if (separate_audio) {
-    phase = "single";
-    two_step = false;
-    use_s3_pipe = IS_RENDER_COM() && !gh_proxy ? true : false;
-    stream_to_pipe = false;
-  }
-
   if (stream_to_pipe) {
     use_s3_pipe = false;
   }
@@ -462,6 +455,13 @@ async function process_data(arg0: {
     use_s3_pipe = true;
   }
 
+  if (separate_audio) {
+    phase = "single";
+    two_step = false;
+    use_s3_pipe = IS_RENDER_COM() && !gh_proxy ? true : false;
+    stream_to_pipe = false;
+  }
+
   const output_destination_clean = NS_misc.cleanNameV2(output_destination);
 
   const clean_file_id =
@@ -669,7 +669,7 @@ async function process_data(arg0: {
         };
       }
 
-      const _ = await NS_ff.ping_probe({ playback });
+      const _ = await NS_ffmpeg_v2.F_ping_probe({ playback, timeout: 0 });
 
       if (!_?.success) {
         throw new Error("Something went wrong: with probe");
@@ -796,7 +796,7 @@ async function process_data(arg0: {
     flags = CMD.flags;
 
     if (ops === "jc") {
-      const _ = await NS_ff.ping_probe({ playback });
+      const _ = await NS_ffmpeg_v2.F_ping_probe({ playback, timeout: 0 });
 
       if (_.success) {
         return {
@@ -863,12 +863,13 @@ async function process_data(arg0: {
       });
     }
 
-    if (
+    const handle_over_to_stream =
       two_step &&
       !(playback as any).i_x &&
       stream_to_pipe &&
-      stream_delivery_handler
-    ) {
+      stream_delivery_handler;
+
+    if (handle_over_to_stream) {
       const _ = new URL(stream_delivery_handler);
 
       _.searchParams.set("x_i", job_id);
@@ -946,7 +947,14 @@ async function process_data(arg0: {
           use_s3_pipe = false;
         }
 
-        fail(["STREAM PIPE FAILED"]);
+        if (IS_GH()) {
+          run({
+            ii: 0,
+            ...((playback as any).i_x ? { keep_subs: true, rebuild: true } : {})
+          });
+        } else {
+          fail(["STREAM PIPE FAILED"]);
+        }
       } else {
         NS_Misc.console.log({
           ENV: "all",
@@ -965,7 +973,7 @@ async function process_data(arg0: {
           ? clean_sp_size > 30 * 1e9
           : undefined;
 
-        NS_promise.F_catch_promise({
+        const [E_, R_] = await NS_promise.F_catch_promise({
           promise: ky.post(
             (() => {
               const _ = new URL(
@@ -1001,6 +1009,12 @@ async function process_data(arg0: {
             }
           )
         });
+
+        NS_Misc.console.log({
+          ENV: "all",
+          _browser: false,
+          _log: [`GH FF-DL PIPE INIT RESULTS`, { E_ }, { R_ }, "\n"]
+        });
       } else {
         run({
           ii: 0,
@@ -2042,8 +2056,6 @@ async function process_data(arg0: {
       return true;
     }
 
-    console.log({ logged_proc_info });
-
     const eof_lines = logged_proc_info
       .map((xx) => xx.toString().toLowerCase())
       .filter(