Mirrors/cobalt
1
0
Fork 0
mirror of https://github.com/wukko/cobalt.git synced 2025-02-23 19:48:48 +01:00
Code Issues Projects Releases Packages Wiki Activity

api/facebook: add dispatcher support (#1115)

Browse source
This commit is contained in:
jj 2025-02-18 12:44:25 +01:00 committed by GitHub
parent a52aee2bb3
commit dba405a6b4
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 7 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
api/src/processing/match.js
View file

@ -227,7 +227,8 @@ export default async function({ host, patternMatch, params }) {
case "facebook": case "facebook":
r = await facebook({ r = await facebook({
...patternMatch ...patternMatch,
dispatcher
}); });
break; break;

10
api/src/processing/services/facebook.js
View file

@ -8,8 +8,8 @@ const headers = {
'Sec-Fetch-Site': 'none', 'Sec-Fetch-Site': 'none',
} }
const resolveUrl = (url) => { const resolveUrl = (url, dispatcher) => {
return fetch(url, { headers }) return fetch(url, { headers, dispatcher })
.then(r => { .then(r => {
if (r.headers.get('location')) { if (r.headers.get('location')) {
return decodeURIComponent(r.headers.get('location')); return decodeURIComponent(r.headers.get('location'));
@ -23,13 +23,13 @@ const resolveUrl = (url) => {
.catch(() => false); .catch(() => false);
} }
export default async function({ id, shareType, shortLink }) { export default async function({ id, shareType, shortLink, dispatcher }) {
let url = `https://web.facebook.com/i/videos/${id}`; let url = `https://web.facebook.com/i/videos/${id}`;
if (shareType) url = `https://web.facebook.com/share/${shareType}/${id}`; if (shareType) url = `https://web.facebook.com/share/${shareType}/${id}`;
if (shortLink) url = await resolveUrl(`https://fb.watch/${shortLink}`); if (shortLink) url = await resolveUrl(`https://fb.watch/${shortLink}`, dispatcher);
const html = await fetch(url, { headers }) const html = await fetch(url, { headers, dispatcher })
.then(r => r.text()) .then(r => r.text())
.catch(() => false); .catch(() => false);