aboutsummaryrefslogtreecommitdiffstats
path: root/lib/private/systemtag/systemtagmanager.php
diff options
context:
space:
mode:
Diffstat (limited to 'lib/private/systemtag/systemtagmanager.php')
-rw-r--r--lib/private/systemtag/systemtagmanager.php322
1 files changed, 0 insertions, 322 deletions
diff --git a/lib/private/systemtag/systemtagmanager.php b/lib/private/systemtag/systemtagmanager.php
deleted file mode 100644
index 76a60a91328..00000000000
--- a/lib/private/systemtag/systemtagmanager.php
+++ /dev/null
@@ -1,322 +0,0 @@
-<?php
-/**
- * @author Joas Schilling <nickvergessen@owncloud.com>
- * @author Vincent Petry <pvince81@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 OC\SystemTag;
-
-use Doctrine\DBAL\Exception\UniqueConstraintViolationException;
-use OCP\DB\QueryBuilder\IQueryBuilder;
-use OCP\IDBConnection;
-use OCP\SystemTag\ISystemTagManager;
-use OCP\SystemTag\ManagerEvent;
-use OCP\SystemTag\TagAlreadyExistsException;
-use OCP\SystemTag\TagNotFoundException;
-use Symfony\Component\EventDispatcher\EventDispatcherInterface;
-
-class SystemTagManager implements ISystemTagManager {
-
- const TAG_TABLE = 'systemtag';
-
- /** @var IDBConnection */
- protected $connection;
-
- /** @var EventDispatcherInterface */
- protected $dispatcher;
-
- /**
- * Prepared query for selecting tags directly
- *
- * @var \OCP\DB\QueryBuilder\IQueryBuilder
- */
- private $selectTagQuery;
-
- /**
- * Constructor.
- *
- * @param IDBConnection $connection database connection
- * @param EventDispatcherInterface $dispatcher
- */
- public function __construct(IDBConnection $connection, EventDispatcherInterface $dispatcher) {
- $this->connection = $connection;
- $this->dispatcher = $dispatcher;
-
- $query = $this->connection->getQueryBuilder();
- $this->selectTagQuery = $query->select('*')
- ->from(self::TAG_TABLE)
- ->where($query->expr()->eq('name', $query->createParameter('name')))
- ->andWhere($query->expr()->eq('visibility', $query->createParameter('visibility')))
- ->andWhere($query->expr()->eq('editable', $query->createParameter('editable')));
- }
-
- /**
- * {@inheritdoc}
- */
- public function getTagsByIds($tagIds) {
- if (!is_array($tagIds)) {
- $tagIds = [$tagIds];
- }
-
- $tags = [];
-
- // note: not all databases will fail if it's a string or starts with a number
- foreach ($tagIds as $tagId) {
- if (!is_numeric($tagId)) {
- throw new \InvalidArgumentException('Tag id must be integer');
- }
- }
-
- $query = $this->connection->getQueryBuilder();
- $query->select('*')
- ->from(self::TAG_TABLE)
- ->where($query->expr()->in('id', $query->createParameter('tagids')))
- ->addOrderBy('name', 'ASC')
- ->addOrderBy('visibility', 'ASC')
- ->addOrderBy('editable', 'ASC')
- ->setParameter('tagids', $tagIds, IQueryBuilder::PARAM_INT_ARRAY);
-
- $result = $query->execute();
- while ($row = $result->fetch()) {
- $tags[$row['id']] = $this->createSystemTagFromRow($row);
- }
-
- $result->closeCursor();
-
- if (count($tags) !== count($tagIds)) {
- throw new TagNotFoundException(
- 'Tag id(s) not found', 0, null, array_diff($tagIds, array_keys($tags))
- );
- }
-
- return $tags;
- }
-
- /**
- * {@inheritdoc}
- */
- public function getAllTags($visibilityFilter = null, $nameSearchPattern = null) {
- $tags = [];
-
- $query = $this->connection->getQueryBuilder();
- $query->select('*')
- ->from(self::TAG_TABLE);
-
- if (!is_null($visibilityFilter)) {
- $query->andWhere($query->expr()->eq('visibility', $query->createNamedParameter((int)$visibilityFilter)));
- }
-
- if (!empty($nameSearchPattern)) {
- $query->andWhere(
- $query->expr()->like(
- 'name',
- $query->expr()->literal('%' . $this->connection->escapeLikeParameter($nameSearchPattern). '%')
- )
- );
- }
-
- $query
- ->addOrderBy('name', 'ASC')
- ->addOrderBy('visibility', 'ASC')
- ->addOrderBy('editable', 'ASC');
-
- $result = $query->execute();
- while ($row = $result->fetch()) {
- $tags[$row['id']] = $this->createSystemTagFromRow($row);
- }
-
- $result->closeCursor();
-
- return $tags;
- }
-
- /**
- * {@inheritdoc}
- */
- public function getTag($tagName, $userVisible, $userAssignable) {
- $userVisible = (int)$userVisible;
- $userAssignable = (int)$userAssignable;
-
- $result = $this->selectTagQuery
- ->setParameter('name', $tagName)
- ->setParameter('visibility', $userVisible)
- ->setParameter('editable', $userAssignable)
- ->execute();
-
- $row = $result->fetch();
- $result->closeCursor();
- if (!$row) {
- throw new TagNotFoundException(
- 'Tag ("' . $tagName . '", '. $userVisible . ', ' . $userAssignable . ') does not exist'
- );
- }
-
- return $this->createSystemTagFromRow($row);
- }
-
- /**
- * {@inheritdoc}
- */
- public function createTag($tagName, $userVisible, $userAssignable) {
- $userVisible = (int)$userVisible;
- $userAssignable = (int)$userAssignable;
-
- $query = $this->connection->getQueryBuilder();
- $query->insert(self::TAG_TABLE)
- ->values([
- 'name' => $query->createNamedParameter($tagName),
- 'visibility' => $query->createNamedParameter($userVisible),
- 'editable' => $query->createNamedParameter($userAssignable),
- ]);
-
- try {
- $query->execute();
- } catch (UniqueConstraintViolationException $e) {
- throw new TagAlreadyExistsException(
- 'Tag ("' . $tagName . '", '. $userVisible . ', ' . $userAssignable . ') already exists',
- 0,
- $e
- );
- }
-
- $tagId = $query->getLastInsertId();
-
- $tag = new SystemTag(
- (int)$tagId,
- $tagName,
- (bool)$userVisible,
- (bool)$userAssignable
- );
-
- $this->dispatcher->dispatch(ManagerEvent::EVENT_CREATE, new ManagerEvent(
- ManagerEvent::EVENT_CREATE, $tag
- ));
-
- return $tag;
- }
-
- /**
- * {@inheritdoc}
- */
- public function updateTag($tagId, $tagName, $userVisible, $userAssignable) {
- $userVisible = (int)$userVisible;
- $userAssignable = (int)$userAssignable;
-
- try {
- $tags = $this->getTagsByIds($tagId);
- } catch (TagNotFoundException $e) {
- throw new TagNotFoundException(
- 'Tag does not exist', 0, null, [$tagId]
- );
- }
-
- $beforeUpdate = array_shift($tags);
- $afterUpdate = new SystemTag(
- (int) $tagId,
- $tagName,
- (bool) $userVisible,
- (bool) $userAssignable
- );
-
- $query = $this->connection->getQueryBuilder();
- $query->update(self::TAG_TABLE)
- ->set('name', $query->createParameter('name'))
- ->set('visibility', $query->createParameter('visibility'))
- ->set('editable', $query->createParameter('editable'))
- ->where($query->expr()->eq('id', $query->createParameter('tagid')))
- ->setParameter('name', $tagName)
- ->setParameter('visibility', $userVisible)
- ->setParameter('editable', $userAssignable)
- ->setParameter('tagid', $tagId);
-
- try {
- if ($query->execute() === 0) {
- throw new TagNotFoundException(
- 'Tag does not exist', 0, null, [$tagId]
- );
- }
- } catch (UniqueConstraintViolationException $e) {
- throw new TagAlreadyExistsException(
- 'Tag ("' . $tagName . '", '. $userVisible . ', ' . $userAssignable . ') already exists',
- 0,
- $e
- );
- }
-
- $this->dispatcher->dispatch(ManagerEvent::EVENT_UPDATE, new ManagerEvent(
- ManagerEvent::EVENT_UPDATE, $afterUpdate, $beforeUpdate
- ));
- }
-
- /**
- * {@inheritdoc}
- */
- public function deleteTags($tagIds) {
- if (!is_array($tagIds)) {
- $tagIds = [$tagIds];
- }
-
- $tagNotFoundException = null;
- $tags = [];
- try {
- $tags = $this->getTagsByIds($tagIds);
- } catch (TagNotFoundException $e) {
- $tagNotFoundException = $e;
-
- // Get existing tag objects for the hooks later
- $existingTags = array_diff($tagIds, $tagNotFoundException->getMissingTags());
- if (!empty($existingTags)) {
- try {
- $tags = $this->getTagsByIds($existingTags);
- } catch (TagNotFoundException $e) {
- // Ignore further errors...
- }
- }
- }
-
- // delete relationships first
- $query = $this->connection->getQueryBuilder();
- $query->delete(SystemTagObjectMapper::RELATION_TABLE)
- ->where($query->expr()->in('systemtagid', $query->createParameter('tagids')))
- ->setParameter('tagids', $tagIds, IQueryBuilder::PARAM_INT_ARRAY)
- ->execute();
-
- $query = $this->connection->getQueryBuilder();
- $query->delete(self::TAG_TABLE)
- ->where($query->expr()->in('id', $query->createParameter('tagids')))
- ->setParameter('tagids', $tagIds, IQueryBuilder::PARAM_INT_ARRAY)
- ->execute();
-
- foreach ($tags as $tag) {
- $this->dispatcher->dispatch(ManagerEvent::EVENT_DELETE, new ManagerEvent(
- ManagerEvent::EVENT_DELETE, $tag
- ));
- }
-
- if ($tagNotFoundException !== null) {
- throw new TagNotFoundException(
- 'Tag id(s) not found', 0, $tagNotFoundException, $tagNotFoundException->getMissingTags()
- );
- }
- }
-
- private function createSystemTagFromRow($row) {
- return new SystemTag((int)$row['id'], $row['name'], (bool)$row['visibility'], (bool)$row['editable']);
- }
-}