fix(federation): Expire messages in the PCM cache

lib/BackgroundJob/ExpireChatMessages.php

@@ -26,6 +26,7 @@
 namespace OCA\Talk\BackgroundJob;
 
 use OCA\Talk\Chat\ChatManager;
+use OCA\Talk\Service\ProxyCacheMessageService;
 use OCP\AppFramework\Utility\ITimeFactory;
 use OCP\BackgroundJob\IJob;
 use OCP\BackgroundJob\TimedJob;
@@ -35,6 +36,7 @@ class ExpireChatMessages extends TimedJob {
 	public function __construct(
 		ITimeFactory $timeFactory,
 		private ChatManager $chatManager,
+		private ProxyCacheMessageService $pcmService,
 	) {
 		parent::__construct($timeFactory);
 
@@ -48,5 +50,6 @@ public function __construct(
 	 */
 	protected function run($argument): void {
 		$this->chatManager->deleteExpiredMessages();
+		$this->pcmService->deleteExpiredMessages();
 	}
 }

lib/Model/ProxyCacheMessageMapper.php

@@ -71,4 +71,13 @@ public function findByRemote(string $remoteServerUrl, string $remoteToken, int $
 
 		return $this->findEntity($query);
 	}
+
+	public function deleteExpiredMessages(\DateTimeInterface $dateTime): int {
+		$query = $this->db->getQueryBuilder();
+		$query->delete($this->getTableName())
+			->where($query->expr()->isNotNull('expire_datetime'))
+			->andWhere($query->expr()->lte('expire_datetime', $query->createNamedParameter($dateTime, IQueryBuilder::PARAM_DATE)));
+
+		return $query->executeStatement();
+	}
 }

lib/Service/ProxyCacheMessageService.php

@@ -35,6 +35,7 @@
 use OCA\Talk\Room;
 use OCP\AppFramework\Db\DoesNotExistException;
 use OCP\AppFramework\Http;
+use OCP\AppFramework\Utility\ITimeFactory;
 use OCP\DB\Exception as DBException;
 use Psr\Log\LoggerInterface;
 
@@ -45,6 +46,7 @@ class ProxyCacheMessageService {
 	public function __construct(
 		protected ProxyCacheMessageMapper $mapper,
 		protected LoggerInterface $logger,
+		protected ITimeFactory $timeFactory,
 	) {
 	}
 
@@ -55,6 +57,10 @@ public function findByRemote(string $remoteServerUrl, string $remoteToken, int $
 		return $this->mapper->findByRemote($remoteServerUrl, $remoteToken, $remoteMessageId);
 	}
 
+	public function deleteExpiredMessages(): void {
+		$this->mapper->deleteExpiredMessages($this->timeFactory->getDateTime());
+	}
+
 	/**
 	 * @throws \InvalidArgumentException
 	 * @throws CannotReachRemoteException