chore: use master for select (#1014)

Author: apsantiso

src/modules/file/file.repository.ts

@@ -1077,13 +1077,17 @@ export class SequelizeFileRepository implements FileRepository {
   async findDeletedFilesUpdatedBefore(
     cutoffDate: Date,
     limit: number,
+    opts?: {
+      useMaster: boolean;
+    },
   ): Promise<string[]> {
     const rows = await this.fileModel.findAll({
       attributes: ['uuid'],
       where: {
         status: FileStatus.DELETED,
         updatedAt: { [Op.lt]: cutoffDate },
       },
+      useMaster: opts?.useMaster,
       limit,
     });
 

src/modules/jobs/tasks/hard-delete-old-files/hard-delete-old-files.processor.spec.ts

@@ -97,6 +97,7 @@ describe('HardDeleteOldFilesProcessor', () => {
       expect(fileRepository.findDeletedFilesUpdatedBefore).toHaveBeenCalledWith(
         expectedCutoff,
         BATCH_SIZE,
+        { useMaster: true },
       );
     });
 

src/modules/jobs/tasks/hard-delete-old-files/hard-delete-old-files.processor.ts

@@ -24,21 +24,26 @@ export class HardDeleteOldFilesProcessor extends WorkerHost {
   }
 
   async process(_job: Job) {
-    const cutoffDate = Time.daysAgo(SIX_MONTHS_IN_DAYS);
+    try {
+      const cutoffDate = Time.daysAgo(SIX_MONTHS_IN_DAYS);
 
-    this.logger.log(
-      { cutoffDate },
-      'Starting hard-delete of old deleted files.',
-    );
+      this.logger.log(
+        { cutoffDate },
+        'Starting hard-delete of old deleted files.',
+      );
 
-    const filesDeleted = await this.deleteInBatches(cutoffDate);
+      const filesDeleted = await this.deleteInBatches(cutoffDate);
 
-    this.logger.log(
-      { filesDeleted },
-      'Hard-delete of old deleted files completed.',
-    );
+      this.logger.log(
+        { filesDeleted },
+        'Hard-delete of old deleted files completed.',
+      );
 
-    return { filesDeleted };
+      return { filesDeleted };
+    } catch (error) {
+      this.logger.error({ error }, 'Hard-delete of old deleted files failed.');
+      throw error;
+    }
   }
 
   private async deleteInBatches(cutoffDate: Date): Promise<number> {
@@ -49,6 +54,7 @@ export class HardDeleteOldFilesProcessor extends WorkerHost {
       const uuids = await this.fileRepository.findDeletedFilesUpdatedBefore(
         cutoffDate,
         BATCH_SIZE,
+        { useMaster: true },
       );
 
       this.logger.log({ uuids }, 'files to delete');