* @author Joas Schilling * @author Morris Jobke * @author Vincent Petry * * @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 * */ namespace OCA\Files_Sharing; use OCP\AppFramework\Utility\ITimeFactory; use OCP\BackgroundJob\TimedJob; /** * Delete all share entries that have no matching entries in the file cache table. */ class DeleteOrphanedSharesJob extends TimedJob { /** * Default interval in minutes * * @var int $defaultIntervalMin **/ protected $defaultIntervalMin = 15; /** * sets the correct interval for this timed job */ public function __construct(ITimeFactory $time) { parent::__construct($time); $this->interval = $this->defaultIntervalMin * 60; } /** * Makes the background job do its work * * @param array $argument unused argument */ public function run($argument) { $connection = \OC::$server->getDatabaseConnection(); $logger = \OC::$server->getLogger(); $sql = 'DELETE FROM `*PREFIX*share` ' . 'WHERE `item_type` in (\'file\', \'folder\') ' . 'AND NOT EXISTS (SELECT `fileid` FROM `*PREFIX*filecache` WHERE `file_source` = `fileid`)'; $deletedEntries = $connection->executeUpdate($sql); $logger->debug("$deletedEntries orphaned share(s) deleted", ['app' => 'DeleteOrphanedSharesJob']); } }