1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677 |
- <?php
- declare(strict_types=1);
- namespace OCA\DAV\BackgroundJob;
- use OC\User\NoUserException;
- use OCP\AppFramework\Utility\ITimeFactory;
- use OCP\BackgroundJob\IJobList;
- use OCP\BackgroundJob\TimedJob;
- use OCP\Files\File;
- use OCP\Files\Folder;
- use OCP\Files\IRootFolder;
- use OCP\Files\NotFoundException;
- use Psr\Log\LoggerInterface;
- class UploadCleanup extends TimedJob {
- public function __construct(
- ITimeFactory $time,
- private IRootFolder $rootFolder,
- private IJobList $jobList,
- private LoggerInterface $logger,
- ) {
- parent::__construct($time);
-
- $this->setInterval(60 * 60 * 24);
- $this->setTimeSensitivity(self::TIME_INSENSITIVE);
- }
- protected function run($argument) {
- $uid = $argument['uid'];
- $folder = $argument['folder'];
- try {
- $userFolder = $this->rootFolder->getUserFolder($uid);
- $userRoot = $userFolder->getParent();
-
- $uploads = $userRoot->get('uploads');
- $uploadFolder = $uploads->get($folder);
- } catch (NotFoundException|NoUserException $e) {
- $this->jobList->remove(self::class, $argument);
- return;
- }
-
- $time = $this->time->getTime() - 60 * 60 * 24;
- if (!($uploadFolder instanceof Folder)) {
- $this->logger->error('Found a file inside the uploads folder. Uid: ' . $uid . ' folder: ' . $folder);
- if ($uploadFolder->getMTime() < $time) {
- $uploadFolder->delete();
- }
- $this->jobList->remove(self::class, $argument);
- return;
- }
-
- $files = $uploadFolder->getDirectoryListing();
-
- $initial = $uploadFolder->getMTime() < $time;
- $expire = array_reduce($files, function (bool $carry, File $file) use ($time) {
- return $carry && $file->getMTime() < $time;
- }, $initial);
- if ($expire) {
- $uploadFolder->delete();
- $this->jobList->remove(self::class, $argument);
- }
- }
- }
|