4 files changed, 389 insertions, 0 deletions
diff --git a/apps/comments/lib/Activity/Filter.php b/apps/comments/lib/Activity/Filter.php
new file mode 100644
index 00000000000..8dcafd872d7
--- /dev/null
+++ b/apps/comments/lib/Activity/Filter.php
@@ -0,0 +1,50 @@
+<?php
+
+/**
+ * SPDX-FileCopyrightText: 2016 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+namespace OCA\Comments\Activity;
+
+use OCP\Activity\IFilter;
+use OCP\IL10N;
+use OCP\IURLGenerator;
+
+class Filter implements IFilter {
+	public function __construct(
+		protected IL10N $l,
+		protected IURLGenerator $url,
+	) {
+	}
+
+	public function getIdentifier(): string {
+		return 'comments';
+	}
+
+	public function getName(): string {
+		return $this->l->t('Comments');
+	}
+
+	public function getPriority(): int {
+		return 40;
+	}
+
+	public function getIcon(): string {
+		return $this->url->getAbsoluteURL($this->url->imagePath('core', 'actions/comment.svg'));
+	}
+
+	/**
+	 * @param string[] $types
+	 * @return string[] An array of allowed apps from which activities should be displayed
+	 */
+	public function filterTypes(array $types): array {
+		return $types;
+	}
+
+	/**
+	 * @return string[] An array of allowed apps from which activities should be displayed
+	 */
+	public function allowedApps(): array {
+		return ['comments'];
+	}
+}
diff --git a/apps/comments/lib/Activity/Listener.php b/apps/comments/lib/Activity/Listener.php
new file mode 100644
index 00000000000..45064f4a6be
--- /dev/null
+++ b/apps/comments/lib/Activity/Listener.php
@@ -0,0 +1,88 @@
+<?php
+
+/**
+ * SPDX-FileCopyrightText: 2016-2024 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-FileCopyrightText: 2016 ownCloud, Inc.
+ * SPDX-License-Identifier: AGPL-3.0-only
+ */
+namespace OCA\Comments\Activity;
+
+use OCP\Activity\IManager;
+use OCP\App\IAppManager;
+use OCP\Comments\CommentsEvent;
+use OCP\Files\Config\IMountProviderCollection;
+use OCP\Files\IRootFolder;
+use OCP\Files\Node;
+use OCP\IUser;
+use OCP\IUserSession;
+use OCP\Share\IShareHelper;
+
+class Listener {
+	public function __construct(
+		protected IManager $activityManager,
+		protected IUserSession $session,
+		protected IAppManager $appManager,
+		protected IMountProviderCollection $mountCollection,
+		protected IRootFolder $rootFolder,
+		protected IShareHelper $shareHelper,
+	) {
+	}
+
+	public function commentEvent(CommentsEvent $event): void {
+		if ($event->getComment()->getObjectType() !== 'files'
+			|| $event->getEvent() !== CommentsEvent::EVENT_ADD
+			|| !$this->appManager->isEnabledForAnyone('activity')) {
+			// Comment not for file, not adding a comment or no activity-app enabled (save the energy)
+			return;
+		}
+
+		// Get all mount point owners
+		$cache = $this->mountCollection->getMountCache();
+		$mounts = $cache->getMountsForFileId((int)$event->getComment()->getObjectId());
+		if (empty($mounts)) {
+			return;
+		}
+
+		$users = [];
+		foreach ($mounts as $mount) {
+			$owner = $mount->getUser()->getUID();
+			$ownerFolder = $this->rootFolder->getUserFolder($owner);
+			$nodes = $ownerFolder->getById((int)$event->getComment()->getObjectId());
+			if (!empty($nodes)) {
+				/** @var Node $node */
+				$node = array_shift($nodes);
+				$al = $this->shareHelper->getPathsForAccessList($node);
+				$users += $al['users'];
+			}
+		}
+
+		$actor = $this->session->getUser();
+		if ($actor instanceof IUser) {
+			$actor = $actor->getUID();
+		} else {
+			$actor = '';
+		}
+
+		$activity = $this->activityManager->generateEvent();
+		$activity->setApp('comments')
+			->setType('comments')
+			->setAuthor($actor)
+			->setObject($event->getComment()->getObjectType(), (int)$event->getComment()->getObjectId())
+			->setMessage('add_comment_message', [
+				'commentId' => $event->getComment()->getId(),
+			]);
+
+		foreach ($users as $user => $path) {
+			// numerical user ids end up as integers from array keys, but string
+			// is required
+			$activity->setAffectedUser((string)$user);
+
+			$activity->setSubject('add_comment_subject', [
+				'actor' => $actor,
+				'fileId' => (int)$event->getComment()->getObjectId(),
+				'filePath' => trim($path, '/'),
+			]);
+			$this->activityManager->publish($activity);
+		}
+	}
+}
diff --git a/apps/comments/lib/Activity/Provider.php b/apps/comments/lib/Activity/Provider.php
new file mode 100644
index 00000000000..ee53357efdb
--- /dev/null
+++ b/apps/comments/lib/Activity/Provider.php
@@ -0,0 +1,198 @@
+<?php
+
+/**
+ * SPDX-FileCopyrightText: 2016 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+namespace OCA\Comments\Activity;
+
+use OCP\Activity\Exceptions\UnknownActivityException;
+use OCP\Activity\IEvent;
+use OCP\Activity\IManager;
+use OCP\Activity\IProvider;
+use OCP\Comments\ICommentsManager;
+use OCP\Comments\NotFoundException;
+use OCP\IL10N;
+use OCP\IURLGenerator;
+use OCP\IUserManager;
+use OCP\L10N\IFactory;
+
+class Provider implements IProvider {
+	protected ?IL10N $l = null;
+
+	public function __construct(
+		protected IFactory $languageFactory,
+		protected IURLGenerator $url,
+		protected ICommentsManager $commentsManager,
+		protected IUserManager $userManager,
+		protected IManager $activityManager,
+	) {
+	}
+
+	/**
+	 * @param string $language
+	 * @param IEvent $event
+	 * @param IEvent|null $previousEvent
+	 * @return IEvent
+	 * @throws UnknownActivityException
+	 * @since 11.0.0
+	 */
+	public function parse($language, IEvent $event, ?IEvent $previousEvent = null): IEvent {
+		if ($event->getApp() !== 'comments') {
+			throw new UnknownActivityException();
+		}
+
+		$this->l = $this->languageFactory->get('comments', $language);
+
+		if ($event->getSubject() === 'add_comment_subject') {
+			$this->parseMessage($event);
+			if ($this->activityManager->getRequirePNG()) {
+				$event->setIcon($this->url->getAbsoluteURL($this->url->imagePath('core', 'actions/comment.png')));
+			} else {
+				$event->setIcon($this->url->getAbsoluteURL($this->url->imagePath('core', 'actions/comment.svg')));
+			}
+
+			if ($this->activityManager->isFormattingFilteredObject()) {
+				try {
+					return $this->parseShortVersion($event);
+				} catch (UnknownActivityException) {
+					// Ignore and simply use the long version...
+				}
+			}
+
+			return $this->parseLongVersion($event);
+		}
+		throw new UnknownActivityException();
+
+	}
+
+	/**
+	 * @throws UnknownActivityException
+	 */
+	protected function parseShortVersion(IEvent $event): IEvent {
+		$subjectParameters = $this->getSubjectParameters($event);
+
+		if ($event->getSubject() === 'add_comment_subject') {
+			if ($subjectParameters['actor'] === $this->activityManager->getCurrentUserId()) {
+				$event->setRichSubject($this->l->t('You commented'), []);
+			} else {
+				$author = $this->generateUserParameter($subjectParameters['actor']);
+				$event->setRichSubject($this->l->t('{author} commented'), [
+					'author' => $author,
+				]);
+			}
+		} else {
+			throw new UnknownActivityException();
+		}
+
+		return $event;
+	}
+
+	/**
+	 * @throws UnknownActivityException
+	 */
+	protected function parseLongVersion(IEvent $event): IEvent {
+		$subjectParameters = $this->getSubjectParameters($event);
+
+		if ($event->getSubject() === 'add_comment_subject') {
+			if ($subjectParameters['actor'] === $this->activityManager->getCurrentUserId()) {
+				$event->setParsedSubject($this->l->t('You commented on %1$s', [
+					$subjectParameters['filePath'],
+				]))
+					->setRichSubject($this->l->t('You commented on {file}'), [
+						'file' => $this->generateFileParameter($subjectParameters['fileId'], $subjectParameters['filePath']),
+					]);
+			} else {
+				$author = $this->generateUserParameter($subjectParameters['actor']);
+				$event->setParsedSubject($this->l->t('%1$s commented on %2$s', [
+					$author['name'],
+					$subjectParameters['filePath'],
+				]))
+					->setRichSubject($this->l->t('{author} commented on {file}'), [
+						'author' => $author,
+						'file' => $this->generateFileParameter($subjectParameters['fileId'], $subjectParameters['filePath']),
+					]);
+			}
+		} else {
+			throw new UnknownActivityException();
+		}
+
+		return $event;
+	}
+
+	protected function getSubjectParameters(IEvent $event): array {
+		$subjectParameters = $event->getSubjectParameters();
+		if (isset($subjectParameters['fileId'])) {
+			return $subjectParameters;
+		}
+
+		// Fix subjects from 12.0.3 and older
+		//
+		// Do NOT Remove unless necessary
+		// Removing this will break parsing of activities that were created on
+		// Nextcloud 12, so we should keep this as long as it's acceptable.
+		// Otherwise if people upgrade over multiple releases in a short period,
+		// they will get the dead entries in their stream.
+		return [
+			'actor' => $subjectParameters[0],
+			'fileId' => $event->getObjectId(),
+			'filePath' => trim($subjectParameters[1], '/'),
+		];
+	}
+
+	protected function parseMessage(IEvent $event): void {
+		$messageParameters = $event->getMessageParameters();
+		if (empty($messageParameters)) {
+			// Email
+			return;
+		}
+
+		$commentId = $messageParameters['commentId'] ?? $messageParameters[0];
+
+		try {
+			$comment = $this->commentsManager->get((string)$commentId);
+			$message = $comment->getMessage();
+
+			$mentionCount = 1;
+			$mentions = [];
+			foreach ($comment->getMentions() as $mention) {
+				if ($mention['type'] !== 'user') {
+					continue;
+				}
+
+				$message = str_replace('@"' . $mention['id'] . '"', '{mention' . $mentionCount . '}', $message);
+				if (!str_contains($mention['id'], ' ') && !str_starts_with($mention['id'], 'guest/')) {
+					$message = str_replace('@' . $mention['id'], '{mention' . $mentionCount . '}', $message);
+				}
+
+				$mentions['mention' . $mentionCount] = $this->generateUserParameter($mention['id']);
+				$mentionCount++;
+			}
+
+			$event->setParsedMessage($comment->getMessage())
+				->setRichMessage($message, $mentions);
+		} catch (NotFoundException $e) {
+		}
+	}
+
+	/**
+	 * @return array<string, string>
+	 */
+	protected function generateFileParameter(int $id, string $path): array {
+		return [
+			'type' => 'file',
+			'id' => (string)$id,
+			'name' => basename($path),
+			'path' => $path,
+			'link' => $this->url->linkToRouteAbsolute('files.viewcontroller.showFile', ['fileid' => $id]),
+		];
+	}
+
+	protected function generateUserParameter(string $uid): array {
+		return [
+			'type' => 'user',
+			'id' => $uid,
+			'name' => $this->userManager->getDisplayName($uid) ?? $uid,
+		];
+	}
+}
diff --git a/apps/comments/lib/Activity/Setting.php b/apps/comments/lib/Activity/Setting.php
new file mode 100644
index 00000000000..7fbf4001b20
--- /dev/null
+++ b/apps/comments/lib/Activity/Setting.php
@@ -0,0 +1,53 @@
+<?php
+
+/**
+ * SPDX-FileCopyrightText: 2016 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+namespace OCA\Comments\Activity;
+
+use OCP\Activity\ActivitySettings;
+use OCP\IL10N;
+
+class Setting extends ActivitySettings {
+	public function __construct(
+		protected IL10N $l,
+	) {
+	}
+
+	public function getIdentifier(): string {
+		return 'comments';
+	}
+
+	public function getName(): string {
+		return $this->l->t('<strong>Comments</strong> for files');
+	}
+
+	public function getGroupIdentifier() {
+		return 'files';
+	}
+
+	public function getGroupName() {
+		return $this->l->t('Files');
+	}
+
+	public function getPriority(): int {
+		return 50;
+	}
+
+	public function canChangeStream(): bool {
+		return true;
+	}
+
+	public function isDefaultEnabledStream(): bool {
+		return true;
+	}
+
+	public function canChangeMail(): bool {
+		return true;
+	}
+
+	public function isDefaultEnabledMail(): bool {
+		return false;
+	}
+}