aboutsummaryrefslogtreecommitdiffstats
path: root/lib/private/TaskProcessing
diff options
context:
space:
mode:
authorMarcel Klehr <mklehr@gmx.net>2024-07-26 13:22:41 +0200
committerMarcel Klehr <mklehr@gmx.net>2025-01-23 11:41:06 +0100
commit4fc0369984224e45090ab12fb6f9e948c168946c (patch)
tree2c0b089ab703a7b393ad063bd145c28f39711730 /lib/private/TaskProcessing
parent108972a542b610ee7d0222189599531985a5310f (diff)
downloadnextcloud-server-fix/taskprocessing-better-errors.tar.gz
nextcloud-server-fix/taskprocessing-better-errors.zip
fix(TaskProcessing): Catch JSON encode errors in Manager#setTaskResultfix/taskprocessing-better-errors
Signed-off-by: Marcel Klehr <mklehr@gmx.net>
Diffstat (limited to 'lib/private/TaskProcessing')
-rw-r--r--lib/private/TaskProcessing/Manager.php8
1 files changed, 6 insertions, 2 deletions
diff --git a/lib/private/TaskProcessing/Manager.php b/lib/private/TaskProcessing/Manager.php
index e2047be9c2c..2f3ba02634d 100644
--- a/lib/private/TaskProcessing/Manager.php
+++ b/lib/private/TaskProcessing/Manager.php
@@ -973,7 +973,7 @@ class Manager implements IManager {
$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]);
+ $this->logger->error($error . ' Output was: ' . var_export($result, true), ['exception' => $e]);
} catch (NotPermittedException $e) {
$task->setProgress(1);
$task->setStatus(Task::STATUS_FAILED);
@@ -990,7 +990,11 @@ class Manager implements IManager {
$this->logger->error($error, ['exception' => $e]);
}
}
- $taskEntity = \OC\TaskProcessing\Db\Task::fromPublicTask($task);
+ 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);