nextcloud / server

lib/public/SystemTag/TagAssignedEvent.php

Indentation +49 added lines, -49 removed lines

@@ -16,58 +16,58 @@
  * @since 32.0.0
  */
 class TagAssignedEvent extends Event implements IWebhookCompatibleEvent {
-	protected string $objectType;
-	/** @var list<string> */
-	protected array $objectIds;
-	/** @var list<int> */
-	protected array $tags;
+    protected string $objectType;
+    /** @var list<string> */
+    protected array $objectIds;
+    /** @var list<int> */
+    protected array $tags;
 
-	/**
-	 * constructor
-	 *
-	 * @param list<string> $objectIds
-	 * @param list<int> $tags
-	 * @since 32.0.0
-	 */
-	public function __construct(string $objectType, array $objectIds, array $tags) {
-		parent::__construct();
-		$this->objectType = $objectType;
-		$this->objectIds = $objectIds;
-		$this->tags = $tags;
-	}
+    /**
+     * constructor
+     *
+     * @param list<string> $objectIds
+     * @param list<int> $tags
+     * @since 32.0.0
+     */
+    public function __construct(string $objectType, array $objectIds, array $tags) {
+        parent::__construct();
+        $this->objectType = $objectType;
+        $this->objectIds = $objectIds;
+        $this->tags = $tags;
+    }
 
-	/**
-	 * @since 32.0.0
-	 */
-	public function getObjectType(): string {
-		return $this->objectType;
-	}
+    /**
+     * @since 32.0.0
+     */
+    public function getObjectType(): string {
+        return $this->objectType;
+    }
 
-	/**
-	 * @return list<string>
-	 * @since 32.0.0
-	 */
-	public function getObjectIds(): array {
-		return $this->objectIds;
-	}
+    /**
+     * @return list<string>
+     * @since 32.0.0
+     */
+    public function getObjectIds(): array {
+        return $this->objectIds;
+    }
 
-	/**
-	 * @return list<int>
-	 * @since 32.0.0
-	 */
-	public function getTags(): array {
-		return $this->tags;
-	}
+    /**
+     * @return list<int>
+     * @since 32.0.0
+     */
+    public function getTags(): array {
+        return $this->tags;
+    }
 
-	/**
-	 * @return array{objectType: string, objectIds: list<string>, tagIds: list<int>}
-	 * @since 32.0.0
-	 */
-	public function getWebhookSerializable(): array {
-		return [
-			'objectType' => $this->getObjectType(),
-			'objectIds' => $this->getObjectIds(),
-			'tagIds' => $this->getTags(),
-		];
-	}
+    /**
+     * @return array{objectType: string, objectIds: list<string>, tagIds: list<int>}
+     * @since 32.0.0
+     */
+    public function getWebhookSerializable(): array {
+        return [
+            'objectType' => $this->getObjectType(),
+            'objectIds' => $this->getObjectIds(),
+            'tagIds' => $this->getTags(),
+        ];
+    }
 }

lib/public/SystemTag/TagUnassignedEvent.php

Indentation +49 added lines, -49 removed lines

@@ -16,58 +16,58 @@
  * @since 32.0.0
  */
 class TagUnassignedEvent extends Event implements IWebhookCompatibleEvent {
-	protected string $objectType;
-	/** @var list<string> */
-	protected array $objectIds;
-	/** @var list<int> */
-	protected array $tags;
+    protected string $objectType;
+    /** @var list<string> */
+    protected array $objectIds;
+    /** @var list<int> */
+    protected array $tags;
 
-	/**
-	 * constructor
-	 *
-	 * @param list<string> $objectIds
-	 * @param list<int> $tags
-	 * @since 32.0.0
-	 */
-	public function __construct(string $objectType, array $objectIds, array $tags) {
-		parent::__construct();
-		$this->objectType = $objectType;
-		$this->objectIds = $objectIds;
-		$this->tags = $tags;
-	}
+    /**
+     * constructor
+     *
+     * @param list<string> $objectIds
+     * @param list<int> $tags
+     * @since 32.0.0
+     */
+    public function __construct(string $objectType, array $objectIds, array $tags) {
+        parent::__construct();
+        $this->objectType = $objectType;
+        $this->objectIds = $objectIds;
+        $this->tags = $tags;
+    }
 
-	/**
-	 * @since 32.0.0
-	 */
-	public function getObjectType(): string {
-		return $this->objectType;
-	}
+    /**
+     * @since 32.0.0
+     */
+    public function getObjectType(): string {
+        return $this->objectType;
+    }
 
-	/**
-	 * @return list<string>
-	 * @since 32.0.0
-	 */
-	public function getObjectIds(): array {
-		return $this->objectIds;
-	}
+    /**
+     * @return list<string>
+     * @since 32.0.0
+     */
+    public function getObjectIds(): array {
+        return $this->objectIds;
+    }
 
-	/**
-	 * @return list<int>
-	 * @since 32.0.0
-	 */
-	public function getTags(): array {
-		return $this->tags;
-	}
+    /**
+     * @return list<int>
+     * @since 32.0.0
+     */
+    public function getTags(): array {
+        return $this->tags;
+    }
 
-	/**
-	 * @return array{objectType: string, objectIds: list<string>, tagIds: list<int>}
-	 * @since 32.0.0
-	 */
-	public function getWebhookSerializable(): array {
-		return [
-			'objectType' => $this->getObjectType(),
-			'objectIds' => $this->getObjectIds(),
-			'tagIds' => $this->getTags(),
-		];
-	}
+    /**
+     * @return array{objectType: string, objectIds: list<string>, tagIds: list<int>}
+     * @since 32.0.0
+     */
+    public function getWebhookSerializable(): array {
+        return [
+            'objectType' => $this->getObjectType(),
+            'objectIds' => $this->getObjectIds(),
+            'tagIds' => $this->getTags(),
+        ];
+    }
 }

lib/private/SystemTag/SystemTagObjectMapper.php

Indentation +355 added lines, -355 removed lines

@@ -22,359 +22,359 @@
 use OCP\SystemTag\TagUnassignedEvent;
 
 class SystemTagObjectMapper implements ISystemTagObjectMapper {
-	public const RELATION_TABLE = 'systemtag_object_mapping';
-
-	public function __construct(
-		protected IDBConnection $connection,
-		protected ISystemTagManager $tagManager,
-		protected IEventDispatcher $dispatcher,
-	) {
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function getTagIdsForObjects($objIds, string $objectType): array {
-		if (!\is_array($objIds)) {
-			$objIds = [$objIds];
-		} elseif (empty($objIds)) {
-			return [];
-		}
-
-		$query = $this->connection->getQueryBuilder();
-		$query->select(['systemtagid', 'objectid'])
-			->from(self::RELATION_TABLE)
-			->where($query->expr()->in('objectid', $query->createParameter('objectids')))
-			->andWhere($query->expr()->eq('objecttype', $query->createParameter('objecttype')))
-			->setParameter('objecttype', $objectType)
-			->addOrderBy('objectid', 'ASC')
-			->addOrderBy('systemtagid', 'ASC');
-		$chunks = array_chunk($objIds, 900, false);
-		$mapping = [];
-		foreach ($objIds as $objId) {
-			$mapping[$objId] = [];
-		}
-		foreach ($chunks as $chunk) {
-			$query->setParameter('objectids', $chunk, IQueryBuilder::PARAM_STR_ARRAY);
-			$result = $query->executeQuery();
-			while ($row = $result->fetch()) {
-				$objectId = $row['objectid'];
-				$mapping[$objectId][] = $row['systemtagid'];
-			}
-
-			$result->closeCursor();
-		}
-
-		return $mapping;
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function getObjectIdsForTags($tagIds, string $objectType, int $limit = 0, string $offset = ''): array {
-		if (!\is_array($tagIds)) {
-			$tagIds = [$tagIds];
-		}
-
-		$this->assertTagsExist($tagIds);
-
-		$query = $this->connection->getQueryBuilder();
-		$query->selectDistinct('objectid')
-			->from(self::RELATION_TABLE)
-			->where($query->expr()->in('systemtagid', $query->createNamedParameter($tagIds, IQueryBuilder::PARAM_INT_ARRAY)))
-			->andWhere($query->expr()->eq('objecttype', $query->createNamedParameter($objectType)));
-
-		if ($limit) {
-			if (\count($tagIds) !== 1) {
-				throw new \InvalidArgumentException('Limit is only allowed with a single tag');
-			}
-
-			$query->setMaxResults($limit)
-				->orderBy('objectid', 'ASC');
-
-			if ($offset !== '') {
-				$query->andWhere($query->expr()->gt('objectid', $query->createNamedParameter($offset)));
-			}
-		}
-
-		$objectIds = [];
-
-		$result = $query->executeQuery();
-		while ($row = $result->fetch()) {
-			$objectIds[] = $row['objectid'];
-		}
-		$result->closeCursor();
-
-		return $objectIds;
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function assignTags(string $objId, string $objectType, $tagIds): void {
-		if (!\is_array($tagIds)) {
-			$tagIds = [$tagIds];
-		}
-
-		$this->assertTagsExist($tagIds);
-		$this->connection->beginTransaction();
-
-		$query = $this->connection->getQueryBuilder();
-		$query->select('systemtagid')
-			->from(self::RELATION_TABLE)
-			->where($query->expr()->in('systemtagid', $query->createNamedParameter($tagIds, IQueryBuilder::PARAM_INT_ARRAY)))
-			->andWhere($query->expr()->eq('objecttype', $query->createNamedParameter($objectType)))
-			->andWhere($query->expr()->eq('objectid', $query->createNamedParameter($objId)));
-		$result = $query->executeQuery();
-		$rows = $result->fetchAll();
-		$existingTags = [];
-		foreach ($rows as $row) {
-			$existingTags[] = $row['systemtagid'];
-		}
-		//filter only tags that do not exist in db
-		$tagIds = array_diff($tagIds, $existingTags);
-		if (empty($tagIds)) {
-			// no tags to insert so return here
-			$this->connection->commit();
-			return;
-		}
-
-		$query = $this->connection->getQueryBuilder();
-		$query->insert(self::RELATION_TABLE)
-			->values([
-				'objectid' => $query->createNamedParameter($objId),
-				'objecttype' => $query->createNamedParameter($objectType),
-				'systemtagid' => $query->createParameter('tagid'),
-			]);
-
-		$tagsAssigned = [];
-		foreach ($tagIds as $tagId) {
-			try {
-				$query->setParameter('tagid', $tagId);
-				$query->executeStatement();
-				$tagsAssigned[] = $tagId;
-			} catch (Exception $e) {
-				if ($e->getReason() !== Exception::REASON_UNIQUE_CONSTRAINT_VIOLATION) {
-					throw $e;
-				}
-				// ignore existing relations
-			}
-		}
-
-		$this->updateEtagForTags($tagIds);
-
-		$this->connection->commit();
-		if (empty($tagsAssigned)) {
-			return;
-		}
-
-		$this->dispatcher->dispatch(MapperEvent::EVENT_ASSIGN, new MapperEvent(
-			MapperEvent::EVENT_ASSIGN,
-			$objectType,
-			$objId,
-			$tagsAssigned
-		));
-		$this->dispatcher->dispatchTyped(new TagAssignedEvent($objectType, [$objId], $tagsAssigned));
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function unassignTags(string $objId, string $objectType, $tagIds): void {
-		if (!\is_array($tagIds)) {
-			$tagIds = [$tagIds];
-		}
-
-		$this->assertTagsExist($tagIds);
-
-		$query = $this->connection->getQueryBuilder();
-		$query->delete(self::RELATION_TABLE)
-			->where($query->expr()->eq('objectid', $query->createParameter('objectid')))
-			->andWhere($query->expr()->eq('objecttype', $query->createParameter('objecttype')))
-			->andWhere($query->expr()->in('systemtagid', $query->createParameter('tagids')))
-			->setParameter('objectid', $objId)
-			->setParameter('objecttype', $objectType)
-			->setParameter('tagids', $tagIds, IQueryBuilder::PARAM_INT_ARRAY)
-			->executeStatement();
-
-		$this->updateEtagForTags($tagIds);
-
-		$this->dispatcher->dispatch(MapperEvent::EVENT_UNASSIGN, new MapperEvent(
-			MapperEvent::EVENT_UNASSIGN,
-			$objectType,
-			$objId,
-			$tagIds
-		));
-		$this->dispatcher->dispatchTyped(new TagUnassignedEvent($objectType, [$objId], $tagIds));
-	}
-
-	/**
-	 * Update the etag for the given tags.
-	 *
-	 * @param string[] $tagIds
-	 */
-	private function updateEtagForTags(array $tagIds): void {
-		// Update etag after assigning tags
-		$md5 = md5(json_encode(time()));
-		$query = $this->connection->getQueryBuilder();
-		$query->update('systemtag')
-			->set('etag', $query->createNamedParameter($md5))
-			->where($query->expr()->in('id', $query->createNamedParameter($tagIds, IQueryBuilder::PARAM_INT_ARRAY)));
-		$query->executeStatement();
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function haveTag($objIds, string $objectType, string $tagId, bool $all = true): bool {
-		$this->assertTagsExist([$tagId]);
-
-		if (!\is_array($objIds)) {
-			$objIds = [$objIds];
-		}
-
-		$query = $this->connection->getQueryBuilder();
-
-		if (!$all) {
-			// If we only need one entry, we make the query lighter, by not
-			// counting the elements
-			$query->select('*')
-				->setMaxResults(1);
-		} else {
-			$query->select($query->func()->count($query->expr()->literal(1)));
-		}
-
-		$query->from(self::RELATION_TABLE)
-			->where($query->expr()->in('objectid', $query->createParameter('objectids')))
-			->andWhere($query->expr()->eq('objecttype', $query->createParameter('objecttype')))
-			->andWhere($query->expr()->eq('systemtagid', $query->createParameter('tagid')))
-			->setParameter('objectids', $objIds, IQueryBuilder::PARAM_STR_ARRAY)
-			->setParameter('tagid', $tagId)
-			->setParameter('objecttype', $objectType);
-
-		$result = $query->executeQuery();
-		$row = $result->fetch(\PDO::FETCH_NUM);
-		$result->closeCursor();
-
-		if ($all) {
-			return ((int)$row[0] === \count($objIds));
-		}
-
-		return (bool)$row;
-	}
-
-	/**
-	 * Asserts that all the given tag ids exist.
-	 *
-	 * @param string[] $tagIds tag ids to check
-	 *
-	 * @throws \OCP\SystemTag\TagNotFoundException if at least one tag did not exist
-	 */
-	private function assertTagsExist(array $tagIds): void {
-		$tags = $this->tagManager->getTagsByIds($tagIds);
-		if (\count($tags) !== \count($tagIds)) {
-			// at least one tag missing, bail out
-			$foundTagIds = array_map(
-				function (ISystemTag $tag) {
-					return $tag->getId();
-				},
-				$tags
-			);
-			$missingTagIds = array_diff($tagIds, $foundTagIds);
-			throw new TagNotFoundException(
-				'Tags not found', 0, null, $missingTagIds
-			);
-		}
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function setObjectIdsForTag(string $tagId, string $objectType, array $objectIds): void {
-		$currentObjectIds = $this->getObjectIdsForTags($tagId, $objectType);
-		$removedObjectIds = array_diff($currentObjectIds, $objectIds);
-		$addedObjectIds = array_diff($objectIds, $currentObjectIds);
-
-		$this->connection->beginTransaction();
-		$query = $this->connection->getQueryBuilder();
-		$query->delete(self::RELATION_TABLE)
-			->where($query->expr()->eq('systemtagid', $query->createNamedParameter($tagId, IQueryBuilder::PARAM_INT)))
-			->andWhere($query->expr()->eq('objecttype', $query->createNamedParameter($objectType)))
-			->executeStatement();
-		$this->connection->commit();
-
-		foreach ($removedObjectIds as $objectId) {
-			$this->dispatcher->dispatch(MapperEvent::EVENT_UNASSIGN, new MapperEvent(
-				MapperEvent::EVENT_UNASSIGN,
-				$objectType,
-				(string)$objectId,
-				[(int)$tagId]
-			));
-		}
-		if (!empty($removedObjectIds)) {
-			$this->dispatcher->dispatchTyped(new TagUnassignedEvent($objectType, array_map(fn ($objectId) => (string)$objectId, $removedObjectIds), [(int)$tagId]));
-		}
-
-		if (empty($objectIds)) {
-			return;
-		}
-
-		$this->connection->beginTransaction();
-		$query = $this->connection->getQueryBuilder();
-		$query->insert(self::RELATION_TABLE)
-			->values([
-				'systemtagid' => $query->createNamedParameter($tagId, IQueryBuilder::PARAM_INT),
-				'objecttype' => $query->createNamedParameter($objectType),
-				'objectid' => $query->createParameter('objectid'),
-			]);
-
-		foreach (array_unique($objectIds) as $objectId) {
-			$query->setParameter('objectid', (string)$objectId);
-			$query->executeStatement();
-		}
-
-		$this->updateEtagForTags([$tagId]);
-		$this->connection->commit();
-
-		// Dispatch assign events for new object ids
-		foreach ($addedObjectIds as $objectId) {
-			$this->dispatcher->dispatch(MapperEvent::EVENT_ASSIGN, new MapperEvent(
-				MapperEvent::EVENT_ASSIGN,
-				$objectType,
-				(string)$objectId,
-				[(int)$tagId]
-			));
-		}
-		if (!empty($addedObjectIds)) {
-			$this->dispatcher->dispatchTyped(new TagAssignedEvent($objectType, array_map(fn ($objectId) => (string)$objectId, $addedObjectIds), [(int)$tagId]));
-		}
-
-		// Dispatch unassign events for removed object ids
-		foreach ($removedObjectIds as $objectId) {
-			$this->dispatcher->dispatch(MapperEvent::EVENT_UNASSIGN, new MapperEvent(
-				MapperEvent::EVENT_UNASSIGN,
-				$objectType,
-				(string)$objectId,
-				[(int)$tagId]
-			));
-		}
-	}
-
-	/**
-	 * {@inheritdoc}
-	 */
-	public function getAvailableObjectTypes(): array {
-		$query = $this->connection->getQueryBuilder();
-		$query->selectDistinct('objecttype')
-			->from(self::RELATION_TABLE);
-
-		$result = $query->executeQuery();
-		$objectTypes = [];
-		while ($row = $result->fetch()) {
-			$objectTypes[] = $row['objecttype'];
-		}
-		$result->closeCursor();
-
-		return $objectTypes;
-	}
+    public const RELATION_TABLE = 'systemtag_object_mapping';
+
+    public function __construct(
+        protected IDBConnection $connection,
+        protected ISystemTagManager $tagManager,
+        protected IEventDispatcher $dispatcher,
+    ) {
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function getTagIdsForObjects($objIds, string $objectType): array {
+        if (!\is_array($objIds)) {
+            $objIds = [$objIds];
+        } elseif (empty($objIds)) {
+            return [];
+        }
+
+        $query = $this->connection->getQueryBuilder();
+        $query->select(['systemtagid', 'objectid'])
+            ->from(self::RELATION_TABLE)
+            ->where($query->expr()->in('objectid', $query->createParameter('objectids')))
+            ->andWhere($query->expr()->eq('objecttype', $query->createParameter('objecttype')))
+            ->setParameter('objecttype', $objectType)
+            ->addOrderBy('objectid', 'ASC')
+            ->addOrderBy('systemtagid', 'ASC');
+        $chunks = array_chunk($objIds, 900, false);
+        $mapping = [];
+        foreach ($objIds as $objId) {
+            $mapping[$objId] = [];
+        }
+        foreach ($chunks as $chunk) {
+            $query->setParameter('objectids', $chunk, IQueryBuilder::PARAM_STR_ARRAY);
+            $result = $query->executeQuery();
+            while ($row = $result->fetch()) {
+                $objectId = $row['objectid'];
+                $mapping[$objectId][] = $row['systemtagid'];
+            }
+
+            $result->closeCursor();
+        }
+
+        return $mapping;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function getObjectIdsForTags($tagIds, string $objectType, int $limit = 0, string $offset = ''): array {
+        if (!\is_array($tagIds)) {
+            $tagIds = [$tagIds];
+        }
+
+        $this->assertTagsExist($tagIds);
+
+        $query = $this->connection->getQueryBuilder();
+        $query->selectDistinct('objectid')
+            ->from(self::RELATION_TABLE)
+            ->where($query->expr()->in('systemtagid', $query->createNamedParameter($tagIds, IQueryBuilder::PARAM_INT_ARRAY)))
+            ->andWhere($query->expr()->eq('objecttype', $query->createNamedParameter($objectType)));
+
+        if ($limit) {
+            if (\count($tagIds) !== 1) {
+                throw new \InvalidArgumentException('Limit is only allowed with a single tag');
+            }
+
+            $query->setMaxResults($limit)
+                ->orderBy('objectid', 'ASC');
+
+            if ($offset !== '') {
+                $query->andWhere($query->expr()->gt('objectid', $query->createNamedParameter($offset)));
+            }
+        }
+
+        $objectIds = [];
+
+        $result = $query->executeQuery();
+        while ($row = $result->fetch()) {
+            $objectIds[] = $row['objectid'];
+        }
+        $result->closeCursor();
+
+        return $objectIds;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function assignTags(string $objId, string $objectType, $tagIds): void {
+        if (!\is_array($tagIds)) {
+            $tagIds = [$tagIds];
+        }
+
+        $this->assertTagsExist($tagIds);
+        $this->connection->beginTransaction();
+
+        $query = $this->connection->getQueryBuilder();
+        $query->select('systemtagid')
+            ->from(self::RELATION_TABLE)
+            ->where($query->expr()->in('systemtagid', $query->createNamedParameter($tagIds, IQueryBuilder::PARAM_INT_ARRAY)))
+            ->andWhere($query->expr()->eq('objecttype', $query->createNamedParameter($objectType)))
+            ->andWhere($query->expr()->eq('objectid', $query->createNamedParameter($objId)));
+        $result = $query->executeQuery();
+        $rows = $result->fetchAll();
+        $existingTags = [];
+        foreach ($rows as $row) {
+            $existingTags[] = $row['systemtagid'];
+        }
+        //filter only tags that do not exist in db
+        $tagIds = array_diff($tagIds, $existingTags);
+        if (empty($tagIds)) {
+            // no tags to insert so return here
+            $this->connection->commit();
+            return;
+        }
+
+        $query = $this->connection->getQueryBuilder();
+        $query->insert(self::RELATION_TABLE)
+            ->values([
+                'objectid' => $query->createNamedParameter($objId),
+                'objecttype' => $query->createNamedParameter($objectType),
+                'systemtagid' => $query->createParameter('tagid'),
+            ]);
+
+        $tagsAssigned = [];
+        foreach ($tagIds as $tagId) {
+            try {
+                $query->setParameter('tagid', $tagId);
+                $query->executeStatement();
+                $tagsAssigned[] = $tagId;
+            } catch (Exception $e) {
+                if ($e->getReason() !== Exception::REASON_UNIQUE_CONSTRAINT_VIOLATION) {
+                    throw $e;
+                }
+                // ignore existing relations
+            }
+        }
+
+        $this->updateEtagForTags($tagIds);
+
+        $this->connection->commit();
+        if (empty($tagsAssigned)) {
+            return;
+        }
+
+        $this->dispatcher->dispatch(MapperEvent::EVENT_ASSIGN, new MapperEvent(
+            MapperEvent::EVENT_ASSIGN,
+            $objectType,
+            $objId,
+            $tagsAssigned
+        ));
+        $this->dispatcher->dispatchTyped(new TagAssignedEvent($objectType, [$objId], $tagsAssigned));
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function unassignTags(string $objId, string $objectType, $tagIds): void {
+        if (!\is_array($tagIds)) {
+            $tagIds = [$tagIds];
+        }
+
+        $this->assertTagsExist($tagIds);
+
+        $query = $this->connection->getQueryBuilder();
+        $query->delete(self::RELATION_TABLE)
+            ->where($query->expr()->eq('objectid', $query->createParameter('objectid')))
+            ->andWhere($query->expr()->eq('objecttype', $query->createParameter('objecttype')))
+            ->andWhere($query->expr()->in('systemtagid', $query->createParameter('tagids')))
+            ->setParameter('objectid', $objId)
+            ->setParameter('objecttype', $objectType)
+            ->setParameter('tagids', $tagIds, IQueryBuilder::PARAM_INT_ARRAY)
+            ->executeStatement();
+
+        $this->updateEtagForTags($tagIds);
+
+        $this->dispatcher->dispatch(MapperEvent::EVENT_UNASSIGN, new MapperEvent(
+            MapperEvent::EVENT_UNASSIGN,
+            $objectType,
+            $objId,
+            $tagIds
+        ));
+        $this->dispatcher->dispatchTyped(new TagUnassignedEvent($objectType, [$objId], $tagIds));
+    }
+
+    /**
+     * Update the etag for the given tags.
+     *
+     * @param string[] $tagIds
+     */
+    private function updateEtagForTags(array $tagIds): void {
+        // Update etag after assigning tags
+        $md5 = md5(json_encode(time()));
+        $query = $this->connection->getQueryBuilder();
+        $query->update('systemtag')
+            ->set('etag', $query->createNamedParameter($md5))
+            ->where($query->expr()->in('id', $query->createNamedParameter($tagIds, IQueryBuilder::PARAM_INT_ARRAY)));
+        $query->executeStatement();
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function haveTag($objIds, string $objectType, string $tagId, bool $all = true): bool {
+        $this->assertTagsExist([$tagId]);
+
+        if (!\is_array($objIds)) {
+            $objIds = [$objIds];
+        }
+
+        $query = $this->connection->getQueryBuilder();
+
+        if (!$all) {
+            // If we only need one entry, we make the query lighter, by not
+            // counting the elements
+            $query->select('*')
+                ->setMaxResults(1);
+        } else {
+            $query->select($query->func()->count($query->expr()->literal(1)));
+        }
+
+        $query->from(self::RELATION_TABLE)
+            ->where($query->expr()->in('objectid', $query->createParameter('objectids')))
+            ->andWhere($query->expr()->eq('objecttype', $query->createParameter('objecttype')))
+            ->andWhere($query->expr()->eq('systemtagid', $query->createParameter('tagid')))
+            ->setParameter('objectids', $objIds, IQueryBuilder::PARAM_STR_ARRAY)
+            ->setParameter('tagid', $tagId)
+            ->setParameter('objecttype', $objectType);
+
+        $result = $query->executeQuery();
+        $row = $result->fetch(\PDO::FETCH_NUM);
+        $result->closeCursor();
+
+        if ($all) {
+            return ((int)$row[0] === \count($objIds));
+        }
+
+        return (bool)$row;
+    }
+
+    /**
+     * Asserts that all the given tag ids exist.
+     *
+     * @param string[] $tagIds tag ids to check
+     *
+     * @throws \OCP\SystemTag\TagNotFoundException if at least one tag did not exist
+     */
+    private function assertTagsExist(array $tagIds): void {
+        $tags = $this->tagManager->getTagsByIds($tagIds);
+        if (\count($tags) !== \count($tagIds)) {
+            // at least one tag missing, bail out
+            $foundTagIds = array_map(
+                function (ISystemTag $tag) {
+                    return $tag->getId();
+                },
+                $tags
+            );
+            $missingTagIds = array_diff($tagIds, $foundTagIds);
+            throw new TagNotFoundException(
+                'Tags not found', 0, null, $missingTagIds
+            );
+        }
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function setObjectIdsForTag(string $tagId, string $objectType, array $objectIds): void {
+        $currentObjectIds = $this->getObjectIdsForTags($tagId, $objectType);
+        $removedObjectIds = array_diff($currentObjectIds, $objectIds);
+        $addedObjectIds = array_diff($objectIds, $currentObjectIds);
+
+        $this->connection->beginTransaction();
+        $query = $this->connection->getQueryBuilder();
+        $query->delete(self::RELATION_TABLE)
+            ->where($query->expr()->eq('systemtagid', $query->createNamedParameter($tagId, IQueryBuilder::PARAM_INT)))
+            ->andWhere($query->expr()->eq('objecttype', $query->createNamedParameter($objectType)))
+            ->executeStatement();
+        $this->connection->commit();
+
+        foreach ($removedObjectIds as $objectId) {
+            $this->dispatcher->dispatch(MapperEvent::EVENT_UNASSIGN, new MapperEvent(
+                MapperEvent::EVENT_UNASSIGN,
+                $objectType,
+                (string)$objectId,
+                [(int)$tagId]
+            ));
+        }
+        if (!empty($removedObjectIds)) {
+            $this->dispatcher->dispatchTyped(new TagUnassignedEvent($objectType, array_map(fn ($objectId) => (string)$objectId, $removedObjectIds), [(int)$tagId]));
+        }
+
+        if (empty($objectIds)) {
+            return;
+        }
+
+        $this->connection->beginTransaction();
+        $query = $this->connection->getQueryBuilder();
+        $query->insert(self::RELATION_TABLE)
+            ->values([
+                'systemtagid' => $query->createNamedParameter($tagId, IQueryBuilder::PARAM_INT),
+                'objecttype' => $query->createNamedParameter($objectType),
+                'objectid' => $query->createParameter('objectid'),
+            ]);
+
+        foreach (array_unique($objectIds) as $objectId) {
+            $query->setParameter('objectid', (string)$objectId);
+            $query->executeStatement();
+        }
+
+        $this->updateEtagForTags([$tagId]);
+        $this->connection->commit();
+
+        // Dispatch assign events for new object ids
+        foreach ($addedObjectIds as $objectId) {
+            $this->dispatcher->dispatch(MapperEvent::EVENT_ASSIGN, new MapperEvent(
+                MapperEvent::EVENT_ASSIGN,
+                $objectType,
+                (string)$objectId,
+                [(int)$tagId]
+            ));
+        }
+        if (!empty($addedObjectIds)) {
+            $this->dispatcher->dispatchTyped(new TagAssignedEvent($objectType, array_map(fn ($objectId) => (string)$objectId, $addedObjectIds), [(int)$tagId]));
+        }
+
+        // Dispatch unassign events for removed object ids
+        foreach ($removedObjectIds as $objectId) {
+            $this->dispatcher->dispatch(MapperEvent::EVENT_UNASSIGN, new MapperEvent(
+                MapperEvent::EVENT_UNASSIGN,
+                $objectType,
+                (string)$objectId,
+                [(int)$tagId]
+            ));
+        }
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function getAvailableObjectTypes(): array {
+        $query = $this->connection->getQueryBuilder();
+        $query->selectDistinct('objecttype')
+            ->from(self::RELATION_TABLE);
+
+        $result = $query->executeQuery();
+        $objectTypes = [];
+        while ($row = $result->fetch()) {
+            $objectTypes[] = $row['objecttype'];
+        }
+        $result->closeCursor();
+
+        return $objectTypes;
+    }
 }

tests/lib/SystemTag/SystemTagObjectMapperTest.php

Indentation +406 added lines, -406 removed lines

@@ -30,410 +30,410 @@
  * @package Test\SystemTag
  */
 class SystemTagObjectMapperTest extends TestCase {
-	/**
-	 * @var ISystemTagManager
-	 **/
-	private $tagManager;
-
-	/**
-	 * @var ISystemTagObjectMapper
-	 **/
-	private $tagMapper;
-
-	/**
-	 * @var IDBConnection
-	 */
-	private $connection;
-
-	/**
-	 * @var IEventDispatcher
-	 */
-	private $dispatcher;
-
-	/**
-	 * @var ISystemTag
-	 */
-	private $tag1;
-
-	/**
-	 * @var ISystemTag
-	 */
-	private $tag2;
-
-	/**
-	 * @var ISystemTag
-	 */
-	private $tag3;
-
-	protected function setUp(): void {
-		parent::setUp();
-
-		$this->connection = Server::get(IDBConnection::class);
-		$this->pruneTagsTables();
-
-		$this->tagManager = $this->createMock(ISystemTagManager::class);
-		$this->dispatcher = $this->createMock(IEventDispatcher::class);
-
-		$this->tagMapper = new SystemTagObjectMapper(
-			$this->connection,
-			$this->tagManager,
-			$this->dispatcher
-		);
-
-		$this->tag1 = new SystemTag(1, 'testtag1', false, false);
-		$this->tag2 = new SystemTag(2, 'testtag2', true, false);
-		$this->tag3 = new SystemTag(3, 'testtag3', false, false);
-
-		$this->tagManager->expects($this->any())
-			->method('getTagsByIds')
-			->willReturnCallback(function ($tagIds) {
-				$result = [];
-				if (in_array(1, $tagIds)) {
-					$result[1] = $this->tag1;
-				}
-				if (in_array(2, $tagIds)) {
-					$result[2] = $this->tag2;
-				}
-				if (in_array(3, $tagIds)) {
-					$result[3] = $this->tag3;
-				}
-				return $result;
-			});
-
-		$this->tagMapper->assignTags('1', 'testtype', $this->tag1->getId());
-		$this->tagMapper->assignTags('1', 'testtype', $this->tag2->getId());
-		$this->tagMapper->assignTags('2', 'testtype', $this->tag1->getId());
-		$this->tagMapper->assignTags('3', 'anothertype', $this->tag1->getId());
-	}
-
-	protected function tearDown(): void {
-		$this->pruneTagsTables();
-		parent::tearDown();
-	}
-
-	protected function pruneTagsTables() {
-		$query = $this->connection->getQueryBuilder();
-		$query->delete(SystemTagObjectMapper::RELATION_TABLE)->executeStatement();
-		$query->delete(SystemTagManager::TAG_TABLE)->executeStatement();
-	}
-
-	public function testGetTagIdsForObjects(): void {
-		$tagIdMapping = $this->tagMapper->getTagIdsForObjects(
-			['1', '2', '3', '4'],
-			'testtype'
-		);
-
-		$this->assertEquals([
-			'1' => [$this->tag1->getId(), $this->tag2->getId()],
-			'2' => [$this->tag1->getId()],
-			'3' => [],
-			'4' => [],
-		], $tagIdMapping);
-	}
-
-	public function testGetTagIdsForNoObjects(): void {
-		$tagIdMapping = $this->tagMapper->getTagIdsForObjects(
-			[],
-			'testtype'
-		);
-
-		$this->assertEquals([], $tagIdMapping);
-	}
-
-	public function testGetTagIdsForALotOfObjects(): void {
-		$ids = range(1, 10500);
-		$tagIdMapping = $this->tagMapper->getTagIdsForObjects(
-			$ids,
-			'testtype'
-		);
-
-		$this->assertEquals(10500, count($tagIdMapping));
-		$this->assertEquals([$this->tag1->getId(), $this->tag2->getId()], $tagIdMapping[1]);
-	}
-
-	public function testGetObjectsForTags(): void {
-		$objectIds = $this->tagMapper->getObjectIdsForTags(
-			[$this->tag1->getId(), $this->tag2->getId(), $this->tag3->getId()],
-			'testtype'
-		);
-		sort($objectIds);
-
-		$this->assertEquals([
-			'1',
-			'2',
-		], $objectIds);
-	}
-
-	public function testGetObjectsForTagsLimit(): void {
-		$objectIds = $this->tagMapper->getObjectIdsForTags(
-			[$this->tag1->getId()],
-			'testtype',
-			1
-		);
-
-		$this->assertEquals([
-			1,
-		], $objectIds);
-	}
-
-
-	public function testGetObjectsForTagsLimitWithMultipleTags(): void {
-		$this->expectException(\InvalidArgumentException::class);
-
-		$this->tagMapper->getObjectIdsForTags(
-			[$this->tag1->getId(), $this->tag2->getId(), $this->tag3->getId()],
-			'testtype',
-			1
-		);
-	}
-
-	public function testGetObjectsForTagsLimitOffset(): void {
-		$objectIds = $this->tagMapper->getObjectIdsForTags(
-			[$this->tag1->getId()],
-			'testtype',
-			1,
-			'1'
-		);
-
-		$this->assertEquals([
-			2,
-		], $objectIds);
-	}
-
-
-	public function testGetObjectsForNonExistingTag(): void {
-		$this->expectException(TagNotFoundException::class);
-
-		$this->tagMapper->getObjectIdsForTags(
-			[100],
-			'testtype'
-		);
-	}
-
-	public function testAssignUnassignTags(): void {
-		$event = null;
-		$this->dispatcher->expects($this->any())->method('dispatchTyped')->willReturnCallback(function (Event $e) use (&$event) {
-			$event = $e;
-		});
-
-		$this->tagMapper->unassignTags('1', 'testtype', [$this->tag1->getId()]);
-
-		$this->assertNotNull($event);
-		$this->assertEquals(TagUnassignedEvent::class, $event::class);
-		$this->assertEquals('testtype', $event->getObjectType());
-		$this->assertCount(1, $event->getObjectIds());
-		$this->assertEquals('1', current($event->getObjectIds()));
-		$this->assertCount(1, $event->getTags());
-		$this->assertEquals($this->tag1->getId(), current($event->getTags()));
-
-		$tagIdMapping = $this->tagMapper->getTagIdsForObjects('1', 'testtype');
-		$this->assertEquals([
-			1 => [$this->tag2->getId()],
-		], $tagIdMapping);
-
-		$this->tagMapper->assignTags('1', 'testtype', [$this->tag1->getId()]);
-
-		$this->assertNotNull($event);
-		$this->assertEquals(TagAssignedEvent::class, $event::class);
-		$this->assertEquals('testtype', $event->getObjectType());
-		$this->assertCount(1, $event->getObjectIds());
-		$this->assertEquals('1', current($event->getObjectIds()));
-		$this->assertCount(1, $event->getTags());
-		$this->assertEquals($this->tag1->getId(), current($event->getTags()));
-
-		$this->tagMapper->assignTags('1', 'testtype', $this->tag3->getId());
-
-		$this->assertNotNull($event);
-		$this->assertEquals(TagAssignedEvent::class, $event::class);
-		$this->assertEquals('testtype', $event->getObjectType());
-		$this->assertCount(1, $event->getObjectIds());
-		$this->assertEquals('1', current($event->getObjectIds()));
-		$this->assertCount(1, $event->getTags());
-		$this->assertEquals($this->tag3->getId(), current($event->getTags()));
-
-		$tagIdMapping = $this->tagMapper->getTagIdsForObjects('1', 'testtype');
-
-		$this->assertEquals([
-			'1' => [$this->tag1->getId(), $this->tag2->getId(), $this->tag3->getId()],
-		], $tagIdMapping);
-	}
-
-	public function testReAssignUnassignTags(): void {
-		// reassign tag1
-		$this->tagMapper->assignTags('1', 'testtype', [$this->tag1->getId()]);
-
-		// tag 3 was never assigned
-		$this->tagMapper->unassignTags('1', 'testtype', [$this->tag3->getId()]);
-
-		$this->assertTrue(true, 'No error when reassigning/unassigning');
-	}
-
-
-	public function testAssignNonExistingTags(): void {
-		$this->expectException(TagNotFoundException::class);
-
-		$this->tagMapper->assignTags('1', 'testtype', [100]);
-	}
-
-	public function testAssignNonExistingTagInArray(): void {
-		$caught = false;
-		try {
-			$this->tagMapper->assignTags('1', 'testtype', [100, $this->tag3->getId()]);
-		} catch (TagNotFoundException $e) {
-			$caught = true;
-		}
-
-		$this->assertTrue($caught, 'Exception thrown');
-
-		$tagIdMapping = $this->tagMapper->getTagIdsForObjects(
-			['1'],
-			'testtype'
-		);
-
-		$this->assertEquals([
-			'1' => [$this->tag1->getId(), $this->tag2->getId()],
-		], $tagIdMapping, 'None of the tags got assigned');
-	}
-
-
-	public function testUnassignNonExistingTags(): void {
-		$this->expectException(TagNotFoundException::class);
-
-		$this->tagMapper->unassignTags('1', 'testtype', [100]);
-	}
-
-	public function testUnassignNonExistingTagsInArray(): void {
-		$caught = false;
-		try {
-			$this->tagMapper->unassignTags('1', 'testtype', [100, $this->tag1->getId()]);
-		} catch (TagNotFoundException $e) {
-			$caught = true;
-		}
-
-		$this->assertTrue($caught, 'Exception thrown');
-
-		$tagIdMapping = $this->tagMapper->getTagIdsForObjects(
-			[1],
-			'testtype'
-		);
-
-		$this->assertEquals([
-			'1' => [$this->tag1->getId(), $this->tag2->getId()],
-		], $tagIdMapping, 'None of the tags got unassigned');
-	}
-
-	public function testHaveTagAllMatches(): void {
-		$this->assertTrue(
-			$this->tagMapper->haveTag(
-				['1'],
-				'testtype',
-				$this->tag1->getId(),
-				true
-			),
-			'object 1 has the tag tag1'
-		);
-
-		$this->assertTrue(
-			$this->tagMapper->haveTag(
-				['1', '2'],
-				'testtype',
-				$this->tag1->getId(),
-				true
-			),
-			'object 1 and object 2 ALL have the tag tag1'
-		);
-
-		$this->assertFalse(
-			$this->tagMapper->haveTag(
-				['1', '2'],
-				'testtype',
-				$this->tag2->getId(),
-				true
-			),
-			'object 1 has tag2 but not object 2, so not ALL of them'
-		);
-
-		$this->assertFalse(
-			$this->tagMapper->haveTag(
-				['2'],
-				'testtype',
-				$this->tag2->getId(),
-				true
-			),
-			'object 2 does not have tag2'
-		);
-
-		$this->assertFalse(
-			$this->tagMapper->haveTag(
-				['3'],
-				'testtype',
-				$this->tag2->getId(),
-				true
-			),
-			'object 3 does not have tag1 due to different type'
-		);
-	}
-
-	public function testHaveTagAtLeastOneMatch(): void {
-		$this->assertTrue(
-			$this->tagMapper->haveTag(
-				['1'],
-				'testtype',
-				$this->tag1->getId(),
-				false
-			),
-			'object1 has the tag tag1'
-		);
-
-		$this->assertTrue(
-			$this->tagMapper->haveTag(
-				['1', '2'],
-				'testtype',
-				$this->tag1->getId(),
-				false
-			),
-			'object 1  and object 2 both the tag tag1'
-		);
-
-		$this->assertTrue(
-			$this->tagMapper->haveTag(
-				['1', '2'],
-				'testtype',
-				$this->tag2->getId(),
-				false
-			),
-			'at least object 1 has the tag tag2'
-		);
-
-		$this->assertFalse(
-			$this->tagMapper->haveTag(
-				['2'],
-				'testtype',
-				$this->tag2->getId(),
-				false
-			),
-			'object 2 does not have tag2'
-		);
-
-		$this->assertFalse(
-			$this->tagMapper->haveTag(
-				['3'],
-				'testtype',
-				$this->tag2->getId(),
-				false
-			),
-			'object 3 does not have tag1 due to different type'
-		);
-	}
-
-
-	public function testHaveTagNonExisting(): void {
-		$this->expectException(TagNotFoundException::class);
-
-		$this->tagMapper->haveTag(
-			['1'],
-			'testtype',
-			100
-		);
-	}
+    /**
+     * @var ISystemTagManager
+     **/
+    private $tagManager;
+
+    /**
+     * @var ISystemTagObjectMapper
+     **/
+    private $tagMapper;
+
+    /**
+     * @var IDBConnection
+     */
+    private $connection;
+
+    /**
+     * @var IEventDispatcher
+     */
+    private $dispatcher;
+
+    /**
+     * @var ISystemTag
+     */
+    private $tag1;
+
+    /**
+     * @var ISystemTag
+     */
+    private $tag2;
+
+    /**
+     * @var ISystemTag
+     */
+    private $tag3;
+
+    protected function setUp(): void {
+        parent::setUp();
+
+        $this->connection = Server::get(IDBConnection::class);
+        $this->pruneTagsTables();
+
+        $this->tagManager = $this->createMock(ISystemTagManager::class);
+        $this->dispatcher = $this->createMock(IEventDispatcher::class);
+
+        $this->tagMapper = new SystemTagObjectMapper(
+            $this->connection,
+            $this->tagManager,
+            $this->dispatcher
+        );
+
+        $this->tag1 = new SystemTag(1, 'testtag1', false, false);
+        $this->tag2 = new SystemTag(2, 'testtag2', true, false);
+        $this->tag3 = new SystemTag(3, 'testtag3', false, false);
+
+        $this->tagManager->expects($this->any())
+            ->method('getTagsByIds')
+            ->willReturnCallback(function ($tagIds) {
+                $result = [];
+                if (in_array(1, $tagIds)) {
+                    $result[1] = $this->tag1;
+                }
+                if (in_array(2, $tagIds)) {
+                    $result[2] = $this->tag2;
+                }
+                if (in_array(3, $tagIds)) {
+                    $result[3] = $this->tag3;
+                }
+                return $result;
+            });
+
+        $this->tagMapper->assignTags('1', 'testtype', $this->tag1->getId());
+        $this->tagMapper->assignTags('1', 'testtype', $this->tag2->getId());
+        $this->tagMapper->assignTags('2', 'testtype', $this->tag1->getId());
+        $this->tagMapper->assignTags('3', 'anothertype', $this->tag1->getId());
+    }
+
+    protected function tearDown(): void {
+        $this->pruneTagsTables();
+        parent::tearDown();
+    }
+
+    protected function pruneTagsTables() {
+        $query = $this->connection->getQueryBuilder();
+        $query->delete(SystemTagObjectMapper::RELATION_TABLE)->executeStatement();
+        $query->delete(SystemTagManager::TAG_TABLE)->executeStatement();
+    }
+
+    public function testGetTagIdsForObjects(): void {
+        $tagIdMapping = $this->tagMapper->getTagIdsForObjects(
+            ['1', '2', '3', '4'],
+            'testtype'
+        );
+
+        $this->assertEquals([
+            '1' => [$this->tag1->getId(), $this->tag2->getId()],
+            '2' => [$this->tag1->getId()],
+            '3' => [],
+            '4' => [],
+        ], $tagIdMapping);
+    }
+
+    public function testGetTagIdsForNoObjects(): void {
+        $tagIdMapping = $this->tagMapper->getTagIdsForObjects(
+            [],
+            'testtype'
+        );
+
+        $this->assertEquals([], $tagIdMapping);
+    }
+
+    public function testGetTagIdsForALotOfObjects(): void {
+        $ids = range(1, 10500);
+        $tagIdMapping = $this->tagMapper->getTagIdsForObjects(
+            $ids,
+            'testtype'
+        );
+
+        $this->assertEquals(10500, count($tagIdMapping));
+        $this->assertEquals([$this->tag1->getId(), $this->tag2->getId()], $tagIdMapping[1]);
+    }
+
+    public function testGetObjectsForTags(): void {
+        $objectIds = $this->tagMapper->getObjectIdsForTags(
+            [$this->tag1->getId(), $this->tag2->getId(), $this->tag3->getId()],
+            'testtype'
+        );
+        sort($objectIds);
+
+        $this->assertEquals([
+            '1',
+            '2',
+        ], $objectIds);
+    }
+
+    public function testGetObjectsForTagsLimit(): void {
+        $objectIds = $this->tagMapper->getObjectIdsForTags(
+            [$this->tag1->getId()],
+            'testtype',
+            1
+        );
+
+        $this->assertEquals([
+            1,
+        ], $objectIds);
+    }
+
+
+    public function testGetObjectsForTagsLimitWithMultipleTags(): void {
+        $this->expectException(\InvalidArgumentException::class);
+
+        $this->tagMapper->getObjectIdsForTags(
+            [$this->tag1->getId(), $this->tag2->getId(), $this->tag3->getId()],
+            'testtype',
+            1
+        );
+    }
+
+    public function testGetObjectsForTagsLimitOffset(): void {
+        $objectIds = $this->tagMapper->getObjectIdsForTags(
+            [$this->tag1->getId()],
+            'testtype',
+            1,
+            '1'
+        );
+
+        $this->assertEquals([
+            2,
+        ], $objectIds);
+    }
+
+
+    public function testGetObjectsForNonExistingTag(): void {
+        $this->expectException(TagNotFoundException::class);
+
+        $this->tagMapper->getObjectIdsForTags(
+            [100],
+            'testtype'
+        );
+    }
+
+    public function testAssignUnassignTags(): void {
+        $event = null;
+        $this->dispatcher->expects($this->any())->method('dispatchTyped')->willReturnCallback(function (Event $e) use (&$event) {
+            $event = $e;
+        });
+
+        $this->tagMapper->unassignTags('1', 'testtype', [$this->tag1->getId()]);
+
+        $this->assertNotNull($event);
+        $this->assertEquals(TagUnassignedEvent::class, $event::class);
+        $this->assertEquals('testtype', $event->getObjectType());
+        $this->assertCount(1, $event->getObjectIds());
+        $this->assertEquals('1', current($event->getObjectIds()));
+        $this->assertCount(1, $event->getTags());
+        $this->assertEquals($this->tag1->getId(), current($event->getTags()));
+
+        $tagIdMapping = $this->tagMapper->getTagIdsForObjects('1', 'testtype');
+        $this->assertEquals([
+            1 => [$this->tag2->getId()],
+        ], $tagIdMapping);
+
+        $this->tagMapper->assignTags('1', 'testtype', [$this->tag1->getId()]);
+
+        $this->assertNotNull($event);
+        $this->assertEquals(TagAssignedEvent::class, $event::class);
+        $this->assertEquals('testtype', $event->getObjectType());
+        $this->assertCount(1, $event->getObjectIds());
+        $this->assertEquals('1', current($event->getObjectIds()));
+        $this->assertCount(1, $event->getTags());
+        $this->assertEquals($this->tag1->getId(), current($event->getTags()));
+
+        $this->tagMapper->assignTags('1', 'testtype', $this->tag3->getId());
+
+        $this->assertNotNull($event);
+        $this->assertEquals(TagAssignedEvent::class, $event::class);
+        $this->assertEquals('testtype', $event->getObjectType());
+        $this->assertCount(1, $event->getObjectIds());
+        $this->assertEquals('1', current($event->getObjectIds()));
+        $this->assertCount(1, $event->getTags());
+        $this->assertEquals($this->tag3->getId(), current($event->getTags()));
+
+        $tagIdMapping = $this->tagMapper->getTagIdsForObjects('1', 'testtype');
+
+        $this->assertEquals([
+            '1' => [$this->tag1->getId(), $this->tag2->getId(), $this->tag3->getId()],
+        ], $tagIdMapping);
+    }
+
+    public function testReAssignUnassignTags(): void {
+        // reassign tag1
+        $this->tagMapper->assignTags('1', 'testtype', [$this->tag1->getId()]);
+
+        // tag 3 was never assigned
+        $this->tagMapper->unassignTags('1', 'testtype', [$this->tag3->getId()]);
+
+        $this->assertTrue(true, 'No error when reassigning/unassigning');
+    }
+
+
+    public function testAssignNonExistingTags(): void {
+        $this->expectException(TagNotFoundException::class);
+
+        $this->tagMapper->assignTags('1', 'testtype', [100]);
+    }
+
+    public function testAssignNonExistingTagInArray(): void {
+        $caught = false;
+        try {
+            $this->tagMapper->assignTags('1', 'testtype', [100, $this->tag3->getId()]);
+        } catch (TagNotFoundException $e) {
+            $caught = true;
+        }
+
+        $this->assertTrue($caught, 'Exception thrown');
+
+        $tagIdMapping = $this->tagMapper->getTagIdsForObjects(
+            ['1'],
+            'testtype'
+        );
+
+        $this->assertEquals([
+            '1' => [$this->tag1->getId(), $this->tag2->getId()],
+        ], $tagIdMapping, 'None of the tags got assigned');
+    }
+
+
+    public function testUnassignNonExistingTags(): void {
+        $this->expectException(TagNotFoundException::class);
+
+        $this->tagMapper->unassignTags('1', 'testtype', [100]);
+    }
+
+    public function testUnassignNonExistingTagsInArray(): void {
+        $caught = false;
+        try {
+            $this->tagMapper->unassignTags('1', 'testtype', [100, $this->tag1->getId()]);
+        } catch (TagNotFoundException $e) {
+            $caught = true;
+        }
+
+        $this->assertTrue($caught, 'Exception thrown');
+
+        $tagIdMapping = $this->tagMapper->getTagIdsForObjects(
+            [1],
+            'testtype'
+        );
+
+        $this->assertEquals([
+            '1' => [$this->tag1->getId(), $this->tag2->getId()],
+        ], $tagIdMapping, 'None of the tags got unassigned');
+    }
+
+    public function testHaveTagAllMatches(): void {
+        $this->assertTrue(
+            $this->tagMapper->haveTag(
+                ['1'],
+                'testtype',
+                $this->tag1->getId(),
+                true
+            ),
+            'object 1 has the tag tag1'
+        );
+
+        $this->assertTrue(
+            $this->tagMapper->haveTag(
+                ['1', '2'],
+                'testtype',
+                $this->tag1->getId(),
+                true
+            ),
+            'object 1 and object 2 ALL have the tag tag1'
+        );
+
+        $this->assertFalse(
+            $this->tagMapper->haveTag(
+                ['1', '2'],
+                'testtype',
+                $this->tag2->getId(),
+                true
+            ),
+            'object 1 has tag2 but not object 2, so not ALL of them'
+        );
+
+        $this->assertFalse(
+            $this->tagMapper->haveTag(
+                ['2'],
+                'testtype',
+                $this->tag2->getId(),
+                true
+            ),
+            'object 2 does not have tag2'
+        );
+
+        $this->assertFalse(
+            $this->tagMapper->haveTag(
+                ['3'],
+                'testtype',
+                $this->tag2->getId(),
+                true
+            ),
+            'object 3 does not have tag1 due to different type'
+        );
+    }
+
+    public function testHaveTagAtLeastOneMatch(): void {
+        $this->assertTrue(
+            $this->tagMapper->haveTag(
+                ['1'],
+                'testtype',
+                $this->tag1->getId(),
+                false
+            ),
+            'object1 has the tag tag1'
+        );
+
+        $this->assertTrue(
+            $this->tagMapper->haveTag(
+                ['1', '2'],
+                'testtype',
+                $this->tag1->getId(),
+                false
+            ),
+            'object 1  and object 2 both the tag tag1'
+        );
+
+        $this->assertTrue(
+            $this->tagMapper->haveTag(
+                ['1', '2'],
+                'testtype',
+                $this->tag2->getId(),
+                false
+            ),
+            'at least object 1 has the tag tag2'
+        );
+
+        $this->assertFalse(
+            $this->tagMapper->haveTag(
+                ['2'],
+                'testtype',
+                $this->tag2->getId(),
+                false
+            ),
+            'object 2 does not have tag2'
+        );
+
+        $this->assertFalse(
+            $this->tagMapper->haveTag(
+                ['3'],
+                'testtype',
+                $this->tag2->getId(),
+                false
+            ),
+            'object 3 does not have tag1 due to different type'
+        );
+    }
+
+
+    public function testHaveTagNonExisting(): void {
+        $this->expectException(TagNotFoundException::class);
+
+        $this->tagMapper->haveTag(
+            ['1'],
+            'testtype',
+            100
+        );
+    }
 }