feat: error handling

Signed-off-by: Jana Peper <[email protected]>

Author: janepie

apps/webhook_listeners/lib/Db/EphemeralTokenMapper.php

@@ -52,7 +52,7 @@ public function getById(int $id): EphemeralToken {
 	}
 
 	/**
-	 * @throws \Exception
+	 * @throws Exception
 	 * @return EphemeralToken[]
 	 */
 	public function getAll(): array {
@@ -64,6 +64,12 @@ public function getAll(): array {
 		return $this->findEntities($qb);
 	}
 
+
+	/**
+	 * @param int $olderThan
+	 * @return EphemeralToken[]
+	 * @throws Exception
+	 */
 	public function getOlderThan($olderThan): array {
 		$qb = $this->db->getQueryBuilder();
 
@@ -106,12 +112,24 @@ public function deleteByTokenId(int $tokenId): bool {
 
 	public function invalidateOldTokens(int $token_lifetime = self::TOKEN_LIFETIME) {
 		$olderThan = $this->time->getTime() - $token_lifetime;
-		$tokensToDelete = $this->getOlderThan($olderThan);
+		try{
+			$tokensToDelete = $this->getOlderThan($olderThan);
+		}
+		catch(Exception $e){
+			$this->logger->error('Webhook token deletion failed: ' . $e->getMessage(), ['exception' => $e]);
+			return;
+		}
+		
 
 		$this->logger->debug('Invalidating ephemeral webhook tokens older than ' . date('c', $olderThan), ['app' => 'webhook_listeners']);
 		foreach ($tokensToDelete as $token) {
-			$this->tokenMapper->invalidate($this->tokenMapper->getTokenById($token->getTokenId())->getToken()); // delete token itself
-			$this->deleteByTokenId($token->getTokenId()); // delete db row in webhook_tokens
+			try {
+				$this->tokenMapper->invalidate($this->tokenMapper->getTokenById($token->getTokenId())->getToken()); // delete token itself
+				$this->deleteByTokenId($token->getTokenId()); // delete db row in webhook_tokens
+			} catch (Exception $e) {
+				$this->logger->error('Webhook token deletion failed: ' . $e->getMessage(), ['exception' => $e]);
+			}
+
 		}
 	}
 }

apps/webhook_listeners/lib/Service/TokenService.php

@@ -18,12 +18,14 @@
 use OCP\IUserManager;
 use OCP\L10N\IFactory;
 use OCP\Security\ISecureRandom;
+use Psr\Log\LoggerInterface;
 
 class TokenService {
 	public function __construct(
 		private IProvider $tokenProvider,
 		private ISecureRandom $random,
 		private EphemeralTokenMapper $tokenMapper,
+		private LoggerInterface $logger,
 		private ITimeFactory $time,
 		private IFactory $l10nFactory,
 		private IUserManager $userManager,
@@ -49,7 +51,12 @@ public function getTokens(WebhookListener $webhookListener, ?string $triggerUser
 		$tokenNeeded = $webhookListener->getTokenNeeded();
 		if (isset($tokenNeeded['user_ids'])) {
 			foreach ($tokenNeeded['user_ids'] as $userId) {
-				$tokens['user_ids'][$userId] = $this->createEphemeralToken($userId);
+				try {
+					$tokens['user_ids'][$userId] = $this->createEphemeralToken($userId);
+				} catch (\Exception $e) {
+					$this->logger->error('Webhook token creation for user ' . $userId . ' failed: ' . $e->getMessage(), ['exception' => $e]);
+				}
+
 			}
 		}
 		if (isset($tokenNeeded['user_roles'])) {
@@ -74,6 +81,9 @@ public function getTokens(WebhookListener $webhookListener, ?string $triggerUser
 							$triggerUserId => $this->createEphemeralToken($triggerUserId)
 						];
 						break;
+					default:
+						$this->logger->error('Webhook token creation for user role ' . $function . ' not defined. ' . $e->getMessage(), ['exception' => $e]);
+
 				}
 			}
 		}