123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189 |
- <?php
- declare(strict_types=1);
- namespace OCA\Files_Versions\Versions;
- use OCP\Files\File;
- use OCP\Files\FileInfo;
- use OCP\Files\IRootFolder;
- use OCP\Files\Lock\ILock;
- use OCP\Files\Lock\ILockManager;
- use OCP\Files\Lock\LockContext;
- use OCP\Files\Node;
- use OCP\Files\Storage\IStorage;
- use OCP\IUser;
- use OCP\Lock\ManuallyLockedException;
- class VersionManager implements IVersionManager, IDeletableVersionBackend, INeedSyncVersionBackend, IMetadataVersionBackend {
-
- private $backends = [];
- public function registerBackend(string $storageType, IVersionBackend $backend) {
- if (!isset($this->backends[$storageType])) {
- $this->backends[$storageType] = [];
- }
- $this->backends[$storageType][] = $backend;
- }
-
- private function getBackends(): array {
- return $this->backends;
- }
-
- public function getBackendForStorage(IStorage $storage): IVersionBackend {
- $fullType = get_class($storage);
- $backends = $this->getBackends();
- $foundType = '';
- $foundBackend = null;
- foreach ($backends as $type => $backendsForType) {
- if (
- $storage->instanceOfStorage($type) &&
- ($foundType === '' || is_subclass_of($type, $foundType))
- ) {
- foreach ($backendsForType as $backend) {
-
- if ($backend->useBackendForStorage($storage)) {
- $foundBackend = $backend;
- $foundType = $type;
- }
- }
- }
- }
- if ($foundType === '' || $foundBackend === null) {
- throw new BackendNotFoundException("Version backend for $fullType not found");
- } else {
- return $foundBackend;
- }
- }
- public function getVersionsForFile(IUser $user, FileInfo $file): array {
- $backend = $this->getBackendForStorage($file->getStorage());
- return $backend->getVersionsForFile($user, $file);
- }
- public function createVersion(IUser $user, FileInfo $file) {
- $backend = $this->getBackendForStorage($file->getStorage());
- $backend->createVersion($user, $file);
- }
- public function rollback(IVersion $version) {
- $backend = $version->getBackend();
- $result = self::handleAppLocks(fn (): ?bool => $backend->rollback($version));
-
- if ($result === null || $result === true) {
- \OC_Hook::emit('\OCP\Versions', 'rollback', [
- 'path' => $version->getVersionPath(),
- 'revision' => $version->getRevisionId(),
- 'node' => $version->getSourceFile(),
- ]);
- }
- return $result;
- }
- public function read(IVersion $version) {
- $backend = $version->getBackend();
- return $backend->read($version);
- }
- public function getVersionFile(IUser $user, FileInfo $sourceFile, $revision): File {
- $backend = $this->getBackendForStorage($sourceFile->getStorage());
- return $backend->getVersionFile($user, $sourceFile, $revision);
- }
- public function useBackendForStorage(IStorage $storage): bool {
- return false;
- }
- public function deleteVersion(IVersion $version): void {
- $backend = $version->getBackend();
- if ($backend instanceof IDeletableVersionBackend) {
- $backend->deleteVersion($version);
- }
- }
- public function createVersionEntity(File $file): void {
- $backend = $this->getBackendForStorage($file->getStorage());
- if ($backend instanceof INeedSyncVersionBackend) {
- $backend->createVersionEntity($file);
- }
- }
- public function updateVersionEntity(File $sourceFile, int $revision, array $properties): void {
- $backend = $this->getBackendForStorage($sourceFile->getStorage());
- if ($backend instanceof INeedSyncVersionBackend) {
- $backend->updateVersionEntity($sourceFile, $revision, $properties);
- }
- }
- public function deleteVersionsEntity(File $file): void {
- $backend = $this->getBackendForStorage($file->getStorage());
- if ($backend instanceof INeedSyncVersionBackend) {
- $backend->deleteVersionsEntity($file);
- }
- }
- public function setMetadataValue(Node $node, int $revision, string $key, string $value): void {
- $backend = $this->getBackendForStorage($node->getStorage());
- if ($backend instanceof IMetadataVersionBackend) {
- $backend->setMetadataValue($node, $revision, $key, $value);
- }
- }
-
- private static function handleAppLocks(callable $callback): ?bool {
- try {
- return $callback();
- } catch (ManuallyLockedException $e) {
- $owner = (string) $e->getOwner();
- $appsThatHandleUpdates = ["text", "richdocuments"];
- if (!in_array($owner, $appsThatHandleUpdates)) {
- throw $e;
- }
-
-
-
-
- $root = \OC::$server->get(IRootFolder::class);
- $lockContext = new LockContext($root, ILock::TYPE_APP, $owner);
- $lockManager = \OC::$server->get(ILockManager::class);
- $result = null;
- $lockManager->runInScope($lockContext, function () use ($callback, &$result) {
- $result = $callback();
- });
- return $result;
- }
- }
- }
|