BreizhHardware/Jellystat
1
0
Fork 0
mirror of https://github.com/BreizhHardware/Jellystat.git synced 2026-01-18 16:27:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

Added LastActivityDate Field to /api/getItemDetails endpoint #235

Browse Source
This commit is contained in:
CyferShepard
2024-08-08 19:01:37 +02:00
parent b7a0d8f761
commit 159679377b
2 changed files with 33 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
backend/db.js
View File

@@ -149,10 +149,24 @@ async function query(text, params) {
}
}
async function querySingle(sql, params) {
try {
const { rows: results } = await query(sql, params);
if (results.length > 0) {
return results[0];
} else {
return null;
}
} catch (error) {
throw error;
}
}
module.exports = {
query: query,
deleteBulk: deleteBulk,
insertBulk: insertBulk,
updateSingleFieldBulk: updateSingleFieldBulk,
querySingle: querySingle,
// initDB: initDB,
};

19
backend/routes/api.js
View File

@@ -807,6 +807,7 @@ router.post("/getItemDetails", async (req, res) => {
}
// let query = `SELECT im."Name" "FileName",im.*,i.* FROM jf_library_items i left join jf_item_info im on i."Id" = im."Id" where i."Id"=$1`;
let query = `SELECT im."Name" "FileName",im."Id",im."Path",im."Name",im."Bitrate",im."MediaStreams",im."Type", COALESCE(im."Size" ,(SELECT SUM(im."Size") FROM jf_library_seasons s JOIN jf_library_episodes e on s."Id"=e."SeasonId" JOIN jf_item_info im ON im."Id" = e."EpisodeId" WHERE s."SeriesId" = i."Id")) "Size",i.*, (select "Name" from jf_libraries l where l."Id"=i."ParentId") "LibraryName" FROM jf_library_items i left join jf_item_info im on i."Id" = im."Id" where i."Id"=$1`;
let activityQuery = `SELECT MAX("ActivityDateInserted") "LastActivityDate" FROM public.jf_playback_activity`;
const { rows: items } = await db.query(query, [Id]);
@@ -820,14 +821,32 @@ router.post("/getItemDetails", async (req, res) => {
const { rows: episodes } = await db.query(query, [Id]);
if (episodes.length !== 0) {
activityQuery = `${activityQuery} where "EpisodeId"=$1`;
const LastActivityDate = await db.querySingle(activityQuery, [Id]);
episodes.forEach((episode) => {
episode.LastActivityDate = LastActivityDate.LastActivityDate ?? null;
});
res.send(episodes);
} else {
res.status(404).send("Item not found");
}
} else {
activityQuery = `${activityQuery} where "SeasonId"=$1`;
const LastActivityDate = await db.querySingle(activityQuery, [Id]);
seasons.forEach((season) => {
season.LastActivityDate = LastActivityDate.LastActivityDate ?? null;
});
res.send(seasons);
}
} else {
activityQuery = `${activityQuery} where "NowPlayingItemId"=$1`;
const LastActivityDate = await db.querySingle(activityQuery, [Id]);
items.forEach((item) => {
item.LastActivityDate = LastActivityDate.LastActivityDate ?? null;
});
res.send(items);
}
} catch (error) {