move task processing provider and task type from https://github.com/nextcloud/slide_deck_generator

Signed-off-by: Julien Veyssier <[email protected]>

Author: julien-nc

lib/AppInfo/Application.php

@@ -32,6 +32,8 @@
 use OCA\Richdocuments\Preview\OpenDocument;
 use OCA\Richdocuments\Preview\Pdf;
 use OCA\Richdocuments\Reference\OfficeTargetReferenceProvider;
+use OCA\Richdocuments\TaskProcessing\SlideDeckGenerationProvider;
+use OCA\Richdocuments\TaskProcessing\SlideDeckGenerationTaskType;
 use OCA\Richdocuments\Template\CollaboraTemplateProvider;
 use OCA\Viewer\Event\LoadViewer;
 use OCP\AppFramework\App;
@@ -84,6 +86,8 @@ public function register(IRegistrationContext $context): void {
 		$context->registerPreviewProvider(Pdf::class, Pdf::MIMETYPE_REGEX);
 		$context->registerFileConversionProvider(ConversionProvider::class);
 		$context->registerNotifierService(Notifier::class);
+		$context->registerTaskProcessingProvider(SlideDeckGenerationProvider::class);
+		$context->registerTaskProcessingTaskType(SlideDeckGenerationTaskType::class);
 	}
 
 	public function boot(IBootContext $context): void {

lib/Service/SlideDeckService.php

@@ -0,0 +1,72 @@
+<?php
+/**
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+namespace OCA\Richdocuments\Service;
+
+use OCA\Richdocuments\AppInfo\Application;
+use OCP\TaskProcessing\Exception\Exception;
+use OCP\TaskProcessing\Exception\NotFoundException;
+use OCP\TaskProcessing\Exception\PreConditionNotMetException;
+use OCP\TaskProcessing\Exception\UnauthorizedException;
+use OCP\TaskProcessing\Exception\ValidationException;
+use OCP\TaskProcessing\IManager;
+use OCP\TaskProcessing\Task;
+use OCP\TaskProcessing\TaskTypes\TextToText;
+use RuntimeException;
+
+class SlideDeckService {
+	public const PROMPT = <<<EOF
+Draft a presentation slide deck with headlines and a maximum of 5 bullet points per headline. Use the following JSON structure for your whole output and output only the JSON array, no introductory text:
+
+```
+[{"headline": "Headline 1", points: ["Bullet point 1", "Bullet point 2"]}, {"headline": "Headline 2", points: ["Bullet point 1", "Bullet point 2"]}]
+```
+
+Here is the presentation text:
+EOF;
+
+	public function __construct(
+		private IManager $taskProcessingManager,
+	) {
+	}
+
+	public function generateSlideDeck(?string $userId, string $presentationText) {
+		$prompt = self::PROMPT;
+		$task = new Task(
+			TextToText::ID,
+			['input' => $prompt . "\n\n" . $presentationText],
+			Application::APPNAME,
+			$userId
+		);
+		try {
+			$this->taskProcessingManager->scheduleTask($task);
+		} catch (PreConditionNotMetException|UnauthorizedException|ValidationException|Exception $e) {
+			throw new RuntimeException($e->getMessage(), $e->getCode(), $e);
+		}
+		while (true) {
+			try {
+				$task = $this->taskProcessingManager->getTask($task->getId());
+			} catch (NotFoundException|Exception $e) {
+				throw new RuntimeException($e->getMessage(), $e->getCode(), $e);
+			}
+			if (in_array($task->getStatus(), [Task::STATUS_SUCCESSFUL, Task::STATUS_FAILED, Task::STATUS_CANCELLED])) {
+				break;
+			}
+		}
+		if ($task->getStatus() !== Task::STATUS_SUCCESSFUL) {
+			throw new RuntimeException('LLM backend Task with id ' . $task->getId() . ' failed or was cancelled');
+		}
+
+		$output = $task->getOutput();
+		if (isset($output['output'])) {
+			throw new RuntimeException('LLM backend Task with id ' . $task->getId() . ' does not have output key');
+		}
+
+		$headlines = json_decode($output['output'], associative: true);
+
+		return $output['output'];
+	}
+}

lib/TaskProcessing/SlideDeckGenerationProvider.php

@@ -0,0 +1,90 @@
+<?php
+/**
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+declare(strict_types=1);
+
+namespace OCA\Richdocuments\TaskProcessing;
+
+use OCA\Richdocuments\AppInfo\Application;
+use OCA\Richdocuments\Service\SlideDeckService;
+use OCP\IL10N;
+use OCP\TaskProcessing\ISynchronousProvider;
+
+class SlideDeckGenerationProvider implements ISynchronousProvider {
+
+	public function __construct(
+		private SlideDeckService $slideDeckService,
+		private IL10N $l10n,
+	) {
+	}
+
+	public function getId(): string {
+		return Application::APPNAME . '-slide_deck_generator';
+	}
+
+	public function getName(): string {
+		return $this->l10n->t('Nextcloud Assistant Slide Deck Generator');
+	}
+
+	public function getTaskTypeId(): string {
+		return SlideDeckGenerationTaskType::ID;
+	}
+
+	public function getExpectedRuntime(): int {
+		return 120;
+	}
+
+	public function getInputShapeEnumValues(): array {
+		return [];
+	}
+
+	public function getInputShapeDefaults(): array {
+		return [];
+	}
+
+	public function getOptionalInputShape(): array {
+		return [];
+	}
+
+	public function getOptionalInputShapeEnumValues(): array {
+		return [];
+	}
+
+	public function getOptionalInputShapeDefaults(): array {
+		return [];
+	}
+
+	public function getOutputShapeEnumValues(): array {
+		return [];
+	}
+
+	public function getOptionalOutputShape(): array {
+		return [];
+	}
+
+	public function getOptionalOutputShapeEnumValues(): array {
+		return [];
+	}
+	/**
+	 * @inheritDoc
+	 */
+	public function process(?string $userId, array $input, callable $reportProgress): array {
+		if ($userId === null) {
+			throw new \RuntimeException('User ID is required to process the prompt.');
+		}
+
+		if (!isset($input['text']) || !is_string($input['text'])) {
+			throw new \RuntimeException('Invalid input, expected "text" key with string value');
+		}
+
+		$response = $this->slideDeckService->generateSlideDeck(
+			$userId,
+			$input['text'],
+		);
+
+		return $response;
+	}
+}

lib/TaskProcessing/SlideDeckGenerationTaskType.php

@@ -0,0 +1,71 @@
+<?php
+/**
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+declare(strict_types=1);
+
+namespace OCA\Richdocuments\TaskProcessing;
+
+use OCA\Richdocuments\AppInfo\Application;
+use OCP\IL10N;
+use OCP\TaskProcessing\EShapeType;
+use OCP\TaskProcessing\ITaskType;
+use OCP\TaskProcessing\ShapeDescriptor;
+
+class SlideDeckGenerationTaskType implements ITaskType {
+	public const ID = Application::APPNAME . ':slide_deck_generation';
+
+	public function __construct(
+		private IL10N $l,
+	) {
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getName(): string {
+		return $this->l->t('Generate Slide Deck');
+	}
+
+	/**
+	 * @inheritDoc
+	 */
+	public function getDescription(): string {
+		return $this->l->t('Generate a slide deck from a presentation script');
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getId(): string {
+		return self::ID;
+	}
+
+	/**
+	 * @return ShapeDescriptor[]
+	 */
+	public function getInputShape(): array {
+		return [
+			'text' => new ShapeDescriptor(
+				$this->l->t('Presentation script'),
+				$this->l->t('Write the text for your presentation here'),
+				EShapeType::Text,
+			),
+		];
+	}
+
+	/**
+	 * @return ShapeDescriptor[]
+	 */
+	public function getOutputShape(): array {
+		return [
+			'slide_deck' => new ShapeDescriptor(
+				$this->l->t('Generated slide deck'),
+				$this->l->t('The slide deck generated'),
+				EShapeType::Text,
+			),
+		];
+	}
+}