Listen to more events for albums

Signed-off-by: Louis Chemineau <[email protected]>

lib/Album/AlbumMapper.php

@@ -273,6 +273,9 @@ public function removeFile(int $albumId, int $fileId): void {
 		$query->executeStatement();
 	}
 
+	/**
+	 * Remove all files added by a user from an album.
+	 */
 	public function removeFilesForUser(int $albumId, string $userId) {
 		// Remove all photos by this user from the album:
 		$query = $this->connection->getQueryBuilder();
@@ -289,6 +292,36 @@ public function removeFilesForUser(int $albumId, string $userId) {
 			->executeStatement();
 	}
 
+	/**
+	 * Remove a given file from any albums in which it was added by a given user.
+	 */
+	public function removeFileWithOwner(int $fileId, string $ownerId): void {
+		// Get concerned albums before deleting them.
+		$query = $this->connection->getQueryBuilder();
+		$albumsRows = $query->select('album_id')
+			->from("photos_albums_files")
+			->where($query->expr()->eq("owner_id", $query->createNamedParameter($ownerId)))
+			->andWhere($query->expr()->eq("file_id", $query->createNamedParameter($fileId, IQueryBuilder::PARAM_INT)))
+			->executeQuery()
+			->fetchAll();
+
+		// Remove any occurrence of fileId when owner is ownerId.
+		$query = $this->connection->getQueryBuilder();
+		$query->delete("photos_albums_files")
+			->where($query->expr()->eq("owner_id", $query->createNamedParameter($ownerId)))
+			->andWhere($query->expr()->eq("file_id", $query->createNamedParameter($fileId, IQueryBuilder::PARAM_INT)))
+			->executeStatement();
+
+		// Update last_added_photo for concerned albums.
+		foreach ($albumsRows as $row) {
+			$query = $this->connection->getQueryBuilder();
+			$query->update("photos_albums")
+				->set('last_added_photo', $query->createNamedParameter($this->getLastAdded($row['album_id']), IQueryBuilder::PARAM_INT))
+				->where($query->expr()->eq('album_id', $query->createNamedParameter($row['album_id'], IQueryBuilder::PARAM_INT)));
+			$query->executeStatement();
+		}
+	}
+
 	private function getLastAdded(int $albumId): int {
 		$query = $this->connection->getQueryBuilder();
 		$query->select("file_id")

lib/Listener/AlbumsManagementEventListener.php

@@ -0,0 +1,64 @@
+<?php
+
+namespace OCA\Photos\Listener;
+
+use OCA\Photos\Album\AlbumMapper;
+use OCP\Files\File;
+use OCP\Files\Folder;
+use OCP\Files\Node;
+use OCP\EventDispatcher\Event;
+use OCP\EventDispatcher\IEventListener;
+use OCP\Files\Cache\CacheEntryRemovedEvent;
+use OCP\Share\Events\ShareDeletedEvent;
+use OCP\User\Events\UserDeletedEvent;
+
+class AlbumsManagementEventListener implements IEventListener {
+	private AlbumMapper $albumMapper;
+
+	public function __construct(AlbumMapper $albumMapper) {
+		$this->albumMapper = $albumMapper;
+	}
+
+	public function handle(Event $event): void {
+		if ($event instanceof CacheEntryRemovedEvent) {
+			// Remove node from all albums containing it.
+			$albums = $this->albumMapper->getForFile($event->getFileId());
+			foreach ($albums as $album) {
+				$this->albumMapper->removeFile($album->getId(), $event->getFileId());
+			}
+		}
+
+		if ($event instanceof UserDeletedEvent) {
+			// Delete all user's albums.
+			$albums = $this->albumMapper->getForUser($event->getUser()->getUID());
+			foreach ($albums as $album) {
+				$this->albumMapper->delete($album->getId());
+			}
+		}
+
+		if ($event instanceof ShareDeletedEvent) {
+			$receiverId = $event->getShare()->getSharedWith();
+			$this->forEachSubNode(
+				$event->getShare()->getNode(),
+				// Remove node from any album when the owner is $receiverId.
+				fn ($node) => $this->albumMapper->removeFileWithOwner($node->getId(), $receiverId),
+			);
+		}
+	}
+
+	private function forEachSubNode(Node $node, callable $callback): void {
+		if ($node instanceof Folder) {
+			foreach ($node->getDirectoryListing() as $subNode) {
+				$this->forEachSubNode($subNode, $callback);
+			}
+		}
+
+		if ($node instanceof File) {
+			if (!str_starts_with($node->getMimeType(), 'image')) {
+				return;
+			}
+
+			$callback($node);
+		}
+	}
+}