GUI-STUDIO commited on
Commit ·
9bf7bb2
1
Parent(s): 56fd70f
changes
Browse files- src/lib/transcode-job.ts +2 -1
- src/sub-router/showtime.ts +1 -17
- src/sub-router/stream.ts +6 -6
src/lib/transcode-job.ts
CHANGED
|
@@ -126,7 +126,8 @@ export async function ping_probe(arg0: { playback: T_playback }) {
|
|
| 126 |
|
| 127 |
const [E_, R_] = await NS_promise.F_catch_promise({
|
| 128 |
promise: NS_ffmpeg_v2.F_probe_t1({
|
| 129 |
-
playback
|
|
|
|
| 130 |
})
|
| 131 |
});
|
| 132 |
|
|
|
|
| 126 |
|
| 127 |
const [E_, R_] = await NS_promise.F_catch_promise({
|
| 128 |
promise: NS_ffmpeg_v2.F_probe_t1({
|
| 129 |
+
playback,
|
| 130 |
+
timeout: 0
|
| 131 |
})
|
| 132 |
});
|
| 133 |
|
src/sub-router/showtime.ts
CHANGED
|
@@ -22,6 +22,7 @@ import { NS_pack_proxima } from "@x/core/server/proxima/pack.ts";
|
|
| 22 |
import { NS_scrape_post_processing_helper } from "@x/post-process/helper";
|
| 23 |
import { NS_Misc } from "@x/core/client/misc.ts";
|
| 24 |
import {
|
|
|
|
| 25 |
record_task_info,
|
| 26 |
relay_progress_info,
|
| 27 |
relay_progress_info_ws,
|
|
@@ -1781,20 +1782,3 @@ function timeToSecondsPrecise(timeStr: string): number {
|
|
| 1781 |
(parseInt(ms) || 0) / 100
|
| 1782 |
);
|
| 1783 |
}
|
| 1784 |
-
|
| 1785 |
-
async function ping_probe(arg0: { playback: T_playback }) {
|
| 1786 |
-
const { playback } = arg0;
|
| 1787 |
-
|
| 1788 |
-
const [E_, R_] = await NS_promise.F_catch_promise({
|
| 1789 |
-
promise: NS_ffmpeg_v2.F_probe_t1({
|
| 1790 |
-
playback,
|
| 1791 |
-
timeout: 0
|
| 1792 |
-
})
|
| 1793 |
-
});
|
| 1794 |
-
|
| 1795 |
-
if (R_) {
|
| 1796 |
-
return { success: true };
|
| 1797 |
-
}
|
| 1798 |
-
|
| 1799 |
-
return { success: false };
|
| 1800 |
-
}
|
|
|
|
| 22 |
import { NS_scrape_post_processing_helper } from "@x/post-process/helper";
|
| 23 |
import { NS_Misc } from "@x/core/client/misc.ts";
|
| 24 |
import {
|
| 25 |
+
ping_probe,
|
| 26 |
record_task_info,
|
| 27 |
relay_progress_info,
|
| 28 |
relay_progress_info_ws,
|
|
|
|
| 1782 |
(parseInt(ms) || 0) / 100
|
| 1783 |
);
|
| 1784 |
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
src/sub-router/stream.ts
CHANGED
|
@@ -873,12 +873,11 @@ async function handle_data(arg0: {
|
|
| 873 |
}
|
| 874 |
|
| 875 |
if (media.initUrl || media?.init?.url) {
|
| 876 |
-
if (!two_step) {
|
| 877 |
-
|
| 878 |
-
}
|
| 879 |
-
|
| 880 |
-
|
| 881 |
-
delivery_format = "mp4";
|
| 882 |
}
|
| 883 |
|
| 884 |
if (media.init) {
|
|
@@ -1422,6 +1421,7 @@ function segmentStream(arg0: {
|
|
| 1422 |
const { readable, writable } = new TransformStream<Uint8Array, Uint8Array>();
|
| 1423 |
const ac = arg0.ac || new AbortController();
|
| 1424 |
const inflight: Promise<Response>[] = [];
|
|
|
|
| 1425 |
let next = 0;
|
| 1426 |
|
| 1427 |
const fetch_part = (url: string, range?: Range) =>
|
|
|
|
| 873 |
}
|
| 874 |
|
| 875 |
if (media.initUrl || media?.init?.url) {
|
| 876 |
+
// if (!two_step) {
|
| 877 |
+
// return { error: "fMP4/CMAF needs remuxing, not supported" };
|
| 878 |
+
// }
|
| 879 |
+
// out_mime = "video/mp4";
|
| 880 |
+
// delivery_format = "mp4";
|
|
|
|
| 881 |
}
|
| 882 |
|
| 883 |
if (media.init) {
|
|
|
|
| 1421 |
const { readable, writable } = new TransformStream<Uint8Array, Uint8Array>();
|
| 1422 |
const ac = arg0.ac || new AbortController();
|
| 1423 |
const inflight: Promise<Response>[] = [];
|
| 1424 |
+
|
| 1425 |
let next = 0;
|
| 1426 |
|
| 1427 |
const fetch_part = (url: string, range?: Range) =>
|