* * @author Julius Härtl * * @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\Deck\AppInfo; use Exception; use InvalidArgumentException; use OC_Util; use OCA\Deck\Activity\CommentEventHandler; use OCA\Deck\Capabilities; use OCA\Deck\Collaboration\Resources\ResourceProvider; use OCA\Deck\Collaboration\Resources\ResourceProviderCard; use OCA\Deck\Db\Acl; use OCA\Deck\Db\AclMapper; use OCA\Deck\Db\AssignedUsersMapper; use OCA\Deck\Db\CardMapper; use OCA\Deck\Middleware\DefaultBoardMiddleware; use OCA\Deck\Middleware\ExceptionMiddleware; use OCA\Deck\Notification\Notifier; use OCA\Deck\Service\FullTextSearchService; use OCA\Deck\Service\PermissionService; use OCP\AppFramework\App; use OCP\Collaboration\Resources\IManager; use OCP\Collaboration\Resources\IProviderManager; use OCP\Comments\CommentsEntityEvent; use OCP\FullTextSearch\IFullTextSearchManager; use OCP\IGroup; use OCP\IServerContainer; use OCP\IUser; use OCP\IUserManager; use OCP\IURLGenerator; use OCP\Util; use Symfony\Component\EventDispatcher\GenericEvent; class Application extends App { public const APP_ID = 'deck'; public const COMMENT_ENTITY_TYPE = 'deckCard'; /** @var IServerContainer */ private $server; /** @var FullTextSearchService */ private $fullTextSearchService; /** @var IFullTextSearchManager */ private $fullTextSearchManager; public function __construct(array $urlParams = array()) { parent::__construct('deck', $urlParams); $container = $this->getContainer(); $server = $this->getContainer()->getServer(); $this->server = $server; $container->registerCapability(Capabilities::class); $container->registerMiddleWare(ExceptionMiddleware::class); $container->registerMiddleWare(DefaultBoardMiddleware::class); $container->registerService('databaseType', static function() use ($server) { return $server->getConfig()->getSystemValue('dbtype', 'sqlite'); }); $container->registerService('database4ByteSupport', static function() use ($server) { return $server->getDatabaseConnection()->supports4ByteText(); }); } public function register(): void { $this->registerNavigationEntry(); $this->registerUserGroupHooks(); $this->registerNotifications(); $this->registerCommentsEntity(); $this->registerFullTextSearch(); $this->registerCollaborationResources(); } public function registerNavigationEntry(): void { $container = $this->getContainer(); $this->server->getNavigationManager()->add(static function() use ($container) { $urlGenerator = $container->query(IURLGenerator::class); return [ 'id' => 'deck', 'order' => 10, 'href' => $urlGenerator->linkToRoute('deck.page.index'), 'icon' => $urlGenerator->imagePath('deck', 'deck.svg'), 'name' => 'Deck', ]; }); } private function registerUserGroupHooks(): void { $container = $this->getContainer(); // Delete user/group acl entries when they get deleted /** @var IUserManager $userManager */ $userManager = $this->server->getUserManager(); $userManager->listen('\OC\User', 'postDelete', static function(IUser $user) use ($container) { // delete existing acl entries for deleted user /** @var AclMapper $aclMapper */ $aclMapper = $container->query(AclMapper::class); $acls = $aclMapper->findByParticipant(Acl::PERMISSION_TYPE_USER, $user->getUID()); foreach ($acls as $acl) { $aclMapper->delete($acl); } // delete existing user assignments $assignmentMapper = $container->query(AssignedUsersMapper::class); $assignments = $assignmentMapper->findByUserId($user->getUID()); foreach ($assignments as $assignment) { $assignmentMapper->delete($assignment); } }); /** @var IUserManager $userManager */ $groupManager = $this->server->getGroupManager(); $groupManager->listen('\OC\Group', 'postDelete', static function(IGroup $group) use ($container) { /** @var AclMapper $aclMapper */ $aclMapper = $container->query(AclMapper::class); $aclMapper->findByParticipant(Acl::PERMISSION_TYPE_GROUP, $group->getGID()); $acls = $aclMapper->findByParticipant(Acl::PERMISSION_TYPE_GROUP, $group->getGID()); foreach ($acls as $acl) { $aclMapper->delete($acl); } }); } public function registerNotifications(): void { $notificationManager = $this->server->getNotificationManager(); $notificationManager->registerNotifierService(Notifier::class); } public function registerCommentsEntity(): void { $this->server->getEventDispatcher()->addListener(CommentsEntityEvent::EVENT_ENTITY, function(CommentsEntityEvent $event) { $event->addEntityCollection(self::COMMENT_ENTITY_TYPE, function($name) { /** @var CardMapper */ $cardMapper = $this->getContainer()->query(CardMapper::class); $permissionService = $this->getContainer()->query(PermissionService::class); try { return $permissionService->checkPermission($cardMapper, (int) $name, Acl::PERMISSION_READ); } catch (\Exception $e) { return false; } }); }); $this->registerCommentsEventHandler(); } /** */ protected function registerCommentsEventHandler(): void { $this->server->getCommentsManager()->registerEventHandler(function () { return $this->getContainer()->query(CommentEventHandler::class); }); } protected function registerCollaborationResources(): void { $version = OC_Util::getVersion()[0]; if ($version < 16) { return; } /** * Register Collaboration ResourceProvider * * @Todo: Remove if min-version is 18 */ if ($version < 18) { /** @var IManager $resourceManager */ $resourceManager = $this->getContainer()->query(IManager::class); } else { /** @var IProviderManager $resourceManager */ $resourceManager = $this->getContainer()->query(IProviderManager::class); } $resourceManager->registerResourceProvider(ResourceProvider::class); $resourceManager->registerResourceProvider(ResourceProviderCard::class); $this->server->getEventDispatcher()->addListener('\OCP\Collaboration\Resources::loadAdditionalScripts', static function () { Util::addScript('deck', 'collections'); }); } public function registerFullTextSearch(): void { if (Util::getVersion()[0] < 16) { return; } $c = $this->getContainer(); try { $this->fullTextSearchService = $c->query(FullTextSearchService::class); $this->fullTextSearchManager = $c->query(IFullTextSearchManager::class); } catch (Exception $e) { return; } if (!$this->fullTextSearchManager->isAvailable()) { return; } $eventDispatcher = $this->server->getEventDispatcher(); $eventDispatcher->addListener( '\OCA\Deck\Card::onCreate', function(GenericEvent $e) { $this->fullTextSearchService->onCardCreated($e); } ); $eventDispatcher->addListener( '\OCA\Deck\Card::onUpdate', function(GenericEvent $e) { $this->fullTextSearchService->onCardUpdated($e); } ); $eventDispatcher->addListener( '\OCA\Deck\Card::onDelete', function(GenericEvent $e) { $this->fullTextSearchService->onCardDeleted($e); } ); $eventDispatcher->addListener( '\OCA\Deck\Board::onShareNew', function(GenericEvent $e) { $this->fullTextSearchService->onBoardShares($e); } ); $eventDispatcher->addListener( '\OCA\Deck\Board::onShareEdit', function(GenericEvent $e) { $this->fullTextSearchService->onBoardShares($e); } ); $eventDispatcher->addListener( '\OCA\Deck\Board::onShareDelete', function(GenericEvent $e) { $this->fullTextSearchService->onBoardShares($e); } ); } }