feat(systemtags): add etag support and handle proppatch

Signed-off-by: skjnldsv <skjnldsv@protonmail.com>

1 files changed, 56 insertions, 0 deletions

diff --git a/lib/private/SystemTag/SystemTagObjectMapper.php b/lib/private/SystemTag/SystemTagObjectMapper.php
index 0bfc03a1227..ddb04fa968d 100644
--- a/lib/private/SystemTag/SystemTagObjectMapper.php
+++ b/lib/private/SystemTag/SystemTagObjectMapper.php
@@ -156,6 +156,8 @@ class SystemTagObjectMapper implements ISystemTagObjectMapper {
 			}
 		}
 
+		$this->updateEtagForTags($tagIds);
+
 		$this->connection->commit();
 		if (empty($tagsAssigned)) {
 			return;
@@ -189,6 +191,8 @@ class SystemTagObjectMapper implements ISystemTagObjectMapper {
 			->setParameter('tagids', $tagIds, IQueryBuilder::PARAM_INT_ARRAY)
 			->executeStatement();
 
+		$this->updateEtagForTags($tagIds);
+
 		$this->dispatcher->dispatch(MapperEvent::EVENT_UNASSIGN, new MapperEvent(
 			MapperEvent::EVENT_UNASSIGN,
 			$objectType,
@@ -198,6 +202,21 @@ class SystemTagObjectMapper implements ISystemTagObjectMapper {
 	}
 
 	/**
+	 * Update the etag for the given tags.
+	 *
+	 * @param int[] $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->execute();
+	}
+
+	/**
 	 * {@inheritdoc}
 	 */
 	public function haveTag($objIds, string $objectType, string $tagId, bool $all = true): bool {
@@ -261,6 +280,43 @@ class SystemTagObjectMapper implements ISystemTagObjectMapper {
 		}
 	}
 
+	/**
+	 * {@inheritdoc}
+	 */
+	public function setObjectIdsForTag(string $tagId, string $objectType, array $objectIds): void {
+		$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();
+
+		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();
+	}
+
+	/**
+	 * {@inheritdoc}
+	 */
 	public function getAvailableObjectTypes(): array {
 		$query = $this->connection->getQueryBuilder();
 		$query->selectDistinct('objecttype')