From ceab17ec276168ee58dcdeff40cb11ea04397394 Mon Sep 17 00:00:00 2001
From: Pas <74743263+Pasithea0@users.noreply.github.com>
Date: Thu, 30 Oct 2025 13:01:02 -0600
Subject: [PATCH] add way to manually delete progress

this works quite differently than the bookmarks since bookmarks overwrites all the bookmarks when we post. But progress items are loaded and send individually via the server to save bandwidth. Since the player posts progress every 5s
---
 server/routes/users/[id]/progress.ts | 86 ++++++++++++++++++++++++++++
 1 file changed, 86 insertions(+)

diff --git a/server/routes/users/[id]/progress.ts b/server/routes/users/[id]/progress.ts
index cad51d3..9aad4fd 100644
--- a/server/routes/users/[id]/progress.ts
+++ b/server/routes/users/[id]/progress.ts
@@ -130,6 +130,92 @@ export default defineEventHandler(async event => {
     }));
   }
 
+  if (method === 'DELETE' && event.path.endsWith('/progress/cleanup')) {
+    // Clean up unwanted progress items (unwatched or finished)
+    const allItems = await prisma.progress_items.findMany({
+      where: { user_id: userId },
+    });
+
+    const itemsToDelete: string[] = [];
+
+    // Group items by tmdbId for show processing
+    const itemsByTmdbId: Record<string, any[]> = {};
+    for (const item of allItems) {
+      if (!itemsByTmdbId[item.tmdb_id]) {
+        itemsByTmdbId[item.tmdb_id] = [];
+      }
+      itemsByTmdbId[item.tmdb_id].push(item);
+    }
+
+    for (const [tmdbId, items] of Object.entries(itemsByTmdbId)) {
+      const movieItems = items.filter(item => !item.episode_id);
+      const episodeItems = items.filter(item => item.episode_id);
+
+      // Process movies
+      for (const item of movieItems) {
+        const duration = Number(item.duration);
+        const watched = Number(item.watched);
+        const isNotStarted = progressIsNotStarted(duration, watched);
+        const isCompleted = progressIsCompleted(duration, watched);
+
+        if (isNotStarted || isCompleted) {
+          itemsToDelete.push(item.id);
+        }
+      }
+
+      // Process episodes - group by season
+      const episodesBySeason: Record<string, any[]> = {};
+      for (const item of episodeItems) {
+        const seasonKey = `${item.season_id}`;
+        if (!episodesBySeason[seasonKey]) {
+          episodesBySeason[seasonKey] = [];
+        }
+        episodesBySeason[seasonKey].push(item);
+      }
+
+      for (const seasonItems of Object.values(episodesBySeason)) {
+        // Check if season has any acceptable episodes
+        const hasAcceptableEpisodes = seasonItems.some((item: any) => {
+          const duration = Number(item.duration);
+          const watched = Number(item.watched);
+          return !progressIsNotStarted(duration, watched) &&
+                 !progressIsCompleted(duration, watched);
+        });
+
+        if (hasAcceptableEpisodes) {
+          // If season has acceptable episodes, only delete unacceptable ones
+          for (const item of seasonItems) {
+            const duration = Number(item.duration);
+            const watched = Number(item.watched);
+            const isNotStarted = progressIsNotStarted(duration, watched);
+            const isCompleted = progressIsCompleted(duration, watched);
+
+            if (isNotStarted || isCompleted) {
+              itemsToDelete.push(item.id);
+            }
+          }
+        } else {
+          // If no acceptable episodes in season, delete all
+          itemsToDelete.push(...seasonItems.map((item: any) => item.id));
+        }
+      }
+    }
+
+    if (itemsToDelete.length > 0) {
+      await prisma.progress_items.deleteMany({
+        where: {
+          id: { in: itemsToDelete },
+          user_id: userId,
+        },
+      });
+    }
+
+    return {
+      deletedCount: itemsToDelete.length,
+      message: `Cleaned up ${itemsToDelete.length} unwanted progress items`,
+    };
+  }
+
   if (event.path.includes('/progress/') && !event.path.endsWith('/import')) {
     const segments = event.path.split('/');
     const tmdbId = segments[segments.length - 1];