chrisryn/requestarr
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

fix(watch-data): use sentinel values to avoid invalid SQL syntax (#2552)

Browse Source
This commit is contained in:
0xsysr3ll
2026-02-23 21:24:48 +01:00
committed by GitHub
parent 3a42f593d5
commit 947f70c3d7
2 changed files with 15 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
server/routes/media.ts
View File

@@ -315,12 +315,12 @@ mediaRoutes.get<{ id: string }, MediaWatchDataResponse>(
if (media.ratingKey) {
const watchStats = await tautulli.getMediaWatchStats(media.ratingKey);
const watchUsers = await tautulli.getMediaWatchUsers(media.ratingKey);
const plexIds = watchUsers.map((u) => u.user_id);
if (!plexIds.length) plexIds.push(-1);
const users = await userRepository
.createQueryBuilder('user')
.where('user.plexId IN (:...plexIds)', {
plexIds: watchUsers.map((u) => u.user_id),
})
.where('user.plexId IN (:...plexIds)', { plexIds })
.getMany();
const playCount =
@@ -347,12 +347,12 @@ mediaRoutes.get<{ id: string }, MediaWatchDataResponse>(
const watchUsers4k = await tautulli.getMediaWatchUsers(
media.ratingKey4k
);
const plexIds4k = watchUsers4k.map((u) => u.user_id);
if (!plexIds4k.length) plexIds4k.push(-1);
const users = await userRepository
.createQueryBuilder('user')
.where('user.plexId IN (:...plexIds)', {
plexIds: watchUsers4k.map((u) => u.user_id),
})
.where('user.plexId IN (:...plexIds)', { plexIds: plexIds4k })
.getMany();
const playCount =

15
server/routes/settings/index.ts
View File

@@ -494,13 +494,16 @@ settingsRoutes.get(
thumb: string;
}[] = [];
const plexIds = plexUsers.map((plexUser) => plexUser.id);
const plexEmails = plexUsers.map((plexUser) =>
plexUser.email.toLowerCase()
);
if (!plexIds.length) plexIds.push('-1');
if (!plexEmails.length) plexEmails.push('@');
const existingUsers = await qb
.where('user.plexId IN (:...plexIds)', {
plexIds: plexUsers.map((plexUser) => plexUser.id),
})
.orWhere('user.email IN (:...plexEmails)', {
plexEmails: plexUsers.map((plexUser) => plexUser.email.toLowerCase()),
})
.where('user.plexId IN (:...plexIds)', { plexIds })
.orWhere('user.email IN (:...plexEmails)', { plexEmails })
.getMany();
await Promise.all(