feat(Assignments): Send notifications for assignment failure

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

Author: marcelklehr

lib/AppInfo/Application.php

@@ -92,6 +92,7 @@ public function register(IRegistrationContext $context): void {
 		$context->registerEventListener(TaskSuccessfulEvent::class, TaskSuccessfulListener::class);
 		$context->registerEventListener(TaskFailedEvent::class, TaskFailedListener::class);
 		$context->registerEventListener(TaskSuccessfulEvent::class, ChattyLLMTaskListener::class);
+		$context->registerEventListener(TaskFailedEvent::class, ChattyLLMTaskListener::class);
 		$context->registerEventListener(TaskSuccessfulEvent::class, FileActionTaskSuccessfulListener::class);
 		$context->registerEventListener(TaskSuccessfulEvent::class, NewFileMenuTaskSuccessfulListener::class);
 		$context->registerEventListener(TaskFailedEvent::class, FileActionTaskFailedListener::class);

lib/Listener/ChattyLLMTaskListener.php

@@ -17,6 +17,7 @@
 use OCA\Assistant\Service\TaskProcessingService;
 use OCP\EventDispatcher\Event;
 use OCP\EventDispatcher\IEventListener;
+use OCP\TaskProcessing\Events\TaskFailedEvent;
 use OCP\TaskProcessing\Events\TaskSuccessfulEvent;
 use OCP\TaskProcessing\Task;
 use Psr\Log\LoggerInterface;
@@ -36,6 +37,21 @@ public function __construct(
 	}
 
 	public function handle(Event $event): void {
+		if ($event instanceof TaskFailedEvent) {
+			$task = $event->getTask();
+			$customId = $task->getCustomId();
+			if (preg_match('/^chatty-llm:(\d+)/', $customId, $matches)) {
+				$sessionId = (int)$matches[1];
+				$session = $this->sessionMapper->getUserSession($task->getUserId(), $sessionId);
+				$assignmentId = $session->getAssignmentId();
+				if ($assignmentId !== null) {
+					$this->notificationService->sendAssignmentNotification(
+						$task->getUserId(), $task, $session
+					);
+				}
+			}
+			return;
+		}
 		if (!($event instanceof TaskSuccessfulEvent)) {
 			return;
 		}