mirror of
https://github.com/nextcloud/server.git
synced 2026-06-10 09:13:19 -04:00
Merge pull request #51861 from nextcloud/artonge/fix/catch_exception_in_expire_trash
fix: Catch exceptions when expiring trashbin
This commit is contained in:
commit
07f4c10919
3 changed files with 33 additions and 14 deletions
|
|
@ -14,12 +14,14 @@ use OCP\AppFramework\Utility\ITimeFactory;
|
|||
use OCP\BackgroundJob\TimedJob;
|
||||
use OCP\IAppConfig;
|
||||
use OCP\IUserManager;
|
||||
use Psr\Log\LoggerInterface;
|
||||
|
||||
class ExpireTrash extends TimedJob {
|
||||
public function __construct(
|
||||
private IAppConfig $appConfig,
|
||||
private IUserManager $userManager,
|
||||
private Expiration $expiration,
|
||||
private LoggerInterface $logger,
|
||||
ITimeFactory $time,
|
||||
) {
|
||||
parent::__construct($time);
|
||||
|
|
@ -43,12 +45,16 @@ class ExpireTrash extends TimedJob {
|
|||
$users = $this->userManager->getSeenUsers($offset);
|
||||
|
||||
foreach ($users as $user) {
|
||||
$uid = $user->getUID();
|
||||
if (!$this->setupFS($uid)) {
|
||||
continue;
|
||||
try {
|
||||
$uid = $user->getUID();
|
||||
if (!$this->setupFS($uid)) {
|
||||
continue;
|
||||
}
|
||||
$dirContent = Helper::getTrashFiles('/', $uid, 'mtime');
|
||||
Trashbin::deleteExpiredFiles($dirContent, $uid);
|
||||
} catch (\Throwable $e) {
|
||||
$this->logger->error('Error while expiring trashbin for user ' . $user->getUID(), ['exception' => $e]);
|
||||
}
|
||||
$dirContent = Helper::getTrashFiles('/', $uid, 'mtime');
|
||||
Trashbin::deleteExpiredFiles($dirContent, $uid);
|
||||
|
||||
$offset++;
|
||||
|
||||
|
|
|
|||
|
|
@ -12,6 +12,7 @@ use OCA\Files_Trashbin\Helper;
|
|||
use OCA\Files_Trashbin\Trashbin;
|
||||
use OCP\IUser;
|
||||
use OCP\IUserManager;
|
||||
use Psr\Log\LoggerInterface;
|
||||
use Symfony\Component\Console\Command\Command;
|
||||
use Symfony\Component\Console\Helper\ProgressBar;
|
||||
use Symfony\Component\Console\Input\InputArgument;
|
||||
|
|
@ -25,6 +26,7 @@ class ExpireTrash extends Command {
|
|||
* @param Expiration|null $expiration
|
||||
*/
|
||||
public function __construct(
|
||||
private LoggerInterface $logger,
|
||||
private ?IUserManager $userManager = null,
|
||||
private ?Expiration $expiration = null,
|
||||
) {
|
||||
|
|
@ -64,10 +66,12 @@ class ExpireTrash extends Command {
|
|||
} else {
|
||||
$p = new ProgressBar($output);
|
||||
$p->start();
|
||||
$this->userManager->callForSeenUsers(function (IUser $user) use ($p): void {
|
||||
|
||||
$users = $this->userManager->getSeenUsers();
|
||||
foreach ($users as $user) {
|
||||
$p->advance();
|
||||
$this->expireTrashForUser($user);
|
||||
});
|
||||
}
|
||||
$p->finish();
|
||||
$output->writeln('');
|
||||
}
|
||||
|
|
@ -75,12 +79,16 @@ class ExpireTrash extends Command {
|
|||
}
|
||||
|
||||
public function expireTrashForUser(IUser $user) {
|
||||
$uid = $user->getUID();
|
||||
if (!$this->setupFS($uid)) {
|
||||
return;
|
||||
try {
|
||||
$uid = $user->getUID();
|
||||
if (!$this->setupFS($uid)) {
|
||||
return;
|
||||
}
|
||||
$dirContent = Helper::getTrashFiles('/', $uid, 'mtime');
|
||||
Trashbin::deleteExpiredFiles($dirContent, $uid);
|
||||
} catch (\Throwable $e) {
|
||||
$this->logger->error('Error while expiring trashbin for user ' . $user->getUID(), ['exception' => $e]);
|
||||
}
|
||||
$dirContent = Helper::getTrashFiles('/', $uid, 'mtime');
|
||||
Trashbin::deleteExpiredFiles($dirContent, $uid);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -14,6 +14,7 @@ use OCP\BackgroundJob\IJobList;
|
|||
use OCP\IAppConfig;
|
||||
use OCP\IUserManager;
|
||||
use PHPUnit\Framework\MockObject\MockObject;
|
||||
use Psr\Log\LoggerInterface;
|
||||
use Test\TestCase;
|
||||
|
||||
class ExpireTrashTest extends TestCase {
|
||||
|
|
@ -29,6 +30,9 @@ class ExpireTrashTest extends TestCase {
|
|||
/** @var IJobList&MockObject */
|
||||
private $jobList;
|
||||
|
||||
/** @var LoggerInterface&MockObject */
|
||||
private $logger;
|
||||
|
||||
/** @var ITimeFactory&MockObject */
|
||||
private $time;
|
||||
|
||||
|
|
@ -39,6 +43,7 @@ class ExpireTrashTest extends TestCase {
|
|||
$this->userManager = $this->createMock(IUserManager::class);
|
||||
$this->expiration = $this->createMock(Expiration::class);
|
||||
$this->jobList = $this->createMock(IJobList::class);
|
||||
$this->logger = $this->createMock(LoggerInterface::class);
|
||||
|
||||
$this->time = $this->createMock(ITimeFactory::class);
|
||||
$this->time->method('getTime')
|
||||
|
|
@ -58,7 +63,7 @@ class ExpireTrashTest extends TestCase {
|
|||
->with('files_trashbin', 'background_job_expire_trash_offset', 0)
|
||||
->willReturn(0);
|
||||
|
||||
$job = new ExpireTrash($this->appConfig, $this->userManager, $this->expiration, $this->time);
|
||||
$job = new ExpireTrash($this->appConfig, $this->userManager, $this->expiration, $this->logger, $this->time);
|
||||
$job->start($this->jobList);
|
||||
}
|
||||
|
||||
|
|
@ -69,7 +74,7 @@ class ExpireTrashTest extends TestCase {
|
|||
$this->expiration->expects($this->never())
|
||||
->method('getMaxAgeAsTimestamp');
|
||||
|
||||
$job = new ExpireTrash($this->appConfig, $this->userManager, $this->expiration, $this->time);
|
||||
$job = new ExpireTrash($this->appConfig, $this->userManager, $this->expiration, $this->logger, $this->time);
|
||||
$job->start($this->jobList);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in a new issue