@@ -21,48 +21,48 @@ |
||
| 21 | 21 | |
| 22 | 22 | class ChunkCleanup implements IRepairStep { |
| 23 | 23 | |
| 24 | - public function __construct( |
|
| 25 | - private IConfig $config, |
|
| 26 | - private IUserManager $userManager, |
|
| 27 | - private IRootFolder $rootFolder, |
|
| 28 | - private IJobList $jobList, |
|
| 29 | - ) { |
|
| 30 | - } |
|
| 24 | + public function __construct( |
|
| 25 | + private IConfig $config, |
|
| 26 | + private IUserManager $userManager, |
|
| 27 | + private IRootFolder $rootFolder, |
|
| 28 | + private IJobList $jobList, |
|
| 29 | + ) { |
|
| 30 | + } |
|
| 31 | 31 | |
| 32 | - public function getName(): string { |
|
| 33 | - return 'Chunk cleanup scheduler'; |
|
| 34 | - } |
|
| 32 | + public function getName(): string { |
|
| 33 | + return 'Chunk cleanup scheduler'; |
|
| 34 | + } |
|
| 35 | 35 | |
| 36 | - public function run(IOutput $output) { |
|
| 37 | - // If we already ran this onec there is no need to run it again |
|
| 38 | - if ($this->config->getAppValue('dav', 'chunks_migrated', '0') === '1') { |
|
| 39 | - $output->info('Cleanup not required'); |
|
| 40 | - return; |
|
| 41 | - } |
|
| 36 | + public function run(IOutput $output) { |
|
| 37 | + // If we already ran this onec there is no need to run it again |
|
| 38 | + if ($this->config->getAppValue('dav', 'chunks_migrated', '0') === '1') { |
|
| 39 | + $output->info('Cleanup not required'); |
|
| 40 | + return; |
|
| 41 | + } |
|
| 42 | 42 | |
| 43 | - $output->startProgress(); |
|
| 44 | - // Loop over all seen users |
|
| 45 | - $this->userManager->callForSeenUsers(function (IUser $user) use ($output): void { |
|
| 46 | - try { |
|
| 47 | - $userFolder = $this->rootFolder->getUserFolder($user->getUID()); |
|
| 48 | - $userRoot = $userFolder->getParent(); |
|
| 49 | - /** @var Folder $uploadFolder */ |
|
| 50 | - $uploadFolder = $userRoot->get('uploads'); |
|
| 51 | - } catch (NotFoundException $e) { |
|
| 52 | - // No folder so skipping |
|
| 53 | - return; |
|
| 54 | - } |
|
| 43 | + $output->startProgress(); |
|
| 44 | + // Loop over all seen users |
|
| 45 | + $this->userManager->callForSeenUsers(function (IUser $user) use ($output): void { |
|
| 46 | + try { |
|
| 47 | + $userFolder = $this->rootFolder->getUserFolder($user->getUID()); |
|
| 48 | + $userRoot = $userFolder->getParent(); |
|
| 49 | + /** @var Folder $uploadFolder */ |
|
| 50 | + $uploadFolder = $userRoot->get('uploads'); |
|
| 51 | + } catch (NotFoundException $e) { |
|
| 52 | + // No folder so skipping |
|
| 53 | + return; |
|
| 54 | + } |
|
| 55 | 55 | |
| 56 | - // Insert a cleanup job for each folder we find |
|
| 57 | - $uploads = $uploadFolder->getDirectoryListing(); |
|
| 58 | - foreach ($uploads as $upload) { |
|
| 59 | - $this->jobList->add(UploadCleanup::class, ['uid' => $user->getUID(), 'folder' => $upload->getName()]); |
|
| 60 | - } |
|
| 61 | - $output->advance(); |
|
| 62 | - }); |
|
| 63 | - $output->finishProgress(); |
|
| 56 | + // Insert a cleanup job for each folder we find |
|
| 57 | + $uploads = $uploadFolder->getDirectoryListing(); |
|
| 58 | + foreach ($uploads as $upload) { |
|
| 59 | + $this->jobList->add(UploadCleanup::class, ['uid' => $user->getUID(), 'folder' => $upload->getName()]); |
|
| 60 | + } |
|
| 61 | + $output->advance(); |
|
| 62 | + }); |
|
| 63 | + $output->finishProgress(); |
|
| 64 | 64 | |
| 65 | 65 | |
| 66 | - $this->config->setAppValue('dav', 'chunks_migrated', '1'); |
|
| 67 | - } |
|
| 66 | + $this->config->setAppValue('dav', 'chunks_migrated', '1'); |
|
| 67 | + } |
|
| 68 | 68 | } |