* * @license GNU AGPL version 3 or any later version * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . * */ namespace OCA\Files_Trashbin\Trash; use OCP\Files\FileInfo; use OCP\Files\Mount\IMountPoint; use OCP\Files\Storage\IStorage; use OCP\IUser; class TrashManager implements ITrashManager { /** @var ITrashBackend[] */ private $backends = []; private $trashPaused = false; public function registerBackend(string $storageType, ITrashBackend $backend) { $this->backends[$storageType] = $backend; } /** * @return ITrashBackend[] */ private function getBackends(): array { return $this->backends; } public function listTrashRoot(IUser $user): array { $items = array_reduce($this->getBackends(), function (array $items, ITrashBackend $backend) use ($user) { return array_merge($items, $backend->listTrashRoot($user)); }, []); usort($items, function (ITrashItem $a, ITrashItem $b) { return $a->getDeletedTime() - $b->getDeletedTime(); }); return $items; } private function getBackendForItem(ITrashItem $item) { return $item->getTrashBackend(); } public function listTrashFolder(IUser $user, ITrashItem $folder): array { return $this->getBackendForItem($folder)->listTrashFolder($user, $folder); } public function restoreItem(ITrashItem $item) { return $this->getBackendForItem($item)->restoreItem($item); } public function removeItem(IUser $user, ITrashItem $item) { $this->getBackendForItem($item)->removeItem($user, $item); } /** * @param IStorage $storage * @return ITrashBackend * @throws BackendNotFoundException */ public function getBackendForStorage(IStorage $storage): ITrashBackend { $fullType = get_class($storage); $foundType = array_reduce(array_keys($this->backends), function ($type, $registeredType) use ($storage) { if ( $storage->instanceOfStorage($registeredType) && ($type === '' || is_subclass_of($registeredType, $type)) ) { return $registeredType; } else { return $type; } }, ''); if ($foundType === '') { throw new BackendNotFoundException("Trash backend for $fullType not found"); } else { return $this->backends[$foundType]; } } public function moveToTrash(IStorage $storage, string $internalPath): bool { if ($this->trashPaused) { return false; } try { $backend = $this->getBackendForStorage($storage); return $backend->moveToTrash($storage, $internalPath); } catch (BackendNotFoundException $e) { return false; } } public function getTrashNodeById(IUser $user, int $fileId) { foreach ($this->backends as $backend) { $item = $backend->getTrashNodeById($user, $fileId); if ($item !== null) { return $item; } } return null; } public function pauseTrash() { $this->trashPaused = true; } public function resumeTrash() { $this->trashPaused = false; } }