summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts
diff options
context:
space:
mode:
authormisskey-release-bot[bot] <157398866+misskey-release-bot[bot]@users.noreply.github.com>2025-07-18 00:28:01 +0000
committerGitHub <noreply@github.com>2025-07-18 00:28:01 +0000
commite86e9b46b3c30391296f04842529f9f8411dcbba (patch)
treebbe0f31106c393c1a742183aedd1c39ccdfa39a2 /packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts
parentMerge pull request #16197 from misskey-dev/develop (diff)
parentRelease: 2025.7.0 (diff)
downloadmisskey-e86e9b46b3c30391296f04842529f9f8411dcbba.tar.gz
misskey-e86e9b46b3c30391296f04842529f9f8411dcbba.tar.bz2
misskey-e86e9b46b3c30391296f04842529f9f8411dcbba.zip
Merge pull request #16244 from misskey-dev/develop
Release: 2025.7.0
Diffstat (limited to 'packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts')
-rw-r--r--packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts12
1 files changed, 6 insertions, 6 deletions
diff --git a/packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts b/packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts
index 728fc9e72b..782b74f0cd 100644
--- a/packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts
+++ b/packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts
@@ -34,6 +34,11 @@ export class CleanRemoteFilesProcessorService {
let deletedCount = 0;
let cursor: MiDriveFile['id'] | null = null;
+ const total = await this.driveFilesRepository.countBy({
+ userHost: Not(IsNull()),
+ isLink: false,
+ });
+
while (true) {
const files = await this.driveFilesRepository.find({
where: {
@@ -58,12 +63,7 @@ export class CleanRemoteFilesProcessorService {
deletedCount += 8;
- const total = await this.driveFilesRepository.countBy({
- userHost: Not(IsNull()),
- isLink: false,
- });
-
- job.updateProgress(100 / total * deletedCount);
+ job.updateProgress(deletedCount * total / 100);
}
this.logger.succ('All cached remote files has been deleted.');