Enhance video streaming and metadata handling

Add support for aniwatch portal, optimize stream concurrency and
probesize, update TMDB metadata shape fields, and fix premiere date
logic across frontend and backend services.

src/lib/dl-showtime-helper.ts

@@ -40,6 +40,7 @@ async function find_seed_file(arg0: {
   sbe_s_e?: string;
   ideal_runtime?: T_playback["ideal_runtime"];
   has_subs?: boolean;
+  is_pipe_stream?: boolean;
 }) {
   const {
     sbe_id,
@@ -54,7 +55,8 @@ async function find_seed_file(arg0: {
     qLevel,
     sbe_s_e,
     ideal_runtime,
-    has_subs
+    has_subs,
+    is_pipe_stream
   } = arg0;
 
   let { picture_quality } = arg0;
@@ -114,16 +116,19 @@ async function find_seed_file(arg0: {
       return;
     }
 
-    const _m = await match_runtime({
-      picture_quality,
-      ideal_runtime,
-      video_path: {
-        h: stream_link,
-        protocol: "http"
-      }
-    });
+    if (!is_pipe_stream) {
+      const _m = await match_runtime({
+        picture_quality,
+        ideal_runtime,
+        probe_timeout: 0,
+        video_path: {
+          h: upstream.url,
+          protocol: "http"
+        }
+      });
 
-    if (!_m) return;
+      if (!_m) return;
+    }
 
     const data = {
       stream_link,
@@ -172,17 +177,29 @@ async function find_seed_file(arg0: {
 
     const stream_link = bucket_file_info!.url;
 
-    const _m = await match_runtime({
-      picture_quality,
-      ideal_runtime,
-      video_path: {
-        h: stream_link,
-        protocol: "http",
-        bucket: true
-      }
-    });
+    const _u = new URL(stream_link);
+    _u.searchParams.set("download", "true");
 
-    if (!_m) return;
+    const upstream = await fetch(_u.toString());
+
+    if (!upstream.ok) {
+      return;
+    }
+
+    if (!is_pipe_stream) {
+      const _m = await match_runtime({
+        picture_quality,
+        ideal_runtime,
+        probe_timeout: 0,
+        video_path: {
+          h: upstream.url,
+          protocol: "http",
+          bucket: true
+        }
+      });
+
+      if (!_m) return;
+    }
 
     const document_metadata = await (async () => {
       if (document !== true || db_?.in_db) return;
@@ -442,13 +459,14 @@ async function document_seed_file(arg0: {
 export async function match_runtime(arg0: {
   ideal_runtime?: number;
   picture_quality?: string;
+  probe_timeout?: number;
   video_path: {
     h: string;
     protocol: "http" | "local";
     bucket?: boolean;
   };
 }) {
-  const { ideal_runtime, picture_quality, video_path } = arg0;
+  const { ideal_runtime, picture_quality, video_path, probe_timeout } = arg0;
 
   // call ffprobe
   const [E_, R_] = await NS_promise.F_catch_promise({
@@ -457,7 +475,8 @@ export async function match_runtime(arg0: {
         url: video_path.h,
         type: "video",
         protocol: video_path.protocol
-      }
+      },
+      timeout: probe_timeout
     })
   });
 

src/lib/ffmpeg-v2.ts

@@ -148,9 +148,10 @@ async function F_probe_t1(arg0: {
 
   flags.push("-protocol_whitelist", "file,http,https,tcp,tls,crypto");
 
-  flags.push("-probesize", `${1_000_000 * 10}`); // Limit probe size to 10MB (default is 5MB)
-  flags.push("-analyzeduration", `${1_000_000 * 10}`); // Analyze only 10 seconds (default is 5s)
+  flags.push("-probesize", `${1_000_000 * 5}`); // Limit probe size (default is 5MB)
+  flags.push("-analyzeduration", `${1_000_000 * 5}`); // Analyze only seconds (default is 5s)
 
+  // flags.push("-nobuffer");
   // flags.push("-count_packets");
 
   if (read_intervals?.duration) {

src/sub-router/showtime.ts

@@ -291,6 +291,12 @@ async function handle_data(arg0: {
 
   let phase: Phase = two_step ? "ts" : "single";
 
+  if (fMP4) {
+    phase = "single";
+    two_step = false;
+    use_s3_pipe = false;
+  }
+
   const xc = REQ0.searchParams.has("xc");
 
   (() => {

src/sub-router/stream.ts

@@ -439,11 +439,14 @@ async function handle_data(arg0: {
       }
 
       const __ = await wide_search_runner({
-        document: true,
-        i_x: two_step ? true : false,
-        skip: { local: true }
+        document: two_step ? false : true,
+        skip: { local: true, db: two_step ? true : false }
       });
 
+      if (two_step && __ && "stream_link" in __ && __.stream_link) {
+        pipe_i_x({ link: __.stream_link });
+      }
+
       return __;
     })();
 
@@ -636,7 +639,7 @@ async function handle_data(arg0: {
           segments: current_segments,
           init,
           headers: _playback.headers || {},
-          concurrency: IS_HF() ? 12 : 6,
+          concurrency: IS_HF() ? 20 : 6,
           ac: controller,
           onError: (arg0) => {
             if (is_dev) console.error("💠", JSON.stringify(arg0), "\n");
@@ -698,7 +701,7 @@ async function handle_data(arg0: {
                   i_x: two_step ? true : false,
                   skip: {
                     local: true,
-                    db: true
+                    db: two_step ? true : false
                   }
                 });
               })();
@@ -1080,6 +1083,46 @@ async function handle_data(arg0: {
     console.log("[CONTROLLER] Request aborted");
   }
 
+  async function pipe_i_x(arg0: { link: string }) {
+    const { link } = arg0;
+
+    if (typeof link !== "string" || !NS_routes_c.F_is_url(link)) {
+      return;
+    }
+
+    const _ = new URL(`/showtimeV2/delivery/${data_key}`, REQ_ORIGIN);
+
+    _.searchParams.set("i_x", link);
+    _.searchParams.set("xc", "");
+
+    phase = "mp4";
+
+    NS_Misc.console.log({
+      ENV: "all",
+      _browser: false,
+      _log: [`🏁 PHRASE [${phase}]: INIT`, "\n"]
+    });
+
+    NS_Misc.console.log({
+      ENV: "all",
+      _browser: false,
+      _log: [`SENT TO FFMPEG PIPE HANDLER`, "\n"]
+    });
+
+    // fetch(_);
+
+    NS_promise.F_catch_promise({
+      promise: ShowtimeV2RouterHandlePayload({
+        data_key,
+        metadata,
+        REQ0: _,
+        REQ_ORIGIN,
+        ctx: ctx as any,
+        throw_error: true
+      })
+    });
+  }
+
   async function wide_search_runner(arg0: {
     skip?: {
       local?: boolean;
@@ -1108,7 +1151,8 @@ async function handle_data(arg0: {
         document,
         ideal_runtime: playback.ideal_runtime,
         skip,
-        has_subs: false
+        has_subs: false,
+        is_pipe_stream: true
       })
     });
 
@@ -1118,37 +1162,7 @@ async function handle_data(arg0: {
       }
 
       if (i_x) {
-        const _ = new URL(`/showtimeV2/delivery/${data_key}`, REQ_ORIGIN);
-
-        _.searchParams.set("i_x", R_.stream_link);
-        _.searchParams.set("xc", "");
-
-        phase = "mp4";
-
-        NS_Misc.console.log({
-          ENV: "all",
-          _browser: false,
-          _log: [`🏁 PHRASE [${phase}]: INIT`, "\n"]
-        });
-
-        NS_Misc.console.log({
-          ENV: "all",
-          _browser: false,
-          _log: [`SENT TO FFMPEG PIPE HANDLER`, "\n"]
-        });
-
-        // fetch(_);
-
-        NS_promise.F_catch_promise({
-          promise: ShowtimeV2RouterHandlePayload({
-            data_key,
-            metadata,
-            REQ0: _,
-            REQ_ORIGIN,
-            ctx: ctx as any,
-            throw_error: true
-          })
-        });
+        pipe_i_x({ link: R_.stream_link });
       }
     }