From 6f2f295cf3728145884c837d02c0368df28ded26 Mon Sep 17 00:00:00 2001
From: Min Idzelis <min123@gmail.com>
Date: Sun, 15 Jun 2025 02:22:37 +0000
Subject: [PATCH] refactor(server): clean up asset repository and add
 getTrashedIds method

- Remove redundant return statement in asset repository update method
- Add getTrashedIds method to trash repository for retrieving trashed asset IDs by user
---
 server/src/repositories/asset.repository.ts |  2 --
 server/src/repositories/trash.repository.ts | 10 ++++++++++
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/server/src/repositories/asset.repository.ts b/server/src/repositories/asset.repository.ts
index af5239ed70..b624bfe92b 100644
--- a/server/src/repositories/asset.repository.ts
+++ b/server/src/repositories/asset.repository.ts
@@ -443,8 +443,6 @@ export class AssetRepository {
         .$call((qb) => qb.select(withFacesAndPeople))
         .executeTakeFirst();
     }
-
-    return this.getById(asset.id, { exifInfo: true, faces: { person: true } });
   }
 
   async remove(asset: { id: string }): Promise<void> {
diff --git a/server/src/repositories/trash.repository.ts b/server/src/repositories/trash.repository.ts
index 69507b1d58..c352d5cd54 100644
--- a/server/src/repositories/trash.repository.ts
+++ b/server/src/repositories/trash.repository.ts
@@ -11,6 +11,16 @@ export class TrashRepository {
     return this.db.selectFrom('assets').select(['id']).where('status', '=', AssetStatus.DELETED).stream();
   }
 
+  @GenerateSql({ params: [DummyValue.UUID] })
+  getTrashedIds(userId: string): AsyncIterableIterator<{ id: string }> {
+    return this.db
+      .selectFrom('assets')
+      .select(['id'])
+      .where('ownerId', '=', userId)
+      .where('status', '=', AssetStatus.TRASHED)
+      .stream();
+  }
+
   @GenerateSql({ params: [DummyValue.UUID] })
   async restore(userId: string): Promise<number> {
     const { numUpdatedRows } = await this.db