From 9986e02097e5c82e1bb21ba3f897b14d82a50c15 Mon Sep 17 00:00:00 2001 From: Julien Veyssier Date: Wed, 2 Aug 2023 16:47:41 +0200 Subject: start implementing ocs endpoint to get task list from user+appId+identifier Signed-off-by: Julien Veyssier --- lib/private/TextProcessing/Db/TaskMapper.php | 19 +++++++++++++++++++ lib/private/TextProcessing/Manager.php | 19 ++++++++++++++++++- 2 files changed, 37 insertions(+), 1 deletion(-) (limited to 'lib/private/TextProcessing') diff --git a/lib/private/TextProcessing/Db/TaskMapper.php b/lib/private/TextProcessing/Db/TaskMapper.php index 624efd042f7..cf78006d6d9 100644 --- a/lib/private/TextProcessing/Db/TaskMapper.php +++ b/lib/private/TextProcessing/Db/TaskMapper.php @@ -59,6 +59,25 @@ class TaskMapper extends QBMapper { return $this->findEntity($qb); } + /** + * @param string $userId + * @param string $appId + * @param string|null $identifier + * @return array + * @throws Exception + */ + public function findByApp(string $userId, string $appId, ?string $identifier = null): array { + $qb = $this->db->getQueryBuilder(); + $qb->select(Task::$columns) + ->from($this->tableName) + ->where($qb->expr()->eq('app_id', $qb->createPositionalParameter($appId))) + ->andWhere($qb->expr()->eq('user_id', $qb->createPositionalParameter($userId))); + if ($identifier !== null) { + $qb->andWhere($qb->expr()->eq('identifier', $qb->createPositionalParameter($identifier))); + } + return $this->findEntities($qb); + } + /** * @param int $timeout * @return int the number of deleted tasks diff --git a/lib/private/TextProcessing/Manager.php b/lib/private/TextProcessing/Manager.php index 05e046a0049..da38dc876a7 100644 --- a/lib/private/TextProcessing/Manager.php +++ b/lib/private/TextProcessing/Manager.php @@ -192,7 +192,24 @@ class Manager implements IManager { } catch (MultipleObjectsReturnedException $e) { throw new RuntimeException('Could not uniquely identify task with given id', 0, $e); } catch (Exception $e) { - throw new RuntimeException('Failure while trying to find task by id: '.$e->getMessage(), 0, $e); + throw new RuntimeException('Failure while trying to find task by id: ' . $e->getMessage(), 0, $e); + } + } + + /** + * @param string $userId + * @param string $appId + * @param string|null $identifier + * @return array + */ + public function getTasksByApp(string $userId, string $appId, ?string $identifier = null): array { + try { + $taskEntities = $this->taskMapper->findByApp($userId, $appId, $identifier); + return array_map(static function (DbTask $taskEntity) { + return $taskEntity->toPublicTask(); + }, $taskEntities); + } catch (Exception $e) { + throw new RuntimeException('Failure while trying to find tasks by appId and identifier: ' . $e->getMessage(), 0, $e); } } } -- cgit v1.2.3