GUI-STUDIO commited on
Commit ·
d4a8291
1
Parent(s): bf6d016
changes
Browse files- src/sub-router/ffmpeg.ts +3 -2
- src/sub-router/showtime.ts +5 -9
src/sub-router/ffmpeg.ts
CHANGED
|
@@ -201,7 +201,8 @@ const sub_router = new Elysia({ prefix: "/ffmpeg" })
|
|
| 201 |
progress_update_endpoint,
|
| 202 |
playback_type,
|
| 203 |
sbe_id,
|
| 204 |
-
picture_quality,
|
|
|
|
| 205 |
};
|
| 206 |
|
| 207 |
const data_str = devalue.stringify(data);
|
|
@@ -220,7 +221,7 @@ const sub_router = new Elysia({ prefix: "/ffmpeg" })
|
|
| 220 |
length: 40
|
| 221 |
});
|
| 222 |
|
| 223 |
-
let key = `
|
| 224 |
if (APP_ACCOUNT_ABC) key = `${key}:${APP_ACCOUNT_ABC}`;
|
| 225 |
|
| 226 |
// 30 days = 30 * 24 * 60 * 60 = 2,592,000 seconds
|
|
|
|
| 201 |
progress_update_endpoint,
|
| 202 |
playback_type,
|
| 203 |
sbe_id,
|
| 204 |
+
picture_quality,
|
| 205 |
+
cache_it
|
| 206 |
};
|
| 207 |
|
| 208 |
const data_str = devalue.stringify(data);
|
|
|
|
| 221 |
length: 40
|
| 222 |
});
|
| 223 |
|
| 224 |
+
let key = `llsvkm:${track_id}`;
|
| 225 |
if (APP_ACCOUNT_ABC) key = `${key}:${APP_ACCOUNT_ABC}`;
|
| 226 |
|
| 227 |
// 30 days = 30 * 24 * 60 * 60 = 2,592,000 seconds
|
src/sub-router/showtime.ts
CHANGED
|
@@ -530,9 +530,9 @@ async function F_handle_process(arg0: {
|
|
| 530 |
S3Dir
|
| 531 |
});
|
| 532 |
|
| 533 |
-
console.log("FOUND A FILE ============ ", found_file?.path, "\n");
|
| 534 |
-
|
| 535 |
if (typeof found_file?.path === "string" && found_file.path.trim()) {
|
|
|
|
|
|
|
| 536 |
const _file_to_serve = await serve_download({
|
| 537 |
file_path: found_file.path.trim(),
|
| 538 |
job_id,
|
|
@@ -654,7 +654,7 @@ async function F_handle_process(arg0: {
|
|
| 654 |
})
|
| 655 |
});
|
| 656 |
|
| 657 |
-
console.log("
|
| 658 |
|
| 659 |
if (E_ || !R_ || !R_.probe_data) {
|
| 660 |
const { status, message } = NS_error.F_collect_error_status_n_message({
|
|
@@ -1114,7 +1114,6 @@ async function F_handle_process(arg0: {
|
|
| 1114 |
}
|
| 1115 |
|
| 1116 |
async function document_the_file() {
|
| 1117 |
-
console.log({ file_mode, job_id, sbe_id, tmp_file_name });
|
| 1118 |
if (!file_mode || !job_id || !sbe_id || !tmp_file_name) {
|
| 1119 |
return;
|
| 1120 |
}
|
|
@@ -1122,20 +1121,17 @@ async function F_handle_process(arg0: {
|
|
| 1122 |
try {
|
| 1123 |
const upload_job = upload_jobs.get(job_id);
|
| 1124 |
|
| 1125 |
-
console.log({ upload_job });
|
| 1126 |
-
|
| 1127 |
if (upload_job?.status === "in-progress") {
|
| 1128 |
return;
|
| 1129 |
}
|
| 1130 |
|
| 1131 |
let already_documented = await check_documented_file();
|
| 1132 |
|
| 1133 |
-
console.log({ already_documented });
|
| 1134 |
-
|
| 1135 |
if (already_documented?.in_db && already_documented?.in_bucket) {
|
| 1136 |
return;
|
| 1137 |
}
|
| 1138 |
|
|
|
|
| 1139 |
console.log("📃 DOCUMENTING FILE");
|
| 1140 |
|
| 1141 |
if (!undocumented_file && !already_documented?.in_bucket) {
|
|
@@ -1167,7 +1163,7 @@ async function F_handle_process(arg0: {
|
|
| 1167 |
}
|
| 1168 |
}
|
| 1169 |
|
| 1170 |
-
console.log("\n");
|
| 1171 |
if (!undocumented_file) {
|
| 1172 |
console.log("❌ NO FILE TO DOCUMENT", "\n");
|
| 1173 |
} else {
|
|
|
|
| 530 |
S3Dir
|
| 531 |
});
|
| 532 |
|
|
|
|
|
|
|
| 533 |
if (typeof found_file?.path === "string" && found_file.path.trim()) {
|
| 534 |
+
console.log("FOUND A FILE ============ ", found_file.path, "\n");
|
| 535 |
+
|
| 536 |
const _file_to_serve = await serve_download({
|
| 537 |
file_path: found_file.path.trim(),
|
| 538 |
job_id,
|
|
|
|
| 654 |
})
|
| 655 |
});
|
| 656 |
|
| 657 |
+
console.log("📶 SIGNAL PROBE: ", { E_ }, { R_ });
|
| 658 |
|
| 659 |
if (E_ || !R_ || !R_.probe_data) {
|
| 660 |
const { status, message } = NS_error.F_collect_error_status_n_message({
|
|
|
|
| 1114 |
}
|
| 1115 |
|
| 1116 |
async function document_the_file() {
|
|
|
|
| 1117 |
if (!file_mode || !job_id || !sbe_id || !tmp_file_name) {
|
| 1118 |
return;
|
| 1119 |
}
|
|
|
|
| 1121 |
try {
|
| 1122 |
const upload_job = upload_jobs.get(job_id);
|
| 1123 |
|
|
|
|
|
|
|
| 1124 |
if (upload_job?.status === "in-progress") {
|
| 1125 |
return;
|
| 1126 |
}
|
| 1127 |
|
| 1128 |
let already_documented = await check_documented_file();
|
| 1129 |
|
|
|
|
|
|
|
| 1130 |
if (already_documented?.in_db && already_documented?.in_bucket) {
|
| 1131 |
return;
|
| 1132 |
}
|
| 1133 |
|
| 1134 |
+
console.log("\n");
|
| 1135 |
console.log("📃 DOCUMENTING FILE");
|
| 1136 |
|
| 1137 |
if (!undocumented_file && !already_documented?.in_bucket) {
|
|
|
|
| 1163 |
}
|
| 1164 |
}
|
| 1165 |
|
| 1166 |
+
// console.log("\n");
|
| 1167 |
if (!undocumented_file) {
|
| 1168 |
console.log("❌ NO FILE TO DOCUMENT", "\n");
|
| 1169 |
} else {
|