0ct0pu5/homepage
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

fix plex proxy async bug

Browse source
This commit is contained in:
Michael Shamoon 2022-12-10 22:26:35 -08:00
parent ccc1229098
commit 146326f427
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/widgets/plex/proxy.js
View file

@ -93,7 +93,8 @@ export default async function plexProxyHandler(req, res) {
movies = 0; movies = 0;
tv = 0; tv = 0;
logger.debug("Getting movie + tv counts from Plex API"); logger.debug("Getting movie + tv counts from Plex API");
await libraries.filter(l => ["movie", "show"].includes(l._attributes.type)).forEach(async (library) => { const movieTVLibraries = libraries.filter(l => ["movie", "show"].includes(l._attributes.type));
await Promise.all(movieTVLibraries.map(async (library) => {
[status, apiData] = await fetchFromPlexAPI(`/library/sections/${library._attributes.key}/all`, widget); [status, apiData] = await fetchFromPlexAPI(`/library/sections/${library._attributes.key}/all`, widget);
if (apiData && apiData.MediaContainer) { if (apiData && apiData.MediaContainer) {
const size = parseInt(apiData.MediaContainer._attributes.size, 10); const size = parseInt(apiData.MediaContainer._attributes.size, 10);
@ -103,9 +104,9 @@ export default async function plexProxyHandler(req, res) {
tv += size; tv += size;
} }
} }
cache.put(`${tvCacheKey}.${service}`, tv, 1000 * 60 * 10); }));
cache.put(`${moviesCacheKey}.${service}`, movies, 1000 * 60 * 10); cache.put(`${tvCacheKey}.${service}`, tv, 1000 * 60 * 10);
}); cache.put(`${moviesCacheKey}.${service}`, movies, 1000 * 60 * 10);
} }
const data = { const data = {