feat(taskprocessing): pass addWatermarking to ISynchronousProvider::process()

julien-nc · julien-nc · commit d43d071f3cc4 · 2025-11-26T16:07:38.000+01:00
Signed-off-by: Julien Veyssier &lt;julien-nc@posteo.net&gt;
diff --git a/lib/private/TaskProcessing/Manager.php b/lib/private/TaskProcessing/Manager.php
@@ -1039,7 +1039,7 @@ public function processTask(Task $task, ISynchronousProvider $provider): bool {
 			}
 			try {
 				$this->setTaskStatus($task, Task::STATUS_RUNNING);
-				$output = $provider->process($task->getUserId(), $input, fn (float $progress) => $this->setTaskProgress($task->getId(), $progress));
+				$output = $provider->process($task->getUserId(), $input, fn (float $progress) => $this->setTaskProgress($task->getId(), $progress), $task->getAddWatermarking());
 			} catch (ProcessingException $e) {
 				$this->logger->warning('Failed to process a TaskProcessing task with synchronous provider ' . $provider->getId(), ['exception' => $e]);
 				$userFacingErrorMessage = $e instanceof UserFacingProcessingException ? $e->getUserFacingMessage() : null;

Original file line number	Diff line number	Diff line change
`@@ -1039,7 +1039,7 @@ public function processTask(Task $task, ISynchronousProvider $provider): bool {`
`1039`	`1039`	`}`
`1040`	`1040`	`try {`
`1041`	`1041`	`$this->setTaskStatus($task, Task::STATUS_RUNNING);`
`1042`		`- $output = $provider->process($task->getUserId(), $input, fn (float $progress) => $this->setTaskProgress($task->getId(), $progress));`
	`1042`	`+ $output = $provider->process($task->getUserId(), $input, fn (float $progress) => $this->setTaskProgress($task->getId(), $progress), $task->getAddWatermarking());`
`1043`	`1043`	`} catch (ProcessingException $e) {`
`1044`	`1044`	`$this->logger->warning('Failed to process a TaskProcessing task with synchronous provider ' . $provider->getId(), ['exception' => $e]);`
`1045`	`1045`	`$userFacingErrorMessage = $e instanceof UserFacingProcessingException ? $e->getUserFacingMessage() : null;`