diff --git a/lib/webPush.js b/lib/webPush.js index 6971df316..89128f09a 100644 --- a/lib/webPush.js +++ b/lib/webPush.js @@ -244,7 +244,7 @@ export const notifyItemParents = async ({ models, item }) => { try { const user = await models.user.findUnique({ where: { id: item.userId } }) const parents = await models.$queryRawUnsafe( - 'SELECT DISTINCT p."userId", (SELECT "userId" FROM "Item" WHERE id = $1) = p."userId" as "isDirect" FROM "Item" i JOIN "Item" p ON p.path @> i.path WHERE i.id = $1 and p."userId" <> $2 ' + + 'SELECT DISTINCT p."userId", i."userId" = p."userId" as "isDirect" FROM "Item" i JOIN "Item" p ON p.path @> i.path WHERE i.id = $1 and p."userId" <> $2 ' + 'AND NOT EXISTS (SELECT 1 FROM "Mute" m WHERE m."muterId" = p."userId" AND m."mutedId" = $2)', Number(item.parentId), Number(user.id)) Promise.allSettled(