From b515c6c7460a65b74b1d8e76f88c5fd0abbc0e5d Mon Sep 17 00:00:00 2001 From: advplyr Date: Sat, 14 Jun 2025 17:56:35 -0500 Subject: [PATCH] Remove mediaProgresses duplicate check --- server/Database.js | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/server/Database.js b/server/Database.js index 2413a269..eb384f25 100644 --- a/server/Database.js +++ b/server/Database.js @@ -767,13 +767,13 @@ class Database { } // Remove mediaProgresses with duplicate mediaItemId (remove the oldest updatedAt) - const [duplicateMediaProgresses] = await this.sequelize.query(`SELECT id, mediaItemId FROM mediaProgresses WHERE (mediaItemId, updatedAt) IN (SELECT mediaItemId, MIN(updatedAt) FROM mediaProgresses GROUP BY mediaItemId HAVING COUNT(*) > 1)`) - for (const duplicateMediaProgress of duplicateMediaProgresses) { - Logger.warn(`Found duplicate mediaProgress for mediaItem "${duplicateMediaProgress.mediaItemId}" - removing it`) - await this.mediaProgressModel.destroy({ - where: { id: duplicateMediaProgress.id } - }) - } + // const [duplicateMediaProgresses] = await this.sequelize.query(`SELECT id, mediaItemId FROM mediaProgresses WHERE (mediaItemId, userId, updatedAt) IN (SELECT mediaItemId, userId, MIN(updatedAt) FROM mediaProgresses GROUP BY mediaItemId, userId HAVING COUNT(*) > 1)`) + // for (const duplicateMediaProgress of duplicateMediaProgresses) { + // Logger.warn(`Found duplicate mediaProgress for mediaItem "${duplicateMediaProgress.mediaItemId}" - removing it`) + // await this.mediaProgressModel.destroy({ + // where: { id: duplicateMediaProgress.id } + // }) + // } } async createTextSearchQuery(query) {