feat: Group activities send by mail

Signed-off-by: Louis Chemineau <louis@chmn.me>

[skip ci]

Signed-off-by: Louis Chemineau <louis@chmn.me>

Author: artonge

lib/AppInfo/Application.php

@@ -31,11 +31,13 @@
 use OCA\Activity\Consumer;
 use OCA\Activity\Data;
 use OCA\Activity\FilesHooksStatic;
+use OCA\Activity\GroupHelper;
 use OCA\Activity\Listener\LoadSidebarScripts;
 use OCA\Activity\Listener\SetUserDefaults;
 use OCA\Activity\Listener\UserDeleted;
 use OCA\Activity\MailQueueHandler;
 use OCA\Activity\NotificationGenerator;
+use OCA\Activity\UserSettings;
 use OCA\Activity\Dashboard\ActivityWidget;
 use OCA\Files\Event\LoadSidebar;
 use OCP\Activity\IManager;
@@ -124,7 +126,10 @@ public function register(IRegistrationContext $context): void {
 				$c->get(IManager::class),
 				$c->get(IValidator::class),
 				$c->get(IConfig::class),
-				$c->get(ILogger::class)
+				$c->get(ILogger::class),
+				$c->get(Data::class),
+				$c->get(GroupHelper::class),
+				$c->get(UserSettings::class),
 			);
 		});
 

lib/GroupHelper.php

@@ -31,12 +31,9 @@
 
 class GroupHelper {
 	/** @var IEvent[] */
-	protected $event = [];
-	/** @var int */
-	protected $lastEvent = 0;
-
-	/** @var bool */
-	protected $allowGrouping;
+	protected array $event = [];
+	protected int $lastEvent = 0;
+	protected bool $allowGrouping = true;
 
 	/** @var IL10N */
 	protected $l;
@@ -53,30 +50,36 @@ class GroupHelper {
 	public function __construct(IL10N $l,
 								IManager $activityManager,
 								IValidator $richObjectValidator,
-								ILogger $logger) {
-		$this->allowGrouping = true;
-
+								ILogger $logger
+	) {
 		$this->l = $l;
 		$this->activityManager = $activityManager;
 		$this->richObjectValidator = $richObjectValidator;
 		$this->logger = $logger;
 	}
 
-	/**
-	 * @param IL10N $l
-	 */
-	public function setL10n(IL10N $l) {
+	public function resetEvents(): void {
+		$this->event = [];
+		$this->lastEvent = 0;
+	}
+
+	public function setL10n(IL10N $l): void {
 		$this->l = $l;
 	}
 
 	/**
 	 * Add an activity to the internal array
-	 *
-	 * @param array $activity
 	 */
-	public function addActivity($activity) {
+	public function addActivity(array $activity): void {
 		$id = (int) $activity['activity_id'];
 		$event = $this->arrayToEvent($activity);
+		$this->addEvent($id, $event);
+	}
+
+	/**
+	 * Add an event to the internal array
+	 */
+	public function addEvent(int $id, IEvent $event): void {
 		$language = $this->l->getLanguageCode();
 
 		foreach ($this->activityManager->getProviders() as $provider) {
@@ -87,34 +90,37 @@ public function addActivity($activity) {
 				} else {
 					$event = $provider->parse($language, $event);
 				}
-				try {
-					$this->richObjectValidator->validate($event->getRichSubject(), $event->getRichSubjectParameters());
-				} catch (InvalidObjectExeption $e) {
-					$this->logger->logException($e);
-					$event->setRichSubject('Rich subject or a parameter for "' . $event->getRichSubject() . '" is malformed', []);
-					$event->setParsedSubject('Rich subject or a parameter for "' . $event->getRichSubject() . '" is malformed');
-				}
-
-				if ($event->getRichMessage()) {
-					try {
-						$this->richObjectValidator->validate($event->getRichMessage(), $event->getRichMessageParameters());
-					} catch (InvalidObjectExeption $e) {
-						$this->logger->logException($e);
-						$event->setRichMessage('Rich message or a parameter is malformed', []);
-						$event->setParsedMessage('Rich message or a parameter is malformed');
-					}
-				}
+			} catch (\InvalidArgumentException $e) {
+			} catch (\Throwable $e) {
+				$this->logger->error('Error while parsing activity event', ['exception' => $e]);
+			}
+		}
 
-				$this->activityManager->setFormattingObject('', 0);
+		try {
+			$this->richObjectValidator->validate($event->getRichSubject(), $event->getRichSubjectParameters());
+		} catch (InvalidObjectExeption $e) {
+			$this->logger->logException($e);
+			$event->setRichSubject('Rich subject or a parameter for "' . $event->getRichSubject() . '" is malformed', []);
+			$event->setParsedSubject('Rich subject or a parameter for "' . $event->getRichSubject() . '" is malformed');
+		}
 
-				$child = $event->getChildEvent();
-				if ($child instanceof IEvent) {
-					unset($this->event[$this->lastEvent]);
-				}
-			} catch (\InvalidArgumentException $e) {
+		if ($event->getRichMessage()) {
+			try {
+				$this->richObjectValidator->validate($event->getRichMessage(), $event->getRichMessageParameters());
+			} catch (InvalidObjectExeption $e) {
+				$this->logger->logException($e);
+				$event->setRichMessage('Rich message or a parameter is malformed', []);
+				$event->setParsedMessage('Rich message or a parameter is malformed');
 			}
 		}
 
+		$this->activityManager->setFormattingObject('', 0);
+
+		$child = $event->getChildEvent();
+		if ($child instanceof IEvent) {
+			unset($this->event[$this->lastEvent]);
+		}
+
 		if (!$event->getParsedSubject()) {
 			$this->logger->debug('Activity "' . $event->getRichSubject() . '" was not parsed by any provider');
 			return;
@@ -129,7 +135,7 @@ public function addActivity($activity) {
 	 *
 	 * @return array translated activities ready for use
 	 */
-	public function getActivities() {
+	public function getActivities(): array {
 		$return = [];
 		foreach ($this->event as $id => $event) {
 			$return[] = $this->eventToArray($event, $id);
@@ -148,11 +154,7 @@ public function getEvents(): array {
 		return $return;
 	}
 
-	/**
-	 * @param array $row
-	 * @return IEvent
-	 */
-	protected function arrayToEvent(array $row) {
+	protected function arrayToEvent(array $row): IEvent {
 		$event = $this->activityManager->generateEvent();
 		$event->setApp((string) $row['app'])
 			->setType((string) $row['type'])
@@ -168,10 +170,8 @@ protected function arrayToEvent(array $row) {
 	}
 
 	/**
-	 * @param IEvent $event
-	 * @return array
 	 */
-	protected function eventToArray(IEvent $event, $id) {
+	protected function eventToArray(IEvent $event, $id): array {
 		return [
 			'activity_id' => $id,
 			'app' => $event->getApp(),
@@ -198,10 +198,6 @@ protected function eventToArray(IEvent $event, $id) {
 		];
 	}
 
-	/**
-	 * @param IEvent $event
-	 * @return array
-	 */
 	protected function getObjectsFromChildren(IEvent $event): array {
 		$child = $event->getChildEvent();
 		$objects = [];