fix(taskprocessing): use the event for AppAPI to get list of AI providers

Signed-off-by: Oleksander Piskun <oleksandr2088@icloud.com>

Author: oleksandr-nc

lib/composer/composer/autoload_classmap.php

@@ -816,6 +816,7 @@
     'OCP\\Talk\\ITalkBackend' => $baseDir . '/lib/public/Talk/ITalkBackend.php',
     'OCP\\TaskProcessing\\EShapeType' => $baseDir . '/lib/public/TaskProcessing/EShapeType.php',
     'OCP\\TaskProcessing\\Events\\AbstractTaskProcessingEvent' => $baseDir . '/lib/public/TaskProcessing/Events/AbstractTaskProcessingEvent.php',
+    'OCP\\TaskProcessing\\Events\\GetTaskProcessingProvidersEvent' => $baseDir . '/lib/public/TaskProcessing/Events/GetTaskProcessingProvidersEvent.php',
     'OCP\\TaskProcessing\\Events\\TaskFailedEvent' => $baseDir . '/lib/public/TaskProcessing/Events/TaskFailedEvent.php',
     'OCP\\TaskProcessing\\Events\\TaskSuccessfulEvent' => $baseDir . '/lib/public/TaskProcessing/Events/TaskSuccessfulEvent.php',
     'OCP\\TaskProcessing\\Exception\\Exception' => $baseDir . '/lib/public/TaskProcessing/Exception/Exception.php',

lib/composer/composer/autoload_static.php

@@ -865,6 +865,7 @@ class ComposerStaticInit749170dad3f5e7f9ca158f5a9f04f6a2
         'OCP\\Talk\\ITalkBackend' => __DIR__ . '/../../..' . '/lib/public/Talk/ITalkBackend.php',
         'OCP\\TaskProcessing\\EShapeType' => __DIR__ . '/../../..' . '/lib/public/TaskProcessing/EShapeType.php',
         'OCP\\TaskProcessing\\Events\\AbstractTaskProcessingEvent' => __DIR__ . '/../../..' . '/lib/public/TaskProcessing/Events/AbstractTaskProcessingEvent.php',
+        'OCP\\TaskProcessing\\Events\\GetTaskProcessingProvidersEvent' => __DIR__ . '/../../..' . '/lib/public/TaskProcessing/Events/GetTaskProcessingProvidersEvent.php',
         'OCP\\TaskProcessing\\Events\\TaskFailedEvent' => __DIR__ . '/../../..' . '/lib/public/TaskProcessing/Events/TaskFailedEvent.php',
         'OCP\\TaskProcessing\\Events\\TaskSuccessfulEvent' => __DIR__ . '/../../..' . '/lib/public/TaskProcessing/Events/TaskSuccessfulEvent.php',
         'OCP\\TaskProcessing\\Exception\\Exception' => __DIR__ . '/../../..' . '/lib/public/TaskProcessing/Exception/Exception.php',

lib/private/TaskProcessing/Manager.php

@@ -41,6 +41,7 @@
 use OCP\SpeechToText\ISpeechToTextProvider;
 use OCP\SpeechToText\ISpeechToTextProviderWithId;
 use OCP\TaskProcessing\EShapeType;
+use OCP\TaskProcessing\Events\GetTaskProcessingProvidersEvent;
 use OCP\TaskProcessing\Events\TaskFailedEvent;
 use OCP\TaskProcessing\Events\TaskSuccessfulEvent;
 use OCP\TaskProcessing\Exception\NotFoundException;
@@ -81,6 +82,9 @@ class Manager implements IManager {
 	private IAppData $appData;
 	private ?array $preferences = null;
 	private ?array $providersById = null;
+
+	/** @var ITaskType[]|null */
+	private ?array $taskTypes = null;
 	private ICache $distributedCache;
 
 	public function __construct(
@@ -488,14 +492,39 @@ public function getOptionalOutputShapeEnumValues(): array {
 		return $newProviders;
 	}
 
+	/**
+	 * Dispatches the event to collect external providers and task types.
+	 * Caches the result within the request.
+	 */
+	private function dispatchGetProvidersEvent(): GetTaskProcessingProvidersEvent {
+		static $eventResult = null;
+
+		if ($eventResult === null) {
+			$event = new GetTaskProcessingProvidersEvent();
+			$this->dispatcher->dispatchTyped($event);
+			$eventResult = $event;
+		}
+		return $eventResult;
+	}
+
 	/**
 	 * @return IProvider[]
 	 */
 	private function _getProviders(): array {
 		$context = $this->coordinator->getRegistrationContext();
 
 		if ($context === null) {
-			return [];
+			$event = $this->dispatchGetProvidersEvent();
+			$externalProviders = $event->getProviders();
+
+			$providers = [];
+			foreach ($externalProviders as $provider) {
+				if (isset($providers[$provider->getId()])) {
+					$this->logger->warning('External task processing provider is using ID ' . $provider->getId() . ' which is already used by ' . $providers[$provider->getId()]::class);
+				}
+				$providers[$provider->getId()] = $provider;
+			}
+			return $providers;
 		}
 
 		$providers = [];
@@ -516,6 +545,19 @@ private function _getProviders(): array {
 			}
 		}
 
+		$event = $this->dispatchGetProvidersEvent();
+		$externalProviders = $event->getProviders();
+		foreach ($externalProviders as $provider) {
+			if (isset($providers[$provider->getId()])) {
+				$this->logger->warning('External task processing provider is using ID ' . $provider->getId() . ' which is already used by a locally registered provider (' . get_class($providers[$provider->getId()]) . ')');
+			}
+			if (!isset($providers[$provider->getId()])) {
+				$providers[$provider->getId()] = $provider;
+			} else {
+				$this->logger->info('Skipping external task processing provider with ID ' . $provider->getId() . ' because a local provider with the same ID already exists.');
+			}
+		}
+
 		$providers += $this->_getTextProcessingProviders() + $this->_getTextToImageProviders() + $this->_getSpeechToTextProviders();
 
 		return $providers;
@@ -525,12 +567,12 @@ private function _getProviders(): array {
 	 * @return ITaskType[]
 	 */
 	private function _getTaskTypes(): array {
-		$context = $this->coordinator->getRegistrationContext();
-
-		if ($context === null) {
-			return [];
+		if ($this->taskTypes !== null) {
+			return $this->taskTypes;
 		}
 
+		$context = $this->coordinator->getRegistrationContext();
+
 		// Default task types
 		$taskTypes = [
 			\OCP\TaskProcessing\TaskTypes\TextToText::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToText::class),
@@ -568,9 +610,19 @@ private function _getTaskTypes(): array {
 			}
 		}
 
+		$event = $this->dispatchGetProvidersEvent();
+		$externalTaskTypes = $event->getTaskTypes();
+		foreach ($externalTaskTypes as $taskType) {
+			if (isset($taskTypes[$taskType->getId()])) {
+				$this->logger->warning('External task processing task type is using ID ' . $taskType->getId() . ' which is already used by a locally registered task type (' . get_class($taskTypes[$taskType->getId()]) . ')');
+			}
+			$taskTypes[$taskType->getId()] = $taskType;
+		}
+
 		$taskTypes += $this->_getTextProcessingTaskTypes();
 
-		return $taskTypes;
+		$this->taskTypes = $taskTypes;
+		return $this->taskTypes;
 	}
 
 	/**

lib/public/TaskProcessing/Events/GetTaskProcessingProvidersEvent.php

@@ -0,0 +1,68 @@
+<?php
+
+/**
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+namespace OCP\TaskProcessing\Events;
+
+use OCP\EventDispatcher\Event;
+use OCP\TaskProcessing\IProvider;
+use OCP\TaskProcessing\ITaskType;
+
+/**
+ * Event dispatched by the server to collect Task Processing Providers
+ * and custom Task Types from listeners (like AppAPI).
+ *
+ * Listeners should add their providers and task types using the
+ * addProvider() and addTaskType() methods.
+ *
+ * @since 32.0.0
+ */
+class GetTaskProcessingProvidersEvent extends Event {
+	/** @var IProvider[] */
+	private array $providers = [];
+
+	/** @var ITaskType[] */
+	private array $taskTypes = [];
+
+	/**
+	 * Add a Task Processing Provider.
+	 *
+	 * @param IProvider $provider The provider instance to add.
+	 * @since 32.0.0
+	 */
+	public function addProvider(IProvider $provider): void {
+		$this->providers[] = $provider;
+	}
+
+	/**
+	 * Get all collected Task Processing Providers.
+	 *
+	 * @return IProvider[]
+	 * @since 32.0.0
+	 */
+	public function getProviders(): array {
+		return $this->providers;
+	}
+
+	/**
+	 * Add a custom Task Processing Task Type.
+	 *
+	 * @param ITaskType $taskType The task type instance to add.
+	 * @since 32.0.0
+	 */
+	public function addTaskType(ITaskType $taskType): void {
+		$this->taskTypes[] = $taskType;
+	}
+
+	/**
+	 * Get all collected custom Task Processing Task Types.
+	 *
+	 * @return ITaskType[]
+	 * @since 32.0.0
+	 */
+	public function getTaskTypes(): array {
+		return $this->taskTypes;
+	}
+}