nextcloud / server

apps/files/lib/DirectEditingCapabilities.php

Indentation +17 added lines, -17 removed lines

@@ -30,23 +30,23 @@
 use OCP\IURLGenerator;
 
 class DirectEditingCapabilities implements ICapability, IInitialStateExcludedCapability {
-	protected DirectEditingService $directEditingService;
-	protected IURLGenerator $urlGenerator;
+    protected DirectEditingService $directEditingService;
+    protected IURLGenerator $urlGenerator;
 
-	public function __construct(DirectEditingService $directEditingService, IURLGenerator $urlGenerator) {
-		$this->directEditingService = $directEditingService;
-		$this->urlGenerator = $urlGenerator;
-	}
+    public function __construct(DirectEditingService $directEditingService, IURLGenerator $urlGenerator) {
+        $this->directEditingService = $directEditingService;
+        $this->urlGenerator = $urlGenerator;
+    }
 
-	public function getCapabilities() {
-		return [
-			'files' => [
-				'directEditing' => [
-					'url' => $this->urlGenerator->linkToOCSRouteAbsolute('files.DirectEditing.info'),
-					'etag' => $this->directEditingService->getDirectEditingETag(),
-					'supportsFileId' => true,
-				]
-			],
-		];
-	}
+    public function getCapabilities() {
+        return [
+            'files' => [
+                'directEditing' => [
+                    'url' => $this->urlGenerator->linkToOCSRouteAbsolute('files.DirectEditing.info'),
+                    'etag' => $this->directEditingService->getDirectEditingETag(),
+                    'supportsFileId' => true,
+                ]
+            ],
+        ];
+    }
 }

apps/files/lib/Controller/DirectEditingController.php

Indentation +93 added lines, -93 removed lines

@@ -35,97 +35,97 @@
 use OCP\IURLGenerator;
 
 class DirectEditingController extends OCSController {
-	/** @var IEventDispatcher */
-	private $eventDispatcher;
-
-	/** @var IManager */
-	private $directEditingManager;
-
-	/** @var IURLGenerator */
-	private $urlGenerator;
-
-	/** @var ILogger */
-	private $logger;
-
-	/** @var DirectEditingService */
-	private $directEditingService;
-
-	public function __construct($appName, IRequest $request, $corsMethods, $corsAllowedHeaders, $corsMaxAge,
-								IEventDispatcher $eventDispatcher, IURLGenerator $urlGenerator, IManager $manager, DirectEditingService $directEditingService, ILogger $logger) {
-		parent::__construct($appName, $request, $corsMethods, $corsAllowedHeaders, $corsMaxAge);
-
-		$this->eventDispatcher = $eventDispatcher;
-		$this->directEditingManager = $manager;
-		$this->directEditingService = $directEditingService;
-		$this->logger = $logger;
-		$this->urlGenerator = $urlGenerator;
-	}
-
-	/**
-	 * @NoAdminRequired
-	 */
-	public function info(): DataResponse {
-		$response = new DataResponse($this->directEditingService->getDirectEditingCapabilitites());
-		$response->setETag($this->directEditingService->getDirectEditingETag());
-		return $response;
-	}
-
-	/**
-	 * @NoAdminRequired
-	 */
-	public function create(string $path, string $editorId, string $creatorId, string $templateId = null): DataResponse {
-		if (!$this->directEditingManager->isEnabled()) {
-			return new DataResponse(['message' => 'Direct editing is not enabled'], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-		$this->eventDispatcher->dispatchTyped(new RegisterDirectEditorEvent($this->directEditingManager));
-
-		try {
-			$token = $this->directEditingManager->create($path, $editorId, $creatorId, $templateId);
-			return new DataResponse([
-				'url' => $this->urlGenerator->linkToRouteAbsolute('files.DirectEditingView.edit', ['token' => $token])
-			]);
-		} catch (Exception $e) {
-			$this->logger->logException($e, ['message' => 'Exception when creating a new file through direct editing']);
-			return new DataResponse(['message' => 'Failed to create file: ' . $e->getMessage()], Http::STATUS_FORBIDDEN);
-		}
-	}
-
-	/**
-	 * @NoAdminRequired
-	 */
-	public function open(string $path, string $editorId = null, ?int $fileId = null): DataResponse {
-		if (!$this->directEditingManager->isEnabled()) {
-			return new DataResponse(['message' => 'Direct editing is not enabled'], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-		$this->eventDispatcher->dispatchTyped(new RegisterDirectEditorEvent($this->directEditingManager));
-
-		try {
-			$token = $this->directEditingManager->open($path, $editorId, $fileId);
-			return new DataResponse([
-				'url' => $this->urlGenerator->linkToRouteAbsolute('files.DirectEditingView.edit', ['token' => $token])
-			]);
-		} catch (Exception $e) {
-			$this->logger->logException($e, ['message' => 'Exception when opening a file through direct editing']);
-			return new DataResponse(['message' => 'Failed to open file: ' . $e->getMessage()], Http::STATUS_FORBIDDEN);
-		}
-	}
-
-
-
-	/**
-	 * @NoAdminRequired
-	 */
-	public function templates(string $editorId, string $creatorId): DataResponse {
-		if (!$this->directEditingManager->isEnabled()) {
-			return new DataResponse(['message' => 'Direct editing is not enabled'], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-		$this->eventDispatcher->dispatchTyped(new RegisterDirectEditorEvent($this->directEditingManager));
-
-		try {
-			return new DataResponse($this->directEditingManager->getTemplates($editorId, $creatorId));
-		} catch (Exception $e) {
-			$this->logger->logException($e);
-			return new DataResponse(['message' => 'Failed to obtain template list: ' . $e->getMessage()], Http::STATUS_INTERNAL_SERVER_ERROR);
-		}
-	}
+    /** @var IEventDispatcher */
+    private $eventDispatcher;
+
+    /** @var IManager */
+    private $directEditingManager;
+
+    /** @var IURLGenerator */
+    private $urlGenerator;
+
+    /** @var ILogger */
+    private $logger;
+
+    /** @var DirectEditingService */
+    private $directEditingService;
+
+    public function __construct($appName, IRequest $request, $corsMethods, $corsAllowedHeaders, $corsMaxAge,
+                                IEventDispatcher $eventDispatcher, IURLGenerator $urlGenerator, IManager $manager, DirectEditingService $directEditingService, ILogger $logger) {
+        parent::__construct($appName, $request, $corsMethods, $corsAllowedHeaders, $corsMaxAge);
+
+        $this->eventDispatcher = $eventDispatcher;
+        $this->directEditingManager = $manager;
+        $this->directEditingService = $directEditingService;
+        $this->logger = $logger;
+        $this->urlGenerator = $urlGenerator;
+    }
+
+    /**
+     * @NoAdminRequired
+     */
+    public function info(): DataResponse {
+        $response = new DataResponse($this->directEditingService->getDirectEditingCapabilitites());
+        $response->setETag($this->directEditingService->getDirectEditingETag());
+        return $response;
+    }
+
+    /**
+     * @NoAdminRequired
+     */
+    public function create(string $path, string $editorId, string $creatorId, string $templateId = null): DataResponse {
+        if (!$this->directEditingManager->isEnabled()) {
+            return new DataResponse(['message' => 'Direct editing is not enabled'], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+        $this->eventDispatcher->dispatchTyped(new RegisterDirectEditorEvent($this->directEditingManager));
+
+        try {
+            $token = $this->directEditingManager->create($path, $editorId, $creatorId, $templateId);
+            return new DataResponse([
+                'url' => $this->urlGenerator->linkToRouteAbsolute('files.DirectEditingView.edit', ['token' => $token])
+            ]);
+        } catch (Exception $e) {
+            $this->logger->logException($e, ['message' => 'Exception when creating a new file through direct editing']);
+            return new DataResponse(['message' => 'Failed to create file: ' . $e->getMessage()], Http::STATUS_FORBIDDEN);
+        }
+    }
+
+    /**
+     * @NoAdminRequired
+     */
+    public function open(string $path, string $editorId = null, ?int $fileId = null): DataResponse {
+        if (!$this->directEditingManager->isEnabled()) {
+            return new DataResponse(['message' => 'Direct editing is not enabled'], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+        $this->eventDispatcher->dispatchTyped(new RegisterDirectEditorEvent($this->directEditingManager));
+
+        try {
+            $token = $this->directEditingManager->open($path, $editorId, $fileId);
+            return new DataResponse([
+                'url' => $this->urlGenerator->linkToRouteAbsolute('files.DirectEditingView.edit', ['token' => $token])
+            ]);
+        } catch (Exception $e) {
+            $this->logger->logException($e, ['message' => 'Exception when opening a file through direct editing']);
+            return new DataResponse(['message' => 'Failed to open file: ' . $e->getMessage()], Http::STATUS_FORBIDDEN);
+        }
+    }
+
+
+
+    /**
+     * @NoAdminRequired
+     */
+    public function templates(string $editorId, string $creatorId): DataResponse {
+        if (!$this->directEditingManager->isEnabled()) {
+            return new DataResponse(['message' => 'Direct editing is not enabled'], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+        $this->eventDispatcher->dispatchTyped(new RegisterDirectEditorEvent($this->directEditingManager));
+
+        try {
+            return new DataResponse($this->directEditingManager->getTemplates($editorId, $creatorId));
+        } catch (Exception $e) {
+            $this->logger->logException($e);
+            return new DataResponse(['message' => 'Failed to obtain template list: ' . $e->getMessage()], Http::STATUS_INTERNAL_SERVER_ERROR);
+        }
+    }
 }

lib/private/DirectEditing/Manager.php

Indentation +282 added lines, -282 removed lines

@@ -52,286 +52,286 @@
 use function in_array;
 
 class Manager implements IManager {
-	private const TOKEN_CLEANUP_TIME = 12 * 60 * 60 ;
-
-	public const TABLE_TOKENS = 'direct_edit';
-
-	/** @var IEditor[] */
-	private $editors = [];
-	/** @var IDBConnection */
-	private $connection;
-	/** @var IUserSession */
-	private $userSession;
-	/** @var ISecureRandom */
-	private $random;
-	/** @var string|null */
-	private $userId;
-	/** @var IRootFolder */
-	private $rootFolder;
-	/** @var IL10N */
-	private $l10n;
-	/** @var EncryptionManager */
-	private $encryptionManager;
-
-	public function __construct(
-		ISecureRandom $random,
-		IDBConnection $connection,
-		IUserSession $userSession,
-		IRootFolder $rootFolder,
-		IFactory $l10nFactory,
-		EncryptionManager $encryptionManager
-	) {
-		$this->random = $random;
-		$this->connection = $connection;
-		$this->userSession = $userSession;
-		$this->userId = $userSession->getUser() ? $userSession->getUser()->getUID() : null;
-		$this->rootFolder = $rootFolder;
-		$this->l10n = $l10nFactory->get('lib');
-		$this->encryptionManager = $encryptionManager;
-	}
-
-	public function registerDirectEditor(IEditor $directEditor): void {
-		$this->editors[$directEditor->getId()] = $directEditor;
-	}
-
-	public function getEditors(): array {
-		return $this->editors;
-	}
-
-	public function getTemplates(string $editor, string $type): array {
-		if (!array_key_exists($editor, $this->editors)) {
-			throw new \RuntimeException('No matching editor found');
-		}
-		$templates = [];
-		foreach ($this->editors[$editor]->getCreators() as $creator) {
-			if ($creator->getId() === $type) {
-				$templates = [
-					'empty' => [
-						'id' => 'empty',
-						'title' => $this->l10n->t('Empty file'),
-						'preview' => null
-					]
-				];
-
-				if ($creator instanceof ACreateFromTemplate) {
-					$templates = $creator->getTemplates();
-				}
-
-				$templates = array_map(function ($template) use ($creator) {
-					$template['extension'] = $creator->getExtension();
-					$template['mimetype'] = $creator->getMimetype();
-					return $template;
-				}, $templates);
-			}
-		}
-		$return = [];
-		$return['templates'] = $templates;
-		return $return;
-	}
-
-	public function create(string $path, string $editorId, string $creatorId, $templateId = null): string {
-		$userFolder = $this->rootFolder->getUserFolder($this->userId);
-		if ($userFolder->nodeExists($path)) {
-			throw new \RuntimeException('File already exists');
-		} else {
-			if (!$userFolder->nodeExists(dirname($path))) {
-				throw new \RuntimeException('Invalid path');
-			}
-			/** @var Folder $folder */
-			$folder = $userFolder->get(dirname($path));
-			$file = $folder->newFile(basename($path));
-			$editor = $this->getEditor($editorId);
-			$creators = $editor->getCreators();
-			foreach ($creators as $creator) {
-				if ($creator->getId() === $creatorId) {
-					$creator->create($file, $creatorId, $templateId);
-					return $this->createToken($editorId, $file, $path);
-				}
-			}
-		}
-
-		throw new \RuntimeException('No creator found');
-	}
-
-	public function open(string $filePath, string $editorId = null, ?int $fileId = null): string {
-		$userFolder = $this->rootFolder->getUserFolder($this->userId);
-		$file = $userFolder->get($filePath);
-		if ($fileId !== null && $file instanceof Folder) {
-			$files = $file->getById($fileId);
-
-			// Workaround to always open files with edit permissions if multiple occurences of
-			// the same file id are in the user home, ideally we should also track the path of the file when opening
-			usort($files, function (Node $a, Node $b) {
-				return ($b->getPermissions() & Constants::PERMISSION_UPDATE) <=> ($a->getPermissions() & Constants::PERMISSION_UPDATE);
-			});
-			$file = array_shift($files);
-		}
-
-		if (!$file instanceof File) {
-			throw new NotFoundException();
-		}
-
-		$filePath = $userFolder->getRelativePath($file->getPath());
-
-		if ($editorId === null) {
-			$editorId = $this->findEditorForFile($file);
-		}
-		if (!array_key_exists($editorId, $this->editors)) {
-			throw new \RuntimeException("Editor $editorId is unknown");
-		}
-
-		return $this->createToken($editorId, $file, $filePath);
-	}
-
-	private function findEditorForFile(File $file) {
-		foreach ($this->editors as $editor) {
-			if (in_array($file->getMimeType(), $editor->getMimetypes())) {
-				return $editor->getId();
-			}
-		}
-		throw new \RuntimeException('No default editor found for files mimetype');
-	}
-
-	public function edit(string $token): Response {
-		try {
-			/** @var IEditor $editor */
-			$tokenObject = $this->getToken($token);
-			if ($tokenObject->hasBeenAccessed()) {
-				throw new \RuntimeException('Token has already been used and can only be used for followup requests');
-			}
-			$editor = $this->getEditor($tokenObject->getEditor());
-			$this->accessToken($token);
-		} catch (Throwable $throwable) {
-			$this->invalidateToken($token);
-			return new NotFoundResponse();
-		}
-
-		try {
-			$this->invokeTokenScope($tokenObject->getUser());
-			return $editor->open($tokenObject);
-		} finally {
-			$this->revertTokenScope();
-		}
-	}
-
-	public function editSecure(File $file, string $editorId): TemplateResponse {
-		// TODO: Implementation in follow up
-	}
-
-	private function getEditor($editorId): IEditor {
-		if (!array_key_exists($editorId, $this->editors)) {
-			throw new \RuntimeException('No editor found');
-		}
-		return $this->editors[$editorId];
-	}
-
-	public function getToken(string $token): IToken {
-		$query = $this->connection->getQueryBuilder();
-		$query->select('*')->from(self::TABLE_TOKENS)
-			->where($query->expr()->eq('token', $query->createNamedParameter($token, IQueryBuilder::PARAM_STR)));
-		$result = $query->execute();
-		if ($tokenRow = $result->fetch(FetchMode::ASSOCIATIVE)) {
-			return new Token($this, $tokenRow);
-		}
-		throw new \RuntimeException('Failed to validate the token');
-	}
-
-	public function cleanup(): int {
-		$query = $this->connection->getQueryBuilder();
-		$query->delete(self::TABLE_TOKENS)
-			->where($query->expr()->lt('timestamp', $query->createNamedParameter(time() - self::TOKEN_CLEANUP_TIME)));
-		return $query->execute();
-	}
-
-	public function refreshToken(string $token): bool {
-		$query = $this->connection->getQueryBuilder();
-		$query->update(self::TABLE_TOKENS)
-			->set('timestamp', $query->createNamedParameter(time(), IQueryBuilder::PARAM_INT))
-			->where($query->expr()->eq('token', $query->createNamedParameter($token, IQueryBuilder::PARAM_STR)));
-		$result = $query->execute();
-		return $result !== 0;
-	}
-
-
-	public function invalidateToken(string $token): bool {
-		$query = $this->connection->getQueryBuilder();
-		$query->delete(self::TABLE_TOKENS)
-			->where($query->expr()->eq('token', $query->createNamedParameter($token, IQueryBuilder::PARAM_STR)));
-		$result = $query->execute();
-		return $result !== 0;
-	}
-
-	public function accessToken(string $token): bool {
-		$query = $this->connection->getQueryBuilder();
-		$query->update(self::TABLE_TOKENS)
-			->set('accessed', $query->createNamedParameter(true, IQueryBuilder::PARAM_BOOL))
-			->set('timestamp', $query->createNamedParameter(time(), IQueryBuilder::PARAM_INT))
-			->where($query->expr()->eq('token', $query->createNamedParameter($token, IQueryBuilder::PARAM_STR)));
-		$result = $query->execute();
-		return $result !== 0;
-	}
-
-	public function invokeTokenScope($userId): void {
-		\OC_User::setIncognitoMode(true);
-		\OC_User::setUserId($userId);
-	}
-
-	public function revertTokenScope(): void {
-		$this->userSession->setUser(null);
-		\OC_User::setIncognitoMode(false);
-	}
-
-	public function createToken($editorId, File $file, string $filePath, IShare $share = null): string {
-		$token = $this->random->generate(64, ISecureRandom::CHAR_HUMAN_READABLE);
-		$query = $this->connection->getQueryBuilder();
-		$query->insert(self::TABLE_TOKENS)
-			->values([
-				'token' => $query->createNamedParameter($token),
-				'editor_id' => $query->createNamedParameter($editorId),
-				'file_id' => $query->createNamedParameter($file->getId()),
-				'file_path' => $query->createNamedParameter($filePath),
-				'user_id' => $query->createNamedParameter($this->userId),
-				'share_id' => $query->createNamedParameter($share !== null ? $share->getId(): null),
-				'timestamp' => $query->createNamedParameter(time())
-			]);
-		$query->execute();
-		return $token;
-	}
-
-	/**
-	 * @param $userId
-	 * @param $fileId
-	 * @param null $filePath
-	 * @return Node
-	 * @throws NotFoundException
-	 */
-	public function getFileForToken($userId, $fileId, $filePath = null): Node {
-		$userFolder = $this->rootFolder->getUserFolder($userId);
-		if ($filePath !== null) {
-			return $userFolder->get($filePath);
-		}
-		$files = $userFolder->getById($fileId);
-		if (count($files) === 0) {
-			throw new NotFoundException('File nound found by id ' . $fileId);
-		}
-		return $files[0];
-	}
-
-	public function isEnabled(): bool {
-		if (!$this->encryptionManager->isEnabled()) {
-			return true;
-		}
-
-		try {
-			$moduleId = $this->encryptionManager->getDefaultEncryptionModuleId();
-			$module = $this->encryptionManager->getEncryptionModule($moduleId);
-			/** @var \OCA\Encryption\Util $util */
-			$util = \OC::$server->get(\OCA\Encryption\Util::class);
-			if ($module->isReadyForUser($this->userId) && $util->isMasterKeyEnabled()) {
-				return true;
-			}
-		} catch (Throwable $e) {
-		}
-		return false;
-	}
+    private const TOKEN_CLEANUP_TIME = 12 * 60 * 60 ;
+
+    public const TABLE_TOKENS = 'direct_edit';
+
+    /** @var IEditor[] */
+    private $editors = [];
+    /** @var IDBConnection */
+    private $connection;
+    /** @var IUserSession */
+    private $userSession;
+    /** @var ISecureRandom */
+    private $random;
+    /** @var string|null */
+    private $userId;
+    /** @var IRootFolder */
+    private $rootFolder;
+    /** @var IL10N */
+    private $l10n;
+    /** @var EncryptionManager */
+    private $encryptionManager;
+
+    public function __construct(
+        ISecureRandom $random,
+        IDBConnection $connection,
+        IUserSession $userSession,
+        IRootFolder $rootFolder,
+        IFactory $l10nFactory,
+        EncryptionManager $encryptionManager
+    ) {
+        $this->random = $random;
+        $this->connection = $connection;
+        $this->userSession = $userSession;
+        $this->userId = $userSession->getUser() ? $userSession->getUser()->getUID() : null;
+        $this->rootFolder = $rootFolder;
+        $this->l10n = $l10nFactory->get('lib');
+        $this->encryptionManager = $encryptionManager;
+    }
+
+    public function registerDirectEditor(IEditor $directEditor): void {
+        $this->editors[$directEditor->getId()] = $directEditor;
+    }
+
+    public function getEditors(): array {
+        return $this->editors;
+    }
+
+    public function getTemplates(string $editor, string $type): array {
+        if (!array_key_exists($editor, $this->editors)) {
+            throw new \RuntimeException('No matching editor found');
+        }
+        $templates = [];
+        foreach ($this->editors[$editor]->getCreators() as $creator) {
+            if ($creator->getId() === $type) {
+                $templates = [
+                    'empty' => [
+                        'id' => 'empty',
+                        'title' => $this->l10n->t('Empty file'),
+                        'preview' => null
+                    ]
+                ];
+
+                if ($creator instanceof ACreateFromTemplate) {
+                    $templates = $creator->getTemplates();
+                }
+
+                $templates = array_map(function ($template) use ($creator) {
+                    $template['extension'] = $creator->getExtension();
+                    $template['mimetype'] = $creator->getMimetype();
+                    return $template;
+                }, $templates);
+            }
+        }
+        $return = [];
+        $return['templates'] = $templates;
+        return $return;
+    }
+
+    public function create(string $path, string $editorId, string $creatorId, $templateId = null): string {
+        $userFolder = $this->rootFolder->getUserFolder($this->userId);
+        if ($userFolder->nodeExists($path)) {
+            throw new \RuntimeException('File already exists');
+        } else {
+            if (!$userFolder->nodeExists(dirname($path))) {
+                throw new \RuntimeException('Invalid path');
+            }
+            /** @var Folder $folder */
+            $folder = $userFolder->get(dirname($path));
+            $file = $folder->newFile(basename($path));
+            $editor = $this->getEditor($editorId);
+            $creators = $editor->getCreators();
+            foreach ($creators as $creator) {
+                if ($creator->getId() === $creatorId) {
+                    $creator->create($file, $creatorId, $templateId);
+                    return $this->createToken($editorId, $file, $path);
+                }
+            }
+        }
+
+        throw new \RuntimeException('No creator found');
+    }
+
+    public function open(string $filePath, string $editorId = null, ?int $fileId = null): string {
+        $userFolder = $this->rootFolder->getUserFolder($this->userId);
+        $file = $userFolder->get($filePath);
+        if ($fileId !== null && $file instanceof Folder) {
+            $files = $file->getById($fileId);
+
+            // Workaround to always open files with edit permissions if multiple occurences of
+            // the same file id are in the user home, ideally we should also track the path of the file when opening
+            usort($files, function (Node $a, Node $b) {
+                return ($b->getPermissions() & Constants::PERMISSION_UPDATE) <=> ($a->getPermissions() & Constants::PERMISSION_UPDATE);
+            });
+            $file = array_shift($files);
+        }
+
+        if (!$file instanceof File) {
+            throw new NotFoundException();
+        }
+
+        $filePath = $userFolder->getRelativePath($file->getPath());
+
+        if ($editorId === null) {
+            $editorId = $this->findEditorForFile($file);
+        }
+        if (!array_key_exists($editorId, $this->editors)) {
+            throw new \RuntimeException("Editor $editorId is unknown");
+        }
+
+        return $this->createToken($editorId, $file, $filePath);
+    }
+
+    private function findEditorForFile(File $file) {
+        foreach ($this->editors as $editor) {
+            if (in_array($file->getMimeType(), $editor->getMimetypes())) {
+                return $editor->getId();
+            }
+        }
+        throw new \RuntimeException('No default editor found for files mimetype');
+    }
+
+    public function edit(string $token): Response {
+        try {
+            /** @var IEditor $editor */
+            $tokenObject = $this->getToken($token);
+            if ($tokenObject->hasBeenAccessed()) {
+                throw new \RuntimeException('Token has already been used and can only be used for followup requests');
+            }
+            $editor = $this->getEditor($tokenObject->getEditor());
+            $this->accessToken($token);
+        } catch (Throwable $throwable) {
+            $this->invalidateToken($token);
+            return new NotFoundResponse();
+        }
+
+        try {
+            $this->invokeTokenScope($tokenObject->getUser());
+            return $editor->open($tokenObject);
+        } finally {
+            $this->revertTokenScope();
+        }
+    }
+
+    public function editSecure(File $file, string $editorId): TemplateResponse {
+        // TODO: Implementation in follow up
+    }
+
+    private function getEditor($editorId): IEditor {
+        if (!array_key_exists($editorId, $this->editors)) {
+            throw new \RuntimeException('No editor found');
+        }
+        return $this->editors[$editorId];
+    }
+
+    public function getToken(string $token): IToken {
+        $query = $this->connection->getQueryBuilder();
+        $query->select('*')->from(self::TABLE_TOKENS)
+            ->where($query->expr()->eq('token', $query->createNamedParameter($token, IQueryBuilder::PARAM_STR)));
+        $result = $query->execute();
+        if ($tokenRow = $result->fetch(FetchMode::ASSOCIATIVE)) {
+            return new Token($this, $tokenRow);
+        }
+        throw new \RuntimeException('Failed to validate the token');
+    }
+
+    public function cleanup(): int {
+        $query = $this->connection->getQueryBuilder();
+        $query->delete(self::TABLE_TOKENS)
+            ->where($query->expr()->lt('timestamp', $query->createNamedParameter(time() - self::TOKEN_CLEANUP_TIME)));
+        return $query->execute();
+    }
+
+    public function refreshToken(string $token): bool {
+        $query = $this->connection->getQueryBuilder();
+        $query->update(self::TABLE_TOKENS)
+            ->set('timestamp', $query->createNamedParameter(time(), IQueryBuilder::PARAM_INT))
+            ->where($query->expr()->eq('token', $query->createNamedParameter($token, IQueryBuilder::PARAM_STR)));
+        $result = $query->execute();
+        return $result !== 0;
+    }
+
+
+    public function invalidateToken(string $token): bool {
+        $query = $this->connection->getQueryBuilder();
+        $query->delete(self::TABLE_TOKENS)
+            ->where($query->expr()->eq('token', $query->createNamedParameter($token, IQueryBuilder::PARAM_STR)));
+        $result = $query->execute();
+        return $result !== 0;
+    }
+
+    public function accessToken(string $token): bool {
+        $query = $this->connection->getQueryBuilder();
+        $query->update(self::TABLE_TOKENS)
+            ->set('accessed', $query->createNamedParameter(true, IQueryBuilder::PARAM_BOOL))
+            ->set('timestamp', $query->createNamedParameter(time(), IQueryBuilder::PARAM_INT))
+            ->where($query->expr()->eq('token', $query->createNamedParameter($token, IQueryBuilder::PARAM_STR)));
+        $result = $query->execute();
+        return $result !== 0;
+    }
+
+    public function invokeTokenScope($userId): void {
+        \OC_User::setIncognitoMode(true);
+        \OC_User::setUserId($userId);
+    }
+
+    public function revertTokenScope(): void {
+        $this->userSession->setUser(null);
+        \OC_User::setIncognitoMode(false);
+    }
+
+    public function createToken($editorId, File $file, string $filePath, IShare $share = null): string {
+        $token = $this->random->generate(64, ISecureRandom::CHAR_HUMAN_READABLE);
+        $query = $this->connection->getQueryBuilder();
+        $query->insert(self::TABLE_TOKENS)
+            ->values([
+                'token' => $query->createNamedParameter($token),
+                'editor_id' => $query->createNamedParameter($editorId),
+                'file_id' => $query->createNamedParameter($file->getId()),
+                'file_path' => $query->createNamedParameter($filePath),
+                'user_id' => $query->createNamedParameter($this->userId),
+                'share_id' => $query->createNamedParameter($share !== null ? $share->getId(): null),
+                'timestamp' => $query->createNamedParameter(time())
+            ]);
+        $query->execute();
+        return $token;
+    }
+
+    /**
+     * @param $userId
+     * @param $fileId
+     * @param null $filePath
+     * @return Node
+     * @throws NotFoundException
+     */
+    public function getFileForToken($userId, $fileId, $filePath = null): Node {
+        $userFolder = $this->rootFolder->getUserFolder($userId);
+        if ($filePath !== null) {
+            return $userFolder->get($filePath);
+        }
+        $files = $userFolder->getById($fileId);
+        if (count($files) === 0) {
+            throw new NotFoundException('File nound found by id ' . $fileId);
+        }
+        return $files[0];
+    }
+
+    public function isEnabled(): bool {
+        if (!$this->encryptionManager->isEnabled()) {
+            return true;
+        }
+
+        try {
+            $moduleId = $this->encryptionManager->getDefaultEncryptionModuleId();
+            $module = $this->encryptionManager->getEncryptionModule($moduleId);
+            /** @var \OCA\Encryption\Util $util */
+            $util = \OC::$server->get(\OCA\Encryption\Util::class);
+            if ($module->isReadyForUser($this->userId) && $util->isMasterKeyEnabled()) {
+                return true;
+            }
+        } catch (Throwable $e) {
+        }
+        return false;
+    }
 }

Spacing +5 added lines, -5 removed lines

@@ -52,7 +52,7 @@ 
 use function in_array;
 
 class Manager implements IManager {
-	private const TOKEN_CLEANUP_TIME = 12 * 60 * 60 ;
+	private const TOKEN_CLEANUP_TIME = 12 * 60 * 60;
 
 	public const TABLE_TOKENS = 'direct_edit';
 
@@ -117,7 +117,7 @@ 
 					$templates = $creator->getTemplates();
 				}
 
-				$templates = array_map(function ($template) use ($creator) {
+				$templates = array_map(function($template) use ($creator) {
 					$template['extension'] = $creator->getExtension();
 					$template['mimetype'] = $creator->getMimetype();
 					return $template;
@@ -161,7 +161,7 @@ 
 
 			// Workaround to always open files with edit permissions if multiple occurences of
 			// the same file id are in the user home, ideally we should also track the path of the file when opening
-			usort($files, function (Node $a, Node $b) {
+			usort($files, function(Node $a, Node $b) {
 				return ($b->getPermissions() & Constants::PERMISSION_UPDATE) <=> ($a->getPermissions() & Constants::PERMISSION_UPDATE);
 			});
 			$file = array_shift($files);
@@ -291,7 +291,7 @@ 
 				'file_id' => $query->createNamedParameter($file->getId()),
 				'file_path' => $query->createNamedParameter($filePath),
 				'user_id' => $query->createNamedParameter($this->userId),
-				'share_id' => $query->createNamedParameter($share !== null ? $share->getId(): null),
+				'share_id' => $query->createNamedParameter($share !== null ? $share->getId() : null),
 				'timestamp' => $query->createNamedParameter(time())
 			]);
 		$query->execute();
@@ -312,7 +312,7 @@ 
 		}
 		$files = $userFolder->getById($fileId);
 		if (count($files) === 0) {
-			throw new NotFoundException('File nound found by id ' . $fileId);
+			throw new NotFoundException('File nound found by id '.$fileId);
 		}
 		return $files[0];
 	}