feat(bin): use removeFilesV1 usecase to remove frames

internxt · Jan 12, 2024 · 2cab454 · 2cab454
1 parent 2120817
commit 2cab454
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/bin/cli/tasks/clean-stalled-frames.task.ts b/bin/cli/tasks/clean-stalled-frames.task.ts
@@ -29,7 +29,7 @@ export const cleanStalledFrames: CleanStalledFramesFunctionType = async (
       }
     }
     if (toDelete.length === deleteInBulksOf) {
-      // await bucketEntriesUsecase.removeFilesV1(toDelete as any);
+      await bucketEntriesUsecase.removeFilesV1(toDelete as any);
 
       stats.totalSize += toDelete.reduce((acc, curr) => acc + curr._frame.size, 0);        
       stats.totalCount += toDelete.length;

diff --git a/lib/core/bucketEntries/usecase.ts b/lib/core/bucketEntries/usecase.ts
@@ -157,7 +157,7 @@ export class BucketEntriesUsecase {
       await this.framesRepository.deleteByIds(frames.map(f => f.id));
     }
 
-    await this.bucketEntriesRepository.deleteByIds(files.map(f => f.id));
+    // await this.bucketEntriesRepository.deleteByIds(files.map(f => f.id));
   }
 
   async removeFilesV2(files: BucketEntry[]): Promise<void> {