blitzwing/cobalt-7
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

api/bluesky: catch video errors & prevent loading videos not from bsky

Browse source
This commit is contained in:
wukko 2024-09-03 13:24:08 +06:00
parent 4b4fce326f
commit 645542c910
No known key found for this signature in database
GPG key ID: 3E30B3F26C7B4AA2
1 changed files with 11 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
api/src/processing/services/bluesky.js
View file

@ -5,15 +5,20 @@ import { createStream } from "../../stream/manage.js";
const extractVideo = async ({ getPost, filename }) => {
const urlMasterHLS = getPost?.thread?.post?.embed?.playlist;
if (!urlMasterHLS) return { error: "fetch.empty" };
if (!urlMasterHLS.startsWith("https://video.bsky.app/")) return { error: "fetch.empty" };
const masterHLS = await fetch(urlMasterHLS)
.then(r => r.text())
.catch(() => {});
if (!masterHLS) return { error: "fetch.fail" };
.then(r => {
if (r.status !== 200) return;
return r.text();
})
.catch(() => {});
if (!masterHLS) return { error: "fetch.empty" };
const video = HLS.parse(masterHLS)
?.variants
?.reduce((a, b) => a?.bandwidth > b?.bandwidth ? a : b);
?.variants
?.reduce((a, b) => a?.bandwidth > b?.bandwidth ? a : b);
const videoURL = new URL(video.uri, urlMasterHLS).toString();
@ -70,9 +75,7 @@ export default async function ({ user, post, alwaysProxy }) {
headers: {
"user-agent": cobaltUserAgent
}
})
.then(r => r.json())
.catch(() => {});
}).then(r => r.json()).catch(() => {});
if (!getPost || getPost?.error) return { error: "fetch.empty" };