LBRYFoundation/Watch-on-LBRY
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/Watch-on-LBRY.git synced 2025-08-23 17:47:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

🍘 ctxFromURL runs once for the same url at a time

Browse source
This commit is contained in:
Shiba 2022-01-09 13:12:05 +00:00
parent 475c38ba0c
commit b750c86b88
1 changed files with 12 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/scripts/tabOnUpdated.ts
View file

@ -16,6 +16,7 @@ async function resolveYT(descriptor: YtIdResolverDescriptor) {
return segments.join('/');
}
const ctxFromURLOnGoingPromise: Record<string, Promise<UpdateContext | void>> = {}
async function ctxFromURL(href: string): Promise<UpdateContext | void> {
if (!href) return;
@ -26,12 +27,18 @@ async function ctxFromURL(href: string): Promise<UpdateContext | void> {
const descriptor = ytService.getId(href);
if (!descriptor) return; // couldn't get the ID, so we're done
// NOTE: API call cached by resolveYT method automatically
const res = await resolveYT(descriptor);
if (!res) return; // couldn't find it on lbry, so we're done
// Don't create a new Promise for same ID until on going one is over.
const promise = ctxFromURLOnGoingPromise[descriptor.id] ?? (ctxFromURLOnGoingPromise[descriptor.id] = (async () => {
// NOTE: API call cached by resolveYT method automatically
const res = await resolveYT(descriptor)
if (!res) return // couldn't find it on lbry, so we're done
const { redirect, targetPlatform } = await getExtensionSettingsAsync('redirect', 'targetPlatform');
return { descriptor, lbryPathname: res, redirect, targetPlatform };
const { redirect, targetPlatform } = await getExtensionSettingsAsync('redirect', 'targetPlatform')
return { descriptor, lbryPathname: res, redirect, targetPlatform }
})())
await promise
delete ctxFromURLOnGoingPromise[descriptor.id]
return await promise
}
// handles lbry.tv -> lbry app redirect