config = $config; $this->userManager = $userManager; $this->rootFolder = $rootFolder; $this->jobList = $jobList; } public function getName(): string { return 'Chunk cleanup scheduler'; } public function run(IOutput $output) { // If we already ran this onec there is no need to run it again if ($this->config->getAppValue('dav', 'chunks_migrated', '0') === '1') { $output->info('Cleanup not required'); } $output->startProgress(); // Loop over all seen users $this->userManager->callForSeenUsers(function (IUser $user) use ($output): void { try { $userFolder = $this->rootFolder->getUserFolder($user->getUID()); $userRoot = $userFolder->getParent(); /** @var Folder $uploadFolder */ $uploadFolder = $userRoot->get('uploads'); } catch (NotFoundException $e) { // No folder so skipping return; } // Insert a cleanup job for each folder we find $uploads = $uploadFolder->getDirectoryListing(); foreach ($uploads as $upload) { $this->jobList->add(UploadCleanup::class, ['uid' => $user->getUID(), 'folder' => $upload->getName()]); } $output->advance(); }); $output->finishProgress(); $this->config->setAppValue('dav', 'chunks_migrated', '1'); } }