* * @author Robin Appelman * @author Roeland Jago Douma * * @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_External\Command; use OC\Core\Command\Base; use OCA\Files_External\Lib\InsufficientDataForMeaningfulAnswerException; use OCA\Files_External\Lib\StorageConfig; use OCA\Files_External\Service\GlobalStoragesService; use OCP\Files\Notify\IChange; use OCP\Files\Notify\INotifyHandler; use OCP\Files\Notify\IRenameChange; use OCP\Files\Storage\INotifyStorage; use OCP\Files\Storage\IStorage; use OCP\Files\StorageNotAvailableException; use OCP\IDBConnection; use Symfony\Component\Console\Input\InputArgument; use Symfony\Component\Console\Input\InputInterface; use Symfony\Component\Console\Input\InputOption; use Symfony\Component\Console\Output\OutputInterface; class Notify extends Base { /** @var GlobalStoragesService */ private $globalService; /** @var IDBConnection */ private $connection; /** @var \OCP\DB\QueryBuilder\IQueryBuilder */ private $updateQuery; function __construct(GlobalStoragesService $globalService, IDBConnection $connection) { parent::__construct(); $this->globalService = $globalService; $this->connection = $connection; // the query builder doesn't really like subqueries with parameters $this->updateQuery = $this->connection->prepare( 'UPDATE *PREFIX*filecache SET size = -1 WHERE `path` = ? AND `storage` IN (SELECT storage_id FROM *PREFIX*mounts WHERE mount_id = ?)' ); } protected function configure() { $this ->setName('files_external:notify') ->setDescription('Listen for active update notifications for a configured external mount') ->addArgument( 'mount_id', InputArgument::REQUIRED, 'the mount id of the mount to listen to' )->addOption( 'user', 'u', InputOption::VALUE_REQUIRED, 'The username for the remote mount (required only for some mount configuration that don\'t store credentials)' )->addOption( 'password', 'p', InputOption::VALUE_REQUIRED, 'The password for the remote mount (required only for some mount configuration that don\'t store credentials)' )->addOption( 'path', '', InputOption::VALUE_REQUIRED, 'The directory in the storage to listen for updates in', '/' ); parent::configure(); } protected function execute(InputInterface $input, OutputInterface $output) { $mount = $this->globalService->getStorage($input->getArgument('mount_id')); if (is_null($mount)) { $output->writeln('Mount not found'); return 1; } $noAuth = false; try { $authBackend = $mount->getAuthMechanism(); $authBackend->manipulateStorageConfig($mount); } catch (InsufficientDataForMeaningfulAnswerException $e) { $noAuth = true; } catch (StorageNotAvailableException $e) { $noAuth = true; } if ($input->getOption('user')) { $mount->setBackendOption('user', $input->getOption('user')); } else if (isset($_ENV['NOTIFY_USER'])) { $mount->setBackendOption('user', $_ENV['NOTIFY_USER']); } else if (isset($_SERVER['NOTIFY_USER'])) { $mount->setBackendOption('user', $_SERVER['NOTIFY_USER']); } if ($input->getOption('password')) { $mount->setBackendOption('password', $input->getOption('password')); } else if (isset($_ENV['NOTIFY_PASSWORD'])) { $mount->setBackendOption('password', $_ENV['NOTIFY_PASSWORD']); } else if (isset($_SERVER['NOTIFY_PASSWORD'])) { $mount->setBackendOption('password', $_SERVER['NOTIFY_PASSWORD']); } try { $storage = $this->createStorage($mount); } catch (\Exception $e) { $output->writeln('Error while trying to create storage'); if ($noAuth) { $output->writeln('Username and/or password required'); } return 1; } if (!$storage instanceof INotifyStorage) { $output->writeln('Mount of type "' . $mount->getBackend()->getText() . '" does not support active update notifications'); return 1; } $verbose = $input->getOption('verbose'); $path = trim($input->getOption('path'), '/'); $notifyHandler = $storage->notify($path); $this->selfTest($storage, $notifyHandler, $verbose, $output); $notifyHandler->listen(function (IChange $change) use ($mount, $verbose, $output) { if ($verbose) { $this->logUpdate($change, $output); } if ($change instanceof IRenameChange) { $this->markParentAsOutdated($mount->getId(), $change->getTargetPath()); } $this->markParentAsOutdated($mount->getId(), $change->getPath()); }); } private function createStorage(StorageConfig $mount) { $class = $mount->getBackend()->getStorageClass(); return new $class($mount->getBackendOptions()); } private function markParentAsOutdated($mountId, $path) { $parent = dirname($path); if ($parent === '.') { $parent = ''; } $this->updateQuery->execute([$parent, $mountId]); } private function logUpdate(IChange $change, OutputInterface $output) { switch ($change->getType()) { case INotifyStorage::NOTIFY_ADDED: $text = 'added'; break; case INotifyStorage::NOTIFY_MODIFIED: $text = 'modified'; break; case INotifyStorage::NOTIFY_REMOVED: $text = 'removed'; break; case INotifyStorage::NOTIFY_RENAMED: $text = 'renamed'; break; default: return; } $text .= ' ' . $change->getPath(); if ($change instanceof IRenameChange) { $text .= ' to ' . $change->getTargetPath(); } $output->writeln($text); } private function selfTest(IStorage $storage, INotifyHandler $notifyHandler, $verbose, OutputInterface $output) { usleep(100 * 1000); //give time for the notify to start $storage->file_put_contents('/.nc_test_file.txt', 'test content'); $storage->mkdir('/.nc_test_folder'); $storage->file_put_contents('/.nc_test_folder/subfile.txt', 'test content'); usleep(100 * 1000); //time for all changes to be processed $changes = $notifyHandler->getChanges(); $storage->unlink('/.nc_test_file.txt'); $storage->unlink('/.nc_test_folder/subfile.txt'); $storage->rmdir('/.nc_test_folder'); usleep(100 * 1000); //time for all changes to be processed $notifyHandler->getChanges(); // flush $foundRootChange = false; $foundSubfolderChange = false; foreach ($changes as $change) { if ($change->getPath() === '/.nc_test_file.txt' || $change->getPath() === '.nc_test_file.txt') { $foundRootChange = true; } else if ($change->getPath() === '/.nc_test_folder/subfile.txt' || $change->getPath() === '.nc_test_folder/subfile.txt') { $foundSubfolderChange = true; } } if ($foundRootChange && $foundSubfolderChange && $verbose) { $output->writeln('Self-test successful'); } else if ($foundRootChange && !$foundSubfolderChange) { $output->writeln('Error while running self-test, change is subfolder not detected'); } else if (!$foundRootChange) { $output->writeln('Error while running self-test, no changes detected'); } } }