aboutsummaryrefslogtreecommitdiffstats
path: root/apps/files_trashbin/command/cleanup.php
diff options
context:
space:
mode:
Diffstat (limited to 'apps/files_trashbin/command/cleanup.php')
-rw-r--r--apps/files_trashbin/command/cleanup.php119
1 files changed, 0 insertions, 119 deletions
diff --git a/apps/files_trashbin/command/cleanup.php b/apps/files_trashbin/command/cleanup.php
deleted file mode 100644
index cffe7f7d1dd..00000000000
--- a/apps/files_trashbin/command/cleanup.php
+++ /dev/null
@@ -1,119 +0,0 @@
-<?php
-/**
- * @author Björn Schießle <schiessle@owncloud.com>
- * @author Joas Schilling <nickvergessen@owncloud.com>
- *
- * @copyright Copyright (c) 2016, ownCloud, Inc.
- * @license AGPL-3.0
- *
- * This code is free software: you can redistribute it and/or modify
- * it under the terms of the GNU Affero General Public License, version 3,
- * as published by the Free Software Foundation.
- *
- * 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, version 3,
- * along with this program. If not, see <http://www.gnu.org/licenses/>
- *
- */
-
-namespace OCA\Files_Trashbin\Command;
-
-use OCP\Files\IRootFolder;
-use OCP\IDBConnection;
-use OCP\IUserBackend;
-use OCP\IUserManager;
-use Symfony\Component\Console\Command\Command;
-use Symfony\Component\Console\Input\InputArgument;
-use Symfony\Component\Console\Input\InputInterface;
-use Symfony\Component\Console\Output\OutputInterface;
-
-class CleanUp extends Command {
-
- /** @var IUserManager */
- protected $userManager;
-
- /** @var IRootFolder */
- protected $rootFolder;
-
- /** @var \OCP\IDBConnection */
- protected $dbConnection;
-
- /**
- * @param IRootFolder $rootFolder
- * @param IUserManager $userManager
- * @param IDBConnection $dbConnection
- */
- function __construct(IRootFolder $rootFolder, IUserManager $userManager, IDBConnection $dbConnection) {
- parent::__construct();
- $this->userManager = $userManager;
- $this->rootFolder = $rootFolder;
- $this->dbConnection = $dbConnection;
- }
-
- protected function configure() {
- $this
- ->setName('trashbin:cleanup')
- ->setDescription('Remove deleted files')
- ->addArgument(
- 'user_id',
- InputArgument::OPTIONAL | InputArgument::IS_ARRAY,
- 'remove deleted files of the given user(s), if no user is given all deleted files will be removed'
- );
- }
-
- protected function execute(InputInterface $input, OutputInterface $output) {
- $users = $input->getArgument('user_id');
- if (!empty($users)) {
- foreach ($users as $user) {
- if ($this->userManager->userExists($user)) {
- $output->writeln("Remove deleted files of <info>$user</info>");
- $this->removeDeletedFiles($user);
- } else {
- $output->writeln("<error>Unknown user $user</error>");
- }
- }
- } else {
- $output->writeln('Remove all deleted files');
- foreach ($this->userManager->getBackends() as $backend) {
- $name = get_class($backend);
- if ($backend instanceof IUserBackend) {
- $name = $backend->getBackendName();
- }
- $output->writeln("Remove deleted files for users on backend <info>$name</info>");
- $limit = 500;
- $offset = 0;
- do {
- $users = $backend->getUsers('', $limit, $offset);
- foreach ($users as $user) {
- $output->writeln(" <info>$user</info>");
- $this->removeDeletedFiles($user);
- }
- $offset += $limit;
- } while (count($users) >= $limit);
- }
- }
- }
-
- /**
- * remove deleted files for the given user
- *
- * @param string $uid
- */
- protected function removeDeletedFiles($uid) {
- \OC_Util::tearDownFS();
- \OC_Util::setupFS($uid);
- if ($this->rootFolder->nodeExists('/' . $uid . '/files_trashbin')) {
- $this->rootFolder->get('/' . $uid . '/files_trashbin')->delete();
- $query = $this->dbConnection->getQueryBuilder();
- $query->delete('files_trash')
- ->where($query->expr()->eq('user', $query->createParameter('uid')))
- ->setParameter('uid', $uid);
- $query->execute();
- }
- }
-
-}