Mirrors/cobalt
1
0
Fork 0
mirror of https://github.com/wukko/cobalt.git synced 2024-11-15 12:50:01 +00:00
Code Issues Projects Releases Packages Wiki Activity

api/bluesky: add support for recordWithMedia embed type

Browse source 
& catch various api errors
This commit is contained in:
wukko 2024-09-13 09:54:05 +06:00
parent 474c8e284f
commit a1feadb917
No known key found for this signature in database
GPG key ID: 3E30B3F26C7B4AA2
1 changed files with 27 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -2,8 +2,8 @@ import HLS from "hls-parser";
import { cobaltUserAgent } from "../../config.js"; import { cobaltUserAgent } from "../../config.js";
import { createStream } from "../../stream/manage.js"; import { createStream } from "../../stream/manage.js";
const extractVideo = async ({ getPost, filename }) => { const extractVideo = async ({ media, filename }) => {
const urlMasterHLS = getPost?.thread?.post?.embed?.playlist; const urlMasterHLS = media?.playlist;
if (!urlMasterHLS) return { error: "fetch.empty" }; if (!urlMasterHLS) return { error: "fetch.empty" };
if (!urlMasterHLS.startsWith("https://video.bsky.app/")) return { error: "fetch.empty" }; if (!urlMasterHLS.startsWith("https://video.bsky.app/")) return { error: "fetch.empty" };
@ -77,14 +77,37 @@ export default async function ({ user, post, alwaysProxy }) {
} }
}).then(r => r.json()).catch(() => {}); }).then(r => r.json()).catch(() => {});
if (!getPost || getPost?.error) return { error: "fetch.empty" }; if (!getPost) return { error: "fetch.empty" };
if (getPost.error) {
switch (getPost.error) {
case "NotFound":
case "InternalServerError":
return { error: "content.post.unavailable" };
case "InvalidRequest":
return { error: "link.unsupported" };
default:
return { error: "fetch.empty" };
}
}
const embedType = getPost?.thread?.post?.embed?.$type; const embedType = getPost?.thread?.post?.embed?.$type;
const filename = `bluesky_${user}_${post}`; const filename = `bluesky_${user}_${post}`;
if (embedType === "app.bsky.embed.video#view") { if (embedType === "app.bsky.embed.video#view") {
return extractVideo({ getPost, filename }); return extractVideo({
media: getPost.thread?.post?.embed,
filename,
})
} }
if (embedType === "app.bsky.embed.recordWithMedia#view") {
return extractVideo({
media: getPost.thread?.post?.embed?.media,
filename,
})
}
if (embedType === "app.bsky.embed.images#view") { if (embedType === "app.bsky.embed.images#view") {
return extractImages({ getPost, filename, alwaysProxy }); return extractImages({ getPost, filename, alwaysProxy });
} }