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

another fix for axtivity tracking, Movies play pause state was not being tracked

Browse Source
This commit is contained in:
CyferShepard
2024-04-09 19:00:23 +02:00
parent eb0b901d89
commit 36e1946ce7
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
backend/tasks/ActivityMonitor.js
View File

@@ -50,10 +50,10 @@ async function ActivityMonitor(interval) {
(wdData) =>
wdData.Id === session.Id &&
wdData.UserId === session.UserId &&
(session.NowPlayingItem.SeriesId
(session.NowPlayingItem.SeriesId != undefined
? wdData.NowPlayingItemId === session.NowPlayingItem.SeriesId
: wdData.NowPlayingItemId === session.NowPlayingItem.Id) &&
wdData.EpisodeId === session.NowPlayingItem.Id
(session.NowPlayingItem.SeriesId != undefined ? wdData.EpisodeId === session.NowPlayingItem.Id : true)
)
).map(jf_activity_watchdog_mapping);
@@ -62,10 +62,10 @@ async function ActivityMonitor(interval) {
(sessionData) =>
wdData.Id === sessionData.Id &&
wdData.UserId === sessionData.UserId &&
(sessionData.NowPlayingItem.SeriesId
(sessionData.NowPlayingItem.SeriesId != undefined
? wdData.NowPlayingItemId === sessionData.NowPlayingItem.SeriesId
: wdData.NowPlayingItemId === sessionData.NowPlayingItem.Id) &&
wdData.EpisodeId === sessionData.NowPlayingItem.Id
(sessionData.NowPlayingItem.SeriesId != undefined ? wdData.EpisodeId === sessionData.NowPlayingItem.Id : true)
);
if (session && session.PlayState) {
if (wdData.IsPaused != session.PlayState.IsPaused) {
@@ -79,11 +79,13 @@ async function ActivityMonitor(interval) {
if (WatchdogDataToInsert.length > 0) {
//insert new rows where not existing items
// console.log("Inserted " + WatchdogDataToInsert.length + " wd playback records");
db.insertBulk("jf_activity_watchdog", WatchdogDataToInsert, jf_activity_watchdog_columns);
}
//update wd state
if (WatchdogDataToUpdate.length > 0) {
// console.log("Updated " + WatchdogDataToUpdate.length + " existing playback records");
const WatchdogDataUpdated = WatchdogDataToUpdate.map((obj) => {
let startTime = moment(obj.ActivityDateInserted, "YYYY-MM-DD HH:mm:ss.SSSZ");
let endTime = moment();
@@ -213,10 +215,12 @@ async function ActivityMonitor(interval) {
}
if (playbackToInsert.length > 0) {
await db.insertBulk("jf_playback_activity", playbackToInsert, columnsPlayback);
// console.log("Inserted " + playbackToInsert.length + " new playback records");
}
if (ExistingDataToUpdate.length > 0) {
await db.insertBulk("jf_playback_activity", ExistingDataToUpdate, columnsPlayback);
// console.log("Updated " + playbackToInsert.length + " playback records");
}
///////////////////////////