use OC\HintException;
use OCP\Files\IRootFolder;
use OCP\IConfig;
+use OCP\ILogger;
use OCP\IUserManager;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
/** @var IConfig */
private $config;
+ /** @var ILogger */
+ private $logger;
+
/** @var IRootFolder */
private $rootFolder;
/** @var View */
private $view;
- public function __construct(IConfig $config, IRootFolder $rootFolder, IUserManager $userManager, View $view) {
+ public function __construct(IConfig $config, ILogger $logger, IRootFolder $rootFolder, IUserManager $userManager, View $view) {
$this->config = $config;
+ $this->logger = $logger;
$this->rootFolder = $rootFolder;
$this->userManager = $userManager;
$this->view = $view;
parent::__construct();
}
- protected function configure() {
+ protected function configure(): void {
parent::configure();
$this
* @param OutputInterface $output
* @return int
*/
- protected function execute(InputInterface $input, OutputInterface $output) {
+ protected function execute(InputInterface $input, OutputInterface $output): int {
$skipSignatureCheck = $this->config->getSystemValue('encryption_skip_signature_check', false);
if ($skipSignatureCheck) {
return 1;
}
- $user = $input->getArgument('user');
+ $user = (string)$input->getArgument('user');
$pathToWalk = "/$user/files";
/**
* @param OutputInterface $output
* @return int 0 for success, 1 for error
*/
- private function walkPathOfUser($user, $path, OutputInterface $output) {
+ private function walkPathOfUser($user, $path, OutputInterface $output): int {
$this->setupUserFs($user);
if (!$this->view->file_exists($path)) {
$output->writeln("<error>Path $path does not exist. Please provide a valid path.</error>");
* @param OutputInterface $output
* @param bool $ignoreCorrectEncVersionCall, setting this variable to false avoids recursion
*/
- private function verifyFileContent($path, OutputInterface $output, $ignoreCorrectEncVersionCall = true) {
+ private function verifyFileContent($path, OutputInterface $output, $ignoreCorrectEncVersionCall = true): bool {
try {
/**
* In encryption, the files are read in a block size of 8192 bytes
return true;
} catch (HintException $e) {
- \OC::$server->getLogger()->warning("Issue: " . $e->getMessage());
+ $this->logger->warning("Issue: " . $e->getMessage());
//If allowOnce is set to false, this becomes recursive.
if ($ignoreCorrectEncVersionCall === true) {
//Lets rectify the file by correcting encrypted version
* @param OutputInterface $output
* @return bool
*/
- private function correctEncryptedVersion($path, OutputInterface $output) {
+ private function correctEncryptedVersion($path, OutputInterface $output): bool {
$fileInfo = $this->view->getFileInfo($path);
+ if (!$fileInfo) {
+ $output->writeln("<warning>File info not found for file: \"$path\"</warning>");
+ return true;
+ }
$fileId = $fileInfo->getId();
$encryptedVersion = $fileInfo->getEncryptedVersion();
$wrongEncryptedVersion = $encryptedVersion;
$cache = $storage->getCache();
$fileCache = $cache->get($fileId);
+ if (!$fileCache) {
+ $output->writeln("<warning>File cache entry not found for file: \"$path\"</warning>");
+ return true;
+ }
if ($storage->instanceOfStorage('OCA\Files_Sharing\ISharedStorage')) {
- $output->writeln("<info>The file: $path is a share. Hence kindly fix this by running the script for the owner of share</info>");
+ $output->writeln("<info>The file: \"$path\" is a share. Please also run the script for the owner of the share</info>");
return true;
}
$cache->put($fileCache->getPath(), $cacheInfo);
$output->writeln("<info>Decrement the encrypted version to $encryptedVersion</info>");
if ($this->verifyFileContent($path, $output, false) === true) {
- $output->writeln("<info>Fixed the file: $path with version " . $encryptedVersion . "</info>");
+ $output->writeln("<info>Fixed the file: \"$path\" with version " . $encryptedVersion . "</info>");
return true;
}
$encryptedVersion--;
$cache->put($fileCache->getPath(), $cacheInfo);
$output->writeln("<info>Increment the encrypted version to $newEncryptedVersion</info>");
if ($this->verifyFileContent($path, $output, false) === true) {
- $output->writeln("<info>Fixed the file: $path with version " . $newEncryptedVersion . "</info>");
+ $output->writeln("<info>Fixed the file: \"$path\" with version " . $newEncryptedVersion . "</info>");
return true;
}
$increment++;
$cacheInfo = ['encryptedVersion' => $originalEncryptedVersion, 'encrypted' => $originalEncryptedVersion];
$cache->put($fileCache->getPath(), $cacheInfo);
- $output->writeln("<info>No fix found for $path, restored version to original: $originalEncryptedVersion</info>");
+ $output->writeln("<info>No fix found for \"$path\", restored version to original: $originalEncryptedVersion</info>");
return false;
}
* Setup user file system
* @param string $uid
*/
- private function setupUserFs($uid) {
+ private function setupUserFs($uid): void {
\OC_Util::tearDownFS();
\OC_Util::setupFS($uid);
}