nextcloud / server

apps/files/lib/Command/Scan.php

Indentation +339 added lines, -339 removed lines

@@ -35,343 +35,343 @@
 use Symfony\Component\Console\Output\OutputInterface;
 
 class Scan extends Base {
-	protected float $execTime = 0;
-	protected int $foldersCounter = 0;
-	protected int $filesCounter = 0;
-	protected int $errorsCounter = 0;
-	protected int $newCounter = 0;
-	protected int $updatedCounter = 0;
-	protected int $removedCounter = 0;
-
-	public function __construct(
-		private IUserManager $userManager,
-		private IRootFolder $rootFolder,
-		private FilesMetadataManager $filesMetadataManager,
-		private IEventDispatcher $eventDispatcher,
-		private LoggerInterface $logger,
-	) {
-		parent::__construct();
-	}
-
-	protected function configure(): void {
-		parent::configure();
-
-		$this
-			->setName('files:scan')
-			->setDescription('rescan filesystem')
-			->addArgument(
-				'user_id',
-				InputArgument::OPTIONAL | InputArgument::IS_ARRAY,
-				'will rescan all files of the given user(s)'
-			)
-			->addOption(
-				'path',
-				'p',
-				InputOption::VALUE_REQUIRED,
-				'limit rescan to this path, eg. --path="/alice/files/Music", the user_id is determined by the path and the user_id parameter and --all are ignored'
-			)
-			->addOption(
-				'generate-metadata',
-				null,
-				InputOption::VALUE_OPTIONAL,
-				'Generate metadata for all scanned files; if specified only generate for named value',
-				''
-			)
-			->addOption(
-				'all',
-				null,
-				InputOption::VALUE_NONE,
-				'will rescan all files of all known users'
-			)->addOption(
-				'unscanned',
-				null,
-				InputOption::VALUE_NONE,
-				'only scan files which are marked as not fully scanned'
-			)->addOption(
-				'shallow',
-				null,
-				InputOption::VALUE_NONE,
-				'do not scan folders recursively'
-			)->addOption(
-				'home-only',
-				null,
-				InputOption::VALUE_NONE,
-				'only scan the home storage, ignoring any mounted external storage or share'
-			);
-	}
-
-	protected function scanFiles(
-		string $user,
-		string $path,
-		?string $scanMetadata,
-		OutputInterface $output,
-		callable $mountFilter,
-		bool $backgroundScan = false,
-		bool $recursive = true,
-	): void {
-		$connection = $this->reconnectToDatabase($output);
-		$scanner = new Scanner(
-			$user,
-			new ConnectionAdapter($connection),
-			Server::get(IEventDispatcher::class),
-			Server::get(LoggerInterface::class)
-		);
-
-		# check on each file/folder if there was a user interrupt (ctrl-c) and throw an exception
-		$scanner->listen('\OC\Files\Utils\Scanner', 'scanFile', function (string $path) use ($output, $scanMetadata): void {
-			$output->writeln("\tFile\t<info>$path</info>", OutputInterface::VERBOSITY_VERBOSE);
-			++$this->filesCounter;
-			$this->abortIfInterrupted();
-			if ($scanMetadata !== null) {
-				$node = $this->rootFolder->get($path);
-				$this->filesMetadataManager->refreshMetadata(
-					$node,
-					($scanMetadata !== '') ? IFilesMetadataManager::PROCESS_NAMED : IFilesMetadataManager::PROCESS_LIVE | IFilesMetadataManager::PROCESS_BACKGROUND,
-					$scanMetadata
-				);
-			}
-		});
-
-		$scanner->listen('\OC\Files\Utils\Scanner', 'scanFolder', function ($path) use ($output): void {
-			$output->writeln("\tFolder\t<info>$path</info>", OutputInterface::VERBOSITY_VERBOSE);
-			++$this->foldersCounter;
-			$this->abortIfInterrupted();
-		});
-
-		$scanner->listen('\OC\Files\Utils\Scanner', 'StorageNotAvailable', function (StorageNotAvailableException $e) use ($output): void {
-			$output->writeln('Error while scanning, storage not available (' . $e->getMessage() . ')', OutputInterface::VERBOSITY_VERBOSE);
-			++$this->errorsCounter;
-		});
-
-		$scanner->listen('\OC\Files\Utils\Scanner', 'normalizedNameMismatch', function ($fullPath) use ($output): void {
-			$output->writeln("\t<error>Entry \"" . $fullPath . '" will not be accessible due to incompatible encoding</error>');
-			++$this->errorsCounter;
-		});
-
-		$this->eventDispatcher->addListener(NodeAddedToCache::class, function (): void {
-			++$this->newCounter;
-		});
-		$this->eventDispatcher->addListener(FileCacheUpdated::class, function (): void {
-			++$this->updatedCounter;
-		});
-		$this->eventDispatcher->addListener(NodeRemovedFromCache::class, function (): void {
-			++$this->removedCounter;
-		});
-
-		try {
-			if ($backgroundScan) {
-				$scanner->backgroundScan($path);
-			} else {
-				$scanner->scan($path, $recursive, $mountFilter);
-			}
-		} catch (ForbiddenException $e) {
-			$output->writeln("<error>Home storage for user $user not writable or 'files' subdirectory missing</error>");
-			$output->writeln('  ' . $e->getMessage());
-			$output->writeln('Make sure you\'re running the scan command only as the user the web server runs as');
-			++$this->errorsCounter;
-		} catch (InterruptedException $e) {
-			# exit the function if ctrl-c has been pressed
-			$output->writeln('Interrupted by user');
-		} catch (NotFoundException $e) {
-			$output->writeln('<error>Path not found: ' . $e->getMessage() . '</error>');
-			++$this->errorsCounter;
-		} catch (LockedException $e) {
-			if (str_starts_with($e->getPath(), 'scanner::')) {
-				$output->writeln('<error>Another process is already scanning \'' . substr($e->getPath(), strlen('scanner::')) . '\'</error>');
-			} else {
-				throw $e;
-			}
-		} catch (\Exception $e) {
-			$output->writeln('<error>Exception during scan: ' . $e->getMessage() . '</error>');
-			$output->writeln('<error>' . $e->getTraceAsString() . '</error>');
-			++$this->errorsCounter;
-		}
-	}
-
-	public function isHomeMount(IMountPoint $mountPoint): bool {
-		// any mountpoint inside '/$user/files/'
-		return substr_count($mountPoint->getMountPoint(), '/') <= 3;
-	}
-
-	protected function execute(InputInterface $input, OutputInterface $output): int {
-		$inputPath = $input->getOption('path');
-		if ($inputPath) {
-			$inputPath = '/' . trim($inputPath, '/');
-			[, $user,] = explode('/', $inputPath, 3);
-			$users = [$user];
-		} elseif ($input->getOption('all')) {
-			$users = $this->userManager->search('');
-		} else {
-			$users = $input->getArgument('user_id');
-		}
-
-		# check quantity of users to be process and show it on the command line
-		$users_total = count($users);
-		if ($users_total === 0) {
-			$output->writeln('<error>Please specify the user id to scan, --all to scan for all users or --path=...</error>');
-			return self::FAILURE;
-		}
-
-		$this->initTools($output);
-
-		// getOption() logic on VALUE_OPTIONAL
-		$metadata = null; // null if --generate-metadata is not set, empty if option have no value, value if set
-		if ($input->getOption('generate-metadata') !== '') {
-			$metadata = $input->getOption('generate-metadata') ?? '';
-		}
-
-		$homeOnly = $input->getOption('home-only');
-		$scannedStorages = [];
-		$mountFilter = function (IMountPoint $mount) use ($homeOnly, &$scannedStorages) {
-			if ($homeOnly && !$this->isHomeMount($mount)) {
-				return false;
-			}
-
-			// when scanning multiple users, the scanner might encounter the same storage multiple times (e.g. external storages, or group folders)
-			// we can filter out any storage we've already scanned to avoid double work
-			$storage = $mount->getStorage();
-			$storageKey = $storage->getId();
-			while ($storage->instanceOfStorage(Jail::class)) {
-				$storageKey .= '/' . $storage->getUnjailedPath('');
-				$storage = $storage->getUnjailedStorage();
-			}
-			if (array_key_exists($storageKey, $scannedStorages)) {
-				return false;
-			}
-
-			$scannedStorages[$storageKey] = true;
-			return true;
-		};
-
-		$user_count = 0;
-		foreach ($users as $user) {
-			if (is_object($user)) {
-				$user = $user->getUID();
-			}
-			$path = $inputPath ?: '/' . $user;
-			++$user_count;
-			if ($this->userManager->userExists($user)) {
-				$output->writeln("Starting scan for user $user_count out of $users_total ($user)");
-				$this->scanFiles(
-					$user,
-					$path,
-					$metadata,
-					$output,
-					$mountFilter,
-					$input->getOption('unscanned'),
-					!$input->getOption('shallow'),
-				);
-				$output->writeln('', OutputInterface::VERBOSITY_VERBOSE);
-			} else {
-				$output->writeln("<error>Unknown user $user_count $user</error>");
-				$output->writeln('', OutputInterface::VERBOSITY_VERBOSE);
-			}
-
-			try {
-				$this->abortIfInterrupted();
-			} catch (InterruptedException $e) {
-				break;
-			}
-		}
-
-		$this->presentStats($output);
-		return self::SUCCESS;
-	}
-
-	/**
-	 * Initialises some useful tools for the Command
-	 */
-	protected function initTools(OutputInterface $output): void {
-		// Start the timer
-		$this->execTime = -microtime(true);
-		// Convert PHP errors to exceptions
-		set_error_handler(
-			fn (int $severity, string $message, string $file, int $line): bool =>
-				$this->exceptionErrorHandler($output, $severity, $message, $file, $line),
-			E_ALL
-		);
-	}
-
-	/**
-	 * Processes PHP errors in order to be able to show them in the output
-	 *
-	 * @see https://www.php.net/manual/en/function.set-error-handler.php
-	 *
-	 * @param int $severity the level of the error raised
-	 * @param string $message
-	 * @param string $file the filename that the error was raised in
-	 * @param int $line the line number the error was raised
-	 */
-	public function exceptionErrorHandler(OutputInterface $output, int $severity, string $message, string $file, int $line): bool {
-		if (($severity === E_DEPRECATED) || ($severity === E_USER_DEPRECATED)) {
-			// Do not show deprecation warnings
-			return false;
-		}
-		$e = new \ErrorException($message, 0, $severity, $file, $line);
-		$output->writeln('<error>Error during scan: ' . $e->getMessage() . '</error>');
-		$output->writeln('<error>' . $e->getTraceAsString() . '</error>', OutputInterface::VERBOSITY_VERY_VERBOSE);
-		++$this->errorsCounter;
-		return true;
-	}
-
-	protected function presentStats(OutputInterface $output): void {
-		// Stop the timer
-		$this->execTime += microtime(true);
-
-		$this->logger->info("Completed scan of {$this->filesCounter} files in {$this->foldersCounter} folder. Found {$this->newCounter} new, {$this->updatedCounter} updated and {$this->removedCounter} removed items");
-
-		$headers = [
-			'Folders',
-			'Files',
-			'New',
-			'Updated',
-			'Removed',
-			'Errors',
-			'Elapsed time',
-		];
-		$niceDate = $this->formatExecTime();
-		$rows = [
-			$this->foldersCounter,
-			$this->filesCounter,
-			$this->newCounter,
-			$this->updatedCounter,
-			$this->removedCounter,
-			$this->errorsCounter,
-			$niceDate,
-		];
-		$table = new Table($output);
-		$table
-			->setHeaders($headers)
-			->setRows([$rows]);
-		$table->render();
-	}
-
-
-	/**
-	 * Formats microtime into a human-readable format
-	 */
-	protected function formatExecTime(): string {
-		$secs = (int)round($this->execTime);
-		# convert seconds into HH:MM:SS form
-		return sprintf('%02d:%02d:%02d', (int)($secs / 3600), ((int)($secs / 60) % 60), $secs % 60);
-	}
-
-	protected function reconnectToDatabase(OutputInterface $output): Connection {
-		/** @var Connection $connection */
-		$connection = Server::get(Connection::class);
-		try {
-			$connection->close();
-		} catch (\Exception $ex) {
-			$output->writeln("<info>Error while disconnecting from database: {$ex->getMessage()}</info>");
-		}
-		while (!$connection->isConnected()) {
-			try {
-				$connection->connect();
-			} catch (\Exception $ex) {
-				$output->writeln("<info>Error while re-connecting to database: {$ex->getMessage()}</info>");
-				sleep(60);
-			}
-		}
-		return $connection;
-	}
+    protected float $execTime = 0;
+    protected int $foldersCounter = 0;
+    protected int $filesCounter = 0;
+    protected int $errorsCounter = 0;
+    protected int $newCounter = 0;
+    protected int $updatedCounter = 0;
+    protected int $removedCounter = 0;
+
+    public function __construct(
+        private IUserManager $userManager,
+        private IRootFolder $rootFolder,
+        private FilesMetadataManager $filesMetadataManager,
+        private IEventDispatcher $eventDispatcher,
+        private LoggerInterface $logger,
+    ) {
+        parent::__construct();
+    }
+
+    protected function configure(): void {
+        parent::configure();
+
+        $this
+            ->setName('files:scan')
+            ->setDescription('rescan filesystem')
+            ->addArgument(
+                'user_id',
+                InputArgument::OPTIONAL | InputArgument::IS_ARRAY,
+                'will rescan all files of the given user(s)'
+            )
+            ->addOption(
+                'path',
+                'p',
+                InputOption::VALUE_REQUIRED,
+                'limit rescan to this path, eg. --path="/alice/files/Music", the user_id is determined by the path and the user_id parameter and --all are ignored'
+            )
+            ->addOption(
+                'generate-metadata',
+                null,
+                InputOption::VALUE_OPTIONAL,
+                'Generate metadata for all scanned files; if specified only generate for named value',
+                ''
+            )
+            ->addOption(
+                'all',
+                null,
+                InputOption::VALUE_NONE,
+                'will rescan all files of all known users'
+            )->addOption(
+                'unscanned',
+                null,
+                InputOption::VALUE_NONE,
+                'only scan files which are marked as not fully scanned'
+            )->addOption(
+                'shallow',
+                null,
+                InputOption::VALUE_NONE,
+                'do not scan folders recursively'
+            )->addOption(
+                'home-only',
+                null,
+                InputOption::VALUE_NONE,
+                'only scan the home storage, ignoring any mounted external storage or share'
+            );
+    }
+
+    protected function scanFiles(
+        string $user,
+        string $path,
+        ?string $scanMetadata,
+        OutputInterface $output,
+        callable $mountFilter,
+        bool $backgroundScan = false,
+        bool $recursive = true,
+    ): void {
+        $connection = $this->reconnectToDatabase($output);
+        $scanner = new Scanner(
+            $user,
+            new ConnectionAdapter($connection),
+            Server::get(IEventDispatcher::class),
+            Server::get(LoggerInterface::class)
+        );
+
+        # check on each file/folder if there was a user interrupt (ctrl-c) and throw an exception
+        $scanner->listen('\OC\Files\Utils\Scanner', 'scanFile', function (string $path) use ($output, $scanMetadata): void {
+            $output->writeln("\tFile\t<info>$path</info>", OutputInterface::VERBOSITY_VERBOSE);
+            ++$this->filesCounter;
+            $this->abortIfInterrupted();
+            if ($scanMetadata !== null) {
+                $node = $this->rootFolder->get($path);
+                $this->filesMetadataManager->refreshMetadata(
+                    $node,
+                    ($scanMetadata !== '') ? IFilesMetadataManager::PROCESS_NAMED : IFilesMetadataManager::PROCESS_LIVE | IFilesMetadataManager::PROCESS_BACKGROUND,
+                    $scanMetadata
+                );
+            }
+        });
+
+        $scanner->listen('\OC\Files\Utils\Scanner', 'scanFolder', function ($path) use ($output): void {
+            $output->writeln("\tFolder\t<info>$path</info>", OutputInterface::VERBOSITY_VERBOSE);
+            ++$this->foldersCounter;
+            $this->abortIfInterrupted();
+        });
+
+        $scanner->listen('\OC\Files\Utils\Scanner', 'StorageNotAvailable', function (StorageNotAvailableException $e) use ($output): void {
+            $output->writeln('Error while scanning, storage not available (' . $e->getMessage() . ')', OutputInterface::VERBOSITY_VERBOSE);
+            ++$this->errorsCounter;
+        });
+
+        $scanner->listen('\OC\Files\Utils\Scanner', 'normalizedNameMismatch', function ($fullPath) use ($output): void {
+            $output->writeln("\t<error>Entry \"" . $fullPath . '" will not be accessible due to incompatible encoding</error>');
+            ++$this->errorsCounter;
+        });
+
+        $this->eventDispatcher->addListener(NodeAddedToCache::class, function (): void {
+            ++$this->newCounter;
+        });
+        $this->eventDispatcher->addListener(FileCacheUpdated::class, function (): void {
+            ++$this->updatedCounter;
+        });
+        $this->eventDispatcher->addListener(NodeRemovedFromCache::class, function (): void {
+            ++$this->removedCounter;
+        });
+
+        try {
+            if ($backgroundScan) {
+                $scanner->backgroundScan($path);
+            } else {
+                $scanner->scan($path, $recursive, $mountFilter);
+            }
+        } catch (ForbiddenException $e) {
+            $output->writeln("<error>Home storage for user $user not writable or 'files' subdirectory missing</error>");
+            $output->writeln('  ' . $e->getMessage());
+            $output->writeln('Make sure you\'re running the scan command only as the user the web server runs as');
+            ++$this->errorsCounter;
+        } catch (InterruptedException $e) {
+            # exit the function if ctrl-c has been pressed
+            $output->writeln('Interrupted by user');
+        } catch (NotFoundException $e) {
+            $output->writeln('<error>Path not found: ' . $e->getMessage() . '</error>');
+            ++$this->errorsCounter;
+        } catch (LockedException $e) {
+            if (str_starts_with($e->getPath(), 'scanner::')) {
+                $output->writeln('<error>Another process is already scanning \'' . substr($e->getPath(), strlen('scanner::')) . '\'</error>');
+            } else {
+                throw $e;
+            }
+        } catch (\Exception $e) {
+            $output->writeln('<error>Exception during scan: ' . $e->getMessage() . '</error>');
+            $output->writeln('<error>' . $e->getTraceAsString() . '</error>');
+            ++$this->errorsCounter;
+        }
+    }
+
+    public function isHomeMount(IMountPoint $mountPoint): bool {
+        // any mountpoint inside '/$user/files/'
+        return substr_count($mountPoint->getMountPoint(), '/') <= 3;
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int {
+        $inputPath = $input->getOption('path');
+        if ($inputPath) {
+            $inputPath = '/' . trim($inputPath, '/');
+            [, $user,] = explode('/', $inputPath, 3);
+            $users = [$user];
+        } elseif ($input->getOption('all')) {
+            $users = $this->userManager->search('');
+        } else {
+            $users = $input->getArgument('user_id');
+        }
+
+        # check quantity of users to be process and show it on the command line
+        $users_total = count($users);
+        if ($users_total === 0) {
+            $output->writeln('<error>Please specify the user id to scan, --all to scan for all users or --path=...</error>');
+            return self::FAILURE;
+        }
+
+        $this->initTools($output);
+
+        // getOption() logic on VALUE_OPTIONAL
+        $metadata = null; // null if --generate-metadata is not set, empty if option have no value, value if set
+        if ($input->getOption('generate-metadata') !== '') {
+            $metadata = $input->getOption('generate-metadata') ?? '';
+        }
+
+        $homeOnly = $input->getOption('home-only');
+        $scannedStorages = [];
+        $mountFilter = function (IMountPoint $mount) use ($homeOnly, &$scannedStorages) {
+            if ($homeOnly && !$this->isHomeMount($mount)) {
+                return false;
+            }
+
+            // when scanning multiple users, the scanner might encounter the same storage multiple times (e.g. external storages, or group folders)
+            // we can filter out any storage we've already scanned to avoid double work
+            $storage = $mount->getStorage();
+            $storageKey = $storage->getId();
+            while ($storage->instanceOfStorage(Jail::class)) {
+                $storageKey .= '/' . $storage->getUnjailedPath('');
+                $storage = $storage->getUnjailedStorage();
+            }
+            if (array_key_exists($storageKey, $scannedStorages)) {
+                return false;
+            }
+
+            $scannedStorages[$storageKey] = true;
+            return true;
+        };
+
+        $user_count = 0;
+        foreach ($users as $user) {
+            if (is_object($user)) {
+                $user = $user->getUID();
+            }
+            $path = $inputPath ?: '/' . $user;
+            ++$user_count;
+            if ($this->userManager->userExists($user)) {
+                $output->writeln("Starting scan for user $user_count out of $users_total ($user)");
+                $this->scanFiles(
+                    $user,
+                    $path,
+                    $metadata,
+                    $output,
+                    $mountFilter,
+                    $input->getOption('unscanned'),
+                    !$input->getOption('shallow'),
+                );
+                $output->writeln('', OutputInterface::VERBOSITY_VERBOSE);
+            } else {
+                $output->writeln("<error>Unknown user $user_count $user</error>");
+                $output->writeln('', OutputInterface::VERBOSITY_VERBOSE);
+            }
+
+            try {
+                $this->abortIfInterrupted();
+            } catch (InterruptedException $e) {
+                break;
+            }
+        }
+
+        $this->presentStats($output);
+        return self::SUCCESS;
+    }
+
+    /**
+     * Initialises some useful tools for the Command
+     */
+    protected function initTools(OutputInterface $output): void {
+        // Start the timer
+        $this->execTime = -microtime(true);
+        // Convert PHP errors to exceptions
+        set_error_handler(
+            fn (int $severity, string $message, string $file, int $line): bool =>
+                $this->exceptionErrorHandler($output, $severity, $message, $file, $line),
+            E_ALL
+        );
+    }
+
+    /**
+     * Processes PHP errors in order to be able to show them in the output
+     *
+     * @see https://www.php.net/manual/en/function.set-error-handler.php
+     *
+     * @param int $severity the level of the error raised
+     * @param string $message
+     * @param string $file the filename that the error was raised in
+     * @param int $line the line number the error was raised
+     */
+    public function exceptionErrorHandler(OutputInterface $output, int $severity, string $message, string $file, int $line): bool {
+        if (($severity === E_DEPRECATED) || ($severity === E_USER_DEPRECATED)) {
+            // Do not show deprecation warnings
+            return false;
+        }
+        $e = new \ErrorException($message, 0, $severity, $file, $line);
+        $output->writeln('<error>Error during scan: ' . $e->getMessage() . '</error>');
+        $output->writeln('<error>' . $e->getTraceAsString() . '</error>', OutputInterface::VERBOSITY_VERY_VERBOSE);
+        ++$this->errorsCounter;
+        return true;
+    }
+
+    protected function presentStats(OutputInterface $output): void {
+        // Stop the timer
+        $this->execTime += microtime(true);
+
+        $this->logger->info("Completed scan of {$this->filesCounter} files in {$this->foldersCounter} folder. Found {$this->newCounter} new, {$this->updatedCounter} updated and {$this->removedCounter} removed items");
+
+        $headers = [
+            'Folders',
+            'Files',
+            'New',
+            'Updated',
+            'Removed',
+            'Errors',
+            'Elapsed time',
+        ];
+        $niceDate = $this->formatExecTime();
+        $rows = [
+            $this->foldersCounter,
+            $this->filesCounter,
+            $this->newCounter,
+            $this->updatedCounter,
+            $this->removedCounter,
+            $this->errorsCounter,
+            $niceDate,
+        ];
+        $table = new Table($output);
+        $table
+            ->setHeaders($headers)
+            ->setRows([$rows]);
+        $table->render();
+    }
+
+
+    /**
+     * Formats microtime into a human-readable format
+     */
+    protected function formatExecTime(): string {
+        $secs = (int)round($this->execTime);
+        # convert seconds into HH:MM:SS form
+        return sprintf('%02d:%02d:%02d', (int)($secs / 3600), ((int)($secs / 60) % 60), $secs % 60);
+    }
+
+    protected function reconnectToDatabase(OutputInterface $output): Connection {
+        /** @var Connection $connection */
+        $connection = Server::get(Connection::class);
+        try {
+            $connection->close();
+        } catch (\Exception $ex) {
+            $output->writeln("<info>Error while disconnecting from database: {$ex->getMessage()}</info>");
+        }
+        while (!$connection->isConnected()) {
+            try {
+                $connection->connect();
+            } catch (\Exception $ex) {
+                $output->writeln("<info>Error while re-connecting to database: {$ex->getMessage()}</info>");
+                sleep(60);
+            }
+        }
+        return $connection;
+    }
 }

Spacing +23 added lines, -23 removed lines

@@ -118,7 +118,7 @@ 
 		);
 
 		# check on each file/folder if there was a user interrupt (ctrl-c) and throw an exception
-		$scanner->listen('\OC\Files\Utils\Scanner', 'scanFile', function (string $path) use ($output, $scanMetadata): void {
+		$scanner->listen('\OC\Files\Utils\Scanner', 'scanFile', function(string $path) use ($output, $scanMetadata): void {
 			$output->writeln("\tFile\t<info>$path</info>", OutputInterface::VERBOSITY_VERBOSE);
 			++$this->filesCounter;
 			$this->abortIfInterrupted();
@@ -132,29 +132,29 @@ 
 			}
 		});
 
-		$scanner->listen('\OC\Files\Utils\Scanner', 'scanFolder', function ($path) use ($output): void {
+		$scanner->listen('\OC\Files\Utils\Scanner', 'scanFolder', function($path) use ($output): void {
 			$output->writeln("\tFolder\t<info>$path</info>", OutputInterface::VERBOSITY_VERBOSE);
 			++$this->foldersCounter;
 			$this->abortIfInterrupted();
 		});
 
-		$scanner->listen('\OC\Files\Utils\Scanner', 'StorageNotAvailable', function (StorageNotAvailableException $e) use ($output): void {
-			$output->writeln('Error while scanning, storage not available (' . $e->getMessage() . ')', OutputInterface::VERBOSITY_VERBOSE);
+		$scanner->listen('\OC\Files\Utils\Scanner', 'StorageNotAvailable', function(StorageNotAvailableException $e) use ($output): void {
+			$output->writeln('Error while scanning, storage not available ('.$e->getMessage().')', OutputInterface::VERBOSITY_VERBOSE);
 			++$this->errorsCounter;
 		});
 
-		$scanner->listen('\OC\Files\Utils\Scanner', 'normalizedNameMismatch', function ($fullPath) use ($output): void {
-			$output->writeln("\t<error>Entry \"" . $fullPath . '" will not be accessible due to incompatible encoding</error>');
+		$scanner->listen('\OC\Files\Utils\Scanner', 'normalizedNameMismatch', function($fullPath) use ($output): void {
+			$output->writeln("\t<error>Entry \"".$fullPath.'" will not be accessible due to incompatible encoding</error>');
 			++$this->errorsCounter;
 		});
 
-		$this->eventDispatcher->addListener(NodeAddedToCache::class, function (): void {
+		$this->eventDispatcher->addListener(NodeAddedToCache::class, function(): void {
 			++$this->newCounter;
 		});
-		$this->eventDispatcher->addListener(FileCacheUpdated::class, function (): void {
+		$this->eventDispatcher->addListener(FileCacheUpdated::class, function(): void {
 			++$this->updatedCounter;
 		});
-		$this->eventDispatcher->addListener(NodeRemovedFromCache::class, function (): void {
+		$this->eventDispatcher->addListener(NodeRemovedFromCache::class, function(): void {
 			++$this->removedCounter;
 		});
 
@@ -166,24 +166,24 @@ 
 			}
 		} catch (ForbiddenException $e) {
 			$output->writeln("<error>Home storage for user $user not writable or 'files' subdirectory missing</error>");
-			$output->writeln('  ' . $e->getMessage());
+			$output->writeln('  '.$e->getMessage());
 			$output->writeln('Make sure you\'re running the scan command only as the user the web server runs as');
 			++$this->errorsCounter;
 		} catch (InterruptedException $e) {
 			# exit the function if ctrl-c has been pressed
 			$output->writeln('Interrupted by user');
 		} catch (NotFoundException $e) {
-			$output->writeln('<error>Path not found: ' . $e->getMessage() . '</error>');
+			$output->writeln('<error>Path not found: '.$e->getMessage().'</error>');
 			++$this->errorsCounter;
 		} catch (LockedException $e) {
 			if (str_starts_with($e->getPath(), 'scanner::')) {
-				$output->writeln('<error>Another process is already scanning \'' . substr($e->getPath(), strlen('scanner::')) . '\'</error>');
+				$output->writeln('<error>Another process is already scanning \''.substr($e->getPath(), strlen('scanner::')).'\'</error>');
 			} else {
 				throw $e;
 			}
 		} catch (\Exception $e) {
-			$output->writeln('<error>Exception during scan: ' . $e->getMessage() . '</error>');
-			$output->writeln('<error>' . $e->getTraceAsString() . '</error>');
+			$output->writeln('<error>Exception during scan: '.$e->getMessage().'</error>');
+			$output->writeln('<error>'.$e->getTraceAsString().'</error>');
 			++$this->errorsCounter;
 		}
 	}
@@ -196,8 +196,8 @@ 
 	protected function execute(InputInterface $input, OutputInterface $output): int {
 		$inputPath = $input->getOption('path');
 		if ($inputPath) {
-			$inputPath = '/' . trim($inputPath, '/');
-			[, $user,] = explode('/', $inputPath, 3);
+			$inputPath = '/'.trim($inputPath, '/');
+			[, $user, ] = explode('/', $inputPath, 3);
 			$users = [$user];
 		} elseif ($input->getOption('all')) {
 			$users = $this->userManager->search('');
@@ -222,7 +222,7 @@ 
 
 		$homeOnly = $input->getOption('home-only');
 		$scannedStorages = [];
-		$mountFilter = function (IMountPoint $mount) use ($homeOnly, &$scannedStorages) {
+		$mountFilter = function(IMountPoint $mount) use ($homeOnly, &$scannedStorages) {
 			if ($homeOnly && !$this->isHomeMount($mount)) {
 				return false;
 			}
@@ -232,7 +232,7 @@ 
 			$storage = $mount->getStorage();
 			$storageKey = $storage->getId();
 			while ($storage->instanceOfStorage(Jail::class)) {
-				$storageKey .= '/' . $storage->getUnjailedPath('');
+				$storageKey .= '/'.$storage->getUnjailedPath('');
 				$storage = $storage->getUnjailedStorage();
 			}
 			if (array_key_exists($storageKey, $scannedStorages)) {
@@ -248,7 +248,7 @@ 
 			if (is_object($user)) {
 				$user = $user->getUID();
 			}
-			$path = $inputPath ?: '/' . $user;
+			$path = $inputPath ?: '/'.$user;
 			++$user_count;
 			if ($this->userManager->userExists($user)) {
 				$output->writeln("Starting scan for user $user_count out of $users_total ($user)");
@@ -308,8 +308,8 @@ 
 			return false;
 		}
 		$e = new \ErrorException($message, 0, $severity, $file, $line);
-		$output->writeln('<error>Error during scan: ' . $e->getMessage() . '</error>');
-		$output->writeln('<error>' . $e->getTraceAsString() . '</error>', OutputInterface::VERBOSITY_VERY_VERBOSE);
+		$output->writeln('<error>Error during scan: '.$e->getMessage().'</error>');
+		$output->writeln('<error>'.$e->getTraceAsString().'</error>', OutputInterface::VERBOSITY_VERY_VERBOSE);
 		++$this->errorsCounter;
 		return true;
 	}
@@ -351,9 +351,9 @@ 
 	 * Formats microtime into a human-readable format
 	 */
 	protected function formatExecTime(): string {
-		$secs = (int)round($this->execTime);
+		$secs = (int) round($this->execTime);
 		# convert seconds into HH:MM:SS form
-		return sprintf('%02d:%02d:%02d', (int)($secs / 3600), ((int)($secs / 60) % 60), $secs % 60);
+		return sprintf('%02d:%02d:%02d', (int) ($secs / 3600), ((int) ($secs / 60) % 60), $secs % 60);
 	}
 
 	protected function reconnectToDatabase(OutputInterface $output): Connection {