mirror of
https://github.com/nextcloud/server.git
synced 2026-04-24 23:59:27 -04:00
fix: Catch exceptions when expiring trashbin
Signed-off-by: Louis Chemineau <louis@chmn.me>
This commit is contained in:
parent
d6c16e95b0
commit
bea43d14c8
3 changed files with 29 additions and 12 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,
|
||||
) {
|
||||
|
|
@ -77,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