123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123 |
- <?php
- namespace OCA\Files\BackgroundJob;
- use OC\Files\Utils\Scanner;
- use OCP\AppFramework\Utility\ITimeFactory;
- use OCP\BackgroundJob\TimedJob;
- use OCP\DB\QueryBuilder\IQueryBuilder;
- use OCP\EventDispatcher\IEventDispatcher;
- use OCP\IConfig;
- use OCP\IDBConnection;
- use Psr\Log\LoggerInterface;
- class ScanFiles extends TimedJob {
- private IConfig $config;
- private IEventDispatcher $dispatcher;
- private LoggerInterface $logger;
- private IDBConnection $connection;
-
- public const USERS_PER_SESSION = 500;
- public function __construct(
- IConfig $config,
- IEventDispatcher $dispatcher,
- LoggerInterface $logger,
- IDBConnection $connection,
- ITimeFactory $time
- ) {
- parent::__construct($time);
-
- $this->setInterval(60 * 10);
- $this->config = $config;
- $this->dispatcher = $dispatcher;
- $this->logger = $logger;
- $this->connection = $connection;
- }
- protected function runScanner(string $user): void {
- try {
- $scanner = new Scanner(
- $user,
- null,
- $this->dispatcher,
- $this->logger
- );
- $scanner->backgroundScan('');
- } catch (\Exception $e) {
- $this->logger->error($e->getMessage(), ['exception' => $e, 'app' => 'files']);
- }
- \OC_Util::tearDownFS();
- }
-
- private function getUserToScan() {
- $query = $this->connection->getQueryBuilder();
- $query->select('user_id')
- ->from('filecache', 'f')
- ->innerJoin('f', 'mounts', 'm', $query->expr()->eq('storage_id', 'storage'))
- ->where($query->expr()->lt('size', $query->createNamedParameter(0, IQueryBuilder::PARAM_INT)))
- ->andWhere($query->expr()->gt('parent', $query->createNamedParameter(-1, IQueryBuilder::PARAM_INT)))
- ->setMaxResults(1);
- return $query->executeQuery()->fetchOne();
- }
-
- protected function run($argument) {
- if ($this->config->getSystemValueBool('files_no_background_scan', false)) {
- return;
- }
- $usersScanned = 0;
- $lastUser = '';
- $user = $this->getUserToScan();
- while ($user && $usersScanned < self::USERS_PER_SESSION && $lastUser !== $user) {
- $this->runScanner($user);
- $lastUser = $user;
- $user = $this->getUserToScan();
- $usersScanned += 1;
- }
- if ($lastUser === $user) {
- $this->logger->warning("User $user still has unscanned files after running background scan, background scan might be stopped prematurely");
- }
- }
- }
|