diff --git a/lib/Migration/ResetSessionsBeforeYjs.php b/lib/Migration/ResetSessionsBeforeYjs.php index a9ad5d451..2056b4076 100644 --- a/lib/Migration/ResetSessionsBeforeYjs.php +++ b/lib/Migration/ResetSessionsBeforeYjs.php @@ -2,7 +2,7 @@ namespace OCA\Text\Migration; -use OCA\Text\Db\SessionMapper; +use OCA\Text\Db\Document; use OCA\Text\Service\DocumentService; use OCP\IConfig; use OCP\Migration\IOutput; @@ -25,31 +25,28 @@ class ResetSessionsBeforeYjs implements IRepairStep { * @return string */ public function getName(): string { - return 'Force-reset all Text sessions before Yjs migration'; + return 'Force-reset all Text document sessions'; } - /** - * @param IOutput $output - * - * @return void - */ public function run(IOutput $output): void { $appVersion = $this->config->getAppValue('text', 'installed_version'); - if (!$appVersion || version_compare($appVersion, '3.7.2') !== -1) { + if (!$appVersion || version_compare($appVersion, '4.0.1') !== -1) { return; } - $sessions = $this->sessionMapper->findAllDocuments(); - if (!$sessions) { + $fileIds = array_map(static function (Document $document) { + return $document->getId(); + }, $this->documentService->getAll()); + + if (!$fileIds) { return; } - $output->startProgress(count($sessions)); - foreach ($sessions as $session) { - $documentId = $session->getDocumentId(); - $this->documentService->unlock($documentId); - $this->documentService->resetDocument($documentId, true); + $output->startProgress(count($fileIds)); + foreach ($fileIds as $fileId) { + $this->documentService->unlock($fileId); + $this->documentService->resetDocument($fileId, true); $output->advance(); } $output->finishProgress();