Skip to content

Commit 8705727

Browse files
committed
fix(files_versions): Improve files version listing
Signed-off-by: Louis Chemineau <louis@chmn.me>
1 parent 1e9f438 commit 8705727

1 file changed

Lines changed: 50 additions & 43 deletions

File tree

apps/files_versions/lib/Versions/LegacyVersionsBackend.php

Lines changed: 50 additions & 43 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
* along with this program. If not, see <http://www.gnu.org/licenses/>.
2525
*
2626
*/
27+
2728
namespace OCA\Files_Versions\Versions;
2829

2930
use OC\Files\View;
@@ -102,64 +103,70 @@ public function getVersionsForFile(IUser $user, FileInfo $file): array {
102103
throw new NotFoundException("File not found ($fileId)");
103104
}
104105

105-
$versions = $this->getVersionsForFileFromDB($file, $user);
106-
107-
// Early exit if we find any version in the database.
108-
// Else we continue to populate the DB from what's on disk.
109-
if (count($versions) > 0) {
110-
return $versions;
111-
}
112-
113-
// Insert the entry in the DB for the current version.
114-
$versionEntity = new VersionEntity();
115-
$versionEntity->setFileId($fileId);
116-
$versionEntity->setTimestamp($file->getMTime());
117-
$versionEntity->setSize($file->getSize());
118-
$versionEntity->setMimetype($this->mimeTypeLoader->getId($file->getMimetype()));
119-
$versionEntity->setMetadata([]);
120-
$this->versionsMapper->insert($versionEntity);
121-
122106
// Insert entries in the DB for existing versions.
123107
$relativePath = $userFolder->getRelativePath($file->getPath());
124108
if ($relativePath === null) {
125109
throw new NotFoundException("Relative path not found for file $fileId (" . $file->getPath() . ')');
126110
}
127111

128-
$versionsOnFS = Storage::getVersions($user->getUID(), $relativePath);
129-
foreach ($versionsOnFS as $version) {
130-
$versionEntity = new VersionEntity();
131-
$versionEntity->setFileId($fileId);
132-
$versionEntity->setTimestamp((int)$version['version']);
133-
$versionEntity->setSize((int)$version['size']);
134-
$versionEntity->setMimetype($this->mimeTypeLoader->getId($version['mimetype']));
135-
$versionEntity->setMetadata([]);
136-
$this->versionsMapper->insert($versionEntity);
112+
$currentVersion = [
113+
'version' => (string)$file->getMtime(),
114+
'size' => $file->getSize(),
115+
'mimetype' => $file->getMimetype(),
116+
];
117+
118+
$versionsInDB = $this->versionsMapper->findAllVersionsForFileId($file->getId());
119+
/** @var array<int, array> */
120+
$versionsInFS = array_values(Storage::getVersions($user->getUID(), $relativePath));
121+
122+
/** @var array<int, array{db: ?VersionEntity, fs: ?mixed}> */
123+
$groupedVersions = [];
124+
$davVersions = [];
125+
126+
foreach ($versionsInDB as $version) {
127+
$revisionId = $version->getTimestamp();
128+
$groupedVersions[$revisionId] = $groupedVersions[$revisionId] ?? [];
129+
$groupedVersions[$revisionId]['db'] = $version;
137130
}
138131

139-
return $this->getVersionsForFileFromDB($file, $user);
140-
}
132+
foreach ([$currentVersion, ...$versionsInFS] as $version) {
133+
$revisionId = $version['version'];
134+
$groupedVersions[$revisionId] = $groupedVersions[$revisionId] ?? [];
135+
$groupedVersions[$revisionId]['fs'] = $version;
136+
}
141137

142-
/**
143-
* @return IVersion[]
144-
*/
145-
private function getVersionsForFileFromDB(FileInfo $file, IUser $user): array {
146-
$userFolder = $this->rootFolder->getUserFolder($user->getUID());
138+
/** @var array<string, array{db: ?VersionEntity, fs: ?mixed}> $groupedVersions */
139+
foreach ($groupedVersions as $versions) {
140+
if (empty($versions['db']) && !empty($versions['fs'])) {
141+
$versions['db'] = new VersionEntity();
142+
$versions['db']->setFileId($fileId);
143+
$versions['db']->setTimestamp((int)$versions['fs']['version']);
144+
$versions['db']->setSize((int)$versions['fs']['size']);
145+
$versions['db']->setMimetype($this->mimeTypeLoader->getId($versions['fs']['mimetype']));
146+
$versions['db']->setMetadata([]);
147+
$this->versionsMapper->insert($versions['db']);
148+
} elseif (!empty($versions['db']) && empty($versions['fs'])) {
149+
$this->versionsMapper->delete($versions['db']);
150+
continue;
151+
}
147152

148-
return array_map(
149-
fn (VersionEntity $versionEntity) => new Version(
150-
$versionEntity->getTimestamp(),
151-
$versionEntity->getTimestamp(),
153+
$version = new Version(
154+
$versions['db']->getTimestamp(),
155+
$versions['db']->getTimestamp(),
152156
$file->getName(),
153-
$versionEntity->getSize(),
154-
$this->mimeTypeLoader->getMimetypeById($versionEntity->getMimetype()),
157+
$versions['db']->getSize(),
158+
$this->mimeTypeLoader->getMimetypeById($versions['db']->getMimetype()),
155159
$userFolder->getRelativePath($file->getPath()),
156160
$file,
157161
$this,
158162
$user,
159-
$versionEntity->getLabel(),
160-
),
161-
$this->versionsMapper->findAllVersionsForFileId($file->getId())
162-
);
163+
$versions['db']->getLabel(),
164+
);
165+
166+
array_push($davVersions, $version);
167+
}
168+
169+
return $davVersions;
163170
}
164171

165172
public function createVersion(IUser $user, FileInfo $file) {

0 commit comments

Comments
 (0)