nextcloud / server

lib/public/TaskProcessing/IManager.php

Indentation +214 added lines, -214 removed lines

@@ -27,240 +27,240 @@
  */
 interface IManager {
 
-	/**
-	 * @since 30.0.0
-	 */
-	public function hasProviders(): bool;
+    /**
+     * @since 30.0.0
+     */
+    public function hasProviders(): bool;
 
-	/**
-	 * @return IProvider[]
-	 * @since 30.0.0
-	 */
-	public function getProviders(): array;
+    /**
+     * @return IProvider[]
+     * @since 30.0.0
+     */
+    public function getProviders(): array;
 
-	/**
-	 * @param string $taskTypeId
-	 * @return IProvider
-	 * @throws Exception
-	 * @since 30.0.0
-	 */
-	public function getPreferredProvider(string $taskTypeId);
+    /**
+     * @param string $taskTypeId
+     * @return IProvider
+     * @throws Exception
+     * @since 30.0.0
+     */
+    public function getPreferredProvider(string $taskTypeId);
 
-	/**
-	 * @param bool $showDisabled if false, disabled task types will be filtered out
-	 * @param ?string $userId to check if the user is a guest. Will be obtained from session if left to default
-	 * @return array<string, array{name: string, description: string, inputShape: ShapeDescriptor[], inputShapeEnumValues: ShapeEnumValue[][], inputShapeDefaults: array<array-key, numeric|string>, isInternal: bool, optionalInputShape: ShapeDescriptor[], optionalInputShapeEnumValues: ShapeEnumValue[][], optionalInputShapeDefaults: array<array-key, numeric|string>, outputShape: ShapeDescriptor[], outputShapeEnumValues: ShapeEnumValue[][], optionalOutputShape: ShapeDescriptor[], optionalOutputShapeEnumValues: ShapeEnumValue[][]}>
-	 * @since 30.0.0
-	 * @since 31.0.0 Added the `showDisabled` argument.
-	 * @since 31.0.7 Added the `userId` argument
-	 * @since 33.0.0 Added `isInternal` to return value
-	 */
-	public function getAvailableTaskTypes(bool $showDisabled = false, ?string $userId = null): array;
+    /**
+     * @param bool $showDisabled if false, disabled task types will be filtered out
+     * @param ?string $userId to check if the user is a guest. Will be obtained from session if left to default
+     * @return array<string, array{name: string, description: string, inputShape: ShapeDescriptor[], inputShapeEnumValues: ShapeEnumValue[][], inputShapeDefaults: array<array-key, numeric|string>, isInternal: bool, optionalInputShape: ShapeDescriptor[], optionalInputShapeEnumValues: ShapeEnumValue[][], optionalInputShapeDefaults: array<array-key, numeric|string>, outputShape: ShapeDescriptor[], outputShapeEnumValues: ShapeEnumValue[][], optionalOutputShape: ShapeDescriptor[], optionalOutputShapeEnumValues: ShapeEnumValue[][]}>
+     * @since 30.0.0
+     * @since 31.0.0 Added the `showDisabled` argument.
+     * @since 31.0.7 Added the `userId` argument
+     * @since 33.0.0 Added `isInternal` to return value
+     */
+    public function getAvailableTaskTypes(bool $showDisabled = false, ?string $userId = null): array;
 
-	/**
-	 * @param bool $showDisabled if false, disabled task types will be filtered out
-	 * @param ?string $userId to check if the user is a guest. Will be obtained from session if left to default
-	 * @return list<string>
-	 * @since 32.0.0
-	 */
-	public function getAvailableTaskTypeIds(bool $showDisabled = false, ?string $userId = null): array;
+    /**
+     * @param bool $showDisabled if false, disabled task types will be filtered out
+     * @param ?string $userId to check if the user is a guest. Will be obtained from session if left to default
+     * @return list<string>
+     * @since 32.0.0
+     */
+    public function getAvailableTaskTypeIds(bool $showDisabled = false, ?string $userId = null): array;
 
-	/**
-	 * @param Task $task The task to run
-	 * @throws PreConditionNotMetException If no or not the requested provider was registered but this method was still called
-	 * @throws ValidationException the given task input didn't pass validation against the task type's input shape and/or the providers optional input shape specs
-	 * @throws Exception storing the task in the database failed
-	 * @throws UnauthorizedException the user scheduling the task does not have access to the files used in the input
-	 * @since 30.0.0
-	 */
-	public function scheduleTask(Task $task): void;
+    /**
+     * @param Task $task The task to run
+     * @throws PreConditionNotMetException If no or not the requested provider was registered but this method was still called
+     * @throws ValidationException the given task input didn't pass validation against the task type's input shape and/or the providers optional input shape specs
+     * @throws Exception storing the task in the database failed
+     * @throws UnauthorizedException the user scheduling the task does not have access to the files used in the input
+     * @since 30.0.0
+     */
+    public function scheduleTask(Task $task): void;
 
-	/**
-	 * Run the task and return the finished task
-	 *
-	 * @param Task $task The task to run
-	 * @return Task The result task
-	 * @throws PreConditionNotMetException If no or not the requested provider was registered but this method was still called
-	 * @throws ValidationException the given task input didn't pass validation against the task type's input shape and/or the providers optional input shape specs
-	 * @throws Exception storing the task in the database failed
-	 * @throws UnauthorizedException the user scheduling the task does not have access to the files used in the input
-	 * @since 30.0.0
-	 */
-	public function runTask(Task $task): Task;
+    /**
+     * Run the task and return the finished task
+     *
+     * @param Task $task The task to run
+     * @return Task The result task
+     * @throws PreConditionNotMetException If no or not the requested provider was registered but this method was still called
+     * @throws ValidationException the given task input didn't pass validation against the task type's input shape and/or the providers optional input shape specs
+     * @throws Exception storing the task in the database failed
+     * @throws UnauthorizedException the user scheduling the task does not have access to the files used in the input
+     * @since 30.0.0
+     */
+    public function runTask(Task $task): Task;
 
-	/**
-	 * Process task with a synchronous provider
-	 *
-	 * Prepare task input data and run the process method of the provider
-	 * This should only be used by OC\TaskProcessing\SynchronousBackgroundJob::run() and OCP\TaskProcessing\IManager::runTask()
-	 *
-	 * @param Task $task
-	 * @param ISynchronousProvider $provider
-	 * @return bool True if the task has run successfully
-	 * @throws Exception
-	 * @since 30.0.0
-	 */
-	public function processTask(Task $task, ISynchronousProvider $provider): bool;
+    /**
+     * Process task with a synchronous provider
+     *
+     * Prepare task input data and run the process method of the provider
+     * This should only be used by OC\TaskProcessing\SynchronousBackgroundJob::run() and OCP\TaskProcessing\IManager::runTask()
+     *
+     * @param Task $task
+     * @param ISynchronousProvider $provider
+     * @return bool True if the task has run successfully
+     * @throws Exception
+     * @since 30.0.0
+     */
+    public function processTask(Task $task, ISynchronousProvider $provider): bool;
 
-	/**
-	 * Delete a task that has been scheduled before
-	 *
-	 * @param Task $task The task to delete
-	 * @throws Exception if deleting the task in the database failed
-	 * @since 30.0.0
-	 */
-	public function deleteTask(Task $task): void;
+    /**
+     * Delete a task that has been scheduled before
+     *
+     * @param Task $task The task to delete
+     * @throws Exception if deleting the task in the database failed
+     * @since 30.0.0
+     */
+    public function deleteTask(Task $task): void;
 
-	/**
-	 * @param int $id The id of the task
-	 * @return Task
-	 * @throws Exception If the query failed
-	 * @throws NotFoundException If the task could not be found
-	 * @since 30.0.0
-	 */
-	public function getTask(int $id): Task;
+    /**
+     * @param int $id The id of the task
+     * @return Task
+     * @throws Exception If the query failed
+     * @throws NotFoundException If the task could not be found
+     * @since 30.0.0
+     */
+    public function getTask(int $id): Task;
 
-	/**
-	 * @param int $id The id of the task
-	 * @throws Exception If the query failed
-	 * @throws NotFoundException If the task could not be found
-	 * @since 30.0.0
-	 */
-	public function cancelTask(int $id): void;
+    /**
+     * @param int $id The id of the task
+     * @throws Exception If the query failed
+     * @throws NotFoundException If the task could not be found
+     * @since 30.0.0
+     */
+    public function cancelTask(int $id): void;
 
-	/**
-	 * @param int $id The id of the task
-	 * @param string|null $error
-	 * @param array|null $result
-	 * @param bool $isUsingFileIds
-	 * @throws Exception If the query failed
-	 * @throws NotFoundException If the task could not be found
-	 * @since 30.0.0
-	 */
-	public function setTaskResult(int $id, ?string $error, ?array $result, bool $isUsingFileIds = false): void;
+    /**
+     * @param int $id The id of the task
+     * @param string|null $error
+     * @param array|null $result
+     * @param bool $isUsingFileIds
+     * @throws Exception If the query failed
+     * @throws NotFoundException If the task could not be found
+     * @since 30.0.0
+     */
+    public function setTaskResult(int $id, ?string $error, ?array $result, bool $isUsingFileIds = false): void;
 
-	/**
-	 * @param int $id
-	 * @param float $progress
-	 * @return bool `true` if the task should still be running; `false` if the task has been cancelled in the meantime
-	 * @throws ValidationException
-	 * @throws Exception
-	 * @throws NotFoundException
-	 * @since 30.0.0
-	 */
-	public function setTaskProgress(int $id, float $progress): bool;
+    /**
+     * @param int $id
+     * @param float $progress
+     * @return bool `true` if the task should still be running; `false` if the task has been cancelled in the meantime
+     * @throws ValidationException
+     * @throws Exception
+     * @throws NotFoundException
+     * @since 30.0.0
+     */
+    public function setTaskProgress(int $id, float $progress): bool;
 
-	/**
-	 * @param list<string> $taskTypeIds
-	 * @param list<int> $taskIdsToIgnore
-	 * @return Task
-	 * @throws Exception If the query failed
-	 * @throws NotFoundException If no task could not be found
-	 * @since 30.0.0
-	 */
-	public function getNextScheduledTask(array $taskTypeIds = [], array $taskIdsToIgnore = []): Task;
+    /**
+     * @param list<string> $taskTypeIds
+     * @param list<int> $taskIdsToIgnore
+     * @return Task
+     * @throws Exception If the query failed
+     * @throws NotFoundException If no task could not be found
+     * @since 30.0.0
+     */
+    public function getNextScheduledTask(array $taskTypeIds = [], array $taskIdsToIgnore = []): Task;
 
-	/**
-	 * @param list<string> $taskTypeIds
-	 * @param list<int> $taskIdsToIgnore
-	 * @param int $numberOfTasks
-	 * @return list<Task>
-	 * @throws Exception If the query failed
-	 * @since 33.0.0
-	 */
-	public function getNextScheduledTasks(array $taskTypeIds = [], array $taskIdsToIgnore = [], int $numberOfTasks = 1): array;
+    /**
+     * @param list<string> $taskTypeIds
+     * @param list<int> $taskIdsToIgnore
+     * @param int $numberOfTasks
+     * @return list<Task>
+     * @throws Exception If the query failed
+     * @since 33.0.0
+     */
+    public function getNextScheduledTasks(array $taskTypeIds = [], array $taskIdsToIgnore = [], int $numberOfTasks = 1): array;
 
-	/**
-	 * @param int $id The id of the task
-	 * @param string|null $userId The user id that scheduled the task
-	 * @return Task
-	 * @throws Exception If the query failed
-	 * @throws NotFoundException If the task could not be found
-	 * @since 30.0.0
-	 */
-	public function getUserTask(int $id, ?string $userId): Task;
+    /**
+     * @param int $id The id of the task
+     * @param string|null $userId The user id that scheduled the task
+     * @return Task
+     * @throws Exception If the query failed
+     * @throws NotFoundException If the task could not be found
+     * @since 30.0.0
+     */
+    public function getUserTask(int $id, ?string $userId): Task;
 
-	/**
-	 * @param string|null $userId The user id that scheduled the task
-	 * @param string|null $taskTypeId The task type id to filter by
-	 * @param string|null $customId
-	 * @return list<Task>
-	 * @throws Exception If the query failed
-	 * @throws NotFoundException If the task could not be found
-	 * @since 30.0.0
-	 */
-	public function getUserTasks(?string $userId, ?string $taskTypeId = null, ?string $customId = null): array;
+    /**
+     * @param string|null $userId The user id that scheduled the task
+     * @param string|null $taskTypeId The task type id to filter by
+     * @param string|null $customId
+     * @return list<Task>
+     * @throws Exception If the query failed
+     * @throws NotFoundException If the task could not be found
+     * @since 30.0.0
+     */
+    public function getUserTasks(?string $userId, ?string $taskTypeId = null, ?string $customId = null): array;
 
-	/**
-	 * @param string|null $userId The user id that scheduled the task
-	 * @param string|null $taskTypeId The task type id to filter by
-	 * @param string|null $appId The app ID of the app that submitted the task
-	 * @param string|null $customId The custom task ID
-	 * @param int|null $status The task status
-	 * @param int|null $scheduleAfter Minimum schedule time filter
-	 * @param int|null $endedBefore Maximum ending time filter
-	 * @return list<Task>
-	 * @throws Exception If the query failed
-	 * @throws NotFoundException If the task could not be found
-	 * @since 30.0.0
-	 */
-	public function getTasks(
-		?string $userId, ?string $taskTypeId = null, ?string $appId = null, ?string $customId = null,
-		?int $status = null, ?int $scheduleAfter = null, ?int $endedBefore = null,
-	): array;
+    /**
+     * @param string|null $userId The user id that scheduled the task
+     * @param string|null $taskTypeId The task type id to filter by
+     * @param string|null $appId The app ID of the app that submitted the task
+     * @param string|null $customId The custom task ID
+     * @param int|null $status The task status
+     * @param int|null $scheduleAfter Minimum schedule time filter
+     * @param int|null $endedBefore Maximum ending time filter
+     * @return list<Task>
+     * @throws Exception If the query failed
+     * @throws NotFoundException If the task could not be found
+     * @since 30.0.0
+     */
+    public function getTasks(
+        ?string $userId, ?string $taskTypeId = null, ?string $appId = null, ?string $customId = null,
+        ?int $status = null, ?int $scheduleAfter = null, ?int $endedBefore = null,
+    ): array;
 
-	/**
-	 * @param string|null $userId
-	 * @param string $appId
-	 * @param string|null $customId
-	 * @return list<Task>
-	 * @throws Exception If the query failed
-	 * @throws \JsonException If parsing the task input and output failed
-	 * @since 30.0.0
-	 */
-	public function getUserTasksByApp(?string $userId, string $appId, ?string $customId = null): array;
+    /**
+     * @param string|null $userId
+     * @param string $appId
+     * @param string|null $customId
+     * @return list<Task>
+     * @throws Exception If the query failed
+     * @throws \JsonException If parsing the task input and output failed
+     * @since 30.0.0
+     */
+    public function getUserTasksByApp(?string $userId, string $appId, ?string $customId = null): array;
 
-	/**
-	 * Prepare the task's input data, so it can be processed by the provider
-	 * ie. this replaces file ids with File objects
-	 *
-	 * @param Task $task
-	 * @return array<array-key, list<numeric|string|File>|numeric|string|File>
-	 * @throws NotPermittedException
-	 * @throws GenericFileException
-	 * @throws LockedException
-	 * @throws ValidationException
-	 * @throws UnauthorizedException
-	 * @since 30.0.0
-	 */
-	public function prepareInputData(Task $task): array;
+    /**
+     * Prepare the task's input data, so it can be processed by the provider
+     * ie. this replaces file ids with File objects
+     *
+     * @param Task $task
+     * @return array<array-key, list<numeric|string|File>|numeric|string|File>
+     * @throws NotPermittedException
+     * @throws GenericFileException
+     * @throws LockedException
+     * @throws ValidationException
+     * @throws UnauthorizedException
+     * @since 30.0.0
+     */
+    public function prepareInputData(Task $task): array;
 
-	/**
-	 * Changes the task status to STATUS_RUNNING and, if successful, returns True.
-	 *
-	 * @param Task $task
-	 * @return bool
-	 * @since 30.0.0
-	 */
-	public function lockTask(Task $task): bool;
+    /**
+     * Changes the task status to STATUS_RUNNING and, if successful, returns True.
+     *
+     * @param Task $task
+     * @return bool
+     * @since 30.0.0
+     */
+    public function lockTask(Task $task): bool;
 
-	/**
-	 * @param Task $task
-	 * @psalm-param Task::STATUS_* $status
-	 * @param int $status
-	 * @throws \JsonException
-	 * @throws Exception
-	 * @since 30.0.0
-	 */
-	public function setTaskStatus(Task $task, int $status): void;
+    /**
+     * @param Task $task
+     * @psalm-param Task::STATUS_* $status
+     * @param int $status
+     * @throws \JsonException
+     * @throws Exception
+     * @since 30.0.0
+     */
+    public function setTaskStatus(Task $task, int $status): void;
 
-	/**
-	 * Extract all input and output file IDs from a task
-	 *
-	 * @param Task $task
-	 * @return list<int>
-	 * @throws NotFoundException
-	 * @since 32.0.0
-	 */
-	public function extractFileIdsFromTask(Task $task): array;
+    /**
+     * Extract all input and output file IDs from a task
+     *
+     * @param Task $task
+     * @return list<int>
+     * @throws NotFoundException
+     * @since 32.0.0
+     */
+    public function extractFileIdsFromTask(Task $task): array;
 }

lib/private/TaskProcessing/Db/TaskMapper.php

Indentation +222 added lines, -222 removed lines

@@ -22,246 +22,246 @@
  * @extends QBMapper<Task>
  */
 class TaskMapper extends QBMapper {
-	public function __construct(
-		IDBConnection $db,
-		private ITimeFactory $timeFactory,
-	) {
-		parent::__construct($db, 'taskprocessing_tasks', Task::class);
-	}
+    public function __construct(
+        IDBConnection $db,
+        private ITimeFactory $timeFactory,
+    ) {
+        parent::__construct($db, 'taskprocessing_tasks', Task::class);
+    }
 
-	/**
-	 * @param int $id
-	 * @return Task
-	 * @throws Exception
-	 * @throws DoesNotExistException
-	 * @throws MultipleObjectsReturnedException
-	 */
-	public function find(int $id): Task {
-		$qb = $this->db->getQueryBuilder();
-		$qb->select(Task::$columns)
-			->from($this->tableName)
-			->where($qb->expr()->eq('id', $qb->createPositionalParameter($id)));
-		return $this->findEntity($qb);
-	}
+    /**
+     * @param int $id
+     * @return Task
+     * @throws Exception
+     * @throws DoesNotExistException
+     * @throws MultipleObjectsReturnedException
+     */
+    public function find(int $id): Task {
+        $qb = $this->db->getQueryBuilder();
+        $qb->select(Task::$columns)
+            ->from($this->tableName)
+            ->where($qb->expr()->eq('id', $qb->createPositionalParameter($id)));
+        return $this->findEntity($qb);
+    }
 
-	/**
-	 * @param list<string> $taskTypes
-	 * @param list<int> $taskIdsToIgnore
-	 * @return Task
-	 * @throws DoesNotExistException
-	 * @throws Exception
-	 */
-	public function findOldestScheduledByType(array $taskTypes, array $taskIdsToIgnore): Task {
-		$qb = $this->db->getQueryBuilder();
-		$qb->select(Task::$columns)
-			->from($this->tableName)
-			->where($qb->expr()->eq('status', $qb->createPositionalParameter(\OCP\TaskProcessing\Task::STATUS_SCHEDULED, IQueryBuilder::PARAM_INT)))
-			->setMaxResults(1)
-			->orderBy('last_updated', 'ASC');
+    /**
+     * @param list<string> $taskTypes
+     * @param list<int> $taskIdsToIgnore
+     * @return Task
+     * @throws DoesNotExistException
+     * @throws Exception
+     */
+    public function findOldestScheduledByType(array $taskTypes, array $taskIdsToIgnore): Task {
+        $qb = $this->db->getQueryBuilder();
+        $qb->select(Task::$columns)
+            ->from($this->tableName)
+            ->where($qb->expr()->eq('status', $qb->createPositionalParameter(\OCP\TaskProcessing\Task::STATUS_SCHEDULED, IQueryBuilder::PARAM_INT)))
+            ->setMaxResults(1)
+            ->orderBy('last_updated', 'ASC');
 
-		if (!empty($taskTypes)) {
-			$filter = [];
-			foreach ($taskTypes as $taskType) {
-				$filter[] = $qb->expr()->eq('type', $qb->createPositionalParameter($taskType));
-			}
+        if (!empty($taskTypes)) {
+            $filter = [];
+            foreach ($taskTypes as $taskType) {
+                $filter[] = $qb->expr()->eq('type', $qb->createPositionalParameter($taskType));
+            }
 
-			$qb->andWhere($qb->expr()->orX(...$filter));
-		}
+            $qb->andWhere($qb->expr()->orX(...$filter));
+        }
 
-		if (!empty($taskIdsToIgnore)) {
-			$qb->andWhere($qb->expr()->notIn('id', $qb->createNamedParameter($taskIdsToIgnore, IQueryBuilder::PARAM_INT_ARRAY)));
-		}
+        if (!empty($taskIdsToIgnore)) {
+            $qb->andWhere($qb->expr()->notIn('id', $qb->createNamedParameter($taskIdsToIgnore, IQueryBuilder::PARAM_INT_ARRAY)));
+        }
 
-		return $this->findEntity($qb);
-	}
+        return $this->findEntity($qb);
+    }
 
-	/**
-	 * @param int $id
-	 * @param string|null $userId
-	 * @return Task
-	 * @throws DoesNotExistException
-	 * @throws Exception
-	 * @throws MultipleObjectsReturnedException
-	 */
-	public function findByIdAndUser(int $id, ?string $userId): Task {
-		$qb = $this->db->getQueryBuilder();
-		$qb->select(Task::$columns)
-			->from($this->tableName)
-			->where($qb->expr()->eq('id', $qb->createPositionalParameter($id)));
-		if ($userId === null) {
-			$qb->andWhere($qb->expr()->isNull('user_id'));
-		} else {
-			$qb->andWhere($qb->expr()->eq('user_id', $qb->createPositionalParameter($userId)));
-		}
-		return $this->findEntity($qb);
-	}
+    /**
+     * @param int $id
+     * @param string|null $userId
+     * @return Task
+     * @throws DoesNotExistException
+     * @throws Exception
+     * @throws MultipleObjectsReturnedException
+     */
+    public function findByIdAndUser(int $id, ?string $userId): Task {
+        $qb = $this->db->getQueryBuilder();
+        $qb->select(Task::$columns)
+            ->from($this->tableName)
+            ->where($qb->expr()->eq('id', $qb->createPositionalParameter($id)));
+        if ($userId === null) {
+            $qb->andWhere($qb->expr()->isNull('user_id'));
+        } else {
+            $qb->andWhere($qb->expr()->eq('user_id', $qb->createPositionalParameter($userId)));
+        }
+        return $this->findEntity($qb);
+    }
 
-	/**
-	 * @param string|null $userId
-	 * @param string|null $taskType
-	 * @param string|null $customId
-	 * @return list<Task>
-	 * @throws Exception
-	 */
-	public function findByUserAndTaskType(?string $userId, ?string $taskType = null, ?string $customId = null): array {
-		$qb = $this->db->getQueryBuilder();
-		$qb->select(Task::$columns)
-			->from($this->tableName)
-			->where($qb->expr()->eq('user_id', $qb->createPositionalParameter($userId)));
-		if ($taskType !== null) {
-			$qb->andWhere($qb->expr()->eq('type', $qb->createPositionalParameter($taskType)));
-		}
-		if ($customId !== null) {
-			$qb->andWhere($qb->expr()->eq('custom_id', $qb->createPositionalParameter($customId)));
-		}
-		return $this->findEntities($qb);
-	}
+    /**
+     * @param string|null $userId
+     * @param string|null $taskType
+     * @param string|null $customId
+     * @return list<Task>
+     * @throws Exception
+     */
+    public function findByUserAndTaskType(?string $userId, ?string $taskType = null, ?string $customId = null): array {
+        $qb = $this->db->getQueryBuilder();
+        $qb->select(Task::$columns)
+            ->from($this->tableName)
+            ->where($qb->expr()->eq('user_id', $qb->createPositionalParameter($userId)));
+        if ($taskType !== null) {
+            $qb->andWhere($qb->expr()->eq('type', $qb->createPositionalParameter($taskType)));
+        }
+        if ($customId !== null) {
+            $qb->andWhere($qb->expr()->eq('custom_id', $qb->createPositionalParameter($customId)));
+        }
+        return $this->findEntities($qb);
+    }
 
-	/**
-	 * @param string $userId
-	 * @param string $appId
-	 * @param string|null $customId
-	 * @return list<Task>
-	 * @throws Exception
-	 */
-	public function findUserTasksByApp(?string $userId, string $appId, ?string $customId = null): array {
-		$qb = $this->db->getQueryBuilder();
-		$qb->select(Task::$columns)
-			->from($this->tableName)
-			->where($qb->expr()->eq('user_id', $qb->createPositionalParameter($userId)))
-			->andWhere($qb->expr()->eq('app_id', $qb->createPositionalParameter($appId)));
-		if ($customId !== null) {
-			$qb->andWhere($qb->expr()->eq('custom_id', $qb->createPositionalParameter($customId)));
-		}
-		return $this->findEntities($qb);
-	}
+    /**
+     * @param string $userId
+     * @param string $appId
+     * @param string|null $customId
+     * @return list<Task>
+     * @throws Exception
+     */
+    public function findUserTasksByApp(?string $userId, string $appId, ?string $customId = null): array {
+        $qb = $this->db->getQueryBuilder();
+        $qb->select(Task::$columns)
+            ->from($this->tableName)
+            ->where($qb->expr()->eq('user_id', $qb->createPositionalParameter($userId)))
+            ->andWhere($qb->expr()->eq('app_id', $qb->createPositionalParameter($appId)));
+        if ($customId !== null) {
+            $qb->andWhere($qb->expr()->eq('custom_id', $qb->createPositionalParameter($customId)));
+        }
+        return $this->findEntities($qb);
+    }
 
-	/**
-	 * @param string|null $userId
-	 * @param string|null $taskType
-	 * @param string|null $appId
-	 * @param string|null $customId
-	 * @param int|null $status
-	 * @param int|null $scheduleAfter
-	 * @param int|null $endedBefore
-	 * @return list<Task>
-	 * @throws Exception
-	 */
-	public function findTasks(
-		?string $userId, ?string $taskType = null, ?string $appId = null, ?string $customId = null,
-		?int $status = null, ?int $scheduleAfter = null, ?int $endedBefore = null): array {
-		$qb = $this->db->getQueryBuilder();
-		$qb->select(Task::$columns)
-			->from($this->tableName);
+    /**
+     * @param string|null $userId
+     * @param string|null $taskType
+     * @param string|null $appId
+     * @param string|null $customId
+     * @param int|null $status
+     * @param int|null $scheduleAfter
+     * @param int|null $endedBefore
+     * @return list<Task>
+     * @throws Exception
+     */
+    public function findTasks(
+        ?string $userId, ?string $taskType = null, ?string $appId = null, ?string $customId = null,
+        ?int $status = null, ?int $scheduleAfter = null, ?int $endedBefore = null): array {
+        $qb = $this->db->getQueryBuilder();
+        $qb->select(Task::$columns)
+            ->from($this->tableName);
 
-		// empty string: no userId filter
-		if ($userId !== '') {
-			$qb->where($qb->expr()->eq('user_id', $qb->createPositionalParameter($userId)));
-		}
-		if ($taskType !== null) {
-			$qb->andWhere($qb->expr()->eq('type', $qb->createPositionalParameter($taskType)));
-		}
-		if ($appId !== null) {
-			$qb->andWhere($qb->expr()->eq('app_id', $qb->createPositionalParameter($appId)));
-		}
-		if ($customId !== null) {
-			$qb->andWhere($qb->expr()->eq('custom_id', $qb->createPositionalParameter($customId)));
-		}
-		if ($status !== null) {
-			$qb->andWhere($qb->expr()->eq('status', $qb->createPositionalParameter($status, IQueryBuilder::PARAM_INT)));
-		}
-		if ($scheduleAfter !== null) {
-			$qb->andWhere($qb->expr()->isNotNull('scheduled_at'));
-			$qb->andWhere($qb->expr()->gt('scheduled_at', $qb->createPositionalParameter($scheduleAfter, IQueryBuilder::PARAM_INT)));
-		}
-		if ($endedBefore !== null) {
-			$qb->andWhere($qb->expr()->isNotNull('ended_at'));
-			$qb->andWhere($qb->expr()->lt('ended_at', $qb->createPositionalParameter($endedBefore, IQueryBuilder::PARAM_INT)));
-		}
-		return $this->findEntities($qb);
-	}
+        // empty string: no userId filter
+        if ($userId !== '') {
+            $qb->where($qb->expr()->eq('user_id', $qb->createPositionalParameter($userId)));
+        }
+        if ($taskType !== null) {
+            $qb->andWhere($qb->expr()->eq('type', $qb->createPositionalParameter($taskType)));
+        }
+        if ($appId !== null) {
+            $qb->andWhere($qb->expr()->eq('app_id', $qb->createPositionalParameter($appId)));
+        }
+        if ($customId !== null) {
+            $qb->andWhere($qb->expr()->eq('custom_id', $qb->createPositionalParameter($customId)));
+        }
+        if ($status !== null) {
+            $qb->andWhere($qb->expr()->eq('status', $qb->createPositionalParameter($status, IQueryBuilder::PARAM_INT)));
+        }
+        if ($scheduleAfter !== null) {
+            $qb->andWhere($qb->expr()->isNotNull('scheduled_at'));
+            $qb->andWhere($qb->expr()->gt('scheduled_at', $qb->createPositionalParameter($scheduleAfter, IQueryBuilder::PARAM_INT)));
+        }
+        if ($endedBefore !== null) {
+            $qb->andWhere($qb->expr()->isNotNull('ended_at'));
+            $qb->andWhere($qb->expr()->lt('ended_at', $qb->createPositionalParameter($endedBefore, IQueryBuilder::PARAM_INT)));
+        }
+        return $this->findEntities($qb);
+    }
 
-	/**
-	 * @param int $timeout
-	 * @param bool $force If true, ignore the allow_cleanup flag
-	 * @return int the number of deleted tasks
-	 * @throws Exception
-	 */
-	public function deleteOlderThan(int $timeout, bool $force = false): int {
-		$qb = $this->db->getQueryBuilder();
-		$qb->delete($this->tableName)
-			->where($qb->expr()->lt('last_updated', $qb->createPositionalParameter($this->timeFactory->getDateTime()->getTimestamp() - $timeout)));
-		if (!$force) {
-			$qb->andWhere($qb->expr()->eq('allow_cleanup', $qb->createPositionalParameter(1, IQueryBuilder::PARAM_INT)));
-		}
-		return $qb->executeStatement();
-	}
+    /**
+     * @param int $timeout
+     * @param bool $force If true, ignore the allow_cleanup flag
+     * @return int the number of deleted tasks
+     * @throws Exception
+     */
+    public function deleteOlderThan(int $timeout, bool $force = false): int {
+        $qb = $this->db->getQueryBuilder();
+        $qb->delete($this->tableName)
+            ->where($qb->expr()->lt('last_updated', $qb->createPositionalParameter($this->timeFactory->getDateTime()->getTimestamp() - $timeout)));
+        if (!$force) {
+            $qb->andWhere($qb->expr()->eq('allow_cleanup', $qb->createPositionalParameter(1, IQueryBuilder::PARAM_INT)));
+        }
+        return $qb->executeStatement();
+    }
 
-	/**
-	 * @param int $timeout
-	 * @param bool $force If true, ignore the allow_cleanup flag
-	 * @return \Generator<Task>
-	 * @throws Exception
-	 */
-	public function getTasksToCleanup(int $timeout, bool $force = false): \Generator {
-		$qb = $this->db->getQueryBuilder();
-		$qb->select(Task::$columns)
-			->from($this->tableName)
-			->where($qb->expr()->lt('last_updated', $qb->createPositionalParameter($this->timeFactory->getDateTime()->getTimestamp() - $timeout)));
-		if (!$force) {
-			$qb->andWhere($qb->expr()->eq('allow_cleanup', $qb->createPositionalParameter(1, IQueryBuilder::PARAM_INT)));
-		}
-		foreach ($this->yieldEntities($qb) as $entity) {
-			yield $entity;
-		};
-	}
+    /**
+     * @param int $timeout
+     * @param bool $force If true, ignore the allow_cleanup flag
+     * @return \Generator<Task>
+     * @throws Exception
+     */
+    public function getTasksToCleanup(int $timeout, bool $force = false): \Generator {
+        $qb = $this->db->getQueryBuilder();
+        $qb->select(Task::$columns)
+            ->from($this->tableName)
+            ->where($qb->expr()->lt('last_updated', $qb->createPositionalParameter($this->timeFactory->getDateTime()->getTimestamp() - $timeout)));
+        if (!$force) {
+            $qb->andWhere($qb->expr()->eq('allow_cleanup', $qb->createPositionalParameter(1, IQueryBuilder::PARAM_INT)));
+        }
+        foreach ($this->yieldEntities($qb) as $entity) {
+            yield $entity;
+        };
+    }
 
-	public function update(Entity $entity): Entity {
-		$entity->setLastUpdated($this->timeFactory->now()->getTimestamp());
-		return parent::update($entity);
-	}
+    public function update(Entity $entity): Entity {
+        $entity->setLastUpdated($this->timeFactory->now()->getTimestamp());
+        return parent::update($entity);
+    }
 
-	public function lockTask(Entity $entity): int {
-		$qb = $this->db->getQueryBuilder();
-		$qb->update($this->tableName)
-			->set('status', $qb->createPositionalParameter(\OCP\TaskProcessing\Task::STATUS_RUNNING, IQueryBuilder::PARAM_INT))
-			->where($qb->expr()->eq('id', $qb->createPositionalParameter($entity->getId(), IQueryBuilder::PARAM_INT)))
-			->andWhere($qb->expr()->neq('status', $qb->createPositionalParameter(2, IQueryBuilder::PARAM_INT)));
-		try {
-			return $qb->executeStatement();
-		} catch (Exception) {
-			return 0;
-		}
-	}
+    public function lockTask(Entity $entity): int {
+        $qb = $this->db->getQueryBuilder();
+        $qb->update($this->tableName)
+            ->set('status', $qb->createPositionalParameter(\OCP\TaskProcessing\Task::STATUS_RUNNING, IQueryBuilder::PARAM_INT))
+            ->where($qb->expr()->eq('id', $qb->createPositionalParameter($entity->getId(), IQueryBuilder::PARAM_INT)))
+            ->andWhere($qb->expr()->neq('status', $qb->createPositionalParameter(2, IQueryBuilder::PARAM_INT)));
+        try {
+            return $qb->executeStatement();
+        } catch (Exception) {
+            return 0;
+        }
+    }
 
-	/**
-	 * @param list<string> $taskTypes
-	 * @param list<int> $taskIdsToIgnore
-	 * @param int $numberOfTasks
-	 * @return list<Task>
-	 * @throws Exception
-	 */
-	public function findNOldestScheduledByType(array $taskTypes, array $taskIdsToIgnore, int $numberOfTasks) {
-		$qb = $this->db->getQueryBuilder();
-		$qb->select(Task::$columns)
-			->from($this->tableName)
-			->where($qb->expr()->eq('status', $qb->createPositionalParameter(\OCP\TaskProcessing\Task::STATUS_SCHEDULED, IQueryBuilder::PARAM_INT)))
-			->setMaxResults($numberOfTasks)
-			->orderBy('last_updated', 'ASC');
+    /**
+     * @param list<string> $taskTypes
+     * @param list<int> $taskIdsToIgnore
+     * @param int $numberOfTasks
+     * @return list<Task>
+     * @throws Exception
+     */
+    public function findNOldestScheduledByType(array $taskTypes, array $taskIdsToIgnore, int $numberOfTasks) {
+        $qb = $this->db->getQueryBuilder();
+        $qb->select(Task::$columns)
+            ->from($this->tableName)
+            ->where($qb->expr()->eq('status', $qb->createPositionalParameter(\OCP\TaskProcessing\Task::STATUS_SCHEDULED, IQueryBuilder::PARAM_INT)))
+            ->setMaxResults($numberOfTasks)
+            ->orderBy('last_updated', 'ASC');
 
-		if (!empty($taskTypes)) {
-			$filter = [];
-			foreach ($taskTypes as $taskType) {
-				$filter[] = $qb->expr()->eq('type', $qb->createPositionalParameter($taskType));
-			}
+        if (!empty($taskTypes)) {
+            $filter = [];
+            foreach ($taskTypes as $taskType) {
+                $filter[] = $qb->expr()->eq('type', $qb->createPositionalParameter($taskType));
+            }
 
-			$qb->andWhere($qb->expr()->orX(...$filter));
-		}
+            $qb->andWhere($qb->expr()->orX(...$filter));
+        }
 
-		if (!empty($taskIdsToIgnore)) {
-			$qb->andWhere($qb->expr()->notIn('id', $qb->createNamedParameter($taskIdsToIgnore, IQueryBuilder::PARAM_INT_ARRAY)));
-		}
+        if (!empty($taskIdsToIgnore)) {
+            $qb->andWhere($qb->expr()->notIn('id', $qb->createNamedParameter($taskIdsToIgnore, IQueryBuilder::PARAM_INT_ARRAY)));
+        }
 
-		return $this->findEntities($qb);
-	}
+        return $this->findEntities($qb);
+    }
 }

lib/private/TaskProcessing/Manager.php

Indentation +1602 added lines, -1602 removed lines

@@ -71,1606 +71,1606 @@
 
 class Manager implements IManager {
 
-	public const LEGACY_PREFIX_TEXTPROCESSING = 'legacy:TextProcessing:';
-	public const LEGACY_PREFIX_TEXTTOIMAGE = 'legacy:TextToImage:';
-	public const LEGACY_PREFIX_SPEECHTOTEXT = 'legacy:SpeechToText:';
-
-	public const LAZY_CONFIG_KEYS = [
-		'ai.taskprocessing_type_preferences',
-		'ai.taskprocessing_provider_preferences',
-	];
-
-	public const MAX_TASK_AGE_SECONDS = 60 * 60 * 24 * 31 * 6; // 6 months
-
-	private const TASK_TYPES_CACHE_KEY = 'available_task_types_v3';
-	private const TASK_TYPE_IDS_CACHE_KEY = 'available_task_type_ids';
-
-	/** @var list<IProvider>|null */
-	private ?array $providers = null;
-
-	/**
-	 * @var array<array-key,array{name: string, description: string, inputShape: ShapeDescriptor[], inputShapeEnumValues: ShapeEnumValue[][], inputShapeDefaults: array<array-key, numeric|string>, isInternal: bool, optionalInputShape: ShapeDescriptor[], optionalInputShapeEnumValues: ShapeEnumValue[][], optionalInputShapeDefaults: array<array-key, numeric|string>, outputShape: ShapeDescriptor[], outputShapeEnumValues: ShapeEnumValue[][], optionalOutputShape: ShapeDescriptor[], optionalOutputShapeEnumValues: ShapeEnumValue[][]}>
-	 */
-	private ?array $availableTaskTypes = null;
-
-	/** @var list<string>|null */
-	private ?array $availableTaskTypeIds = null;
-
-	private IAppData $appData;
-	private ?array $preferences = null;
-	private ?array $providersById = null;
-
-	/** @var ITaskType[]|null */
-	private ?array $taskTypes = null;
-	private ICache $distributedCache;
-
-	private ?GetTaskProcessingProvidersEvent $eventResult = null;
-
-	public function __construct(
-		private IAppConfig $appConfig,
-		private Coordinator $coordinator,
-		private IServerContainer $serverContainer,
-		private LoggerInterface $logger,
-		private TaskMapper $taskMapper,
-		private IJobList $jobList,
-		private IEventDispatcher $dispatcher,
-		IAppDataFactory $appDataFactory,
-		private IRootFolder $rootFolder,
-		private \OCP\TextToImage\IManager $textToImageManager,
-		private IUserMountCache $userMountCache,
-		private IClientService $clientService,
-		private IAppManager $appManager,
-		private IUserManager $userManager,
-		private IUserSession $userSession,
-		ICacheFactory $cacheFactory,
-		private IFactory $l10nFactory,
-	) {
-		$this->appData = $appDataFactory->get('core');
-		$this->distributedCache = $cacheFactory->createDistributed('task_processing::');
-	}
-
-
-	/**
-	 * This is almost a copy of textProcessingManager->getProviders
-	 * to avoid a dependency cycle between TextProcessingManager and TaskProcessingManager
-	 */
-	private function _getRawTextProcessingProviders(): array {
-		$context = $this->coordinator->getRegistrationContext();
-		if ($context === null) {
-			return [];
-		}
-
-		$providers = [];
-
-		foreach ($context->getTextProcessingProviders() as $providerServiceRegistration) {
-			$class = $providerServiceRegistration->getService();
-			try {
-				$providers[$class] = $this->serverContainer->get($class);
-			} catch (\Throwable $e) {
-				$this->logger->error('Failed to load Text processing provider ' . $class, [
-					'exception' => $e,
-				]);
-			}
-		}
-
-		return $providers;
-	}
-
-	private function _getTextProcessingProviders(): array {
-		$oldProviders = $this->_getRawTextProcessingProviders();
-		$newProviders = [];
-		foreach ($oldProviders as $oldProvider) {
-			$provider = new class($oldProvider) implements IProvider, ISynchronousProvider {
-				private \OCP\TextProcessing\IProvider $provider;
-
-				public function __construct(\OCP\TextProcessing\IProvider $provider) {
-					$this->provider = $provider;
-				}
-
-				public function getId(): string {
-					if ($this->provider instanceof \OCP\TextProcessing\IProviderWithId) {
-						return $this->provider->getId();
-					}
-					return Manager::LEGACY_PREFIX_TEXTPROCESSING . $this->provider::class;
-				}
-
-				public function getName(): string {
-					return $this->provider->getName();
-				}
-
-				public function getTaskTypeId(): string {
-					return match ($this->provider->getTaskType()) {
-						\OCP\TextProcessing\FreePromptTaskType::class => TextToText::ID,
-						\OCP\TextProcessing\HeadlineTaskType::class => TextToTextHeadline::ID,
-						\OCP\TextProcessing\TopicsTaskType::class => TextToTextTopics::ID,
-						\OCP\TextProcessing\SummaryTaskType::class => TextToTextSummary::ID,
-						default => Manager::LEGACY_PREFIX_TEXTPROCESSING . $this->provider->getTaskType(),
-					};
-				}
-
-				public function getExpectedRuntime(): int {
-					if ($this->provider instanceof \OCP\TextProcessing\IProviderWithExpectedRuntime) {
-						return $this->provider->getExpectedRuntime();
-					}
-					return 60;
-				}
-
-				public function getOptionalInputShape(): array {
-					return [];
-				}
-
-				public function getOptionalOutputShape(): array {
-					return [];
-				}
-
-				public function process(?string $userId, array $input, callable $reportProgress): array {
-					if ($this->provider instanceof \OCP\TextProcessing\IProviderWithUserId) {
-						$this->provider->setUserId($userId);
-					}
-					try {
-						return ['output' => $this->provider->process($input['input'])];
-					} catch (\RuntimeException $e) {
-						throw new ProcessingException($e->getMessage(), 0, $e);
-					}
-				}
-
-				public function getInputShapeEnumValues(): array {
-					return [];
-				}
-
-				public function getInputShapeDefaults(): array {
-					return [];
-				}
-
-				public function getOptionalInputShapeEnumValues(): array {
-					return [];
-				}
-
-				public function getOptionalInputShapeDefaults(): array {
-					return [];
-				}
-
-				public function getOutputShapeEnumValues(): array {
-					return [];
-				}
-
-				public function getOptionalOutputShapeEnumValues(): array {
-					return [];
-				}
-			};
-			$newProviders[$provider->getId()] = $provider;
-		}
-
-		return $newProviders;
-	}
-
-	/**
-	 * @return ITaskType[]
-	 */
-	private function _getTextProcessingTaskTypes(): array {
-		$oldProviders = $this->_getRawTextProcessingProviders();
-		$newTaskTypes = [];
-		foreach ($oldProviders as $oldProvider) {
-			// These are already implemented in the TaskProcessing realm
-			if (in_array($oldProvider->getTaskType(), [
-				\OCP\TextProcessing\FreePromptTaskType::class,
-				\OCP\TextProcessing\HeadlineTaskType::class,
-				\OCP\TextProcessing\TopicsTaskType::class,
-				\OCP\TextProcessing\SummaryTaskType::class
-			], true)) {
-				continue;
-			}
-			$taskType = new class($oldProvider->getTaskType()) implements ITaskType {
-				private string $oldTaskTypeClass;
-				private \OCP\TextProcessing\ITaskType $oldTaskType;
-				private IL10N $l;
-
-				public function __construct(string $oldTaskTypeClass) {
-					$this->oldTaskTypeClass = $oldTaskTypeClass;
-					$this->oldTaskType = \OCP\Server::get($oldTaskTypeClass);
-					$this->l = \OCP\Server::get(IFactory::class)->get('core');
-				}
-
-				public function getId(): string {
-					return Manager::LEGACY_PREFIX_TEXTPROCESSING . $this->oldTaskTypeClass;
-				}
-
-				public function getName(): string {
-					return $this->oldTaskType->getName();
-				}
-
-				public function getDescription(): string {
-					return $this->oldTaskType->getDescription();
-				}
-
-				public function getInputShape(): array {
-					return ['input' => new ShapeDescriptor($this->l->t('Input text'), $this->l->t('The input text'), EShapeType::Text)];
-				}
-
-				public function getOutputShape(): array {
-					return ['output' => new ShapeDescriptor($this->l->t('Input text'), $this->l->t('The input text'), EShapeType::Text)];
-				}
-			};
-			$newTaskTypes[$taskType->getId()] = $taskType;
-		}
-
-		return $newTaskTypes;
-	}
-
-	/**
-	 * @return IProvider[]
-	 */
-	private function _getTextToImageProviders(): array {
-		$oldProviders = $this->textToImageManager->getProviders();
-		$newProviders = [];
-		foreach ($oldProviders as $oldProvider) {
-			$newProvider = new class($oldProvider, $this->appData) implements IProvider, ISynchronousProvider {
-				private \OCP\TextToImage\IProvider $provider;
-				private IAppData $appData;
-
-				public function __construct(\OCP\TextToImage\IProvider $provider, IAppData $appData) {
-					$this->provider = $provider;
-					$this->appData = $appData;
-				}
-
-				public function getId(): string {
-					return Manager::LEGACY_PREFIX_TEXTTOIMAGE . $this->provider->getId();
-				}
-
-				public function getName(): string {
-					return $this->provider->getName();
-				}
-
-				public function getTaskTypeId(): string {
-					return TextToImage::ID;
-				}
-
-				public function getExpectedRuntime(): int {
-					return $this->provider->getExpectedRuntime();
-				}
-
-				public function getOptionalInputShape(): array {
-					return [];
-				}
-
-				public function getOptionalOutputShape(): array {
-					return [];
-				}
-
-				public function process(?string $userId, array $input, callable $reportProgress): array {
-					try {
-						$folder = $this->appData->getFolder('text2image');
-					} catch (\OCP\Files\NotFoundException) {
-						$folder = $this->appData->newFolder('text2image');
-					}
-					$resources = [];
-					$files = [];
-					for ($i = 0; $i < $input['numberOfImages']; $i++) {
-						$file = $folder->newFile(time() . '-' . rand(1, 100000) . '-' . $i);
-						$files[] = $file;
-						$resource = $file->write();
-						if ($resource !== false && $resource !== true && is_resource($resource)) {
-							$resources[] = $resource;
-						} else {
-							throw new ProcessingException('Text2Image generation using provider "' . $this->getName() . '" failed: Couldn\'t open file to write.');
-						}
-					}
-					if ($this->provider instanceof \OCP\TextToImage\IProviderWithUserId) {
-						$this->provider->setUserId($userId);
-					}
-					try {
-						$this->provider->generate($input['input'], $resources);
-					} catch (\RuntimeException $e) {
-						throw new ProcessingException($e->getMessage(), 0, $e);
-					}
-					for ($i = 0; $i < $input['numberOfImages']; $i++) {
-						if (is_resource($resources[$i])) {
-							// If $resource hasn't been closed yet, we'll do that here
-							fclose($resources[$i]);
-						}
-					}
-					return ['images' => array_map(fn (ISimpleFile $file) => $file->getContent(), $files)];
-				}
-
-				public function getInputShapeEnumValues(): array {
-					return [];
-				}
-
-				public function getInputShapeDefaults(): array {
-					return [];
-				}
-
-				public function getOptionalInputShapeEnumValues(): array {
-					return [];
-				}
-
-				public function getOptionalInputShapeDefaults(): array {
-					return [];
-				}
-
-				public function getOutputShapeEnumValues(): array {
-					return [];
-				}
-
-				public function getOptionalOutputShapeEnumValues(): array {
-					return [];
-				}
-			};
-			$newProviders[$newProvider->getId()] = $newProvider;
-		}
-
-		return $newProviders;
-	}
-
-	/**
-	 * This is almost a copy of SpeechToTextManager->getProviders
-	 * to avoid a dependency cycle between SpeechToTextManager and TaskProcessingManager
-	 */
-	private function _getRawSpeechToTextProviders(): array {
-		$context = $this->coordinator->getRegistrationContext();
-		if ($context === null) {
-			return [];
-		}
-		$providers = [];
-		foreach ($context->getSpeechToTextProviders() as $providerServiceRegistration) {
-			$class = $providerServiceRegistration->getService();
-			try {
-				$providers[$class] = $this->serverContainer->get($class);
-			} catch (NotFoundExceptionInterface|ContainerExceptionInterface|\Throwable $e) {
-				$this->logger->error('Failed to load SpeechToText provider ' . $class, [
-					'exception' => $e,
-				]);
-			}
-		}
-
-		return $providers;
-	}
-
-	/**
-	 * @return IProvider[]
-	 */
-	private function _getSpeechToTextProviders(): array {
-		$oldProviders = $this->_getRawSpeechToTextProviders();
-		$newProviders = [];
-		foreach ($oldProviders as $oldProvider) {
-			$newProvider = new class($oldProvider, $this->rootFolder, $this->appData) implements IProvider, ISynchronousProvider {
-				private ISpeechToTextProvider $provider;
-				private IAppData $appData;
-
-				private IRootFolder $rootFolder;
-
-				public function __construct(ISpeechToTextProvider $provider, IRootFolder $rootFolder, IAppData $appData) {
-					$this->provider = $provider;
-					$this->rootFolder = $rootFolder;
-					$this->appData = $appData;
-				}
-
-				public function getId(): string {
-					if ($this->provider instanceof ISpeechToTextProviderWithId) {
-						return Manager::LEGACY_PREFIX_SPEECHTOTEXT . $this->provider->getId();
-					}
-					return Manager::LEGACY_PREFIX_SPEECHTOTEXT . $this->provider::class;
-				}
-
-				public function getName(): string {
-					return $this->provider->getName();
-				}
-
-				public function getTaskTypeId(): string {
-					return AudioToText::ID;
-				}
-
-				public function getExpectedRuntime(): int {
-					return 60;
-				}
-
-				public function getOptionalInputShape(): array {
-					return [];
-				}
-
-				public function getOptionalOutputShape(): array {
-					return [];
-				}
-
-				public function process(?string $userId, array $input, callable $reportProgress): array {
-					if ($this->provider instanceof \OCP\SpeechToText\ISpeechToTextProviderWithUserId) {
-						$this->provider->setUserId($userId);
-					}
-					try {
-						$result = $this->provider->transcribeFile($input['input']);
-					} catch (\RuntimeException $e) {
-						throw new ProcessingException($e->getMessage(), 0, $e);
-					}
-					return ['output' => $result];
-				}
-
-				public function getInputShapeEnumValues(): array {
-					return [];
-				}
-
-				public function getInputShapeDefaults(): array {
-					return [];
-				}
-
-				public function getOptionalInputShapeEnumValues(): array {
-					return [];
-				}
-
-				public function getOptionalInputShapeDefaults(): array {
-					return [];
-				}
-
-				public function getOutputShapeEnumValues(): array {
-					return [];
-				}
-
-				public function getOptionalOutputShapeEnumValues(): array {
-					return [];
-				}
-			};
-			$newProviders[$newProvider->getId()] = $newProvider;
-		}
-
-		return $newProviders;
-	}
-
-	/**
-	 * Dispatches the event to collect external providers and task types.
-	 * Caches the result within the request.
-	 */
-	private function dispatchGetProvidersEvent(): GetTaskProcessingProvidersEvent {
-		if ($this->eventResult !== null) {
-			return $this->eventResult;
-		}
-
-		$this->eventResult = new GetTaskProcessingProvidersEvent();
-		$this->dispatcher->dispatchTyped($this->eventResult);
-		return $this->eventResult ;
-	}
-
-	/**
-	 * @return IProvider[]
-	 */
-	private function _getProviders(): array {
-		$context = $this->coordinator->getRegistrationContext();
-
-		if ($context === null) {
-			return [];
-		}
-
-		$providers = [];
-
-		foreach ($context->getTaskProcessingProviders() as $providerServiceRegistration) {
-			$class = $providerServiceRegistration->getService();
-			try {
-				/** @var IProvider $provider */
-				$provider = $this->serverContainer->get($class);
-				if (isset($providers[$provider->getId()])) {
-					$this->logger->warning('Task processing provider ' . $class . ' is using ID ' . $provider->getId() . ' which is already used by ' . $providers[$provider->getId()]::class);
-				}
-				$providers[$provider->getId()] = $provider;
-			} catch (\Throwable $e) {
-				$this->logger->error('Failed to load task processing provider ' . $class, [
-					'exception' => $e,
-				]);
-			}
-		}
-
-		$event = $this->dispatchGetProvidersEvent();
-		$externalProviders = $event->getProviders();
-		foreach ($externalProviders as $provider) {
-			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;
-	}
-
-	/**
-	 * @return ITaskType[]
-	 */
-	private function _getTaskTypes(): array {
-		$context = $this->coordinator->getRegistrationContext();
-
-		if ($context === null) {
-			return [];
-		}
-
-		if ($this->taskTypes !== null) {
-			return $this->taskTypes;
-		}
-
-		// Default task types
-		$taskTypes = [
-			\OCP\TaskProcessing\TaskTypes\TextToText::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToText::class),
-			\OCP\TaskProcessing\TaskTypes\TextToTextTopics::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextTopics::class),
-			\OCP\TaskProcessing\TaskTypes\TextToTextHeadline::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextHeadline::class),
-			\OCP\TaskProcessing\TaskTypes\TextToTextSummary::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextSummary::class),
-			\OCP\TaskProcessing\TaskTypes\TextToTextFormalization::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextFormalization::class),
-			\OCP\TaskProcessing\TaskTypes\TextToTextSimplification::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextSimplification::class),
-			\OCP\TaskProcessing\TaskTypes\TextToTextChat::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextChat::class),
-			\OCP\TaskProcessing\TaskTypes\TextToTextTranslate::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextTranslate::class),
-			\OCP\TaskProcessing\TaskTypes\TextToTextReformulation::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextReformulation::class),
-			\OCP\TaskProcessing\TaskTypes\TextToImage::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToImage::class),
-			\OCP\TaskProcessing\TaskTypes\AudioToText::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\AudioToText::class),
-			\OCP\TaskProcessing\TaskTypes\ContextWrite::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\ContextWrite::class),
-			\OCP\TaskProcessing\TaskTypes\GenerateEmoji::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\GenerateEmoji::class),
-			\OCP\TaskProcessing\TaskTypes\TextToTextChangeTone::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextChangeTone::class),
-			\OCP\TaskProcessing\TaskTypes\TextToTextChatWithTools::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextChatWithTools::class),
-			\OCP\TaskProcessing\TaskTypes\ContextAgentInteraction::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\ContextAgentInteraction::class),
-			\OCP\TaskProcessing\TaskTypes\TextToTextProofread::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextProofread::class),
-			\OCP\TaskProcessing\TaskTypes\TextToSpeech::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToSpeech::class),
-			\OCP\TaskProcessing\TaskTypes\AudioToAudioChat::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\AudioToAudioChat::class),
-			\OCP\TaskProcessing\TaskTypes\ContextAgentAudioInteraction::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\ContextAgentAudioInteraction::class),
-			\OCP\TaskProcessing\TaskTypes\AnalyzeImages::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\AnalyzeImages::class),
-		];
-
-		foreach ($context->getTaskProcessingTaskTypes() as $providerServiceRegistration) {
-			$class = $providerServiceRegistration->getService();
-			try {
-				/** @var ITaskType $provider */
-				$taskType = $this->serverContainer->get($class);
-				if (isset($taskTypes[$taskType->getId()])) {
-					$this->logger->warning('Task processing task type ' . $class . ' is using ID ' . $taskType->getId() . ' which is already used by ' . $taskTypes[$taskType->getId()]::class);
-				}
-				$taskTypes[$taskType->getId()] = $taskType;
-			} catch (\Throwable $e) {
-				$this->logger->error('Failed to load task processing task type ' . $class, [
-					'exception' => $e,
-				]);
-			}
-		}
-
-		$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();
-
-		$this->taskTypes = $taskTypes;
-		return $this->taskTypes;
-	}
-
-	/**
-	 * @return array
-	 */
-	private function _getTaskTypeSettings(): array {
-		try {
-			$json = $this->appConfig->getValueString('core', 'ai.taskprocessing_type_preferences', '', lazy: true);
-			if ($json === '') {
-				return [];
-			}
-			return json_decode($json, true, flags: JSON_THROW_ON_ERROR);
-		} catch (\JsonException $e) {
-			$this->logger->error('Failed to get settings. JSON Error in ai.taskprocessing_type_preferences', ['exception' => $e]);
-			$taskTypeSettings = [];
-			$taskTypes = $this->_getTaskTypes();
-			foreach ($taskTypes as $taskType) {
-				$taskTypeSettings[$taskType->getId()] = false;
-			};
-
-			return $taskTypeSettings;
-		}
-
-	}
-
-	/**
-	 * @param ShapeDescriptor[] $spec
-	 * @param array<array-key, string|numeric> $defaults
-	 * @param array<array-key, ShapeEnumValue[]> $enumValues
-	 * @param array $io
-	 * @param bool $optional
-	 * @return void
-	 * @throws ValidationException
-	 */
-	private static function validateInput(array $spec, array $defaults, array $enumValues, array $io, bool $optional = false): void {
-		foreach ($spec as $key => $descriptor) {
-			$type = $descriptor->getShapeType();
-			if (!isset($io[$key])) {
-				if ($optional) {
-					continue;
-				}
-				if (isset($defaults[$key])) {
-					if (EShapeType::getScalarType($type) !== $type) {
-						throw new ValidationException('Provider tried to set a default value for a non-scalar slot');
-					}
-					if (EShapeType::isFileType($type)) {
-						throw new ValidationException('Provider tried to set a default value for a slot that is not text or number');
-					}
-					$type->validateInput($defaults[$key]);
-					continue;
-				}
-				throw new ValidationException('Missing key: "' . $key . '"');
-			}
-			try {
-				$type->validateInput($io[$key]);
-				if ($type === EShapeType::Enum) {
-					if (!isset($enumValues[$key])) {
-						throw new ValidationException('Provider did not provide enum values for an enum slot: "' . $key . '"');
-					}
-					$type->validateEnum($io[$key], $enumValues[$key]);
-				}
-			} catch (ValidationException $e) {
-				throw new ValidationException('Failed to validate input key "' . $key . '": ' . $e->getMessage());
-			}
-		}
-	}
-
-	/**
-	 * Takes task input data and replaces fileIds with File objects
-	 *
-	 * @param array<array-key, list<numeric|string>|numeric|string> $input
-	 * @param array<array-key, numeric|string> ...$defaultSpecs the specs
-	 * @return array<array-key, list<numeric|string>|numeric|string>
-	 */
-	public function fillInputDefaults(array $input, ...$defaultSpecs): array {
-		$spec = array_reduce($defaultSpecs, fn ($carry, $spec) => array_merge($carry, $spec), []);
-		return array_merge($spec, $input);
-	}
-
-	/**
-	 * @param ShapeDescriptor[] $spec
-	 * @param array<array-key, ShapeEnumValue[]> $enumValues
-	 * @param array $io
-	 * @param bool $optional
-	 * @return void
-	 * @throws ValidationException
-	 */
-	private static function validateOutputWithFileIds(array $spec, array $enumValues, array $io, bool $optional = false): void {
-		foreach ($spec as $key => $descriptor) {
-			$type = $descriptor->getShapeType();
-			if (!isset($io[$key])) {
-				if ($optional) {
-					continue;
-				}
-				throw new ValidationException('Missing key: "' . $key . '"');
-			}
-			try {
-				$type->validateOutputWithFileIds($io[$key]);
-				if (isset($enumValues[$key])) {
-					$type->validateEnum($io[$key], $enumValues[$key]);
-				}
-			} catch (ValidationException $e) {
-				throw new ValidationException('Failed to validate output key "' . $key . '": ' . $e->getMessage());
-			}
-		}
-	}
-
-	/**
-	 * @param ShapeDescriptor[] $spec
-	 * @param array<array-key, ShapeEnumValue[]> $enumValues
-	 * @param array $io
-	 * @param bool $optional
-	 * @return void
-	 * @throws ValidationException
-	 */
-	private static function validateOutputWithFileData(array $spec, array $enumValues, array $io, bool $optional = false): void {
-		foreach ($spec as $key => $descriptor) {
-			$type = $descriptor->getShapeType();
-			if (!isset($io[$key])) {
-				if ($optional) {
-					continue;
-				}
-				throw new ValidationException('Missing key: "' . $key . '"');
-			}
-			try {
-				$type->validateOutputWithFileData($io[$key]);
-				if (isset($enumValues[$key])) {
-					$type->validateEnum($io[$key], $enumValues[$key]);
-				}
-			} catch (ValidationException $e) {
-				throw new ValidationException('Failed to validate output key "' . $key . '": ' . $e->getMessage());
-			}
-		}
-	}
-
-	/**
-	 * @param array<array-key, T> $array The array to filter
-	 * @param ShapeDescriptor[] ...$specs the specs that define which keys to keep
-	 * @return array<array-key, T>
-	 * @psalm-template T
-	 */
-	private function removeSuperfluousArrayKeys(array $array, ...$specs): array {
-		$keys = array_unique(array_reduce($specs, fn ($carry, $spec) => array_merge($carry, array_keys($spec)), []));
-		$keys = array_filter($keys, fn ($key) => array_key_exists($key, $array));
-		$values = array_map(fn (string $key) => $array[$key], $keys);
-		return array_combine($keys, $values);
-	}
-
-	public function hasProviders(): bool {
-		return count($this->getProviders()) !== 0;
-	}
-
-	public function getProviders(): array {
-		if ($this->providers === null) {
-			$this->providers = $this->_getProviders();
-		}
-
-		return $this->providers;
-	}
-
-	public function getPreferredProvider(string $taskTypeId) {
-		try {
-			if ($this->preferences === null) {
-				$this->preferences = $this->distributedCache->get('ai.taskprocessing_provider_preferences');
-				if ($this->preferences === null) {
-					$this->preferences = json_decode(
-						$this->appConfig->getValueString('core', 'ai.taskprocessing_provider_preferences', 'null', lazy: true),
-						associative: true,
-						flags: JSON_THROW_ON_ERROR,
-					);
-					$this->distributedCache->set('ai.taskprocessing_provider_preferences', $this->preferences, 60 * 3);
-				}
-			}
-
-			$providers = $this->getProviders();
-			if (isset($this->preferences[$taskTypeId])) {
-				$providersById = $this->providersById ?? array_reduce($providers, static function (array $carry, IProvider $provider) {
-					$carry[$provider->getId()] = $provider;
-					return $carry;
-				}, []);
-				$this->providersById = $providersById;
-				if (isset($providersById[$this->preferences[$taskTypeId]])) {
-					return $providersById[$this->preferences[$taskTypeId]];
-				}
-			}
-			// By default, use the first available provider
-			foreach ($providers as $provider) {
-				if ($provider->getTaskTypeId() === $taskTypeId) {
-					return $provider;
-				}
-			}
-		} catch (\JsonException $e) {
-			$this->logger->warning('Failed to parse provider preferences while getting preferred provider for task type ' . $taskTypeId, ['exception' => $e]);
-		}
-		throw new \OCP\TaskProcessing\Exception\Exception('No matching provider found');
-	}
-
-	public function getAvailableTaskTypes(bool $showDisabled = false, ?string $userId = null): array {
-		// We cache by language, because some task type fields are translated
-		$cacheKey = self::TASK_TYPES_CACHE_KEY . ':' . $this->l10nFactory->findLanguage();
-
-		// userId will be obtained from the session if left to null
-		if (!$this->checkGuestAccess($userId)) {
-			return [];
-		}
-		if ($this->availableTaskTypes === null) {
-			$cachedValue = $this->distributedCache->get($cacheKey);
-			if ($cachedValue !== null) {
-				$this->availableTaskTypes = unserialize($cachedValue);
-			}
-		}
-		// Either we have no cache or showDisabled is turned on, which we don't want to cache, ever.
-		if ($this->availableTaskTypes === null || $showDisabled) {
-			$taskTypes = $this->_getTaskTypes();
-			$taskTypeSettings = $this->_getTaskTypeSettings();
-
-			$availableTaskTypes = [];
-			foreach ($taskTypes as $taskType) {
-				if ((!$showDisabled) && isset($taskTypeSettings[$taskType->getId()]) && !$taskTypeSettings[$taskType->getId()]) {
-					continue;
-				}
-				try {
-					$provider = $this->getPreferredProvider($taskType->getId());
-				} catch (\OCP\TaskProcessing\Exception\Exception $e) {
-					continue;
-				}
-				try {
-					$availableTaskTypes[$provider->getTaskTypeId()] = [
-						'name' => $taskType->getName(),
-						'description' => $taskType->getDescription(),
-						'optionalInputShape' => $provider->getOptionalInputShape(),
-						'inputShapeEnumValues' => $provider->getInputShapeEnumValues(),
-						'inputShapeDefaults' => $provider->getInputShapeDefaults(),
-						'inputShape' => $taskType->getInputShape(),
-						'optionalInputShapeEnumValues' => $provider->getOptionalInputShapeEnumValues(),
-						'optionalInputShapeDefaults' => $provider->getOptionalInputShapeDefaults(),
-						'outputShape' => $taskType->getOutputShape(),
-						'outputShapeEnumValues' => $provider->getOutputShapeEnumValues(),
-						'optionalOutputShape' => $provider->getOptionalOutputShape(),
-						'optionalOutputShapeEnumValues' => $provider->getOptionalOutputShapeEnumValues(),
-						'isInternal' => $taskType instanceof IInternalTaskType,
-					];
-				} catch (\Throwable $e) {
-					$this->logger->error('Failed to set up TaskProcessing provider ' . $provider::class, ['exception' => $e]);
-				}
-			}
-
-			if ($showDisabled) {
-				// Do not cache showDisabled, ever.
-				return $availableTaskTypes;
-			}
-
-			$this->availableTaskTypes = $availableTaskTypes;
-			$this->distributedCache->set($cacheKey, serialize($this->availableTaskTypes), 60);
-		}
-
-
-		return $this->availableTaskTypes;
-	}
-	public function getAvailableTaskTypeIds(bool $showDisabled = false, ?string $userId = null): array {
-		// userId will be obtained from the session if left to null
-		if (!$this->checkGuestAccess($userId)) {
-			return [];
-		}
-		if ($this->availableTaskTypeIds === null) {
-			$cachedValue = $this->distributedCache->get(self::TASK_TYPE_IDS_CACHE_KEY);
-			if ($cachedValue !== null) {
-				$this->availableTaskTypeIds = $cachedValue;
-			}
-		}
-		// Either we have no cache or showDisabled is turned on, which we don't want to cache, ever.
-		if ($this->availableTaskTypeIds === null || $showDisabled) {
-			$taskTypes = $this->_getTaskTypes();
-			$taskTypeSettings = $this->_getTaskTypeSettings();
-
-			$availableTaskTypeIds = [];
-			foreach ($taskTypes as $taskType) {
-				if ((!$showDisabled) && isset($taskTypeSettings[$taskType->getId()]) && !$taskTypeSettings[$taskType->getId()]) {
-					continue;
-				}
-				try {
-					$provider = $this->getPreferredProvider($taskType->getId());
-				} catch (\OCP\TaskProcessing\Exception\Exception $e) {
-					continue;
-				}
-				$availableTaskTypeIds[] = $taskType->getId();
-			}
-
-			if ($showDisabled) {
-				// Do not cache showDisabled, ever.
-				return $availableTaskTypeIds;
-			}
-
-			$this->availableTaskTypeIds = $availableTaskTypeIds;
-			$this->distributedCache->set(self::TASK_TYPE_IDS_CACHE_KEY, $this->availableTaskTypeIds, 60);
-		}
-
-
-		return $this->availableTaskTypeIds;
-	}
-
-	public function canHandleTask(Task $task): bool {
-		return isset($this->getAvailableTaskTypes()[$task->getTaskTypeId()]);
-	}
-
-	private function checkGuestAccess(?string $userId = null): bool {
-		if ($userId === null && !$this->userSession->isLoggedIn()) {
-			return true;
-		}
-		if ($userId === null) {
-			$user = $this->userSession->getUser();
-		} else {
-			$user = $this->userManager->get($userId);
-		}
-
-		$guestsAllowed = $this->appConfig->getValueString('core', 'ai.taskprocessing_guests', 'false');
-		if ($guestsAllowed == 'true' || !class_exists(\OCA\Guests\UserBackend::class) || !($user->getBackend() instanceof \OCA\Guests\UserBackend)) {
-			return true;
-		}
-		return false;
-	}
-
-	public function scheduleTask(Task $task): void {
-		if (!$this->checkGuestAccess($task->getUserId())) {
-			throw new \OCP\TaskProcessing\Exception\PreConditionNotMetException('Access to this resource is forbidden for guests.');
-		}
-		if (!$this->canHandleTask($task)) {
-			throw new \OCP\TaskProcessing\Exception\PreConditionNotMetException('No task processing provider is installed that can handle this task type: ' . $task->getTaskTypeId());
-		}
-		$this->prepareTask($task);
-		$task->setStatus(Task::STATUS_SCHEDULED);
-		$this->storeTask($task);
-		// schedule synchronous job if the provider is synchronous
-		$provider = $this->getPreferredProvider($task->getTaskTypeId());
-		if ($provider instanceof ISynchronousProvider) {
-			$this->jobList->add(SynchronousBackgroundJob::class, null);
-		}
-	}
-
-	public function runTask(Task $task): Task {
-		if (!$this->checkGuestAccess($task->getUserId())) {
-			throw new \OCP\TaskProcessing\Exception\PreConditionNotMetException('Access to this resource is forbidden for guests.');
-		}
-		if (!$this->canHandleTask($task)) {
-			throw new \OCP\TaskProcessing\Exception\PreConditionNotMetException('No task processing provider is installed that can handle this task type: ' . $task->getTaskTypeId());
-		}
-
-		$provider = $this->getPreferredProvider($task->getTaskTypeId());
-		if ($provider instanceof ISynchronousProvider) {
-			$this->prepareTask($task);
-			$task->setStatus(Task::STATUS_SCHEDULED);
-			$this->storeTask($task);
-			$this->processTask($task, $provider);
-			$task = $this->getTask($task->getId());
-		} else {
-			$this->scheduleTask($task);
-			// poll task
-			while ($task->getStatus() === Task::STATUS_SCHEDULED || $task->getStatus() === Task::STATUS_RUNNING) {
-				sleep(1);
-				$task = $this->getTask($task->getId());
-			}
-		}
-		return $task;
-	}
-
-	public function processTask(Task $task, ISynchronousProvider $provider): bool {
-		try {
-			try {
-				$input = $this->prepareInputData($task);
-			} catch (GenericFileException|NotPermittedException|LockedException|ValidationException|UnauthorizedException $e) {
-				$this->logger->warning('Failed to prepare input data for a TaskProcessing task with synchronous provider ' . $provider->getId(), ['exception' => $e]);
-				$this->setTaskResult($task->getId(), $e->getMessage(), null);
-				return false;
-			}
-			try {
-				$this->setTaskStatus($task, Task::STATUS_RUNNING);
-				$output = $provider->process($task->getUserId(), $input, fn (float $progress) => $this->setTaskProgress($task->getId(), $progress));
-			} catch (ProcessingException $e) {
-				$this->logger->warning('Failed to process a TaskProcessing task with synchronous provider ' . $provider->getId(), ['exception' => $e]);
-				$this->setTaskResult($task->getId(), $e->getMessage(), null);
-				return false;
-			} catch (\Throwable $e) {
-				$this->logger->error('Unknown error while processing TaskProcessing task', ['exception' => $e]);
-				$this->setTaskResult($task->getId(), $e->getMessage(), null);
-				return false;
-			}
-			$this->setTaskResult($task->getId(), null, $output);
-		} catch (NotFoundException $e) {
-			$this->logger->info('Could not find task anymore after execution. Moving on.', ['exception' => $e]);
-		} catch (Exception $e) {
-			$this->logger->error('Failed to report result of TaskProcessing task', ['exception' => $e]);
-		}
-		return true;
-	}
-
-	public function deleteTask(Task $task): void {
-		$taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
-		$this->taskMapper->delete($taskEntity);
-	}
-
-	public function getTask(int $id): Task {
-		try {
-			$taskEntity = $this->taskMapper->find($id);
-			return $taskEntity->toPublicTask();
-		} catch (DoesNotExistException $e) {
-			throw new NotFoundException('Couldn\'t find task with id ' . $id, 0, $e);
-		} catch (MultipleObjectsReturnedException|\OCP\DB\Exception $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', 0, $e);
-		} catch (\JsonException $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the task', 0, $e);
-		}
-	}
-
-	public function cancelTask(int $id): void {
-		$task = $this->getTask($id);
-		if ($task->getStatus() !== Task::STATUS_SCHEDULED && $task->getStatus() !== Task::STATUS_RUNNING) {
-			return;
-		}
-		$task->setStatus(Task::STATUS_CANCELLED);
-		$task->setEndedAt(time());
-		$taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
-		try {
-			$this->taskMapper->update($taskEntity);
-			$this->runWebhook($task);
-		} catch (\OCP\DB\Exception $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', 0, $e);
-		}
-	}
-
-	public function setTaskProgress(int $id, float $progress): bool {
-		// TODO: Not sure if we should rather catch the exceptions of getTask here and fail silently
-		$task = $this->getTask($id);
-		if ($task->getStatus() === Task::STATUS_CANCELLED) {
-			return false;
-		}
-		// only set the start time if the task is going from scheduled to running
-		if ($task->getstatus() === Task::STATUS_SCHEDULED) {
-			$task->setStartedAt(time());
-		}
-		$task->setStatus(Task::STATUS_RUNNING);
-		$task->setProgress($progress);
-		$taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
-		try {
-			$this->taskMapper->update($taskEntity);
-		} catch (\OCP\DB\Exception $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', 0, $e);
-		}
-		return true;
-	}
-
-	public function setTaskResult(int $id, ?string $error, ?array $result, bool $isUsingFileIds = false): void {
-		// TODO: Not sure if we should rather catch the exceptions of getTask here and fail silently
-		$task = $this->getTask($id);
-		if ($task->getStatus() === Task::STATUS_CANCELLED) {
-			$this->logger->info('A TaskProcessing ' . $task->getTaskTypeId() . ' task with id ' . $id . ' finished but was cancelled in the mean time. Moving on without storing result.');
-			return;
-		}
-		if ($error !== null) {
-			$task->setStatus(Task::STATUS_FAILED);
-			$task->setEndedAt(time());
-			// truncate error message to 1000 characters
-			$task->setErrorMessage(mb_substr($error, 0, 1000));
-			$this->logger->warning('A TaskProcessing ' . $task->getTaskTypeId() . ' task with id ' . $id . ' failed with the following message: ' . $error);
-		} elseif ($result !== null) {
-			$taskTypes = $this->getAvailableTaskTypes();
-			$outputShape = $taskTypes[$task->getTaskTypeId()]['outputShape'];
-			$outputShapeEnumValues = $taskTypes[$task->getTaskTypeId()]['outputShapeEnumValues'];
-			$optionalOutputShape = $taskTypes[$task->getTaskTypeId()]['optionalOutputShape'];
-			$optionalOutputShapeEnumValues = $taskTypes[$task->getTaskTypeId()]['optionalOutputShapeEnumValues'];
-			try {
-				// validate output
-				if (!$isUsingFileIds) {
-					$this->validateOutputWithFileData($outputShape, $outputShapeEnumValues, $result);
-					$this->validateOutputWithFileData($optionalOutputShape, $optionalOutputShapeEnumValues, $result, true);
-				} else {
-					$this->validateOutputWithFileIds($outputShape, $outputShapeEnumValues, $result);
-					$this->validateOutputWithFileIds($optionalOutputShape, $optionalOutputShapeEnumValues, $result, true);
-				}
-				$output = $this->removeSuperfluousArrayKeys($result, $outputShape, $optionalOutputShape);
-				// extract raw data and put it in files, replace it with file ids
-				if (!$isUsingFileIds) {
-					$output = $this->encapsulateOutputFileData($output, $outputShape, $optionalOutputShape);
-				} else {
-					$this->validateOutputFileIds($output, $outputShape, $optionalOutputShape);
-				}
-				// Turn file objects into IDs
-				foreach ($output as $key => $value) {
-					if ($value instanceof Node) {
-						$output[$key] = $value->getId();
-					}
-					if (is_array($value) && isset($value[0]) && $value[0] instanceof Node) {
-						$output[$key] = array_map(fn ($node) => $node->getId(), $value);
-					}
-				}
-				$task->setOutput($output);
-				$task->setProgress(1);
-				$task->setStatus(Task::STATUS_SUCCESSFUL);
-				$task->setEndedAt(time());
-			} catch (ValidationException $e) {
-				$task->setProgress(1);
-				$task->setStatus(Task::STATUS_FAILED);
-				$task->setEndedAt(time());
-				$error = 'The task was processed successfully but the provider\'s output doesn\'t pass validation against the task type\'s outputShape spec and/or the provider\'s own optionalOutputShape spec';
-				$task->setErrorMessage($error);
-				$this->logger->error($error, ['exception' => $e, 'output' => $result]);
-			} catch (NotPermittedException $e) {
-				$task->setProgress(1);
-				$task->setStatus(Task::STATUS_FAILED);
-				$task->setEndedAt(time());
-				$error = 'The task was processed successfully but storing the output in a file failed';
-				$task->setErrorMessage($error);
-				$this->logger->error($error, ['exception' => $e]);
-			} catch (InvalidPathException|\OCP\Files\NotFoundException $e) {
-				$task->setProgress(1);
-				$task->setStatus(Task::STATUS_FAILED);
-				$task->setEndedAt(time());
-				$error = 'The task was processed successfully but the result file could not be found';
-				$task->setErrorMessage($error);
-				$this->logger->error($error, ['exception' => $e]);
-			}
-		}
-		try {
-			$taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
-		} catch (\JsonException $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('The task was processed successfully but the provider\'s output could not be encoded as JSON for the database.', 0, $e);
-		}
-		try {
-			$this->taskMapper->update($taskEntity);
-			$this->runWebhook($task);
-		} catch (\OCP\DB\Exception $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception($e->getMessage());
-		}
-		if ($task->getStatus() === Task::STATUS_SUCCESSFUL) {
-			$event = new TaskSuccessfulEvent($task);
-		} else {
-			$event = new TaskFailedEvent($task, $error);
-		}
-		$this->dispatcher->dispatchTyped($event);
-	}
-
-	public function getNextScheduledTask(array $taskTypeIds = [], array $taskIdsToIgnore = []): Task {
-		try {
-			$taskEntity = $this->taskMapper->findOldestScheduledByType($taskTypeIds, $taskIdsToIgnore);
-			return $taskEntity->toPublicTask();
-		} catch (DoesNotExistException $e) {
-			throw new \OCP\TaskProcessing\Exception\NotFoundException('Could not find the task', previous: $e);
-		} catch (\OCP\DB\Exception $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', previous: $e);
-		} catch (\JsonException $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the task', previous: $e);
-		}
-	}
-
-	public function getNextScheduledTasks(array $taskTypeIds = [], array $taskIdsToIgnore = [], int $numberOfTasks = 1): array {
-		try {
-			return array_map(fn ($taskEntity) => $taskEntity->toPublicTask(), $this->taskMapper->findNOldestScheduledByType($taskTypeIds, $taskIdsToIgnore, $numberOfTasks));
-		} catch (DoesNotExistException $e) {
-			throw new \OCP\TaskProcessing\Exception\NotFoundException('Could not find the task', previous: $e);
-		} catch (\OCP\DB\Exception $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', previous: $e);
-		} catch (\JsonException $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the task', previous: $e);
-		}
-	}
-
-	/**
-	 * Takes task input data and replaces fileIds with File objects
-	 *
-	 * @param string|null $userId
-	 * @param array<array-key, list<numeric|string>|numeric|string> $input
-	 * @param ShapeDescriptor[] ...$specs the specs
-	 * @return array<array-key, list<File|numeric|string>|numeric|string|File>
-	 * @throws GenericFileException|LockedException|NotPermittedException|ValidationException|UnauthorizedException
-	 */
-	public function fillInputFileData(?string $userId, array $input, ...$specs): array {
-		if ($userId !== null) {
-			\OC_Util::setupFS($userId);
-		}
-		$newInputOutput = [];
-		$spec = array_reduce($specs, fn ($carry, $spec) => $carry + $spec, []);
-		foreach ($spec as $key => $descriptor) {
-			$type = $descriptor->getShapeType();
-			if (!isset($input[$key])) {
-				continue;
-			}
-			if (!in_array(EShapeType::getScalarType($type), [EShapeType::Image, EShapeType::Audio, EShapeType::Video, EShapeType::File], true)) {
-				$newInputOutput[$key] = $input[$key];
-				continue;
-			}
-			if (EShapeType::getScalarType($type) === $type) {
-				// is scalar
-				$node = $this->validateFileId((int)$input[$key]);
-				$this->validateUserAccessToFile($input[$key], $userId);
-				$newInputOutput[$key] = $node;
-			} else {
-				// is list
-				$newInputOutput[$key] = [];
-				foreach ($input[$key] as $item) {
-					$node = $this->validateFileId((int)$item);
-					$this->validateUserAccessToFile($item, $userId);
-					$newInputOutput[$key][] = $node;
-				}
-			}
-		}
-		return $newInputOutput;
-	}
-
-	public function getUserTask(int $id, ?string $userId): Task {
-		try {
-			$taskEntity = $this->taskMapper->findByIdAndUser($id, $userId);
-			return $taskEntity->toPublicTask();
-		} catch (DoesNotExistException $e) {
-			throw new \OCP\TaskProcessing\Exception\NotFoundException('Could not find the task', 0, $e);
-		} catch (MultipleObjectsReturnedException|\OCP\DB\Exception $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', 0, $e);
-		} catch (\JsonException $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the task', 0, $e);
-		}
-	}
-
-	public function getUserTasks(?string $userId, ?string $taskTypeId = null, ?string $customId = null): array {
-		try {
-			$taskEntities = $this->taskMapper->findByUserAndTaskType($userId, $taskTypeId, $customId);
-			return array_map(fn ($taskEntity): Task => $taskEntity->toPublicTask(), $taskEntities);
-		} catch (\OCP\DB\Exception $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the tasks', 0, $e);
-		} catch (\JsonException $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the tasks', 0, $e);
-		}
-	}
-
-	public function getTasks(
-		?string $userId, ?string $taskTypeId = null, ?string $appId = null, ?string $customId = null,
-		?int $status = null, ?int $scheduleAfter = null, ?int $endedBefore = null,
-	): array {
-		try {
-			$taskEntities = $this->taskMapper->findTasks($userId, $taskTypeId, $appId, $customId, $status, $scheduleAfter, $endedBefore);
-			return array_map(fn ($taskEntity): Task => $taskEntity->toPublicTask(), $taskEntities);
-		} catch (\OCP\DB\Exception $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the tasks', 0, $e);
-		} catch (\JsonException $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the tasks', 0, $e);
-		}
-	}
-
-	public function getUserTasksByApp(?string $userId, string $appId, ?string $customId = null): array {
-		try {
-			$taskEntities = $this->taskMapper->findUserTasksByApp($userId, $appId, $customId);
-			return array_map(fn ($taskEntity): Task => $taskEntity->toPublicTask(), $taskEntities);
-		} catch (\OCP\DB\Exception $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding a task', 0, $e);
-		} catch (\JsonException $e) {
-			throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding a task', 0, $e);
-		}
-	}
-
-	/**
-	 *Takes task input or output and replaces base64 data with file ids
-	 *
-	 * @param array $output
-	 * @param ShapeDescriptor[] ...$specs the specs that define which keys to keep
-	 * @return array
-	 * @throws NotPermittedException
-	 */
-	public function encapsulateOutputFileData(array $output, ...$specs): array {
-		$newOutput = [];
-		try {
-			$folder = $this->appData->getFolder('TaskProcessing');
-		} catch (\OCP\Files\NotFoundException) {
-			$folder = $this->appData->newFolder('TaskProcessing');
-		}
-		$spec = array_reduce($specs, fn ($carry, $spec) => $carry + $spec, []);
-		foreach ($spec as $key => $descriptor) {
-			$type = $descriptor->getShapeType();
-			if (!isset($output[$key])) {
-				continue;
-			}
-			if (!in_array(EShapeType::getScalarType($type), [EShapeType::Image, EShapeType::Audio, EShapeType::Video, EShapeType::File], true)) {
-				$newOutput[$key] = $output[$key];
-				continue;
-			}
-			if (EShapeType::getScalarType($type) === $type) {
-				/** @var SimpleFile $file */
-				$file = $folder->newFile(time() . '-' . rand(1, 100000), $output[$key]);
-				$newOutput[$key] = $file->getId(); // polymorphic call to SimpleFile
-			} else {
-				$newOutput = [];
-				foreach ($output[$key] as $item) {
-					/** @var SimpleFile $file */
-					$file = $folder->newFile(time() . '-' . rand(1, 100000), $item);
-					$newOutput[$key][] = $file->getId();
-				}
-			}
-		}
-		return $newOutput;
-	}
-
-	/**
-	 * @param Task $task
-	 * @return array<array-key, list<numeric|string|File>|numeric|string|File>
-	 * @throws GenericFileException
-	 * @throws LockedException
-	 * @throws NotPermittedException
-	 * @throws ValidationException|UnauthorizedException
-	 */
-	public function prepareInputData(Task $task): array {
-		$taskTypes = $this->getAvailableTaskTypes();
-		$inputShape = $taskTypes[$task->getTaskTypeId()]['inputShape'];
-		$optionalInputShape = $taskTypes[$task->getTaskTypeId()]['optionalInputShape'];
-		$input = $task->getInput();
-		$input = $this->removeSuperfluousArrayKeys($input, $inputShape, $optionalInputShape);
-		$input = $this->fillInputFileData($task->getUserId(), $input, $inputShape, $optionalInputShape);
-		return $input;
-	}
-
-	public function lockTask(Task $task): bool {
-		$taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
-		if ($this->taskMapper->lockTask($taskEntity) === 0) {
-			return false;
-		}
-		$task->setStatus(Task::STATUS_RUNNING);
-		return true;
-	}
-
-	/**
-	 * @throws \JsonException
-	 * @throws Exception
-	 */
-	public function setTaskStatus(Task $task, int $status): void {
-		$currentTaskStatus = $task->getStatus();
-		if ($currentTaskStatus === Task::STATUS_SCHEDULED && $status === Task::STATUS_RUNNING) {
-			$task->setStartedAt(time());
-		} elseif ($currentTaskStatus === Task::STATUS_RUNNING && ($status === Task::STATUS_FAILED || $status === Task::STATUS_CANCELLED)) {
-			$task->setEndedAt(time());
-		} elseif ($currentTaskStatus === Task::STATUS_UNKNOWN && $status === Task::STATUS_SCHEDULED) {
-			$task->setScheduledAt(time());
-		}
-		$task->setStatus($status);
-		$taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
-		$this->taskMapper->update($taskEntity);
-	}
-
-	/**
-	 * Validate input, fill input default values, set completionExpectedAt, set scheduledAt
-	 *
-	 * @param Task $task
-	 * @return void
-	 * @throws UnauthorizedException
-	 * @throws ValidationException
-	 * @throws \OCP\TaskProcessing\Exception\Exception
-	 */
-	private function prepareTask(Task $task): void {
-		$taskTypes = $this->getAvailableTaskTypes();
-		$taskType = $taskTypes[$task->getTaskTypeId()];
-		$inputShape = $taskType['inputShape'];
-		$inputShapeDefaults = $taskType['inputShapeDefaults'];
-		$inputShapeEnumValues = $taskType['inputShapeEnumValues'];
-		$optionalInputShape = $taskType['optionalInputShape'];
-		$optionalInputShapeEnumValues = $taskType['optionalInputShapeEnumValues'];
-		$optionalInputShapeDefaults = $taskType['optionalInputShapeDefaults'];
-		// validate input
-		$this->validateInput($inputShape, $inputShapeDefaults, $inputShapeEnumValues, $task->getInput());
-		$this->validateInput($optionalInputShape, $optionalInputShapeDefaults, $optionalInputShapeEnumValues, $task->getInput(), true);
-		// authenticate access to mentioned files
-		$ids = [];
-		foreach ($inputShape + $optionalInputShape as $key => $descriptor) {
-			if (in_array(EShapeType::getScalarType($descriptor->getShapeType()), [EShapeType::File, EShapeType::Image, EShapeType::Audio, EShapeType::Video], true)) {
-				/** @var list<int>|int $inputSlot */
-				$inputSlot = $task->getInput()[$key];
-				if (is_array($inputSlot)) {
-					$ids += $inputSlot;
-				} else {
-					$ids[] = $inputSlot;
-				}
-			}
-		}
-		foreach ($ids as $fileId) {
-			$this->validateFileId($fileId);
-			$this->validateUserAccessToFile($fileId, $task->getUserId());
-		}
-		// remove superfluous keys and set input
-		$input = $this->removeSuperfluousArrayKeys($task->getInput(), $inputShape, $optionalInputShape);
-		$inputWithDefaults = $this->fillInputDefaults($input, $inputShapeDefaults, $optionalInputShapeDefaults);
-		$task->setInput($inputWithDefaults);
-		$task->setScheduledAt(time());
-		$provider = $this->getPreferredProvider($task->getTaskTypeId());
-		// calculate expected completion time
-		$completionExpectedAt = new \DateTime('now');
-		$completionExpectedAt->add(new \DateInterval('PT' . $provider->getExpectedRuntime() . 'S'));
-		$task->setCompletionExpectedAt($completionExpectedAt);
-	}
-
-	/**
-	 * Store the task in the DB and set its ID in the \OCP\TaskProcessing\Task input param
-	 *
-	 * @param Task $task
-	 * @return void
-	 * @throws Exception
-	 * @throws \JsonException
-	 */
-	private function storeTask(Task $task): void {
-		// create a db entity and insert into db table
-		$taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
-		$this->taskMapper->insert($taskEntity);
-		// make sure the scheduler knows the id
-		$task->setId($taskEntity->getId());
-	}
-
-	/**
-	 * @param array $output
-	 * @param ShapeDescriptor[] ...$specs the specs that define which keys to keep
-	 * @return array
-	 * @throws NotPermittedException
-	 */
-	private function validateOutputFileIds(array $output, ...$specs): array {
-		$newOutput = [];
-		$spec = array_reduce($specs, fn ($carry, $spec) => $carry + $spec, []);
-		foreach ($spec as $key => $descriptor) {
-			$type = $descriptor->getShapeType();
-			if (!isset($output[$key])) {
-				continue;
-			}
-			if (!in_array(EShapeType::getScalarType($type), [EShapeType::Image, EShapeType::Audio, EShapeType::Video, EShapeType::File], true)) {
-				$newOutput[$key] = $output[$key];
-				continue;
-			}
-			if (EShapeType::getScalarType($type) === $type) {
-				// Is scalar file ID
-				$newOutput[$key] = $this->validateFileId($output[$key]);
-			} else {
-				// Is list of file IDs
-				$newOutput = [];
-				foreach ($output[$key] as $item) {
-					$newOutput[$key][] = $this->validateFileId($item);
-				}
-			}
-		}
-		return $newOutput;
-	}
-
-	/**
-	 * @param mixed $id
-	 * @return File
-	 * @throws ValidationException
-	 */
-	private function validateFileId(mixed $id): File {
-		$node = $this->rootFolder->getFirstNodeById($id);
-		if ($node === null) {
-			$node = $this->rootFolder->getFirstNodeByIdInPath($id, '/' . $this->rootFolder->getAppDataDirectoryName() . '/');
-			if ($node === null) {
-				throw new ValidationException('Could not find file ' . $id);
-			} elseif (!$node instanceof File) {
-				throw new ValidationException('File with id "' . $id . '" is not a file');
-			}
-		} elseif (!$node instanceof File) {
-			throw new ValidationException('File with id "' . $id . '" is not a file');
-		}
-		return $node;
-	}
-
-	/**
-	 * @param mixed $fileId
-	 * @param string|null $userId
-	 * @return void
-	 * @throws UnauthorizedException
-	 */
-	private function validateUserAccessToFile(mixed $fileId, ?string $userId): void {
-		if ($userId === null) {
-			throw new UnauthorizedException('User does not have access to file ' . $fileId);
-		}
-		$mounts = $this->userMountCache->getMountsForFileId($fileId);
-		$userIds = array_map(fn ($mount) => $mount->getUser()->getUID(), $mounts);
-		if (!in_array($userId, $userIds)) {
-			throw new UnauthorizedException('User ' . $userId . ' does not have access to file ' . $fileId);
-		}
-	}
-
-	/**
-	 * @param Task $task
-	 * @return list<int>
-	 * @throws NotFoundException
-	 */
-	public function extractFileIdsFromTask(Task $task): array {
-		$ids = [];
-		$taskTypes = $this->getAvailableTaskTypes();
-		if (!isset($taskTypes[$task->getTaskTypeId()])) {
-			throw new NotFoundException('Could not find task type');
-		}
-		$taskType = $taskTypes[$task->getTaskTypeId()];
-		foreach ($taskType['inputShape'] + $taskType['optionalInputShape'] as $key => $descriptor) {
-			if (in_array(EShapeType::getScalarType($descriptor->getShapeType()), [EShapeType::File, EShapeType::Image, EShapeType::Audio, EShapeType::Video], true)) {
-				/** @var int|list<int> $inputSlot */
-				$inputSlot = $task->getInput()[$key];
-				if (is_array($inputSlot)) {
-					$ids = array_merge($inputSlot, $ids);
-				} else {
-					$ids[] = $inputSlot;
-				}
-			}
-		}
-		if ($task->getOutput() !== null) {
-			foreach ($taskType['outputShape'] + $taskType['optionalOutputShape'] as $key => $descriptor) {
-				if (in_array(EShapeType::getScalarType($descriptor->getShapeType()), [EShapeType::File, EShapeType::Image, EShapeType::Audio, EShapeType::Video], true)) {
-					/** @var int|list<int> $outputSlot */
-					$outputSlot = $task->getOutput()[$key];
-					if (is_array($outputSlot)) {
-						$ids = array_merge($outputSlot, $ids);
-					} else {
-						$ids[] = $outputSlot;
-					}
-				}
-			}
-		}
-		return $ids;
-	}
-
-	/**
-	 * @param ISimpleFolder $folder
-	 * @param int $ageInSeconds
-	 * @return \Generator
-	 */
-	public function clearFilesOlderThan(ISimpleFolder $folder, int $ageInSeconds = self::MAX_TASK_AGE_SECONDS): \Generator {
-		foreach ($folder->getDirectoryListing() as $file) {
-			if ($file->getMTime() < time() - $ageInSeconds) {
-				try {
-					$fileName = $file->getName();
-					$file->delete();
-					yield $fileName;
-				} catch (NotPermittedException $e) {
-					$this->logger->warning('Failed to delete a stale task processing file', ['exception' => $e]);
-				}
-			}
-		}
-	}
-
-	/**
-	 * @param int $ageInSeconds
-	 * @return \Generator
-	 * @throws Exception
-	 * @throws InvalidPathException
-	 * @throws NotFoundException
-	 * @throws \JsonException
-	 * @throws \OCP\Files\NotFoundException
-	 */
-	public function cleanupTaskProcessingTaskFiles(int $ageInSeconds = self::MAX_TASK_AGE_SECONDS): \Generator {
-		$taskIdsToCleanup = [];
-		foreach ($this->taskMapper->getTasksToCleanup($ageInSeconds) as $task) {
-			$taskIdsToCleanup[] = $task->getId();
-			$ocpTask = $task->toPublicTask();
-			$fileIds = $this->extractFileIdsFromTask($ocpTask);
-			foreach ($fileIds as $fileId) {
-				// only look for output files stored in appData/TaskProcessing/
-				$file = $this->rootFolder->getFirstNodeByIdInPath($fileId, '/' . $this->rootFolder->getAppDataDirectoryName() . '/core/TaskProcessing/');
-				if ($file instanceof File) {
-					try {
-						$fileId = $file->getId();
-						$fileName = $file->getName();
-						$file->delete();
-						yield ['task_id' => $task->getId(), 'file_id' => $fileId, 'file_name' => $fileName];
-					} catch (NotPermittedException $e) {
-						$this->logger->warning('Failed to delete a stale task processing file', ['exception' => $e]);
-					}
-				}
-			}
-		}
-		return $taskIdsToCleanup;
-	}
-
-	/**
-	 * Make a request to the task's webhookUri if necessary
-	 *
-	 * @param Task $task
-	 */
-	private function runWebhook(Task $task): void {
-		$uri = $task->getWebhookUri();
-		$method = $task->getWebhookMethod();
-
-		if (!$uri || !$method) {
-			return;
-		}
-
-		if (in_array($method, ['HTTP:GET', 'HTTP:POST', 'HTTP:PUT', 'HTTP:DELETE'], true)) {
-			$client = $this->clientService->newClient();
-			$httpMethod = preg_replace('/^HTTP:/', '', $method);
-			$options = [
-				'timeout' => 30,
-				'body' => json_encode([
-					'task' => $task->jsonSerialize(),
-				]),
-				'headers' => ['Content-Type' => 'application/json'],
-			];
-			try {
-				$client->request($httpMethod, $uri, $options);
-			} catch (ClientException|ServerException $e) {
-				$this->logger->warning('Task processing HTTP webhook failed for task ' . $task->getId() . '. Request failed', ['exception' => $e]);
-			} catch (\Exception|\Throwable $e) {
-				$this->logger->warning('Task processing HTTP webhook failed for task ' . $task->getId() . '. Unknown error', ['exception' => $e]);
-			}
-		} elseif (str_starts_with($method, 'AppAPI:') && str_starts_with($uri, '/')) {
-			$parsedMethod = explode(':', $method, 4);
-			if (count($parsedMethod) < 3) {
-				$this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. Invalid method: ' . $method);
-			}
-			[, $exAppId, $httpMethod] = $parsedMethod;
-			if (!$this->appManager->isEnabledForAnyone('app_api')) {
-				$this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. AppAPI is disabled or not installed.');
-				return;
-			}
-			try {
-				$appApiFunctions = \OCP\Server::get(\OCA\AppAPI\PublicFunctions::class);
-			} catch (ContainerExceptionInterface|NotFoundExceptionInterface) {
-				$this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. Could not get AppAPI public functions.');
-				return;
-			}
-			$exApp = $appApiFunctions->getExApp($exAppId);
-			if ($exApp === null) {
-				$this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. ExApp ' . $exAppId . ' is missing.');
-				return;
-			} elseif (!$exApp['enabled']) {
-				$this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. ExApp ' . $exAppId . ' is disabled.');
-				return;
-			}
-			$requestParams = [
-				'task' => $task->jsonSerialize(),
-			];
-			$requestOptions = [
-				'timeout' => 30,
-			];
-			$response = $appApiFunctions->exAppRequest($exAppId, $uri, $task->getUserId(), $httpMethod, $requestParams, $requestOptions);
-			if (is_array($response) && isset($response['error'])) {
-				$this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. Error during request to ExApp(' . $exAppId . '): ', $response['error']);
-			}
-		}
-	}
+    public const LEGACY_PREFIX_TEXTPROCESSING = 'legacy:TextProcessing:';
+    public const LEGACY_PREFIX_TEXTTOIMAGE = 'legacy:TextToImage:';
+    public const LEGACY_PREFIX_SPEECHTOTEXT = 'legacy:SpeechToText:';
+
+    public const LAZY_CONFIG_KEYS = [
+        'ai.taskprocessing_type_preferences',
+        'ai.taskprocessing_provider_preferences',
+    ];
+
+    public const MAX_TASK_AGE_SECONDS = 60 * 60 * 24 * 31 * 6; // 6 months
+
+    private const TASK_TYPES_CACHE_KEY = 'available_task_types_v3';
+    private const TASK_TYPE_IDS_CACHE_KEY = 'available_task_type_ids';
+
+    /** @var list<IProvider>|null */
+    private ?array $providers = null;
+
+    /**
+     * @var array<array-key,array{name: string, description: string, inputShape: ShapeDescriptor[], inputShapeEnumValues: ShapeEnumValue[][], inputShapeDefaults: array<array-key, numeric|string>, isInternal: bool, optionalInputShape: ShapeDescriptor[], optionalInputShapeEnumValues: ShapeEnumValue[][], optionalInputShapeDefaults: array<array-key, numeric|string>, outputShape: ShapeDescriptor[], outputShapeEnumValues: ShapeEnumValue[][], optionalOutputShape: ShapeDescriptor[], optionalOutputShapeEnumValues: ShapeEnumValue[][]}>
+     */
+    private ?array $availableTaskTypes = null;
+
+    /** @var list<string>|null */
+    private ?array $availableTaskTypeIds = null;
+
+    private IAppData $appData;
+    private ?array $preferences = null;
+    private ?array $providersById = null;
+
+    /** @var ITaskType[]|null */
+    private ?array $taskTypes = null;
+    private ICache $distributedCache;
+
+    private ?GetTaskProcessingProvidersEvent $eventResult = null;
+
+    public function __construct(
+        private IAppConfig $appConfig,
+        private Coordinator $coordinator,
+        private IServerContainer $serverContainer,
+        private LoggerInterface $logger,
+        private TaskMapper $taskMapper,
+        private IJobList $jobList,
+        private IEventDispatcher $dispatcher,
+        IAppDataFactory $appDataFactory,
+        private IRootFolder $rootFolder,
+        private \OCP\TextToImage\IManager $textToImageManager,
+        private IUserMountCache $userMountCache,
+        private IClientService $clientService,
+        private IAppManager $appManager,
+        private IUserManager $userManager,
+        private IUserSession $userSession,
+        ICacheFactory $cacheFactory,
+        private IFactory $l10nFactory,
+    ) {
+        $this->appData = $appDataFactory->get('core');
+        $this->distributedCache = $cacheFactory->createDistributed('task_processing::');
+    }
+
+
+    /**
+     * This is almost a copy of textProcessingManager->getProviders
+     * to avoid a dependency cycle between TextProcessingManager and TaskProcessingManager
+     */
+    private function _getRawTextProcessingProviders(): array {
+        $context = $this->coordinator->getRegistrationContext();
+        if ($context === null) {
+            return [];
+        }
+
+        $providers = [];
+
+        foreach ($context->getTextProcessingProviders() as $providerServiceRegistration) {
+            $class = $providerServiceRegistration->getService();
+            try {
+                $providers[$class] = $this->serverContainer->get($class);
+            } catch (\Throwable $e) {
+                $this->logger->error('Failed to load Text processing provider ' . $class, [
+                    'exception' => $e,
+                ]);
+            }
+        }
+
+        return $providers;
+    }
+
+    private function _getTextProcessingProviders(): array {
+        $oldProviders = $this->_getRawTextProcessingProviders();
+        $newProviders = [];
+        foreach ($oldProviders as $oldProvider) {
+            $provider = new class($oldProvider) implements IProvider, ISynchronousProvider {
+                private \OCP\TextProcessing\IProvider $provider;
+
+                public function __construct(\OCP\TextProcessing\IProvider $provider) {
+                    $this->provider = $provider;
+                }
+
+                public function getId(): string {
+                    if ($this->provider instanceof \OCP\TextProcessing\IProviderWithId) {
+                        return $this->provider->getId();
+                    }
+                    return Manager::LEGACY_PREFIX_TEXTPROCESSING . $this->provider::class;
+                }
+
+                public function getName(): string {
+                    return $this->provider->getName();
+                }
+
+                public function getTaskTypeId(): string {
+                    return match ($this->provider->getTaskType()) {
+                        \OCP\TextProcessing\FreePromptTaskType::class => TextToText::ID,
+                        \OCP\TextProcessing\HeadlineTaskType::class => TextToTextHeadline::ID,
+                        \OCP\TextProcessing\TopicsTaskType::class => TextToTextTopics::ID,
+                        \OCP\TextProcessing\SummaryTaskType::class => TextToTextSummary::ID,
+                        default => Manager::LEGACY_PREFIX_TEXTPROCESSING . $this->provider->getTaskType(),
+                    };
+                }
+
+                public function getExpectedRuntime(): int {
+                    if ($this->provider instanceof \OCP\TextProcessing\IProviderWithExpectedRuntime) {
+                        return $this->provider->getExpectedRuntime();
+                    }
+                    return 60;
+                }
+
+                public function getOptionalInputShape(): array {
+                    return [];
+                }
+
+                public function getOptionalOutputShape(): array {
+                    return [];
+                }
+
+                public function process(?string $userId, array $input, callable $reportProgress): array {
+                    if ($this->provider instanceof \OCP\TextProcessing\IProviderWithUserId) {
+                        $this->provider->setUserId($userId);
+                    }
+                    try {
+                        return ['output' => $this->provider->process($input['input'])];
+                    } catch (\RuntimeException $e) {
+                        throw new ProcessingException($e->getMessage(), 0, $e);
+                    }
+                }
+
+                public function getInputShapeEnumValues(): array {
+                    return [];
+                }
+
+                public function getInputShapeDefaults(): array {
+                    return [];
+                }
+
+                public function getOptionalInputShapeEnumValues(): array {
+                    return [];
+                }
+
+                public function getOptionalInputShapeDefaults(): array {
+                    return [];
+                }
+
+                public function getOutputShapeEnumValues(): array {
+                    return [];
+                }
+
+                public function getOptionalOutputShapeEnumValues(): array {
+                    return [];
+                }
+            };
+            $newProviders[$provider->getId()] = $provider;
+        }
+
+        return $newProviders;
+    }
+
+    /**
+     * @return ITaskType[]
+     */
+    private function _getTextProcessingTaskTypes(): array {
+        $oldProviders = $this->_getRawTextProcessingProviders();
+        $newTaskTypes = [];
+        foreach ($oldProviders as $oldProvider) {
+            // These are already implemented in the TaskProcessing realm
+            if (in_array($oldProvider->getTaskType(), [
+                \OCP\TextProcessing\FreePromptTaskType::class,
+                \OCP\TextProcessing\HeadlineTaskType::class,
+                \OCP\TextProcessing\TopicsTaskType::class,
+                \OCP\TextProcessing\SummaryTaskType::class
+            ], true)) {
+                continue;
+            }
+            $taskType = new class($oldProvider->getTaskType()) implements ITaskType {
+                private string $oldTaskTypeClass;
+                private \OCP\TextProcessing\ITaskType $oldTaskType;
+                private IL10N $l;
+
+                public function __construct(string $oldTaskTypeClass) {
+                    $this->oldTaskTypeClass = $oldTaskTypeClass;
+                    $this->oldTaskType = \OCP\Server::get($oldTaskTypeClass);
+                    $this->l = \OCP\Server::get(IFactory::class)->get('core');
+                }
+
+                public function getId(): string {
+                    return Manager::LEGACY_PREFIX_TEXTPROCESSING . $this->oldTaskTypeClass;
+                }
+
+                public function getName(): string {
+                    return $this->oldTaskType->getName();
+                }
+
+                public function getDescription(): string {
+                    return $this->oldTaskType->getDescription();
+                }
+
+                public function getInputShape(): array {
+                    return ['input' => new ShapeDescriptor($this->l->t('Input text'), $this->l->t('The input text'), EShapeType::Text)];
+                }
+
+                public function getOutputShape(): array {
+                    return ['output' => new ShapeDescriptor($this->l->t('Input text'), $this->l->t('The input text'), EShapeType::Text)];
+                }
+            };
+            $newTaskTypes[$taskType->getId()] = $taskType;
+        }
+
+        return $newTaskTypes;
+    }
+
+    /**
+     * @return IProvider[]
+     */
+    private function _getTextToImageProviders(): array {
+        $oldProviders = $this->textToImageManager->getProviders();
+        $newProviders = [];
+        foreach ($oldProviders as $oldProvider) {
+            $newProvider = new class($oldProvider, $this->appData) implements IProvider, ISynchronousProvider {
+                private \OCP\TextToImage\IProvider $provider;
+                private IAppData $appData;
+
+                public function __construct(\OCP\TextToImage\IProvider $provider, IAppData $appData) {
+                    $this->provider = $provider;
+                    $this->appData = $appData;
+                }
+
+                public function getId(): string {
+                    return Manager::LEGACY_PREFIX_TEXTTOIMAGE . $this->provider->getId();
+                }
+
+                public function getName(): string {
+                    return $this->provider->getName();
+                }
+
+                public function getTaskTypeId(): string {
+                    return TextToImage::ID;
+                }
+
+                public function getExpectedRuntime(): int {
+                    return $this->provider->getExpectedRuntime();
+                }
+
+                public function getOptionalInputShape(): array {
+                    return [];
+                }
+
+                public function getOptionalOutputShape(): array {
+                    return [];
+                }
+
+                public function process(?string $userId, array $input, callable $reportProgress): array {
+                    try {
+                        $folder = $this->appData->getFolder('text2image');
+                    } catch (\OCP\Files\NotFoundException) {
+                        $folder = $this->appData->newFolder('text2image');
+                    }
+                    $resources = [];
+                    $files = [];
+                    for ($i = 0; $i < $input['numberOfImages']; $i++) {
+                        $file = $folder->newFile(time() . '-' . rand(1, 100000) . '-' . $i);
+                        $files[] = $file;
+                        $resource = $file->write();
+                        if ($resource !== false && $resource !== true && is_resource($resource)) {
+                            $resources[] = $resource;
+                        } else {
+                            throw new ProcessingException('Text2Image generation using provider "' . $this->getName() . '" failed: Couldn\'t open file to write.');
+                        }
+                    }
+                    if ($this->provider instanceof \OCP\TextToImage\IProviderWithUserId) {
+                        $this->provider->setUserId($userId);
+                    }
+                    try {
+                        $this->provider->generate($input['input'], $resources);
+                    } catch (\RuntimeException $e) {
+                        throw new ProcessingException($e->getMessage(), 0, $e);
+                    }
+                    for ($i = 0; $i < $input['numberOfImages']; $i++) {
+                        if (is_resource($resources[$i])) {
+                            // If $resource hasn't been closed yet, we'll do that here
+                            fclose($resources[$i]);
+                        }
+                    }
+                    return ['images' => array_map(fn (ISimpleFile $file) => $file->getContent(), $files)];
+                }
+
+                public function getInputShapeEnumValues(): array {
+                    return [];
+                }
+
+                public function getInputShapeDefaults(): array {
+                    return [];
+                }
+
+                public function getOptionalInputShapeEnumValues(): array {
+                    return [];
+                }
+
+                public function getOptionalInputShapeDefaults(): array {
+                    return [];
+                }
+
+                public function getOutputShapeEnumValues(): array {
+                    return [];
+                }
+
+                public function getOptionalOutputShapeEnumValues(): array {
+                    return [];
+                }
+            };
+            $newProviders[$newProvider->getId()] = $newProvider;
+        }
+
+        return $newProviders;
+    }
+
+    /**
+     * This is almost a copy of SpeechToTextManager->getProviders
+     * to avoid a dependency cycle between SpeechToTextManager and TaskProcessingManager
+     */
+    private function _getRawSpeechToTextProviders(): array {
+        $context = $this->coordinator->getRegistrationContext();
+        if ($context === null) {
+            return [];
+        }
+        $providers = [];
+        foreach ($context->getSpeechToTextProviders() as $providerServiceRegistration) {
+            $class = $providerServiceRegistration->getService();
+            try {
+                $providers[$class] = $this->serverContainer->get($class);
+            } catch (NotFoundExceptionInterface|ContainerExceptionInterface|\Throwable $e) {
+                $this->logger->error('Failed to load SpeechToText provider ' . $class, [
+                    'exception' => $e,
+                ]);
+            }
+        }
+
+        return $providers;
+    }
+
+    /**
+     * @return IProvider[]
+     */
+    private function _getSpeechToTextProviders(): array {
+        $oldProviders = $this->_getRawSpeechToTextProviders();
+        $newProviders = [];
+        foreach ($oldProviders as $oldProvider) {
+            $newProvider = new class($oldProvider, $this->rootFolder, $this->appData) implements IProvider, ISynchronousProvider {
+                private ISpeechToTextProvider $provider;
+                private IAppData $appData;
+
+                private IRootFolder $rootFolder;
+
+                public function __construct(ISpeechToTextProvider $provider, IRootFolder $rootFolder, IAppData $appData) {
+                    $this->provider = $provider;
+                    $this->rootFolder = $rootFolder;
+                    $this->appData = $appData;
+                }
+
+                public function getId(): string {
+                    if ($this->provider instanceof ISpeechToTextProviderWithId) {
+                        return Manager::LEGACY_PREFIX_SPEECHTOTEXT . $this->provider->getId();
+                    }
+                    return Manager::LEGACY_PREFIX_SPEECHTOTEXT . $this->provider::class;
+                }
+
+                public function getName(): string {
+                    return $this->provider->getName();
+                }
+
+                public function getTaskTypeId(): string {
+                    return AudioToText::ID;
+                }
+
+                public function getExpectedRuntime(): int {
+                    return 60;
+                }
+
+                public function getOptionalInputShape(): array {
+                    return [];
+                }
+
+                public function getOptionalOutputShape(): array {
+                    return [];
+                }
+
+                public function process(?string $userId, array $input, callable $reportProgress): array {
+                    if ($this->provider instanceof \OCP\SpeechToText\ISpeechToTextProviderWithUserId) {
+                        $this->provider->setUserId($userId);
+                    }
+                    try {
+                        $result = $this->provider->transcribeFile($input['input']);
+                    } catch (\RuntimeException $e) {
+                        throw new ProcessingException($e->getMessage(), 0, $e);
+                    }
+                    return ['output' => $result];
+                }
+
+                public function getInputShapeEnumValues(): array {
+                    return [];
+                }
+
+                public function getInputShapeDefaults(): array {
+                    return [];
+                }
+
+                public function getOptionalInputShapeEnumValues(): array {
+                    return [];
+                }
+
+                public function getOptionalInputShapeDefaults(): array {
+                    return [];
+                }
+
+                public function getOutputShapeEnumValues(): array {
+                    return [];
+                }
+
+                public function getOptionalOutputShapeEnumValues(): array {
+                    return [];
+                }
+            };
+            $newProviders[$newProvider->getId()] = $newProvider;
+        }
+
+        return $newProviders;
+    }
+
+    /**
+     * Dispatches the event to collect external providers and task types.
+     * Caches the result within the request.
+     */
+    private function dispatchGetProvidersEvent(): GetTaskProcessingProvidersEvent {
+        if ($this->eventResult !== null) {
+            return $this->eventResult;
+        }
+
+        $this->eventResult = new GetTaskProcessingProvidersEvent();
+        $this->dispatcher->dispatchTyped($this->eventResult);
+        return $this->eventResult ;
+    }
+
+    /**
+     * @return IProvider[]
+     */
+    private function _getProviders(): array {
+        $context = $this->coordinator->getRegistrationContext();
+
+        if ($context === null) {
+            return [];
+        }
+
+        $providers = [];
+
+        foreach ($context->getTaskProcessingProviders() as $providerServiceRegistration) {
+            $class = $providerServiceRegistration->getService();
+            try {
+                /** @var IProvider $provider */
+                $provider = $this->serverContainer->get($class);
+                if (isset($providers[$provider->getId()])) {
+                    $this->logger->warning('Task processing provider ' . $class . ' is using ID ' . $provider->getId() . ' which is already used by ' . $providers[$provider->getId()]::class);
+                }
+                $providers[$provider->getId()] = $provider;
+            } catch (\Throwable $e) {
+                $this->logger->error('Failed to load task processing provider ' . $class, [
+                    'exception' => $e,
+                ]);
+            }
+        }
+
+        $event = $this->dispatchGetProvidersEvent();
+        $externalProviders = $event->getProviders();
+        foreach ($externalProviders as $provider) {
+            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;
+    }
+
+    /**
+     * @return ITaskType[]
+     */
+    private function _getTaskTypes(): array {
+        $context = $this->coordinator->getRegistrationContext();
+
+        if ($context === null) {
+            return [];
+        }
+
+        if ($this->taskTypes !== null) {
+            return $this->taskTypes;
+        }
+
+        // Default task types
+        $taskTypes = [
+            \OCP\TaskProcessing\TaskTypes\TextToText::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToText::class),
+            \OCP\TaskProcessing\TaskTypes\TextToTextTopics::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextTopics::class),
+            \OCP\TaskProcessing\TaskTypes\TextToTextHeadline::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextHeadline::class),
+            \OCP\TaskProcessing\TaskTypes\TextToTextSummary::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextSummary::class),
+            \OCP\TaskProcessing\TaskTypes\TextToTextFormalization::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextFormalization::class),
+            \OCP\TaskProcessing\TaskTypes\TextToTextSimplification::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextSimplification::class),
+            \OCP\TaskProcessing\TaskTypes\TextToTextChat::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextChat::class),
+            \OCP\TaskProcessing\TaskTypes\TextToTextTranslate::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextTranslate::class),
+            \OCP\TaskProcessing\TaskTypes\TextToTextReformulation::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextReformulation::class),
+            \OCP\TaskProcessing\TaskTypes\TextToImage::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToImage::class),
+            \OCP\TaskProcessing\TaskTypes\AudioToText::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\AudioToText::class),
+            \OCP\TaskProcessing\TaskTypes\ContextWrite::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\ContextWrite::class),
+            \OCP\TaskProcessing\TaskTypes\GenerateEmoji::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\GenerateEmoji::class),
+            \OCP\TaskProcessing\TaskTypes\TextToTextChangeTone::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextChangeTone::class),
+            \OCP\TaskProcessing\TaskTypes\TextToTextChatWithTools::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextChatWithTools::class),
+            \OCP\TaskProcessing\TaskTypes\ContextAgentInteraction::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\ContextAgentInteraction::class),
+            \OCP\TaskProcessing\TaskTypes\TextToTextProofread::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToTextProofread::class),
+            \OCP\TaskProcessing\TaskTypes\TextToSpeech::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\TextToSpeech::class),
+            \OCP\TaskProcessing\TaskTypes\AudioToAudioChat::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\AudioToAudioChat::class),
+            \OCP\TaskProcessing\TaskTypes\ContextAgentAudioInteraction::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\ContextAgentAudioInteraction::class),
+            \OCP\TaskProcessing\TaskTypes\AnalyzeImages::ID => \OCP\Server::get(\OCP\TaskProcessing\TaskTypes\AnalyzeImages::class),
+        ];
+
+        foreach ($context->getTaskProcessingTaskTypes() as $providerServiceRegistration) {
+            $class = $providerServiceRegistration->getService();
+            try {
+                /** @var ITaskType $provider */
+                $taskType = $this->serverContainer->get($class);
+                if (isset($taskTypes[$taskType->getId()])) {
+                    $this->logger->warning('Task processing task type ' . $class . ' is using ID ' . $taskType->getId() . ' which is already used by ' . $taskTypes[$taskType->getId()]::class);
+                }
+                $taskTypes[$taskType->getId()] = $taskType;
+            } catch (\Throwable $e) {
+                $this->logger->error('Failed to load task processing task type ' . $class, [
+                    'exception' => $e,
+                ]);
+            }
+        }
+
+        $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();
+
+        $this->taskTypes = $taskTypes;
+        return $this->taskTypes;
+    }
+
+    /**
+     * @return array
+     */
+    private function _getTaskTypeSettings(): array {
+        try {
+            $json = $this->appConfig->getValueString('core', 'ai.taskprocessing_type_preferences', '', lazy: true);
+            if ($json === '') {
+                return [];
+            }
+            return json_decode($json, true, flags: JSON_THROW_ON_ERROR);
+        } catch (\JsonException $e) {
+            $this->logger->error('Failed to get settings. JSON Error in ai.taskprocessing_type_preferences', ['exception' => $e]);
+            $taskTypeSettings = [];
+            $taskTypes = $this->_getTaskTypes();
+            foreach ($taskTypes as $taskType) {
+                $taskTypeSettings[$taskType->getId()] = false;
+            };
+
+            return $taskTypeSettings;
+        }
+
+    }
+
+    /**
+     * @param ShapeDescriptor[] $spec
+     * @param array<array-key, string|numeric> $defaults
+     * @param array<array-key, ShapeEnumValue[]> $enumValues
+     * @param array $io
+     * @param bool $optional
+     * @return void
+     * @throws ValidationException
+     */
+    private static function validateInput(array $spec, array $defaults, array $enumValues, array $io, bool $optional = false): void {
+        foreach ($spec as $key => $descriptor) {
+            $type = $descriptor->getShapeType();
+            if (!isset($io[$key])) {
+                if ($optional) {
+                    continue;
+                }
+                if (isset($defaults[$key])) {
+                    if (EShapeType::getScalarType($type) !== $type) {
+                        throw new ValidationException('Provider tried to set a default value for a non-scalar slot');
+                    }
+                    if (EShapeType::isFileType($type)) {
+                        throw new ValidationException('Provider tried to set a default value for a slot that is not text or number');
+                    }
+                    $type->validateInput($defaults[$key]);
+                    continue;
+                }
+                throw new ValidationException('Missing key: "' . $key . '"');
+            }
+            try {
+                $type->validateInput($io[$key]);
+                if ($type === EShapeType::Enum) {
+                    if (!isset($enumValues[$key])) {
+                        throw new ValidationException('Provider did not provide enum values for an enum slot: "' . $key . '"');
+                    }
+                    $type->validateEnum($io[$key], $enumValues[$key]);
+                }
+            } catch (ValidationException $e) {
+                throw new ValidationException('Failed to validate input key "' . $key . '": ' . $e->getMessage());
+            }
+        }
+    }
+
+    /**
+     * Takes task input data and replaces fileIds with File objects
+     *
+     * @param array<array-key, list<numeric|string>|numeric|string> $input
+     * @param array<array-key, numeric|string> ...$defaultSpecs the specs
+     * @return array<array-key, list<numeric|string>|numeric|string>
+     */
+    public function fillInputDefaults(array $input, ...$defaultSpecs): array {
+        $spec = array_reduce($defaultSpecs, fn ($carry, $spec) => array_merge($carry, $spec), []);
+        return array_merge($spec, $input);
+    }
+
+    /**
+     * @param ShapeDescriptor[] $spec
+     * @param array<array-key, ShapeEnumValue[]> $enumValues
+     * @param array $io
+     * @param bool $optional
+     * @return void
+     * @throws ValidationException
+     */
+    private static function validateOutputWithFileIds(array $spec, array $enumValues, array $io, bool $optional = false): void {
+        foreach ($spec as $key => $descriptor) {
+            $type = $descriptor->getShapeType();
+            if (!isset($io[$key])) {
+                if ($optional) {
+                    continue;
+                }
+                throw new ValidationException('Missing key: "' . $key . '"');
+            }
+            try {
+                $type->validateOutputWithFileIds($io[$key]);
+                if (isset($enumValues[$key])) {
+                    $type->validateEnum($io[$key], $enumValues[$key]);
+                }
+            } catch (ValidationException $e) {
+                throw new ValidationException('Failed to validate output key "' . $key . '": ' . $e->getMessage());
+            }
+        }
+    }
+
+    /**
+     * @param ShapeDescriptor[] $spec
+     * @param array<array-key, ShapeEnumValue[]> $enumValues
+     * @param array $io
+     * @param bool $optional
+     * @return void
+     * @throws ValidationException
+     */
+    private static function validateOutputWithFileData(array $spec, array $enumValues, array $io, bool $optional = false): void {
+        foreach ($spec as $key => $descriptor) {
+            $type = $descriptor->getShapeType();
+            if (!isset($io[$key])) {
+                if ($optional) {
+                    continue;
+                }
+                throw new ValidationException('Missing key: "' . $key . '"');
+            }
+            try {
+                $type->validateOutputWithFileData($io[$key]);
+                if (isset($enumValues[$key])) {
+                    $type->validateEnum($io[$key], $enumValues[$key]);
+                }
+            } catch (ValidationException $e) {
+                throw new ValidationException('Failed to validate output key "' . $key . '": ' . $e->getMessage());
+            }
+        }
+    }
+
+    /**
+     * @param array<array-key, T> $array The array to filter
+     * @param ShapeDescriptor[] ...$specs the specs that define which keys to keep
+     * @return array<array-key, T>
+     * @psalm-template T
+     */
+    private function removeSuperfluousArrayKeys(array $array, ...$specs): array {
+        $keys = array_unique(array_reduce($specs, fn ($carry, $spec) => array_merge($carry, array_keys($spec)), []));
+        $keys = array_filter($keys, fn ($key) => array_key_exists($key, $array));
+        $values = array_map(fn (string $key) => $array[$key], $keys);
+        return array_combine($keys, $values);
+    }
+
+    public function hasProviders(): bool {
+        return count($this->getProviders()) !== 0;
+    }
+
+    public function getProviders(): array {
+        if ($this->providers === null) {
+            $this->providers = $this->_getProviders();
+        }
+
+        return $this->providers;
+    }
+
+    public function getPreferredProvider(string $taskTypeId) {
+        try {
+            if ($this->preferences === null) {
+                $this->preferences = $this->distributedCache->get('ai.taskprocessing_provider_preferences');
+                if ($this->preferences === null) {
+                    $this->preferences = json_decode(
+                        $this->appConfig->getValueString('core', 'ai.taskprocessing_provider_preferences', 'null', lazy: true),
+                        associative: true,
+                        flags: JSON_THROW_ON_ERROR,
+                    );
+                    $this->distributedCache->set('ai.taskprocessing_provider_preferences', $this->preferences, 60 * 3);
+                }
+            }
+
+            $providers = $this->getProviders();
+            if (isset($this->preferences[$taskTypeId])) {
+                $providersById = $this->providersById ?? array_reduce($providers, static function (array $carry, IProvider $provider) {
+                    $carry[$provider->getId()] = $provider;
+                    return $carry;
+                }, []);
+                $this->providersById = $providersById;
+                if (isset($providersById[$this->preferences[$taskTypeId]])) {
+                    return $providersById[$this->preferences[$taskTypeId]];
+                }
+            }
+            // By default, use the first available provider
+            foreach ($providers as $provider) {
+                if ($provider->getTaskTypeId() === $taskTypeId) {
+                    return $provider;
+                }
+            }
+        } catch (\JsonException $e) {
+            $this->logger->warning('Failed to parse provider preferences while getting preferred provider for task type ' . $taskTypeId, ['exception' => $e]);
+        }
+        throw new \OCP\TaskProcessing\Exception\Exception('No matching provider found');
+    }
+
+    public function getAvailableTaskTypes(bool $showDisabled = false, ?string $userId = null): array {
+        // We cache by language, because some task type fields are translated
+        $cacheKey = self::TASK_TYPES_CACHE_KEY . ':' . $this->l10nFactory->findLanguage();
+
+        // userId will be obtained from the session if left to null
+        if (!$this->checkGuestAccess($userId)) {
+            return [];
+        }
+        if ($this->availableTaskTypes === null) {
+            $cachedValue = $this->distributedCache->get($cacheKey);
+            if ($cachedValue !== null) {
+                $this->availableTaskTypes = unserialize($cachedValue);
+            }
+        }
+        // Either we have no cache or showDisabled is turned on, which we don't want to cache, ever.
+        if ($this->availableTaskTypes === null || $showDisabled) {
+            $taskTypes = $this->_getTaskTypes();
+            $taskTypeSettings = $this->_getTaskTypeSettings();
+
+            $availableTaskTypes = [];
+            foreach ($taskTypes as $taskType) {
+                if ((!$showDisabled) && isset($taskTypeSettings[$taskType->getId()]) && !$taskTypeSettings[$taskType->getId()]) {
+                    continue;
+                }
+                try {
+                    $provider = $this->getPreferredProvider($taskType->getId());
+                } catch (\OCP\TaskProcessing\Exception\Exception $e) {
+                    continue;
+                }
+                try {
+                    $availableTaskTypes[$provider->getTaskTypeId()] = [
+                        'name' => $taskType->getName(),
+                        'description' => $taskType->getDescription(),
+                        'optionalInputShape' => $provider->getOptionalInputShape(),
+                        'inputShapeEnumValues' => $provider->getInputShapeEnumValues(),
+                        'inputShapeDefaults' => $provider->getInputShapeDefaults(),
+                        'inputShape' => $taskType->getInputShape(),
+                        'optionalInputShapeEnumValues' => $provider->getOptionalInputShapeEnumValues(),
+                        'optionalInputShapeDefaults' => $provider->getOptionalInputShapeDefaults(),
+                        'outputShape' => $taskType->getOutputShape(),
+                        'outputShapeEnumValues' => $provider->getOutputShapeEnumValues(),
+                        'optionalOutputShape' => $provider->getOptionalOutputShape(),
+                        'optionalOutputShapeEnumValues' => $provider->getOptionalOutputShapeEnumValues(),
+                        'isInternal' => $taskType instanceof IInternalTaskType,
+                    ];
+                } catch (\Throwable $e) {
+                    $this->logger->error('Failed to set up TaskProcessing provider ' . $provider::class, ['exception' => $e]);
+                }
+            }
+
+            if ($showDisabled) {
+                // Do not cache showDisabled, ever.
+                return $availableTaskTypes;
+            }
+
+            $this->availableTaskTypes = $availableTaskTypes;
+            $this->distributedCache->set($cacheKey, serialize($this->availableTaskTypes), 60);
+        }
+
+
+        return $this->availableTaskTypes;
+    }
+    public function getAvailableTaskTypeIds(bool $showDisabled = false, ?string $userId = null): array {
+        // userId will be obtained from the session if left to null
+        if (!$this->checkGuestAccess($userId)) {
+            return [];
+        }
+        if ($this->availableTaskTypeIds === null) {
+            $cachedValue = $this->distributedCache->get(self::TASK_TYPE_IDS_CACHE_KEY);
+            if ($cachedValue !== null) {
+                $this->availableTaskTypeIds = $cachedValue;
+            }
+        }
+        // Either we have no cache or showDisabled is turned on, which we don't want to cache, ever.
+        if ($this->availableTaskTypeIds === null || $showDisabled) {
+            $taskTypes = $this->_getTaskTypes();
+            $taskTypeSettings = $this->_getTaskTypeSettings();
+
+            $availableTaskTypeIds = [];
+            foreach ($taskTypes as $taskType) {
+                if ((!$showDisabled) && isset($taskTypeSettings[$taskType->getId()]) && !$taskTypeSettings[$taskType->getId()]) {
+                    continue;
+                }
+                try {
+                    $provider = $this->getPreferredProvider($taskType->getId());
+                } catch (\OCP\TaskProcessing\Exception\Exception $e) {
+                    continue;
+                }
+                $availableTaskTypeIds[] = $taskType->getId();
+            }
+
+            if ($showDisabled) {
+                // Do not cache showDisabled, ever.
+                return $availableTaskTypeIds;
+            }
+
+            $this->availableTaskTypeIds = $availableTaskTypeIds;
+            $this->distributedCache->set(self::TASK_TYPE_IDS_CACHE_KEY, $this->availableTaskTypeIds, 60);
+        }
+
+
+        return $this->availableTaskTypeIds;
+    }
+
+    public function canHandleTask(Task $task): bool {
+        return isset($this->getAvailableTaskTypes()[$task->getTaskTypeId()]);
+    }
+
+    private function checkGuestAccess(?string $userId = null): bool {
+        if ($userId === null && !$this->userSession->isLoggedIn()) {
+            return true;
+        }
+        if ($userId === null) {
+            $user = $this->userSession->getUser();
+        } else {
+            $user = $this->userManager->get($userId);
+        }
+
+        $guestsAllowed = $this->appConfig->getValueString('core', 'ai.taskprocessing_guests', 'false');
+        if ($guestsAllowed == 'true' || !class_exists(\OCA\Guests\UserBackend::class) || !($user->getBackend() instanceof \OCA\Guests\UserBackend)) {
+            return true;
+        }
+        return false;
+    }
+
+    public function scheduleTask(Task $task): void {
+        if (!$this->checkGuestAccess($task->getUserId())) {
+            throw new \OCP\TaskProcessing\Exception\PreConditionNotMetException('Access to this resource is forbidden for guests.');
+        }
+        if (!$this->canHandleTask($task)) {
+            throw new \OCP\TaskProcessing\Exception\PreConditionNotMetException('No task processing provider is installed that can handle this task type: ' . $task->getTaskTypeId());
+        }
+        $this->prepareTask($task);
+        $task->setStatus(Task::STATUS_SCHEDULED);
+        $this->storeTask($task);
+        // schedule synchronous job if the provider is synchronous
+        $provider = $this->getPreferredProvider($task->getTaskTypeId());
+        if ($provider instanceof ISynchronousProvider) {
+            $this->jobList->add(SynchronousBackgroundJob::class, null);
+        }
+    }
+
+    public function runTask(Task $task): Task {
+        if (!$this->checkGuestAccess($task->getUserId())) {
+            throw new \OCP\TaskProcessing\Exception\PreConditionNotMetException('Access to this resource is forbidden for guests.');
+        }
+        if (!$this->canHandleTask($task)) {
+            throw new \OCP\TaskProcessing\Exception\PreConditionNotMetException('No task processing provider is installed that can handle this task type: ' . $task->getTaskTypeId());
+        }
+
+        $provider = $this->getPreferredProvider($task->getTaskTypeId());
+        if ($provider instanceof ISynchronousProvider) {
+            $this->prepareTask($task);
+            $task->setStatus(Task::STATUS_SCHEDULED);
+            $this->storeTask($task);
+            $this->processTask($task, $provider);
+            $task = $this->getTask($task->getId());
+        } else {
+            $this->scheduleTask($task);
+            // poll task
+            while ($task->getStatus() === Task::STATUS_SCHEDULED || $task->getStatus() === Task::STATUS_RUNNING) {
+                sleep(1);
+                $task = $this->getTask($task->getId());
+            }
+        }
+        return $task;
+    }
+
+    public function processTask(Task $task, ISynchronousProvider $provider): bool {
+        try {
+            try {
+                $input = $this->prepareInputData($task);
+            } catch (GenericFileException|NotPermittedException|LockedException|ValidationException|UnauthorizedException $e) {
+                $this->logger->warning('Failed to prepare input data for a TaskProcessing task with synchronous provider ' . $provider->getId(), ['exception' => $e]);
+                $this->setTaskResult($task->getId(), $e->getMessage(), null);
+                return false;
+            }
+            try {
+                $this->setTaskStatus($task, Task::STATUS_RUNNING);
+                $output = $provider->process($task->getUserId(), $input, fn (float $progress) => $this->setTaskProgress($task->getId(), $progress));
+            } catch (ProcessingException $e) {
+                $this->logger->warning('Failed to process a TaskProcessing task with synchronous provider ' . $provider->getId(), ['exception' => $e]);
+                $this->setTaskResult($task->getId(), $e->getMessage(), null);
+                return false;
+            } catch (\Throwable $e) {
+                $this->logger->error('Unknown error while processing TaskProcessing task', ['exception' => $e]);
+                $this->setTaskResult($task->getId(), $e->getMessage(), null);
+                return false;
+            }
+            $this->setTaskResult($task->getId(), null, $output);
+        } catch (NotFoundException $e) {
+            $this->logger->info('Could not find task anymore after execution. Moving on.', ['exception' => $e]);
+        } catch (Exception $e) {
+            $this->logger->error('Failed to report result of TaskProcessing task', ['exception' => $e]);
+        }
+        return true;
+    }
+
+    public function deleteTask(Task $task): void {
+        $taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
+        $this->taskMapper->delete($taskEntity);
+    }
+
+    public function getTask(int $id): Task {
+        try {
+            $taskEntity = $this->taskMapper->find($id);
+            return $taskEntity->toPublicTask();
+        } catch (DoesNotExistException $e) {
+            throw new NotFoundException('Couldn\'t find task with id ' . $id, 0, $e);
+        } catch (MultipleObjectsReturnedException|\OCP\DB\Exception $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', 0, $e);
+        } catch (\JsonException $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the task', 0, $e);
+        }
+    }
+
+    public function cancelTask(int $id): void {
+        $task = $this->getTask($id);
+        if ($task->getStatus() !== Task::STATUS_SCHEDULED && $task->getStatus() !== Task::STATUS_RUNNING) {
+            return;
+        }
+        $task->setStatus(Task::STATUS_CANCELLED);
+        $task->setEndedAt(time());
+        $taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
+        try {
+            $this->taskMapper->update($taskEntity);
+            $this->runWebhook($task);
+        } catch (\OCP\DB\Exception $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', 0, $e);
+        }
+    }
+
+    public function setTaskProgress(int $id, float $progress): bool {
+        // TODO: Not sure if we should rather catch the exceptions of getTask here and fail silently
+        $task = $this->getTask($id);
+        if ($task->getStatus() === Task::STATUS_CANCELLED) {
+            return false;
+        }
+        // only set the start time if the task is going from scheduled to running
+        if ($task->getstatus() === Task::STATUS_SCHEDULED) {
+            $task->setStartedAt(time());
+        }
+        $task->setStatus(Task::STATUS_RUNNING);
+        $task->setProgress($progress);
+        $taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
+        try {
+            $this->taskMapper->update($taskEntity);
+        } catch (\OCP\DB\Exception $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', 0, $e);
+        }
+        return true;
+    }
+
+    public function setTaskResult(int $id, ?string $error, ?array $result, bool $isUsingFileIds = false): void {
+        // TODO: Not sure if we should rather catch the exceptions of getTask here and fail silently
+        $task = $this->getTask($id);
+        if ($task->getStatus() === Task::STATUS_CANCELLED) {
+            $this->logger->info('A TaskProcessing ' . $task->getTaskTypeId() . ' task with id ' . $id . ' finished but was cancelled in the mean time. Moving on without storing result.');
+            return;
+        }
+        if ($error !== null) {
+            $task->setStatus(Task::STATUS_FAILED);
+            $task->setEndedAt(time());
+            // truncate error message to 1000 characters
+            $task->setErrorMessage(mb_substr($error, 0, 1000));
+            $this->logger->warning('A TaskProcessing ' . $task->getTaskTypeId() . ' task with id ' . $id . ' failed with the following message: ' . $error);
+        } elseif ($result !== null) {
+            $taskTypes = $this->getAvailableTaskTypes();
+            $outputShape = $taskTypes[$task->getTaskTypeId()]['outputShape'];
+            $outputShapeEnumValues = $taskTypes[$task->getTaskTypeId()]['outputShapeEnumValues'];
+            $optionalOutputShape = $taskTypes[$task->getTaskTypeId()]['optionalOutputShape'];
+            $optionalOutputShapeEnumValues = $taskTypes[$task->getTaskTypeId()]['optionalOutputShapeEnumValues'];
+            try {
+                // validate output
+                if (!$isUsingFileIds) {
+                    $this->validateOutputWithFileData($outputShape, $outputShapeEnumValues, $result);
+                    $this->validateOutputWithFileData($optionalOutputShape, $optionalOutputShapeEnumValues, $result, true);
+                } else {
+                    $this->validateOutputWithFileIds($outputShape, $outputShapeEnumValues, $result);
+                    $this->validateOutputWithFileIds($optionalOutputShape, $optionalOutputShapeEnumValues, $result, true);
+                }
+                $output = $this->removeSuperfluousArrayKeys($result, $outputShape, $optionalOutputShape);
+                // extract raw data and put it in files, replace it with file ids
+                if (!$isUsingFileIds) {
+                    $output = $this->encapsulateOutputFileData($output, $outputShape, $optionalOutputShape);
+                } else {
+                    $this->validateOutputFileIds($output, $outputShape, $optionalOutputShape);
+                }
+                // Turn file objects into IDs
+                foreach ($output as $key => $value) {
+                    if ($value instanceof Node) {
+                        $output[$key] = $value->getId();
+                    }
+                    if (is_array($value) && isset($value[0]) && $value[0] instanceof Node) {
+                        $output[$key] = array_map(fn ($node) => $node->getId(), $value);
+                    }
+                }
+                $task->setOutput($output);
+                $task->setProgress(1);
+                $task->setStatus(Task::STATUS_SUCCESSFUL);
+                $task->setEndedAt(time());
+            } catch (ValidationException $e) {
+                $task->setProgress(1);
+                $task->setStatus(Task::STATUS_FAILED);
+                $task->setEndedAt(time());
+                $error = 'The task was processed successfully but the provider\'s output doesn\'t pass validation against the task type\'s outputShape spec and/or the provider\'s own optionalOutputShape spec';
+                $task->setErrorMessage($error);
+                $this->logger->error($error, ['exception' => $e, 'output' => $result]);
+            } catch (NotPermittedException $e) {
+                $task->setProgress(1);
+                $task->setStatus(Task::STATUS_FAILED);
+                $task->setEndedAt(time());
+                $error = 'The task was processed successfully but storing the output in a file failed';
+                $task->setErrorMessage($error);
+                $this->logger->error($error, ['exception' => $e]);
+            } catch (InvalidPathException|\OCP\Files\NotFoundException $e) {
+                $task->setProgress(1);
+                $task->setStatus(Task::STATUS_FAILED);
+                $task->setEndedAt(time());
+                $error = 'The task was processed successfully but the result file could not be found';
+                $task->setErrorMessage($error);
+                $this->logger->error($error, ['exception' => $e]);
+            }
+        }
+        try {
+            $taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
+        } catch (\JsonException $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('The task was processed successfully but the provider\'s output could not be encoded as JSON for the database.', 0, $e);
+        }
+        try {
+            $this->taskMapper->update($taskEntity);
+            $this->runWebhook($task);
+        } catch (\OCP\DB\Exception $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception($e->getMessage());
+        }
+        if ($task->getStatus() === Task::STATUS_SUCCESSFUL) {
+            $event = new TaskSuccessfulEvent($task);
+        } else {
+            $event = new TaskFailedEvent($task, $error);
+        }
+        $this->dispatcher->dispatchTyped($event);
+    }
+
+    public function getNextScheduledTask(array $taskTypeIds = [], array $taskIdsToIgnore = []): Task {
+        try {
+            $taskEntity = $this->taskMapper->findOldestScheduledByType($taskTypeIds, $taskIdsToIgnore);
+            return $taskEntity->toPublicTask();
+        } catch (DoesNotExistException $e) {
+            throw new \OCP\TaskProcessing\Exception\NotFoundException('Could not find the task', previous: $e);
+        } catch (\OCP\DB\Exception $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', previous: $e);
+        } catch (\JsonException $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the task', previous: $e);
+        }
+    }
+
+    public function getNextScheduledTasks(array $taskTypeIds = [], array $taskIdsToIgnore = [], int $numberOfTasks = 1): array {
+        try {
+            return array_map(fn ($taskEntity) => $taskEntity->toPublicTask(), $this->taskMapper->findNOldestScheduledByType($taskTypeIds, $taskIdsToIgnore, $numberOfTasks));
+        } catch (DoesNotExistException $e) {
+            throw new \OCP\TaskProcessing\Exception\NotFoundException('Could not find the task', previous: $e);
+        } catch (\OCP\DB\Exception $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', previous: $e);
+        } catch (\JsonException $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the task', previous: $e);
+        }
+    }
+
+    /**
+     * Takes task input data and replaces fileIds with File objects
+     *
+     * @param string|null $userId
+     * @param array<array-key, list<numeric|string>|numeric|string> $input
+     * @param ShapeDescriptor[] ...$specs the specs
+     * @return array<array-key, list<File|numeric|string>|numeric|string|File>
+     * @throws GenericFileException|LockedException|NotPermittedException|ValidationException|UnauthorizedException
+     */
+    public function fillInputFileData(?string $userId, array $input, ...$specs): array {
+        if ($userId !== null) {
+            \OC_Util::setupFS($userId);
+        }
+        $newInputOutput = [];
+        $spec = array_reduce($specs, fn ($carry, $spec) => $carry + $spec, []);
+        foreach ($spec as $key => $descriptor) {
+            $type = $descriptor->getShapeType();
+            if (!isset($input[$key])) {
+                continue;
+            }
+            if (!in_array(EShapeType::getScalarType($type), [EShapeType::Image, EShapeType::Audio, EShapeType::Video, EShapeType::File], true)) {
+                $newInputOutput[$key] = $input[$key];
+                continue;
+            }
+            if (EShapeType::getScalarType($type) === $type) {
+                // is scalar
+                $node = $this->validateFileId((int)$input[$key]);
+                $this->validateUserAccessToFile($input[$key], $userId);
+                $newInputOutput[$key] = $node;
+            } else {
+                // is list
+                $newInputOutput[$key] = [];
+                foreach ($input[$key] as $item) {
+                    $node = $this->validateFileId((int)$item);
+                    $this->validateUserAccessToFile($item, $userId);
+                    $newInputOutput[$key][] = $node;
+                }
+            }
+        }
+        return $newInputOutput;
+    }
+
+    public function getUserTask(int $id, ?string $userId): Task {
+        try {
+            $taskEntity = $this->taskMapper->findByIdAndUser($id, $userId);
+            return $taskEntity->toPublicTask();
+        } catch (DoesNotExistException $e) {
+            throw new \OCP\TaskProcessing\Exception\NotFoundException('Could not find the task', 0, $e);
+        } catch (MultipleObjectsReturnedException|\OCP\DB\Exception $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the task', 0, $e);
+        } catch (\JsonException $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the task', 0, $e);
+        }
+    }
+
+    public function getUserTasks(?string $userId, ?string $taskTypeId = null, ?string $customId = null): array {
+        try {
+            $taskEntities = $this->taskMapper->findByUserAndTaskType($userId, $taskTypeId, $customId);
+            return array_map(fn ($taskEntity): Task => $taskEntity->toPublicTask(), $taskEntities);
+        } catch (\OCP\DB\Exception $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the tasks', 0, $e);
+        } catch (\JsonException $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the tasks', 0, $e);
+        }
+    }
+
+    public function getTasks(
+        ?string $userId, ?string $taskTypeId = null, ?string $appId = null, ?string $customId = null,
+        ?int $status = null, ?int $scheduleAfter = null, ?int $endedBefore = null,
+    ): array {
+        try {
+            $taskEntities = $this->taskMapper->findTasks($userId, $taskTypeId, $appId, $customId, $status, $scheduleAfter, $endedBefore);
+            return array_map(fn ($taskEntity): Task => $taskEntity->toPublicTask(), $taskEntities);
+        } catch (\OCP\DB\Exception $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding the tasks', 0, $e);
+        } catch (\JsonException $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding the tasks', 0, $e);
+        }
+    }
+
+    public function getUserTasksByApp(?string $userId, string $appId, ?string $customId = null): array {
+        try {
+            $taskEntities = $this->taskMapper->findUserTasksByApp($userId, $appId, $customId);
+            return array_map(fn ($taskEntity): Task => $taskEntity->toPublicTask(), $taskEntities);
+        } catch (\OCP\DB\Exception $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem finding a task', 0, $e);
+        } catch (\JsonException $e) {
+            throw new \OCP\TaskProcessing\Exception\Exception('There was a problem parsing JSON after finding a task', 0, $e);
+        }
+    }
+
+    /**
+     *Takes task input or output and replaces base64 data with file ids
+     *
+     * @param array $output
+     * @param ShapeDescriptor[] ...$specs the specs that define which keys to keep
+     * @return array
+     * @throws NotPermittedException
+     */
+    public function encapsulateOutputFileData(array $output, ...$specs): array {
+        $newOutput = [];
+        try {
+            $folder = $this->appData->getFolder('TaskProcessing');
+        } catch (\OCP\Files\NotFoundException) {
+            $folder = $this->appData->newFolder('TaskProcessing');
+        }
+        $spec = array_reduce($specs, fn ($carry, $spec) => $carry + $spec, []);
+        foreach ($spec as $key => $descriptor) {
+            $type = $descriptor->getShapeType();
+            if (!isset($output[$key])) {
+                continue;
+            }
+            if (!in_array(EShapeType::getScalarType($type), [EShapeType::Image, EShapeType::Audio, EShapeType::Video, EShapeType::File], true)) {
+                $newOutput[$key] = $output[$key];
+                continue;
+            }
+            if (EShapeType::getScalarType($type) === $type) {
+                /** @var SimpleFile $file */
+                $file = $folder->newFile(time() . '-' . rand(1, 100000), $output[$key]);
+                $newOutput[$key] = $file->getId(); // polymorphic call to SimpleFile
+            } else {
+                $newOutput = [];
+                foreach ($output[$key] as $item) {
+                    /** @var SimpleFile $file */
+                    $file = $folder->newFile(time() . '-' . rand(1, 100000), $item);
+                    $newOutput[$key][] = $file->getId();
+                }
+            }
+        }
+        return $newOutput;
+    }
+
+    /**
+     * @param Task $task
+     * @return array<array-key, list<numeric|string|File>|numeric|string|File>
+     * @throws GenericFileException
+     * @throws LockedException
+     * @throws NotPermittedException
+     * @throws ValidationException|UnauthorizedException
+     */
+    public function prepareInputData(Task $task): array {
+        $taskTypes = $this->getAvailableTaskTypes();
+        $inputShape = $taskTypes[$task->getTaskTypeId()]['inputShape'];
+        $optionalInputShape = $taskTypes[$task->getTaskTypeId()]['optionalInputShape'];
+        $input = $task->getInput();
+        $input = $this->removeSuperfluousArrayKeys($input, $inputShape, $optionalInputShape);
+        $input = $this->fillInputFileData($task->getUserId(), $input, $inputShape, $optionalInputShape);
+        return $input;
+    }
+
+    public function lockTask(Task $task): bool {
+        $taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
+        if ($this->taskMapper->lockTask($taskEntity) === 0) {
+            return false;
+        }
+        $task->setStatus(Task::STATUS_RUNNING);
+        return true;
+    }
+
+    /**
+     * @throws \JsonException
+     * @throws Exception
+     */
+    public function setTaskStatus(Task $task, int $status): void {
+        $currentTaskStatus = $task->getStatus();
+        if ($currentTaskStatus === Task::STATUS_SCHEDULED && $status === Task::STATUS_RUNNING) {
+            $task->setStartedAt(time());
+        } elseif ($currentTaskStatus === Task::STATUS_RUNNING && ($status === Task::STATUS_FAILED || $status === Task::STATUS_CANCELLED)) {
+            $task->setEndedAt(time());
+        } elseif ($currentTaskStatus === Task::STATUS_UNKNOWN && $status === Task::STATUS_SCHEDULED) {
+            $task->setScheduledAt(time());
+        }
+        $task->setStatus($status);
+        $taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
+        $this->taskMapper->update($taskEntity);
+    }
+
+    /**
+     * Validate input, fill input default values, set completionExpectedAt, set scheduledAt
+     *
+     * @param Task $task
+     * @return void
+     * @throws UnauthorizedException
+     * @throws ValidationException
+     * @throws \OCP\TaskProcessing\Exception\Exception
+     */
+    private function prepareTask(Task $task): void {
+        $taskTypes = $this->getAvailableTaskTypes();
+        $taskType = $taskTypes[$task->getTaskTypeId()];
+        $inputShape = $taskType['inputShape'];
+        $inputShapeDefaults = $taskType['inputShapeDefaults'];
+        $inputShapeEnumValues = $taskType['inputShapeEnumValues'];
+        $optionalInputShape = $taskType['optionalInputShape'];
+        $optionalInputShapeEnumValues = $taskType['optionalInputShapeEnumValues'];
+        $optionalInputShapeDefaults = $taskType['optionalInputShapeDefaults'];
+        // validate input
+        $this->validateInput($inputShape, $inputShapeDefaults, $inputShapeEnumValues, $task->getInput());
+        $this->validateInput($optionalInputShape, $optionalInputShapeDefaults, $optionalInputShapeEnumValues, $task->getInput(), true);
+        // authenticate access to mentioned files
+        $ids = [];
+        foreach ($inputShape + $optionalInputShape as $key => $descriptor) {
+            if (in_array(EShapeType::getScalarType($descriptor->getShapeType()), [EShapeType::File, EShapeType::Image, EShapeType::Audio, EShapeType::Video], true)) {
+                /** @var list<int>|int $inputSlot */
+                $inputSlot = $task->getInput()[$key];
+                if (is_array($inputSlot)) {
+                    $ids += $inputSlot;
+                } else {
+                    $ids[] = $inputSlot;
+                }
+            }
+        }
+        foreach ($ids as $fileId) {
+            $this->validateFileId($fileId);
+            $this->validateUserAccessToFile($fileId, $task->getUserId());
+        }
+        // remove superfluous keys and set input
+        $input = $this->removeSuperfluousArrayKeys($task->getInput(), $inputShape, $optionalInputShape);
+        $inputWithDefaults = $this->fillInputDefaults($input, $inputShapeDefaults, $optionalInputShapeDefaults);
+        $task->setInput($inputWithDefaults);
+        $task->setScheduledAt(time());
+        $provider = $this->getPreferredProvider($task->getTaskTypeId());
+        // calculate expected completion time
+        $completionExpectedAt = new \DateTime('now');
+        $completionExpectedAt->add(new \DateInterval('PT' . $provider->getExpectedRuntime() . 'S'));
+        $task->setCompletionExpectedAt($completionExpectedAt);
+    }
+
+    /**
+     * Store the task in the DB and set its ID in the \OCP\TaskProcessing\Task input param
+     *
+     * @param Task $task
+     * @return void
+     * @throws Exception
+     * @throws \JsonException
+     */
+    private function storeTask(Task $task): void {
+        // create a db entity and insert into db table
+        $taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
+        $this->taskMapper->insert($taskEntity);
+        // make sure the scheduler knows the id
+        $task->setId($taskEntity->getId());
+    }
+
+    /**
+     * @param array $output
+     * @param ShapeDescriptor[] ...$specs the specs that define which keys to keep
+     * @return array
+     * @throws NotPermittedException
+     */
+    private function validateOutputFileIds(array $output, ...$specs): array {
+        $newOutput = [];
+        $spec = array_reduce($specs, fn ($carry, $spec) => $carry + $spec, []);
+        foreach ($spec as $key => $descriptor) {
+            $type = $descriptor->getShapeType();
+            if (!isset($output[$key])) {
+                continue;
+            }
+            if (!in_array(EShapeType::getScalarType($type), [EShapeType::Image, EShapeType::Audio, EShapeType::Video, EShapeType::File], true)) {
+                $newOutput[$key] = $output[$key];
+                continue;
+            }
+            if (EShapeType::getScalarType($type) === $type) {
+                // Is scalar file ID
+                $newOutput[$key] = $this->validateFileId($output[$key]);
+            } else {
+                // Is list of file IDs
+                $newOutput = [];
+                foreach ($output[$key] as $item) {
+                    $newOutput[$key][] = $this->validateFileId($item);
+                }
+            }
+        }
+        return $newOutput;
+    }
+
+    /**
+     * @param mixed $id
+     * @return File
+     * @throws ValidationException
+     */
+    private function validateFileId(mixed $id): File {
+        $node = $this->rootFolder->getFirstNodeById($id);
+        if ($node === null) {
+            $node = $this->rootFolder->getFirstNodeByIdInPath($id, '/' . $this->rootFolder->getAppDataDirectoryName() . '/');
+            if ($node === null) {
+                throw new ValidationException('Could not find file ' . $id);
+            } elseif (!$node instanceof File) {
+                throw new ValidationException('File with id "' . $id . '" is not a file');
+            }
+        } elseif (!$node instanceof File) {
+            throw new ValidationException('File with id "' . $id . '" is not a file');
+        }
+        return $node;
+    }
+
+    /**
+     * @param mixed $fileId
+     * @param string|null $userId
+     * @return void
+     * @throws UnauthorizedException
+     */
+    private function validateUserAccessToFile(mixed $fileId, ?string $userId): void {
+        if ($userId === null) {
+            throw new UnauthorizedException('User does not have access to file ' . $fileId);
+        }
+        $mounts = $this->userMountCache->getMountsForFileId($fileId);
+        $userIds = array_map(fn ($mount) => $mount->getUser()->getUID(), $mounts);
+        if (!in_array($userId, $userIds)) {
+            throw new UnauthorizedException('User ' . $userId . ' does not have access to file ' . $fileId);
+        }
+    }
+
+    /**
+     * @param Task $task
+     * @return list<int>
+     * @throws NotFoundException
+     */
+    public function extractFileIdsFromTask(Task $task): array {
+        $ids = [];
+        $taskTypes = $this->getAvailableTaskTypes();
+        if (!isset($taskTypes[$task->getTaskTypeId()])) {
+            throw new NotFoundException('Could not find task type');
+        }
+        $taskType = $taskTypes[$task->getTaskTypeId()];
+        foreach ($taskType['inputShape'] + $taskType['optionalInputShape'] as $key => $descriptor) {
+            if (in_array(EShapeType::getScalarType($descriptor->getShapeType()), [EShapeType::File, EShapeType::Image, EShapeType::Audio, EShapeType::Video], true)) {
+                /** @var int|list<int> $inputSlot */
+                $inputSlot = $task->getInput()[$key];
+                if (is_array($inputSlot)) {
+                    $ids = array_merge($inputSlot, $ids);
+                } else {
+                    $ids[] = $inputSlot;
+                }
+            }
+        }
+        if ($task->getOutput() !== null) {
+            foreach ($taskType['outputShape'] + $taskType['optionalOutputShape'] as $key => $descriptor) {
+                if (in_array(EShapeType::getScalarType($descriptor->getShapeType()), [EShapeType::File, EShapeType::Image, EShapeType::Audio, EShapeType::Video], true)) {
+                    /** @var int|list<int> $outputSlot */
+                    $outputSlot = $task->getOutput()[$key];
+                    if (is_array($outputSlot)) {
+                        $ids = array_merge($outputSlot, $ids);
+                    } else {
+                        $ids[] = $outputSlot;
+                    }
+                }
+            }
+        }
+        return $ids;
+    }
+
+    /**
+     * @param ISimpleFolder $folder
+     * @param int $ageInSeconds
+     * @return \Generator
+     */
+    public function clearFilesOlderThan(ISimpleFolder $folder, int $ageInSeconds = self::MAX_TASK_AGE_SECONDS): \Generator {
+        foreach ($folder->getDirectoryListing() as $file) {
+            if ($file->getMTime() < time() - $ageInSeconds) {
+                try {
+                    $fileName = $file->getName();
+                    $file->delete();
+                    yield $fileName;
+                } catch (NotPermittedException $e) {
+                    $this->logger->warning('Failed to delete a stale task processing file', ['exception' => $e]);
+                }
+            }
+        }
+    }
+
+    /**
+     * @param int $ageInSeconds
+     * @return \Generator
+     * @throws Exception
+     * @throws InvalidPathException
+     * @throws NotFoundException
+     * @throws \JsonException
+     * @throws \OCP\Files\NotFoundException
+     */
+    public function cleanupTaskProcessingTaskFiles(int $ageInSeconds = self::MAX_TASK_AGE_SECONDS): \Generator {
+        $taskIdsToCleanup = [];
+        foreach ($this->taskMapper->getTasksToCleanup($ageInSeconds) as $task) {
+            $taskIdsToCleanup[] = $task->getId();
+            $ocpTask = $task->toPublicTask();
+            $fileIds = $this->extractFileIdsFromTask($ocpTask);
+            foreach ($fileIds as $fileId) {
+                // only look for output files stored in appData/TaskProcessing/
+                $file = $this->rootFolder->getFirstNodeByIdInPath($fileId, '/' . $this->rootFolder->getAppDataDirectoryName() . '/core/TaskProcessing/');
+                if ($file instanceof File) {
+                    try {
+                        $fileId = $file->getId();
+                        $fileName = $file->getName();
+                        $file->delete();
+                        yield ['task_id' => $task->getId(), 'file_id' => $fileId, 'file_name' => $fileName];
+                    } catch (NotPermittedException $e) {
+                        $this->logger->warning('Failed to delete a stale task processing file', ['exception' => $e]);
+                    }
+                }
+            }
+        }
+        return $taskIdsToCleanup;
+    }
+
+    /**
+     * Make a request to the task's webhookUri if necessary
+     *
+     * @param Task $task
+     */
+    private function runWebhook(Task $task): void {
+        $uri = $task->getWebhookUri();
+        $method = $task->getWebhookMethod();
+
+        if (!$uri || !$method) {
+            return;
+        }
+
+        if (in_array($method, ['HTTP:GET', 'HTTP:POST', 'HTTP:PUT', 'HTTP:DELETE'], true)) {
+            $client = $this->clientService->newClient();
+            $httpMethod = preg_replace('/^HTTP:/', '', $method);
+            $options = [
+                'timeout' => 30,
+                'body' => json_encode([
+                    'task' => $task->jsonSerialize(),
+                ]),
+                'headers' => ['Content-Type' => 'application/json'],
+            ];
+            try {
+                $client->request($httpMethod, $uri, $options);
+            } catch (ClientException|ServerException $e) {
+                $this->logger->warning('Task processing HTTP webhook failed for task ' . $task->getId() . '. Request failed', ['exception' => $e]);
+            } catch (\Exception|\Throwable $e) {
+                $this->logger->warning('Task processing HTTP webhook failed for task ' . $task->getId() . '. Unknown error', ['exception' => $e]);
+            }
+        } elseif (str_starts_with($method, 'AppAPI:') && str_starts_with($uri, '/')) {
+            $parsedMethod = explode(':', $method, 4);
+            if (count($parsedMethod) < 3) {
+                $this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. Invalid method: ' . $method);
+            }
+            [, $exAppId, $httpMethod] = $parsedMethod;
+            if (!$this->appManager->isEnabledForAnyone('app_api')) {
+                $this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. AppAPI is disabled or not installed.');
+                return;
+            }
+            try {
+                $appApiFunctions = \OCP\Server::get(\OCA\AppAPI\PublicFunctions::class);
+            } catch (ContainerExceptionInterface|NotFoundExceptionInterface) {
+                $this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. Could not get AppAPI public functions.');
+                return;
+            }
+            $exApp = $appApiFunctions->getExApp($exAppId);
+            if ($exApp === null) {
+                $this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. ExApp ' . $exAppId . ' is missing.');
+                return;
+            } elseif (!$exApp['enabled']) {
+                $this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. ExApp ' . $exAppId . ' is disabled.');
+                return;
+            }
+            $requestParams = [
+                'task' => $task->jsonSerialize(),
+            ];
+            $requestOptions = [
+                'timeout' => 30,
+            ];
+            $response = $appApiFunctions->exAppRequest($exAppId, $uri, $task->getUserId(), $httpMethod, $requestParams, $requestOptions);
+            if (is_array($response) && isset($response['error'])) {
+                $this->logger->warning('Task processing AppAPI webhook failed for task ' . $task->getId() . '. Error during request to ExApp(' . $exAppId . '): ', $response['error']);
+            }
+        }
+    }
 }

core/Controller/TaskProcessingApiController.php

Indentation +631 added lines, -631 removed lines

@@ -45,635 +45,635 @@
  * @psalm-import-type CoreTaskProcessingTaskType from ResponseDefinitions
  */
 class TaskProcessingApiController extends OCSController {
-	public function __construct(
-		string $appName,
-		IRequest $request,
-		private IManager $taskProcessingManager,
-		private IL10N $l,
-		private ?string $userId,
-		private IRootFolder $rootFolder,
-		private IAppData $appData,
-		private IMimeTypeDetector $mimeTypeDetector,
-	) {
-		parent::__construct($appName, $request);
-	}
-
-	/**
-	 * Returns all available TaskProcessing task types
-	 *
-	 * @return DataResponse<Http::STATUS_OK, array{types: array<string, CoreTaskProcessingTaskType>}, array{}>
-	 *
-	 * 200: Task types returned
-	 */
-	#[NoAdminRequired]
-	#[ApiRoute(verb: 'GET', url: '/tasktypes', root: '/taskprocessing')]
-	public function taskTypes(): DataResponse {
-		/** @var array<string, CoreTaskProcessingTaskType> $taskTypes */
-		$taskTypes = array_map(function (array $tt) {
-			$tt['inputShape'] = array_map(function ($descriptor) {
-				return $descriptor->jsonSerialize();
-			}, $tt['inputShape']);
-			if (empty($tt['inputShape'])) {
-				$tt['inputShape'] = new stdClass;
-			}
-
-			$tt['outputShape'] = array_map(function ($descriptor) {
-				return $descriptor->jsonSerialize();
-			}, $tt['outputShape']);
-			if (empty($tt['outputShape'])) {
-				$tt['outputShape'] = new stdClass;
-			}
-
-			$tt['optionalInputShape'] = array_map(function ($descriptor) {
-				return $descriptor->jsonSerialize();
-			}, $tt['optionalInputShape']);
-			if (empty($tt['optionalInputShape'])) {
-				$tt['optionalInputShape'] = new stdClass;
-			}
-
-			$tt['optionalOutputShape'] = array_map(function ($descriptor) {
-				return $descriptor->jsonSerialize();
-			}, $tt['optionalOutputShape']);
-			if (empty($tt['optionalOutputShape'])) {
-				$tt['optionalOutputShape'] = new stdClass;
-			}
-
-			$tt['inputShapeEnumValues'] = array_map(function (array $enumValues) {
-				return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
-			}, $tt['inputShapeEnumValues']);
-			if (empty($tt['inputShapeEnumValues'])) {
-				$tt['inputShapeEnumValues'] = new stdClass;
-			}
-
-			$tt['optionalInputShapeEnumValues'] = array_map(function (array $enumValues) {
-				return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
-			}, $tt['optionalInputShapeEnumValues']);
-			if (empty($tt['optionalInputShapeEnumValues'])) {
-				$tt['optionalInputShapeEnumValues'] = new stdClass;
-			}
-
-			$tt['outputShapeEnumValues'] = array_map(function (array $enumValues) {
-				return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
-			}, $tt['outputShapeEnumValues']);
-			if (empty($tt['outputShapeEnumValues'])) {
-				$tt['outputShapeEnumValues'] = new stdClass;
-			}
-
-			$tt['optionalOutputShapeEnumValues'] = array_map(function (array $enumValues) {
-				return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
-			}, $tt['optionalOutputShapeEnumValues']);
-			if (empty($tt['optionalOutputShapeEnumValues'])) {
-				$tt['optionalOutputShapeEnumValues'] = new stdClass;
-			}
-
-			if (empty($tt['inputShapeDefaults'])) {
-				$tt['inputShapeDefaults'] = new stdClass;
-			}
-			if (empty($tt['optionalInputShapeDefaults'])) {
-				$tt['optionalInputShapeDefaults'] = new stdClass;
-			}
-			return $tt;
-		}, $this->taskProcessingManager->getAvailableTaskTypes());
-		return new DataResponse([
-			'types' => $taskTypes,
-		]);
-	}
-
-	/**
-	 * Schedules a task
-	 *
-	 * @param array<string, mixed> $input Task's input parameters
-	 * @param string $type Type of the task
-	 * @param string $appId ID of the app that will execute the task
-	 * @param string $customId An arbitrary identifier for the task
-	 * @param string|null $webhookUri URI to be requested when the task finishes
-	 * @param string|null $webhookMethod Method used for the webhook request (HTTP:GET, HTTP:POST, HTTP:PUT, HTTP:DELETE or AppAPI:APP_ID:GET, AppAPI:APP_ID:POST...)
-	 * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_BAD_REQUEST|Http::STATUS_PRECONDITION_FAILED|Http::STATUS_UNAUTHORIZED, array{message: string}, array{}>
-	 *
-	 * 200: Task scheduled successfully
-	 * 400: Scheduling task is not possible
-	 * 412: Scheduling task is not possible
-	 * 401: Cannot schedule task because it references files in its input that the user doesn't have access to
-	 */
-	#[UserRateLimit(limit: 20, period: 120)]
-	#[NoAdminRequired]
-	#[ApiRoute(verb: 'POST', url: '/schedule', root: '/taskprocessing')]
-	public function schedule(
-		array $input, string $type, string $appId, string $customId = '',
-		?string $webhookUri = null, ?string $webhookMethod = null,
-	): DataResponse {
-		$task = new Task($type, $input, $appId, $this->userId, $customId);
-		$task->setWebhookUri($webhookUri);
-		$task->setWebhookMethod($webhookMethod);
-		try {
-			$this->taskProcessingManager->scheduleTask($task);
-
-			/** @var CoreTaskProcessingTask $json */
-			$json = $task->jsonSerialize();
-
-			return new DataResponse([
-				'task' => $json,
-			]);
-		} catch (PreConditionNotMetException) {
-			return new DataResponse(['message' => $this->l->t('The given provider is not available')], Http::STATUS_PRECONDITION_FAILED);
-		} catch (ValidationException $e) {
-			return new DataResponse(['message' => $e->getMessage()], Http::STATUS_BAD_REQUEST);
-		} catch (UnauthorizedException) {
-			return new DataResponse(['message' => 'User does not have access to the files mentioned in the task input'], Http::STATUS_UNAUTHORIZED);
-		} catch (Exception) {
-			return new DataResponse(['message' => 'Internal server error'], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * Gets a task including status and result
-	 *
-	 * Tasks are removed 1 week after receiving their last update
-	 *
-	 * @param int $id The id of the task
-	 *
-	 * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask}, array{}>|DataResponse<Http::STATUS_NOT_FOUND|Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
-	 *
-	 * 200: Task returned
-	 * 404: Task not found
-	 */
-	#[NoAdminRequired]
-	#[ApiRoute(verb: 'GET', url: '/task/{id}', root: '/taskprocessing')]
-	public function getTask(int $id): DataResponse {
-		try {
-			$task = $this->taskProcessingManager->getUserTask($id, $this->userId);
-
-			/** @var CoreTaskProcessingTask $json */
-			$json = $task->jsonSerialize();
-
-			return new DataResponse([
-				'task' => $json,
-			]);
-		} catch (NotFoundException) {
-			return new DataResponse(['message' => $this->l->t('Task not found')], Http::STATUS_NOT_FOUND);
-		} catch (RuntimeException) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * Deletes a task
-	 *
-	 * @param int $id The id of the task
-	 *
-	 * @return DataResponse<Http::STATUS_OK, null, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
-	 *
-	 * 200: Task deleted
-	 */
-	#[NoAdminRequired]
-	#[ApiRoute(verb: 'DELETE', url: '/task/{id}', root: '/taskprocessing')]
-	public function deleteTask(int $id): DataResponse {
-		try {
-			$task = $this->taskProcessingManager->getUserTask($id, $this->userId);
-
-			$this->taskProcessingManager->deleteTask($task);
-
-			return new DataResponse(null);
-		} catch (NotFoundException) {
-			return new DataResponse(null);
-		} catch (Exception) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-
-	/**
-	 * Returns tasks for the current user filtered by the appId and optional customId
-	 *
-	 * @param string $appId ID of the app
-	 * @param string|null $customId An arbitrary identifier for the task
-	 * @return DataResponse<Http::STATUS_OK, array{tasks: list<CoreTaskProcessingTask>}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
-	 *
-	 * 200: Tasks returned
-	 */
-	#[NoAdminRequired]
-	#[ApiRoute(verb: 'GET', url: '/tasks/app/{appId}', root: '/taskprocessing')]
-	public function listTasksByApp(string $appId, ?string $customId = null): DataResponse {
-		try {
-			$tasks = $this->taskProcessingManager->getUserTasksByApp($this->userId, $appId, $customId);
-			$json = array_map(static function (Task $task) {
-				return $task->jsonSerialize();
-			}, $tasks);
-
-			return new DataResponse([
-				'tasks' => $json,
-			]);
-		} catch (Exception) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * Returns tasks for the current user filtered by the optional taskType and optional customId
-	 *
-	 * @param string|null $taskType The task type to filter by
-	 * @param string|null $customId An arbitrary identifier for the task
-	 * @return DataResponse<Http::STATUS_OK, array{tasks: list<CoreTaskProcessingTask>}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
-	 *
-	 * 200: Tasks returned
-	 */
-	#[NoAdminRequired]
-	#[ApiRoute(verb: 'GET', url: '/tasks', root: '/taskprocessing')]
-	public function listTasks(?string $taskType, ?string $customId = null): DataResponse {
-		try {
-			$tasks = $this->taskProcessingManager->getUserTasks($this->userId, $taskType, $customId);
-			$json = array_map(static function (Task $task) {
-				return $task->jsonSerialize();
-			}, $tasks);
-
-			return new DataResponse([
-				'tasks' => $json,
-			]);
-		} catch (Exception) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * Returns the contents of a file referenced in a task
-	 *
-	 * @param int $taskId The id of the task
-	 * @param int $fileId The file id of the file to retrieve
-	 * @return StreamResponse<Http::STATUS_OK, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
-	 *
-	 * 200: File content returned
-	 * 404: Task or file not found
-	 */
-	#[NoAdminRequired]
-	#[NoCSRFRequired]
-	#[ApiRoute(verb: 'GET', url: '/tasks/{taskId}/file/{fileId}', root: '/taskprocessing')]
-	public function getFileContents(int $taskId, int $fileId): StreamResponse|DataResponse {
-		try {
-			$task = $this->taskProcessingManager->getUserTask($taskId, $this->userId);
-			return $this->getFileContentsInternal($task, $fileId);
-		} catch (NotFoundException) {
-			return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
-		} catch (LockedException) {
-			return new DataResponse(['message' => $this->l->t('Node is locked')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		} catch (Exception) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * Returns the contents of a file referenced in a task(ExApp route version)
-	 *
-	 * @param int $taskId The id of the task
-	 * @param int $fileId The file id of the file to retrieve
-	 * @return StreamResponse<Http::STATUS_OK, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
-	 *
-	 * 200: File content returned
-	 * 404: Task or file not found
-	 */
-	#[ExAppRequired]
-	#[ApiRoute(verb: 'GET', url: '/tasks_provider/{taskId}/file/{fileId}', root: '/taskprocessing')]
-	public function getFileContentsExApp(int $taskId, int $fileId): StreamResponse|DataResponse {
-		try {
-			$task = $this->taskProcessingManager->getTask($taskId);
-			return $this->getFileContentsInternal($task, $fileId);
-		} catch (NotFoundException) {
-			return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
-		} catch (LockedException) {
-			return new DataResponse(['message' => $this->l->t('Node is locked')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		} catch (Exception) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * Upload a file so it can be referenced in a task result (ExApp route version)
-	 *
-	 * Use field 'file' for the file upload
-	 *
-	 * @param int $taskId The id of the task
-	 * @return DataResponse<Http::STATUS_CREATED, array{fileId: int}, array{}>|DataResponse<Http::STATUS_BAD_REQUEST|Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
-	 *
-	 * 201: File created
-	 * 400: File upload failed or no file was uploaded
-	 * 404: Task not found
-	 */
-	#[ExAppRequired]
-	#[ApiRoute(verb: 'POST', url: '/tasks_provider/{taskId}/file', root: '/taskprocessing')]
-	public function setFileContentsExApp(int $taskId): DataResponse {
-		try {
-			$task = $this->taskProcessingManager->getTask($taskId);
-			$file = $this->request->getUploadedFile('file');
-			if (!isset($file['tmp_name'])) {
-				return new DataResponse(['message' => $this->l->t('Bad request')], Http::STATUS_BAD_REQUEST);
-			}
-			$handle = fopen($file['tmp_name'], 'r');
-			if (!$handle) {
-				return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-			}
-			$fileId = $this->setFileContentsInternal($handle);
-			return new DataResponse(['fileId' => $fileId], Http::STATUS_CREATED);
-		} catch (NotFoundException) {
-			return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
-		} catch (Exception) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * @throws NotPermittedException
-	 * @throws NotFoundException
-	 * @throws LockedException
-	 *
-	 * @return StreamResponse<Http::STATUS_OK, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
-	 */
-	private function getFileContentsInternal(Task $task, int $fileId): StreamResponse|DataResponse {
-		$ids = $this->taskProcessingManager->extractFileIdsFromTask($task);
-		if (!in_array($fileId, $ids)) {
-			return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
-		}
-		if ($task->getUserId() !== null) {
-			\OC_Util::setupFS($task->getUserId());
-		}
-		$node = $this->rootFolder->getFirstNodeById($fileId);
-		if ($node === null) {
-			$node = $this->rootFolder->getFirstNodeByIdInPath($fileId, '/' . $this->rootFolder->getAppDataDirectoryName() . '/');
-			if (!$node instanceof File) {
-				throw new NotFoundException('Node is not a file');
-			}
-		} elseif (!$node instanceof File) {
-			throw new NotFoundException('Node is not a file');
-		}
-
-		$contentType = $node->getMimeType();
-		if (function_exists('mime_content_type')) {
-			$mimeType = mime_content_type($node->fopen('rb'));
-			if ($mimeType !== false) {
-				$mimeType = $this->mimeTypeDetector->getSecureMimeType($mimeType);
-				if ($mimeType !== 'application/octet-stream') {
-					$contentType = $mimeType;
-				}
-			}
-		}
-
-		$response = new StreamResponse($node->fopen('rb'));
-		$response->addHeader(
-			'Content-Disposition',
-			'attachment; filename="' . rawurldecode($node->getName()) . '"'
-		);
-		$response->addHeader('Content-Type', $contentType);
-		return $response;
-	}
-
-	/**
-	 * Sets the task progress
-	 *
-	 * @param int $taskId The id of the task
-	 * @param float $progress The progress
-	 * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
-	 *
-	 * 200: Progress updated successfully
-	 * 404: Task not found
-	 */
-	#[ExAppRequired]
-	#[ApiRoute(verb: 'POST', url: '/tasks_provider/{taskId}/progress', root: '/taskprocessing')]
-	public function setProgress(int $taskId, float $progress): DataResponse {
-		try {
-			$this->taskProcessingManager->setTaskProgress($taskId, $progress);
-			$task = $this->taskProcessingManager->getTask($taskId);
-
-			/** @var CoreTaskProcessingTask $json */
-			$json = $task->jsonSerialize();
-
-			return new DataResponse([
-				'task' => $json,
-			]);
-		} catch (NotFoundException) {
-			return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
-		} catch (Exception) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * Sets the task result
-	 *
-	 * @param int $taskId The id of the task
-	 * @param array<string,mixed>|null $output The resulting task output, files are represented by their IDs
-	 * @param string|null $errorMessage An error message if the task failed
-	 * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
-	 *
-	 * 200: Result updated successfully
-	 * 404: Task not found
-	 */
-	#[ExAppRequired]
-	#[ApiRoute(verb: 'POST', url: '/tasks_provider/{taskId}/result', root: '/taskprocessing')]
-	public function setResult(int $taskId, ?array $output = null, ?string $errorMessage = null): DataResponse {
-		try {
-			// set result
-			$this->taskProcessingManager->setTaskResult($taskId, $errorMessage, $output, true);
-			$task = $this->taskProcessingManager->getTask($taskId);
-
-			/** @var CoreTaskProcessingTask $json */
-			$json = $task->jsonSerialize();
-
-			return new DataResponse([
-				'task' => $json,
-			]);
-		} catch (NotFoundException) {
-			return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
-		} catch (Exception) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * Cancels a task
-	 *
-	 * @param int $taskId The id of the task
-	 * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
-	 *
-	 * 200: Task canceled successfully
-	 * 404: Task not found
-	 */
-	#[NoAdminRequired]
-	#[ApiRoute(verb: 'POST', url: '/tasks/{taskId}/cancel', root: '/taskprocessing')]
-	public function cancelTask(int $taskId): DataResponse {
-		try {
-			// Check if the current user can access the task
-			$this->taskProcessingManager->getUserTask($taskId, $this->userId);
-			// set result
-			$this->taskProcessingManager->cancelTask($taskId);
-			$task = $this->taskProcessingManager->getUserTask($taskId, $this->userId);
-
-			/** @var CoreTaskProcessingTask $json */
-			$json = $task->jsonSerialize();
-
-			return new DataResponse([
-				'task' => $json,
-			]);
-		} catch (NotFoundException) {
-			return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
-		} catch (Exception) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * Returns the next scheduled task for the taskTypeId
-	 *
-	 * @param list<string> $providerIds The ids of the providers
-	 * @param list<string> $taskTypeIds The ids of the task types
-	 * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask, provider: array{name: string}}, array{}>|DataResponse<Http::STATUS_NO_CONTENT, null, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
-	 *
-	 * 200: Task returned
-	 * 204: No task found
-	 */
-	#[ExAppRequired]
-	#[ApiRoute(verb: 'GET', url: '/tasks_provider/next', root: '/taskprocessing')]
-	public function getNextScheduledTask(array $providerIds, array $taskTypeIds): DataResponse {
-		try {
-			[$possibleProviderIds, $possibleTaskTypeIds] = $this->intersectTaskTypesAndProviders($taskTypeIds, $providerIds);
-
-			if (count($possibleProviderIds) === 0 || count($possibleTaskTypeIds) === 0) {
-				throw new NotFoundException();
-			}
-
-			$taskIdsToIgnore = [];
-			while (true) {
-				// Until we find a task whose task type is set to be provided by the providers requested with this request
-				// Or no scheduled task is found anymore (given the taskIds to ignore)
-				$task = $this->taskProcessingManager->getNextScheduledTask($possibleTaskTypeIds, $taskIdsToIgnore);
-				try {
-					$provider = $this->taskProcessingManager->getPreferredProvider($task->getTaskTypeId());
-					if (in_array($provider->getId(), $possibleProviderIds, true)) {
-						if ($this->taskProcessingManager->lockTask($task)) {
-							break;
-						}
-					}
-				} catch (Exception) {
-					// There is no provider set for the task type of this task
-					// proceed to ignore this task
-				}
-
-				$taskIdsToIgnore[] = (int)$task->getId();
-			}
-
-			/** @var CoreTaskProcessingTask $json */
-			$json = $task->jsonSerialize();
-
-			return new DataResponse([
-				'task' => $json,
-				'provider' => [
-					'name' => $provider->getId(),
-				],
-			]);
-		} catch (NotFoundException) {
-			return new DataResponse(null, Http::STATUS_NO_CONTENT);
-		} catch (Exception) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * Returns the next n scheduled tasks for the specified set of taskTypes and providers
-	 * The returned tasks are capped at ~50MiB
-	 *
-	 * @param list<string> $providerIds The ids of the providers
-	 * @param list<string> $taskTypeIds The ids of the task types
-	 * @param int $numberOfTasks The number of tasks to return
-	 * @return DataResponse<Http::STATUS_OK, array{tasks: list<array{task: CoreTaskProcessingTask, provider: string}>, has_more: bool}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
-	 *
-	 * 200: Tasks returned
-	 */
-	#[ExAppRequired]
-	#[ApiRoute(verb: 'GET', url: '/tasks_provider/next_batch', root: '/taskprocessing')]
-	public function getNextScheduledTaskBatch(array $providerIds, array $taskTypeIds, int $numberOfTasks = 1): DataResponse {
-		try {
-			[$possibleProviderIds, $possibleTaskTypeIds] = $this->intersectTaskTypesAndProviders($taskTypeIds, $providerIds);
-
-			if (count($possibleProviderIds) === 0 || count($possibleTaskTypeIds) === 0) {
-				return new DataResponse([
-					'tasks' => [],
-					'has_more' => false,
-				]);
-			}
-
-			$tasks = $this->taskProcessingManager->getNextScheduledTasks($possibleTaskTypeIds, numberOfTasks: $numberOfTasks + 1);
-			$tasksJson = [];
-			// Stop when $numberOfTasks is reached or the json payload is larger than 50MiB
-			while (count($tasks) > 0 && count($tasksJson) < $numberOfTasks && strlen(json_encode($tasks)) < 50 * 1024 * 1024) {
-				// Until we find a task whose task type is set to be provided by the providers requested with this request
-				// Or no scheduled task is found anymore (given the taskIds to ignore)
-				$task = array_shift($tasks);
-				try {
-					$provider = $this->taskProcessingManager->getPreferredProvider($task->getTaskTypeId());
-					if (in_array($provider->getId(), $possibleProviderIds, true)) {
-						if ($this->taskProcessingManager->lockTask($task)) {
-							$tasksJson[] = ['task' => $task->jsonSerialize(), 'provider' => $provider->getId()];
-							continue;
-						}
-					}
-				} catch (Exception) {
-					// There is no provider set for the task type of this task
-					// proceed to ignore this task
-				}
-			}
-			$hasMore = count($tasks) > 0;
-
-			return new DataResponse([
-				'tasks' => $tasksJson,
-				'has_more' => $hasMore,
-			]);
-		} catch (Exception) {
-			return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
-
-	/**
-	 * @param resource $data
-	 * @return int
-	 * @throws NotPermittedException
-	 */
-	private function setFileContentsInternal($data): int {
-		try {
-			$folder = $this->appData->getFolder('TaskProcessing');
-		} catch (\OCP\Files\NotFoundException) {
-			$folder = $this->appData->newFolder('TaskProcessing');
-		}
-		/** @var SimpleFile $file */
-		$file = $folder->newFile(time() . '-' . rand(1, 100000), $data);
-		return $file->getId();
-	}
-
-	/**
-	 * @param array $taskTypeIds
-	 * @param array $providerIds
-	 * @return array
-	 */
-	private function intersectTaskTypesAndProviders(array $taskTypeIds, array $providerIds): array {
-		$providerIdsBasedOnTaskTypesWithNull = array_unique(array_map(function ($taskTypeId) {
-			try {
-				return $this->taskProcessingManager->getPreferredProvider($taskTypeId)->getId();
-			} catch (Exception) {
-				return null;
-			}
-		}, $taskTypeIds));
-
-		$providerIdsBasedOnTaskTypes = array_filter($providerIdsBasedOnTaskTypesWithNull, fn ($providerId) => $providerId !== null);
-
-		// restrict $providerIds to providers that are configured as preferred for the passed task types
-		$possibleProviderIds = array_values(array_intersect($providerIdsBasedOnTaskTypes, $providerIds));
-
-		// restrict $taskTypeIds to task types that can actually be run by one of the now restricted providers
-		$possibleTaskTypeIds = array_values(array_filter($taskTypeIds, function ($taskTypeId) use ($possibleProviderIds) {
-			try {
-				$providerForTaskType = $this->taskProcessingManager->getPreferredProvider($taskTypeId)->getId();
-			} catch (Exception) {
-				// no provider found for task type
-				return false;
-			}
-			return in_array($providerForTaskType, $possibleProviderIds, true);
-		}));
-		return [$possibleProviderIds, $possibleTaskTypeIds];
-	}
+    public function __construct(
+        string $appName,
+        IRequest $request,
+        private IManager $taskProcessingManager,
+        private IL10N $l,
+        private ?string $userId,
+        private IRootFolder $rootFolder,
+        private IAppData $appData,
+        private IMimeTypeDetector $mimeTypeDetector,
+    ) {
+        parent::__construct($appName, $request);
+    }
+
+    /**
+     * Returns all available TaskProcessing task types
+     *
+     * @return DataResponse<Http::STATUS_OK, array{types: array<string, CoreTaskProcessingTaskType>}, array{}>
+     *
+     * 200: Task types returned
+     */
+    #[NoAdminRequired]
+    #[ApiRoute(verb: 'GET', url: '/tasktypes', root: '/taskprocessing')]
+    public function taskTypes(): DataResponse {
+        /** @var array<string, CoreTaskProcessingTaskType> $taskTypes */
+        $taskTypes = array_map(function (array $tt) {
+            $tt['inputShape'] = array_map(function ($descriptor) {
+                return $descriptor->jsonSerialize();
+            }, $tt['inputShape']);
+            if (empty($tt['inputShape'])) {
+                $tt['inputShape'] = new stdClass;
+            }
+
+            $tt['outputShape'] = array_map(function ($descriptor) {
+                return $descriptor->jsonSerialize();
+            }, $tt['outputShape']);
+            if (empty($tt['outputShape'])) {
+                $tt['outputShape'] = new stdClass;
+            }
+
+            $tt['optionalInputShape'] = array_map(function ($descriptor) {
+                return $descriptor->jsonSerialize();
+            }, $tt['optionalInputShape']);
+            if (empty($tt['optionalInputShape'])) {
+                $tt['optionalInputShape'] = new stdClass;
+            }
+
+            $tt['optionalOutputShape'] = array_map(function ($descriptor) {
+                return $descriptor->jsonSerialize();
+            }, $tt['optionalOutputShape']);
+            if (empty($tt['optionalOutputShape'])) {
+                $tt['optionalOutputShape'] = new stdClass;
+            }
+
+            $tt['inputShapeEnumValues'] = array_map(function (array $enumValues) {
+                return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
+            }, $tt['inputShapeEnumValues']);
+            if (empty($tt['inputShapeEnumValues'])) {
+                $tt['inputShapeEnumValues'] = new stdClass;
+            }
+
+            $tt['optionalInputShapeEnumValues'] = array_map(function (array $enumValues) {
+                return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
+            }, $tt['optionalInputShapeEnumValues']);
+            if (empty($tt['optionalInputShapeEnumValues'])) {
+                $tt['optionalInputShapeEnumValues'] = new stdClass;
+            }
+
+            $tt['outputShapeEnumValues'] = array_map(function (array $enumValues) {
+                return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
+            }, $tt['outputShapeEnumValues']);
+            if (empty($tt['outputShapeEnumValues'])) {
+                $tt['outputShapeEnumValues'] = new stdClass;
+            }
+
+            $tt['optionalOutputShapeEnumValues'] = array_map(function (array $enumValues) {
+                return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
+            }, $tt['optionalOutputShapeEnumValues']);
+            if (empty($tt['optionalOutputShapeEnumValues'])) {
+                $tt['optionalOutputShapeEnumValues'] = new stdClass;
+            }
+
+            if (empty($tt['inputShapeDefaults'])) {
+                $tt['inputShapeDefaults'] = new stdClass;
+            }
+            if (empty($tt['optionalInputShapeDefaults'])) {
+                $tt['optionalInputShapeDefaults'] = new stdClass;
+            }
+            return $tt;
+        }, $this->taskProcessingManager->getAvailableTaskTypes());
+        return new DataResponse([
+            'types' => $taskTypes,
+        ]);
+    }
+
+    /**
+     * Schedules a task
+     *
+     * @param array<string, mixed> $input Task's input parameters
+     * @param string $type Type of the task
+     * @param string $appId ID of the app that will execute the task
+     * @param string $customId An arbitrary identifier for the task
+     * @param string|null $webhookUri URI to be requested when the task finishes
+     * @param string|null $webhookMethod Method used for the webhook request (HTTP:GET, HTTP:POST, HTTP:PUT, HTTP:DELETE or AppAPI:APP_ID:GET, AppAPI:APP_ID:POST...)
+     * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_BAD_REQUEST|Http::STATUS_PRECONDITION_FAILED|Http::STATUS_UNAUTHORIZED, array{message: string}, array{}>
+     *
+     * 200: Task scheduled successfully
+     * 400: Scheduling task is not possible
+     * 412: Scheduling task is not possible
+     * 401: Cannot schedule task because it references files in its input that the user doesn't have access to
+     */
+    #[UserRateLimit(limit: 20, period: 120)]
+    #[NoAdminRequired]
+    #[ApiRoute(verb: 'POST', url: '/schedule', root: '/taskprocessing')]
+    public function schedule(
+        array $input, string $type, string $appId, string $customId = '',
+        ?string $webhookUri = null, ?string $webhookMethod = null,
+    ): DataResponse {
+        $task = new Task($type, $input, $appId, $this->userId, $customId);
+        $task->setWebhookUri($webhookUri);
+        $task->setWebhookMethod($webhookMethod);
+        try {
+            $this->taskProcessingManager->scheduleTask($task);
+
+            /** @var CoreTaskProcessingTask $json */
+            $json = $task->jsonSerialize();
+
+            return new DataResponse([
+                'task' => $json,
+            ]);
+        } catch (PreConditionNotMetException) {
+            return new DataResponse(['message' => $this->l->t('The given provider is not available')], Http::STATUS_PRECONDITION_FAILED);
+        } catch (ValidationException $e) {
+            return new DataResponse(['message' => $e->getMessage()], Http::STATUS_BAD_REQUEST);
+        } catch (UnauthorizedException) {
+            return new DataResponse(['message' => 'User does not have access to the files mentioned in the task input'], Http::STATUS_UNAUTHORIZED);
+        } catch (Exception) {
+            return new DataResponse(['message' => 'Internal server error'], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * Gets a task including status and result
+     *
+     * Tasks are removed 1 week after receiving their last update
+     *
+     * @param int $id The id of the task
+     *
+     * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask}, array{}>|DataResponse<Http::STATUS_NOT_FOUND|Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
+     *
+     * 200: Task returned
+     * 404: Task not found
+     */
+    #[NoAdminRequired]
+    #[ApiRoute(verb: 'GET', url: '/task/{id}', root: '/taskprocessing')]
+    public function getTask(int $id): DataResponse {
+        try {
+            $task = $this->taskProcessingManager->getUserTask($id, $this->userId);
+
+            /** @var CoreTaskProcessingTask $json */
+            $json = $task->jsonSerialize();
+
+            return new DataResponse([
+                'task' => $json,
+            ]);
+        } catch (NotFoundException) {
+            return new DataResponse(['message' => $this->l->t('Task not found')], Http::STATUS_NOT_FOUND);
+        } catch (RuntimeException) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * Deletes a task
+     *
+     * @param int $id The id of the task
+     *
+     * @return DataResponse<Http::STATUS_OK, null, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
+     *
+     * 200: Task deleted
+     */
+    #[NoAdminRequired]
+    #[ApiRoute(verb: 'DELETE', url: '/task/{id}', root: '/taskprocessing')]
+    public function deleteTask(int $id): DataResponse {
+        try {
+            $task = $this->taskProcessingManager->getUserTask($id, $this->userId);
+
+            $this->taskProcessingManager->deleteTask($task);
+
+            return new DataResponse(null);
+        } catch (NotFoundException) {
+            return new DataResponse(null);
+        } catch (Exception) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+
+    /**
+     * Returns tasks for the current user filtered by the appId and optional customId
+     *
+     * @param string $appId ID of the app
+     * @param string|null $customId An arbitrary identifier for the task
+     * @return DataResponse<Http::STATUS_OK, array{tasks: list<CoreTaskProcessingTask>}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
+     *
+     * 200: Tasks returned
+     */
+    #[NoAdminRequired]
+    #[ApiRoute(verb: 'GET', url: '/tasks/app/{appId}', root: '/taskprocessing')]
+    public function listTasksByApp(string $appId, ?string $customId = null): DataResponse {
+        try {
+            $tasks = $this->taskProcessingManager->getUserTasksByApp($this->userId, $appId, $customId);
+            $json = array_map(static function (Task $task) {
+                return $task->jsonSerialize();
+            }, $tasks);
+
+            return new DataResponse([
+                'tasks' => $json,
+            ]);
+        } catch (Exception) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * Returns tasks for the current user filtered by the optional taskType and optional customId
+     *
+     * @param string|null $taskType The task type to filter by
+     * @param string|null $customId An arbitrary identifier for the task
+     * @return DataResponse<Http::STATUS_OK, array{tasks: list<CoreTaskProcessingTask>}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
+     *
+     * 200: Tasks returned
+     */
+    #[NoAdminRequired]
+    #[ApiRoute(verb: 'GET', url: '/tasks', root: '/taskprocessing')]
+    public function listTasks(?string $taskType, ?string $customId = null): DataResponse {
+        try {
+            $tasks = $this->taskProcessingManager->getUserTasks($this->userId, $taskType, $customId);
+            $json = array_map(static function (Task $task) {
+                return $task->jsonSerialize();
+            }, $tasks);
+
+            return new DataResponse([
+                'tasks' => $json,
+            ]);
+        } catch (Exception) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * Returns the contents of a file referenced in a task
+     *
+     * @param int $taskId The id of the task
+     * @param int $fileId The file id of the file to retrieve
+     * @return StreamResponse<Http::STATUS_OK, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
+     *
+     * 200: File content returned
+     * 404: Task or file not found
+     */
+    #[NoAdminRequired]
+    #[NoCSRFRequired]
+    #[ApiRoute(verb: 'GET', url: '/tasks/{taskId}/file/{fileId}', root: '/taskprocessing')]
+    public function getFileContents(int $taskId, int $fileId): StreamResponse|DataResponse {
+        try {
+            $task = $this->taskProcessingManager->getUserTask($taskId, $this->userId);
+            return $this->getFileContentsInternal($task, $fileId);
+        } catch (NotFoundException) {
+            return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
+        } catch (LockedException) {
+            return new DataResponse(['message' => $this->l->t('Node is locked')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        } catch (Exception) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * Returns the contents of a file referenced in a task(ExApp route version)
+     *
+     * @param int $taskId The id of the task
+     * @param int $fileId The file id of the file to retrieve
+     * @return StreamResponse<Http::STATUS_OK, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
+     *
+     * 200: File content returned
+     * 404: Task or file not found
+     */
+    #[ExAppRequired]
+    #[ApiRoute(verb: 'GET', url: '/tasks_provider/{taskId}/file/{fileId}', root: '/taskprocessing')]
+    public function getFileContentsExApp(int $taskId, int $fileId): StreamResponse|DataResponse {
+        try {
+            $task = $this->taskProcessingManager->getTask($taskId);
+            return $this->getFileContentsInternal($task, $fileId);
+        } catch (NotFoundException) {
+            return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
+        } catch (LockedException) {
+            return new DataResponse(['message' => $this->l->t('Node is locked')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        } catch (Exception) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * Upload a file so it can be referenced in a task result (ExApp route version)
+     *
+     * Use field 'file' for the file upload
+     *
+     * @param int $taskId The id of the task
+     * @return DataResponse<Http::STATUS_CREATED, array{fileId: int}, array{}>|DataResponse<Http::STATUS_BAD_REQUEST|Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
+     *
+     * 201: File created
+     * 400: File upload failed or no file was uploaded
+     * 404: Task not found
+     */
+    #[ExAppRequired]
+    #[ApiRoute(verb: 'POST', url: '/tasks_provider/{taskId}/file', root: '/taskprocessing')]
+    public function setFileContentsExApp(int $taskId): DataResponse {
+        try {
+            $task = $this->taskProcessingManager->getTask($taskId);
+            $file = $this->request->getUploadedFile('file');
+            if (!isset($file['tmp_name'])) {
+                return new DataResponse(['message' => $this->l->t('Bad request')], Http::STATUS_BAD_REQUEST);
+            }
+            $handle = fopen($file['tmp_name'], 'r');
+            if (!$handle) {
+                return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+            }
+            $fileId = $this->setFileContentsInternal($handle);
+            return new DataResponse(['fileId' => $fileId], Http::STATUS_CREATED);
+        } catch (NotFoundException) {
+            return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
+        } catch (Exception) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * @throws NotPermittedException
+     * @throws NotFoundException
+     * @throws LockedException
+     *
+     * @return StreamResponse<Http::STATUS_OK, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
+     */
+    private function getFileContentsInternal(Task $task, int $fileId): StreamResponse|DataResponse {
+        $ids = $this->taskProcessingManager->extractFileIdsFromTask($task);
+        if (!in_array($fileId, $ids)) {
+            return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
+        }
+        if ($task->getUserId() !== null) {
+            \OC_Util::setupFS($task->getUserId());
+        }
+        $node = $this->rootFolder->getFirstNodeById($fileId);
+        if ($node === null) {
+            $node = $this->rootFolder->getFirstNodeByIdInPath($fileId, '/' . $this->rootFolder->getAppDataDirectoryName() . '/');
+            if (!$node instanceof File) {
+                throw new NotFoundException('Node is not a file');
+            }
+        } elseif (!$node instanceof File) {
+            throw new NotFoundException('Node is not a file');
+        }
+
+        $contentType = $node->getMimeType();
+        if (function_exists('mime_content_type')) {
+            $mimeType = mime_content_type($node->fopen('rb'));
+            if ($mimeType !== false) {
+                $mimeType = $this->mimeTypeDetector->getSecureMimeType($mimeType);
+                if ($mimeType !== 'application/octet-stream') {
+                    $contentType = $mimeType;
+                }
+            }
+        }
+
+        $response = new StreamResponse($node->fopen('rb'));
+        $response->addHeader(
+            'Content-Disposition',
+            'attachment; filename="' . rawurldecode($node->getName()) . '"'
+        );
+        $response->addHeader('Content-Type', $contentType);
+        return $response;
+    }
+
+    /**
+     * Sets the task progress
+     *
+     * @param int $taskId The id of the task
+     * @param float $progress The progress
+     * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
+     *
+     * 200: Progress updated successfully
+     * 404: Task not found
+     */
+    #[ExAppRequired]
+    #[ApiRoute(verb: 'POST', url: '/tasks_provider/{taskId}/progress', root: '/taskprocessing')]
+    public function setProgress(int $taskId, float $progress): DataResponse {
+        try {
+            $this->taskProcessingManager->setTaskProgress($taskId, $progress);
+            $task = $this->taskProcessingManager->getTask($taskId);
+
+            /** @var CoreTaskProcessingTask $json */
+            $json = $task->jsonSerialize();
+
+            return new DataResponse([
+                'task' => $json,
+            ]);
+        } catch (NotFoundException) {
+            return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
+        } catch (Exception) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * Sets the task result
+     *
+     * @param int $taskId The id of the task
+     * @param array<string,mixed>|null $output The resulting task output, files are represented by their IDs
+     * @param string|null $errorMessage An error message if the task failed
+     * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
+     *
+     * 200: Result updated successfully
+     * 404: Task not found
+     */
+    #[ExAppRequired]
+    #[ApiRoute(verb: 'POST', url: '/tasks_provider/{taskId}/result', root: '/taskprocessing')]
+    public function setResult(int $taskId, ?array $output = null, ?string $errorMessage = null): DataResponse {
+        try {
+            // set result
+            $this->taskProcessingManager->setTaskResult($taskId, $errorMessage, $output, true);
+            $task = $this->taskProcessingManager->getTask($taskId);
+
+            /** @var CoreTaskProcessingTask $json */
+            $json = $task->jsonSerialize();
+
+            return new DataResponse([
+                'task' => $json,
+            ]);
+        } catch (NotFoundException) {
+            return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
+        } catch (Exception) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * Cancels a task
+     *
+     * @param int $taskId The id of the task
+     * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
+     *
+     * 200: Task canceled successfully
+     * 404: Task not found
+     */
+    #[NoAdminRequired]
+    #[ApiRoute(verb: 'POST', url: '/tasks/{taskId}/cancel', root: '/taskprocessing')]
+    public function cancelTask(int $taskId): DataResponse {
+        try {
+            // Check if the current user can access the task
+            $this->taskProcessingManager->getUserTask($taskId, $this->userId);
+            // set result
+            $this->taskProcessingManager->cancelTask($taskId);
+            $task = $this->taskProcessingManager->getUserTask($taskId, $this->userId);
+
+            /** @var CoreTaskProcessingTask $json */
+            $json = $task->jsonSerialize();
+
+            return new DataResponse([
+                'task' => $json,
+            ]);
+        } catch (NotFoundException) {
+            return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
+        } catch (Exception) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * Returns the next scheduled task for the taskTypeId
+     *
+     * @param list<string> $providerIds The ids of the providers
+     * @param list<string> $taskTypeIds The ids of the task types
+     * @return DataResponse<Http::STATUS_OK, array{task: CoreTaskProcessingTask, provider: array{name: string}}, array{}>|DataResponse<Http::STATUS_NO_CONTENT, null, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
+     *
+     * 200: Task returned
+     * 204: No task found
+     */
+    #[ExAppRequired]
+    #[ApiRoute(verb: 'GET', url: '/tasks_provider/next', root: '/taskprocessing')]
+    public function getNextScheduledTask(array $providerIds, array $taskTypeIds): DataResponse {
+        try {
+            [$possibleProviderIds, $possibleTaskTypeIds] = $this->intersectTaskTypesAndProviders($taskTypeIds, $providerIds);
+
+            if (count($possibleProviderIds) === 0 || count($possibleTaskTypeIds) === 0) {
+                throw new NotFoundException();
+            }
+
+            $taskIdsToIgnore = [];
+            while (true) {
+                // Until we find a task whose task type is set to be provided by the providers requested with this request
+                // Or no scheduled task is found anymore (given the taskIds to ignore)
+                $task = $this->taskProcessingManager->getNextScheduledTask($possibleTaskTypeIds, $taskIdsToIgnore);
+                try {
+                    $provider = $this->taskProcessingManager->getPreferredProvider($task->getTaskTypeId());
+                    if (in_array($provider->getId(), $possibleProviderIds, true)) {
+                        if ($this->taskProcessingManager->lockTask($task)) {
+                            break;
+                        }
+                    }
+                } catch (Exception) {
+                    // There is no provider set for the task type of this task
+                    // proceed to ignore this task
+                }
+
+                $taskIdsToIgnore[] = (int)$task->getId();
+            }
+
+            /** @var CoreTaskProcessingTask $json */
+            $json = $task->jsonSerialize();
+
+            return new DataResponse([
+                'task' => $json,
+                'provider' => [
+                    'name' => $provider->getId(),
+                ],
+            ]);
+        } catch (NotFoundException) {
+            return new DataResponse(null, Http::STATUS_NO_CONTENT);
+        } catch (Exception) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * Returns the next n scheduled tasks for the specified set of taskTypes and providers
+     * The returned tasks are capped at ~50MiB
+     *
+     * @param list<string> $providerIds The ids of the providers
+     * @param list<string> $taskTypeIds The ids of the task types
+     * @param int $numberOfTasks The number of tasks to return
+     * @return DataResponse<Http::STATUS_OK, array{tasks: list<array{task: CoreTaskProcessingTask, provider: string}>, has_more: bool}, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR, array{message: string}, array{}>
+     *
+     * 200: Tasks returned
+     */
+    #[ExAppRequired]
+    #[ApiRoute(verb: 'GET', url: '/tasks_provider/next_batch', root: '/taskprocessing')]
+    public function getNextScheduledTaskBatch(array $providerIds, array $taskTypeIds, int $numberOfTasks = 1): DataResponse {
+        try {
+            [$possibleProviderIds, $possibleTaskTypeIds] = $this->intersectTaskTypesAndProviders($taskTypeIds, $providerIds);
+
+            if (count($possibleProviderIds) === 0 || count($possibleTaskTypeIds) === 0) {
+                return new DataResponse([
+                    'tasks' => [],
+                    'has_more' => false,
+                ]);
+            }
+
+            $tasks = $this->taskProcessingManager->getNextScheduledTasks($possibleTaskTypeIds, numberOfTasks: $numberOfTasks + 1);
+            $tasksJson = [];
+            // Stop when $numberOfTasks is reached or the json payload is larger than 50MiB
+            while (count($tasks) > 0 && count($tasksJson) < $numberOfTasks && strlen(json_encode($tasks)) < 50 * 1024 * 1024) {
+                // Until we find a task whose task type is set to be provided by the providers requested with this request
+                // Or no scheduled task is found anymore (given the taskIds to ignore)
+                $task = array_shift($tasks);
+                try {
+                    $provider = $this->taskProcessingManager->getPreferredProvider($task->getTaskTypeId());
+                    if (in_array($provider->getId(), $possibleProviderIds, true)) {
+                        if ($this->taskProcessingManager->lockTask($task)) {
+                            $tasksJson[] = ['task' => $task->jsonSerialize(), 'provider' => $provider->getId()];
+                            continue;
+                        }
+                    }
+                } catch (Exception) {
+                    // There is no provider set for the task type of this task
+                    // proceed to ignore this task
+                }
+            }
+            $hasMore = count($tasks) > 0;
+
+            return new DataResponse([
+                'tasks' => $tasksJson,
+                'has_more' => $hasMore,
+            ]);
+        } catch (Exception) {
+            return new DataResponse(['message' => $this->l->t('Internal error')], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
+
+    /**
+     * @param resource $data
+     * @return int
+     * @throws NotPermittedException
+     */
+    private function setFileContentsInternal($data): int {
+        try {
+            $folder = $this->appData->getFolder('TaskProcessing');
+        } catch (\OCP\Files\NotFoundException) {
+            $folder = $this->appData->newFolder('TaskProcessing');
+        }
+        /** @var SimpleFile $file */
+        $file = $folder->newFile(time() . '-' . rand(1, 100000), $data);
+        return $file->getId();
+    }
+
+    /**
+     * @param array $taskTypeIds
+     * @param array $providerIds
+     * @return array
+     */
+    private function intersectTaskTypesAndProviders(array $taskTypeIds, array $providerIds): array {
+        $providerIdsBasedOnTaskTypesWithNull = array_unique(array_map(function ($taskTypeId) {
+            try {
+                return $this->taskProcessingManager->getPreferredProvider($taskTypeId)->getId();
+            } catch (Exception) {
+                return null;
+            }
+        }, $taskTypeIds));
+
+        $providerIdsBasedOnTaskTypes = array_filter($providerIdsBasedOnTaskTypesWithNull, fn ($providerId) => $providerId !== null);
+
+        // restrict $providerIds to providers that are configured as preferred for the passed task types
+        $possibleProviderIds = array_values(array_intersect($providerIdsBasedOnTaskTypes, $providerIds));
+
+        // restrict $taskTypeIds to task types that can actually be run by one of the now restricted providers
+        $possibleTaskTypeIds = array_values(array_filter($taskTypeIds, function ($taskTypeId) use ($possibleProviderIds) {
+            try {
+                $providerForTaskType = $this->taskProcessingManager->getPreferredProvider($taskTypeId)->getId();
+            } catch (Exception) {
+                // no provider found for task type
+                return false;
+            }
+            return in_array($providerForTaskType, $possibleProviderIds, true);
+        }));
+        return [$possibleProviderIds, $possibleTaskTypeIds];
+    }
 }

Spacing +20 added lines, -20 removed lines

@@ -69,57 +69,57 @@ 
 	#[ApiRoute(verb: 'GET', url: '/tasktypes', root: '/taskprocessing')]
 	public function taskTypes(): DataResponse {
 		/** @var array<string, CoreTaskProcessingTaskType> $taskTypes */
-		$taskTypes = array_map(function (array $tt) {
-			$tt['inputShape'] = array_map(function ($descriptor) {
+		$taskTypes = array_map(function(array $tt) {
+			$tt['inputShape'] = array_map(function($descriptor) {
 				return $descriptor->jsonSerialize();
 			}, $tt['inputShape']);
 			if (empty($tt['inputShape'])) {
 				$tt['inputShape'] = new stdClass;
 			}
 
-			$tt['outputShape'] = array_map(function ($descriptor) {
+			$tt['outputShape'] = array_map(function($descriptor) {
 				return $descriptor->jsonSerialize();
 			}, $tt['outputShape']);
 			if (empty($tt['outputShape'])) {
 				$tt['outputShape'] = new stdClass;
 			}
 
-			$tt['optionalInputShape'] = array_map(function ($descriptor) {
+			$tt['optionalInputShape'] = array_map(function($descriptor) {
 				return $descriptor->jsonSerialize();
 			}, $tt['optionalInputShape']);
 			if (empty($tt['optionalInputShape'])) {
 				$tt['optionalInputShape'] = new stdClass;
 			}
 
-			$tt['optionalOutputShape'] = array_map(function ($descriptor) {
+			$tt['optionalOutputShape'] = array_map(function($descriptor) {
 				return $descriptor->jsonSerialize();
 			}, $tt['optionalOutputShape']);
 			if (empty($tt['optionalOutputShape'])) {
 				$tt['optionalOutputShape'] = new stdClass;
 			}
 
-			$tt['inputShapeEnumValues'] = array_map(function (array $enumValues) {
+			$tt['inputShapeEnumValues'] = array_map(function(array $enumValues) {
 				return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
 			}, $tt['inputShapeEnumValues']);
 			if (empty($tt['inputShapeEnumValues'])) {
 				$tt['inputShapeEnumValues'] = new stdClass;
 			}
 
-			$tt['optionalInputShapeEnumValues'] = array_map(function (array $enumValues) {
+			$tt['optionalInputShapeEnumValues'] = array_map(function(array $enumValues) {
 				return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
 			}, $tt['optionalInputShapeEnumValues']);
 			if (empty($tt['optionalInputShapeEnumValues'])) {
 				$tt['optionalInputShapeEnumValues'] = new stdClass;
 			}
 
-			$tt['outputShapeEnumValues'] = array_map(function (array $enumValues) {
+			$tt['outputShapeEnumValues'] = array_map(function(array $enumValues) {
 				return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
 			}, $tt['outputShapeEnumValues']);
 			if (empty($tt['outputShapeEnumValues'])) {
 				$tt['outputShapeEnumValues'] = new stdClass;
 			}
 
-			$tt['optionalOutputShapeEnumValues'] = array_map(function (array $enumValues) {
+			$tt['optionalOutputShapeEnumValues'] = array_map(function(array $enumValues) {
 				return array_map(fn (ShapeEnumValue $enumValue) => $enumValue->jsonSerialize(), $enumValues);
 			}, $tt['optionalOutputShapeEnumValues']);
 			if (empty($tt['optionalOutputShapeEnumValues'])) {
@@ -256,7 +256,7 @@ 
 	public function listTasksByApp(string $appId, ?string $customId = null): DataResponse {
 		try {
 			$tasks = $this->taskProcessingManager->getUserTasksByApp($this->userId, $appId, $customId);
-			$json = array_map(static function (Task $task) {
+			$json = array_map(static function(Task $task) {
 				return $task->jsonSerialize();
 			}, $tasks);
 
@@ -282,7 +282,7 @@ 
 	public function listTasks(?string $taskType, ?string $customId = null): DataResponse {
 		try {
 			$tasks = $this->taskProcessingManager->getUserTasks($this->userId, $taskType, $customId);
-			$json = array_map(static function (Task $task) {
+			$json = array_map(static function(Task $task) {
 				return $task->jsonSerialize();
 			}, $tasks);
 
@@ -307,7 +307,7 @@ 
 	#[NoAdminRequired]
 	#[NoCSRFRequired]
 	#[ApiRoute(verb: 'GET', url: '/tasks/{taskId}/file/{fileId}', root: '/taskprocessing')]
-	public function getFileContents(int $taskId, int $fileId): StreamResponse|DataResponse {
+	public function getFileContents(int $taskId, int $fileId): StreamResponse | DataResponse {
 		try {
 			$task = $this->taskProcessingManager->getUserTask($taskId, $this->userId);
 			return $this->getFileContentsInternal($task, $fileId);
@@ -332,7 +332,7 @@ 
 	 */
 	#[ExAppRequired]
 	#[ApiRoute(verb: 'GET', url: '/tasks_provider/{taskId}/file/{fileId}', root: '/taskprocessing')]
-	public function getFileContentsExApp(int $taskId, int $fileId): StreamResponse|DataResponse {
+	public function getFileContentsExApp(int $taskId, int $fileId): StreamResponse | DataResponse {
 		try {
 			$task = $this->taskProcessingManager->getTask($taskId);
 			return $this->getFileContentsInternal($task, $fileId);
@@ -386,7 +386,7 @@ 
 	 *
 	 * @return StreamResponse<Http::STATUS_OK, array{}>|DataResponse<Http::STATUS_INTERNAL_SERVER_ERROR|Http::STATUS_NOT_FOUND, array{message: string}, array{}>
 	 */
-	private function getFileContentsInternal(Task $task, int $fileId): StreamResponse|DataResponse {
+	private function getFileContentsInternal(Task $task, int $fileId): StreamResponse | DataResponse {
 		$ids = $this->taskProcessingManager->extractFileIdsFromTask($task);
 		if (!in_array($fileId, $ids)) {
 			return new DataResponse(['message' => $this->l->t('Not found')], Http::STATUS_NOT_FOUND);
@@ -396,7 +396,7 @@ 
 		}
 		$node = $this->rootFolder->getFirstNodeById($fileId);
 		if ($node === null) {
-			$node = $this->rootFolder->getFirstNodeByIdInPath($fileId, '/' . $this->rootFolder->getAppDataDirectoryName() . '/');
+			$node = $this->rootFolder->getFirstNodeByIdInPath($fileId, '/'.$this->rootFolder->getAppDataDirectoryName().'/');
 			if (!$node instanceof File) {
 				throw new NotFoundException('Node is not a file');
 			}
@@ -418,7 +418,7 @@ 
 		$response = new StreamResponse($node->fopen('rb'));
 		$response->addHeader(
 			'Content-Disposition',
-			'attachment; filename="' . rawurldecode($node->getName()) . '"'
+			'attachment; filename="'.rawurldecode($node->getName()).'"'
 		);
 		$response->addHeader('Content-Type', $contentType);
 		return $response;
@@ -555,7 +555,7 @@ 
 					// proceed to ignore this task
 				}
 
-				$taskIdsToIgnore[] = (int)$task->getId();
+				$taskIdsToIgnore[] = (int) $task->getId();
 			}
 
 			/** @var CoreTaskProcessingTask $json */
@@ -641,7 +641,7 @@ 
 			$folder = $this->appData->newFolder('TaskProcessing');
 		}
 		/** @var SimpleFile $file */
-		$file = $folder->newFile(time() . '-' . rand(1, 100000), $data);
+		$file = $folder->newFile(time().'-'.rand(1, 100000), $data);
 		return $file->getId();
 	}
 
@@ -651,7 +651,7 @@ 
 	 * @return array
 	 */
 	private function intersectTaskTypesAndProviders(array $taskTypeIds, array $providerIds): array {
-		$providerIdsBasedOnTaskTypesWithNull = array_unique(array_map(function ($taskTypeId) {
+		$providerIdsBasedOnTaskTypesWithNull = array_unique(array_map(function($taskTypeId) {
 			try {
 				return $this->taskProcessingManager->getPreferredProvider($taskTypeId)->getId();
 			} catch (Exception) {
@@ -665,7 +665,7 @@ 
 		$possibleProviderIds = array_values(array_intersect($providerIdsBasedOnTaskTypes, $providerIds));
 
 		// restrict $taskTypeIds to task types that can actually be run by one of the now restricted providers
-		$possibleTaskTypeIds = array_values(array_filter($taskTypeIds, function ($taskTypeId) use ($possibleProviderIds) {
+		$possibleTaskTypeIds = array_values(array_filter($taskTypeIds, function($taskTypeId) use ($possibleProviderIds) {
 			try {
 				$providerForTaskType = $this->taskProcessingManager->getPreferredProvider($taskTypeId)->getId();
 			} catch (Exception) {