diff options
author | Joas Schilling <coding@schilljs.com> | 2019-03-13 22:53:48 +0300 |
---|---|---|
committer | Joas Schilling <coding@schilljs.com> | 2019-03-27 12:43:19 +0300 |
commit | 18b75cf9979250be8af6cf709d136a5865eb4bb0 (patch) | |
tree | 13d6cb5148f9c88b00df4855bfa77fb1c303cf44 /lib/Collaboration/Resources/Listener.php | |
parent | cd90f8a43a33f0cf284d019c9379970c00f15065 (diff) |
Add a provider for linked collaboration resources
Signed-off-by: Joas Schilling <coding@schilljs.com>
Diffstat (limited to 'lib/Collaboration/Resources/Listener.php')
-rw-r--r-- | lib/Collaboration/Resources/Listener.php | 108 |
1 files changed, 108 insertions, 0 deletions
diff --git a/lib/Collaboration/Resources/Listener.php b/lib/Collaboration/Resources/Listener.php new file mode 100644 index 000000000..1b3970f70 --- /dev/null +++ b/lib/Collaboration/Resources/Listener.php @@ -0,0 +1,108 @@ +<?php +declare(strict_types=1); +/** + * @copyright Copyright (c) 2019 Joas Schilling <coding@schilljs.com> + * + * @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 <http://www.gnu.org/licenses/>. + * + */ + +namespace OCA\Spreed\Collaboration\Resources; + +use OCA\Spreed\Participant; +use OCA\Spreed\Room; +use OCP\Collaboration\Resources\IManager; +use OCP\IUser; +use OCP\IUserManager; +use Symfony\Component\EventDispatcher\EventDispatcherInterface; +use Symfony\Component\EventDispatcher\GenericEvent; + +class Listener { + public static function register(EventDispatcherInterface $dispatcher): void { + $listener = function(GenericEvent $event) { + /** @var Room $room */ + $room = $event->getSubject(); + /** @var IManager $manager */ + $resourceManager = \OC::$server->query(IManager::class); + + $resource = $resourceManager->getResourceForUser('room', $room->getToken(), null); + $resourceManager->invalidateAccessCacheForResource($resource); + }; + $dispatcher->addListener(Room::class . '::postDeleteRoom', $listener); + + $listener = function(GenericEvent $event) { + /** @var Room $room */ + $room = $event->getSubject(); + /** @var IManager $manager */ + $resourceManager = \OC::$server->query(IManager::class); + /** @var IUserManager $userManager */ + $userManager = \OC::$server->getUserManager(); + $resource = $resourceManager->getResourceForUser('room', $room->getToken(), null); + + $participants = $event->getArgument('users'); + foreach ($participants as $participant) { + $user = null; + if ($participant['user_id'] !== '') { + $user = $userManager->get($participant['user_id']); + } + + $resourceManager->invalidateAccessCacheForResourceByUser($resource, $user); + } + }; + $dispatcher->addListener(Room::class . '::postAddUser', $listener); + + $listener = function(GenericEvent $event) { + /** @var Room $room */ + $room = $event->getSubject(); + /** @var IManager $manager */ + $resourceManager = \OC::$server->query(IManager::class); + /** @var IUser $user */ + $user = $event->getArgument('user'); + $resource = $resourceManager->getResourceForUser('room', $room->getToken(), null); + + $resourceManager->invalidateAccessCacheForResourceByUser($resource, $user); + }; + $dispatcher->addListener(Room::class . '::postRemoveUser', $listener); + + $listener = function(GenericEvent $event) { + /** @var Room $room */ + $room = $event->getSubject(); + /** @var IManager $manager */ + $resourceManager = \OC::$server->query(IManager::class); + /** @var IUserManager $userManager */ + $userManager = \OC::$server->getUserManager(); + $resource = $resourceManager->getResourceForUser('room', $room->getToken(), null); + + /** @var Participant $participant */ + $participant = $event->getArgument('participant'); + $user = $userManager->get($participant->getUser()); + $resourceManager->invalidateAccessCacheForResourceByUser($resource, $user); + }; + $dispatcher->addListener(Room::class . '::postRemoveBySession', $listener); + + $listener = function(GenericEvent $event) { + /** @var Room $room */ + $room = $event->getSubject(); + /** @var IManager $manager */ + $resourceManager = \OC::$server->query(IManager::class); + + $resource = $resourceManager->getResourceForUser('room', $room->getToken(), null); + $resourceManager->invalidateAccessCacheForResourceByUser($resource, null); + }; + $dispatcher->addListener(Room::class . '::postChangeType', $listener); + $dispatcher->addListener(Room::class . '::postInviteByEmail', $listener); + } +} |