fix(ContextChat): Listen for new db-level change events

Signed-off-by: Marcel Klehr <mklehr@gmx.net>

Author: marcelklehr

lib/ContextChat/ContextChatProvider.php

@@ -12,6 +12,8 @@
 use OCA\Bookmarks\Db\TreeMapper;
 use OCA\Bookmarks\Events\BeforeDeleteEvent;
 use OCA\Bookmarks\Events\CreateEvent;
+use OCA\Bookmarks\Events\InsertEvent;
+use OCA\Bookmarks\Events\ManipulateEvent;
 use OCA\Bookmarks\Events\UpdateEvent;
 use OCA\Bookmarks\Service\BookmarkService;
 use OCA\ContextChat\Event\ContentProviderRegisterEvent;
@@ -39,10 +41,10 @@ public function __construct(
 
 	public function handle(Event $event): void {
 		if ($event instanceof ContentProviderRegisterEvent) {
-			$this->register($event);
+			$this->register();
 			return;
 		}
-		if ($event instanceof CreateEvent || $event instanceof UpdateEvent) {
+		if ($event instanceof InsertEvent || $event instanceof ManipulateEvent) {
 			if ($event->getType() !== TreeMapper::TYPE_BOOKMARK) {
 				return;
 			}
@@ -70,8 +72,8 @@ public function handle(Event $event): void {
 
 	public function register(): void {
 		$this->contentManager->registerContentProvider($this->getAppId(), $this->getId(), self::class);
-		$this->eventDispatcher->addServiceListener(CreateEvent::class, self::class);
-		$this->eventDispatcher->addServiceListener(UpdateEvent::class, self::class);
+		$this->eventDispatcher->addServiceListener(InsertEvent::class, self::class);
+		$this->eventDispatcher->addServiceListener(ManipulateEvent::class, self::class);
 		$this->eventDispatcher->addServiceListener(BeforeDeleteEvent::class, self::class);
 	}
 

lib/Db/BookmarkMapper.php

@@ -9,6 +9,8 @@
 namespace OCA\Bookmarks\Db;
 
 use OCA\Bookmarks\Events\BeforeDeleteEvent;
+use OCA\Bookmarks\Events\InsertEvent;
+use OCA\Bookmarks\Events\ManipulateEvent;
 use OCA\Bookmarks\Exception\AlreadyExistsError;
 use OCA\Bookmarks\Exception\UrlParseError;
 use OCA\Bookmarks\Exception\UserLimitExceededError;
@@ -775,7 +777,9 @@ public function update(Entity $entity): Bookmark {
 			$entity->setUrl($this->urlNormalizer->normalize($entity->getUrl()));
 		}
 		$entity->setLastmodified(time());
-		return parent::update($entity);
+		parent::update($entity);
+		$this->eventDispatcher->dispatchTyped(new ManipulateEvent('bookmark', $entity->getId()));
+		return $entity;
 	}
 
 	/**
@@ -808,6 +812,7 @@ public function insert(Entity $entity): Bookmark {
 			$this->findByUrl($entity->getUserId(), $entity->getUrl());
 		} catch (DoesNotExistException $e) {
 			parent::insert($entity);
+			$this->eventDispatcher->dispatchTyped(new InsertEvent('bookmark', $entity->getId()));
 			return $entity;
 		} catch (MultipleObjectsReturnedException $e) {
 			// noop

lib/Events/InsertEvent.php

@@ -0,0 +1,16 @@
+<?php
+
+/*
+ * Copyright (c) 2020-2024. The Nextcloud Bookmarks contributors.
+ *
+ * This file is licensed under the Affero General Public License version 3 or later. See the COPYING file.
+ */
+
+namespace OCA\Bookmarks\Events;
+
+/**
+ * Event emitted when a bookmarks entity is inserted into the DB
+ * Not exposed via the activity app
+ */
+class InsertEvent extends ChangeEvent {
+}

lib/Events/ManipulateEvent.php

@@ -0,0 +1,16 @@
+<?php
+
+/*
+ * Copyright (c) 2020-2024. The Nextcloud Bookmarks contributors.
+ *
+ * This file is licensed under the Affero General Public License version 3 or later. See the COPYING file.
+ */
+
+namespace OCA\Bookmarks\Events;
+
+/**
+ * Event emitted when a bookmarks entity is manipulated into the DB
+ * Not exposed via the activity app
+ */
+class ManipulateEvent extends ChangeEvent {
+}