chore(trash-expiration): added new partial index and drop old index (#998)

Author: apsantiso

migrations/20260316162527-add-updated-at-user-id-uuid-partial-index-trashed-items.js

@@ -0,0 +1,19 @@
+'use strict';
+
+const indexName = 'idx_files_updated_at_user_id';
+
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    await queryInterface.sequelize.query(`
+      CREATE INDEX CONCURRENTLY IF NOT EXISTS ${indexName}
+      ON files (updated_at, user_id, uuid)
+      WHERE status = 'TRASHED'
+    `);
+  },
+
+  async down(queryInterface, Sequelize) {
+    await queryInterface.sequelize.query(`
+      DROP INDEX CONCURRENTLY IF EXISTS ${indexName}
+    `);
+  },
+};

migrations/20260316162529-drop-index-files-status-trash.js

@@ -0,0 +1,17 @@
+'use strict';
+
+const indexName = 'idx_files_status_trash';
+
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    await queryInterface.sequelize.query(
+      `DROP INDEX CONCURRENTLY IF EXISTS ${indexName}`,
+    );
+  },
+
+  async down(queryInterface, Sequelize) {
+    await queryInterface.sequelize.query(
+      `CREATE INDEX CONCURRENTLY IF NOT EXISTS ${indexName} ON files (user_id, updated_at, uuid) WHERE status = 'TRASHED'`,
+    );
+  },
+};

src/modules/jobs/tasks/delete-expired-trash-items.task.ts

@@ -225,11 +225,6 @@ export class DeleteExpiredTrashItemsTask implements BeforeApplicationShutdown {
       }
 
       totalDeleted += deletedUuids.length;
-
-      // TODO: Remove the delay after ensuring the deletion queue is not overwhelmed
-      await new Promise((resolve) =>
-        setTimeout(resolve, 500 + Math.random() * 1500),
-      );
     } while (deletedUuids.length === this.batchSize);
 
     onFinish(totalDeleted);