nextcloud / server

apps/files_sharing/lib/OrphanHelper.php

Indentation +76 added lines, -76 removed lines

@@ -15,88 +15,88 @@
 use OCP\IDBConnection;
 
 class OrphanHelper {
-	public function __construct(
-		private IDBConnection $connection,
-		private IRootFolder $rootFolder,
-		private IUserMountCache $userMountCache,
-	) {
-	}
+    public function __construct(
+        private IDBConnection $connection,
+        private IRootFolder $rootFolder,
+        private IUserMountCache $userMountCache,
+    ) {
+    }
 
-	public function isShareValid(string $owner, int $fileId): bool {
-		try {
-			$userFolder = $this->rootFolder->getUserFolder($owner);
-		} catch (NoUserException $e) {
-			return false;
-		}
-		$node = $userFolder->getFirstNodeById($fileId);
-		return $node !== null;
-	}
+    public function isShareValid(string $owner, int $fileId): bool {
+        try {
+            $userFolder = $this->rootFolder->getUserFolder($owner);
+        } catch (NoUserException $e) {
+            return false;
+        }
+        $node = $userFolder->getFirstNodeById($fileId);
+        return $node !== null;
+    }
 
-	/**
-	 * @param int[] $ids
-	 * @return void
-	 */
-	public function deleteShares(array $ids): void {
-		$query = $this->connection->getQueryBuilder();
-		$query->delete('share')
-			->where($query->expr()->in('id', $query->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY)));
-		$query->executeStatement();
-	}
+    /**
+     * @param int[] $ids
+     * @return void
+     */
+    public function deleteShares(array $ids): void {
+        $query = $this->connection->getQueryBuilder();
+        $query->delete('share')
+            ->where($query->expr()->in('id', $query->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY)));
+        $query->executeStatement();
+    }
 
-	public function fileExists(int $fileId): bool {
-		$query = $this->connection->getQueryBuilder();
-		$query->select('fileid')
-			->from('filecache')
-			->where($query->expr()->eq('fileid', $query->createNamedParameter($fileId, IQueryBuilder::PARAM_INT)));
-		return $query->executeQuery()->fetchOne() !== false;
-	}
+    public function fileExists(int $fileId): bool {
+        $query = $this->connection->getQueryBuilder();
+        $query->select('fileid')
+            ->from('filecache')
+            ->where($query->expr()->eq('fileid', $query->createNamedParameter($fileId, IQueryBuilder::PARAM_INT)));
+        return $query->executeQuery()->fetchOne() !== false;
+    }
 
-	/**
-	 * @return \Traversable<int, array{id: int, owner: string, fileid: int, target: string}>
-	 */
-	public function getAllShares(?string $owner = null, ?string $with = null) {
-		$query = $this->connection->getQueryBuilder();
-		$query->select('id', 'file_source', 'uid_owner', 'file_target')
-			->from('share')
-			->where($query->expr()->in('item_type', $query->createNamedParameter(['file', 'folder'], IQueryBuilder::PARAM_STR_ARRAY)));
+    /**
+     * @return \Traversable<int, array{id: int, owner: string, fileid: int, target: string}>
+     */
+    public function getAllShares(?string $owner = null, ?string $with = null) {
+        $query = $this->connection->getQueryBuilder();
+        $query->select('id', 'file_source', 'uid_owner', 'file_target')
+            ->from('share')
+            ->where($query->expr()->in('item_type', $query->createNamedParameter(['file', 'folder'], IQueryBuilder::PARAM_STR_ARRAY)));
 
-		if ($owner !== null) {
-			$query->andWhere($query->expr()->eq('uid_owner', $query->createNamedParameter($owner)));
-		}
-		if ($with !== null) {
-			$query->andWhere($query->expr()->eq('share_with', $query->createNamedParameter($with)));
-		}
+        if ($owner !== null) {
+            $query->andWhere($query->expr()->eq('uid_owner', $query->createNamedParameter($owner)));
+        }
+        if ($with !== null) {
+            $query->andWhere($query->expr()->eq('share_with', $query->createNamedParameter($with)));
+        }
 
-		$result = $query->executeQuery();
-		while ($row = $result->fetch()) {
-			yield [
-				'id' => (int)$row['id'],
-				'owner' => (string)$row['uid_owner'],
-				'fileid' => (int)$row['file_source'],
-				'target' => (string)$row['file_target'],
-			];
-		}
-	}
+        $result = $query->executeQuery();
+        while ($row = $result->fetch()) {
+            yield [
+                'id' => (int)$row['id'],
+                'owner' => (string)$row['uid_owner'],
+                'fileid' => (int)$row['file_source'],
+                'target' => (string)$row['file_target'],
+            ];
+        }
+    }
 
-	public function findOwner(int $fileId): ?string {
-		$mounts = $this->userMountCache->getMountsForFileId($fileId);
-		if (!$mounts) {
-			return null;
-		}
-		foreach ($mounts as $mount) {
-			$userHomeMountPoint = '/' . $mount->getUser()->getUID() . '/';
-			if ($mount->getMountPoint() === $userHomeMountPoint) {
-				return $mount->getUser()->getUID();
-			}
-		}
-		return null;
-	}
+    public function findOwner(int $fileId): ?string {
+        $mounts = $this->userMountCache->getMountsForFileId($fileId);
+        if (!$mounts) {
+            return null;
+        }
+        foreach ($mounts as $mount) {
+            $userHomeMountPoint = '/' . $mount->getUser()->getUID() . '/';
+            if ($mount->getMountPoint() === $userHomeMountPoint) {
+                return $mount->getUser()->getUID();
+            }
+        }
+        return null;
+    }
 
-	public function updateShareOwner(int $shareId, string $owner): void {
-		$query = $this->connection->getQueryBuilder();
-		$query->update('share')
-			->set('uid_owner', $query->createNamedParameter($owner))
-			->where($query->expr()->eq('id', $query->createNamedParameter($shareId, IQueryBuilder::PARAM_INT)));
-		$query->executeStatement();
-	}
+    public function updateShareOwner(int $shareId, string $owner): void {
+        $query = $this->connection->getQueryBuilder();
+        $query->update('share')
+            ->set('uid_owner', $query->createNamedParameter($owner))
+            ->where($query->expr()->eq('id', $query->createNamedParameter($shareId, IQueryBuilder::PARAM_INT)));
+        $query->executeStatement();
+    }
 }

apps/files_sharing/lib/Command/DeleteOrphanShares.php

Indentation +55 added lines, -55 removed lines

@@ -17,67 +17,67 @@
 use Symfony\Component\Console\Question\ConfirmationQuestion;
 
 class DeleteOrphanShares extends Base {
-	public function __construct(
-		private OrphanHelper $orphanHelper,
-	) {
-		parent::__construct();
-	}
+    public function __construct(
+        private OrphanHelper $orphanHelper,
+    ) {
+        parent::__construct();
+    }
 
-	protected function configure(): void {
-		$this
-			->setName('sharing:delete-orphan-shares')
-			->setDescription('Delete shares where the owner no longer has access to the file')
-			->addOption(
-				'force',
-				'f',
-				InputOption::VALUE_NONE,
-				'delete the shares without asking'
-			)
-			->addOption('owner', null, InputOption::VALUE_REQUIRED, 'Only check shares owned by a specific user')
-			->addOption('with', null, InputOption::VALUE_REQUIRED, 'Only check shares with a specific user');
-	}
+    protected function configure(): void {
+        $this
+            ->setName('sharing:delete-orphan-shares')
+            ->setDescription('Delete shares where the owner no longer has access to the file')
+            ->addOption(
+                'force',
+                'f',
+                InputOption::VALUE_NONE,
+                'delete the shares without asking'
+            )
+            ->addOption('owner', null, InputOption::VALUE_REQUIRED, 'Only check shares owned by a specific user')
+            ->addOption('with', null, InputOption::VALUE_REQUIRED, 'Only check shares with a specific user');
+    }
 
-	public function execute(InputInterface $input, OutputInterface $output): int {
-		$force = $input->getOption('force');
-		$owner = $input->getOption('owner') ?: null;
-		$with = $input->getOption('with') ?: null;
-		$shares = $this->orphanHelper->getAllShares($owner, $with);
+    public function execute(InputInterface $input, OutputInterface $output): int {
+        $force = $input->getOption('force');
+        $owner = $input->getOption('owner') ?: null;
+        $with = $input->getOption('with') ?: null;
+        $shares = $this->orphanHelper->getAllShares($owner, $with);
 
-		$orphans = [];
-		foreach ($shares as $share) {
-			if (!$this->orphanHelper->isShareValid($share['owner'], $share['fileid'])) {
-				$orphans[] = $share['id'];
-				$exists = $this->orphanHelper->fileExists($share['fileid']);
-				$output->writeln("<info>{$share['target']}</info> owned by <info>{$share['owner']}</info>");
-				if ($exists) {
-					$output->writeln("  file still exists but the share owner lost access to it, run <info>occ info:file {$share['fileid']}</info> for more information about the file");
-				} else {
-					$output->writeln('  file no longer exists');
-				}
-			}
-		}
+        $orphans = [];
+        foreach ($shares as $share) {
+            if (!$this->orphanHelper->isShareValid($share['owner'], $share['fileid'])) {
+                $orphans[] = $share['id'];
+                $exists = $this->orphanHelper->fileExists($share['fileid']);
+                $output->writeln("<info>{$share['target']}</info> owned by <info>{$share['owner']}</info>");
+                if ($exists) {
+                    $output->writeln("  file still exists but the share owner lost access to it, run <info>occ info:file {$share['fileid']}</info> for more information about the file");
+                } else {
+                    $output->writeln('  file no longer exists');
+                }
+            }
+        }
 
-		$count = count($orphans);
+        $count = count($orphans);
 
-		if ($count === 0) {
-			$output->writeln('No orphan shares detected');
-			return 0;
-		}
+        if ($count === 0) {
+            $output->writeln('No orphan shares detected');
+            return 0;
+        }
 
-		if ($force) {
-			$doDelete = true;
-		} else {
-			$output->writeln('');
-			/** @var QuestionHelper $helper */
-			$helper = $this->getHelper('question');
-			$question = new ConfirmationQuestion("Delete <info>$count</info> orphan shares? [y/N] ", false);
-			$doDelete = $helper->ask($input, $output, $question);
-		}
+        if ($force) {
+            $doDelete = true;
+        } else {
+            $output->writeln('');
+            /** @var QuestionHelper $helper */
+            $helper = $this->getHelper('question');
+            $question = new ConfirmationQuestion("Delete <info>$count</info> orphan shares? [y/N] ", false);
+            $doDelete = $helper->ask($input, $output, $question);
+        }
 
-		if ($doDelete) {
-			$this->orphanHelper->deleteShares($orphans);
-		}
+        if ($doDelete) {
+            $this->orphanHelper->deleteShares($orphans);
+        }
 
-		return 0;
-	}
+        return 0;
+    }
 }