@@ -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 | } |