userId = $userId; $this->notificationManager = $notificationManager; $this->timeFactory = $timeFactory; $this->jobList = $jobList; $this->mapper = $mapper; $this->userManager = $userManager; $this->rootFolder = $rootFolder; } /** * @NoAdminRequired * * Transfer the ownership to another user * * @param string $recipient Username of the recipient * @param string $path Path of the file * * @return DataResponse, array{}> * * 200: Ownership transferred successfully * 400: Transferring ownership is not possible * 403: Transferring ownership is not allowed */ public function transfer(string $recipient, string $path): DataResponse { $recipientUser = $this->userManager->get($recipient); if ($recipientUser === null) { return new DataResponse([], Http::STATUS_BAD_REQUEST); } $userRoot = $this->rootFolder->getUserFolder($this->userId); try { $node = $userRoot->get($path); } catch (\Exception $e) { return new DataResponse([], Http::STATUS_BAD_REQUEST); } if ($node->getOwner()->getUID() !== $this->userId || !$node->getStorage()->instanceOfStorage(IHomeStorage::class)) { return new DataResponse([], Http::STATUS_FORBIDDEN); } $transferOwnership = new TransferOwnershipEntity(); $transferOwnership->setSourceUser($this->userId); $transferOwnership->setTargetUser($recipient); $transferOwnership->setFileId($node->getId()); $transferOwnership->setNodeName($node->getName()); $transferOwnership = $this->mapper->insert($transferOwnership); $notification = $this->notificationManager->createNotification(); $notification->setUser($recipient) ->setApp($this->appName) ->setDateTime($this->timeFactory->getDateTime()) ->setSubject('transferownershipRequest', [ 'sourceUser' => $this->userId, 'targetUser' => $recipient, 'nodeName' => $node->getName(), ]) ->setObject('transfer', (string)$transferOwnership->getId()); $this->notificationManager->notify($notification); return new DataResponse([]); } /** * @NoAdminRequired * * Accept an ownership transfer * * @param int $id ID of the ownership transfer * * @return DataResponse, array{}> * * 200: Ownership transfer accepted successfully * 403: Accepting ownership transfer is not allowed * 404: Ownership transfer not found */ public function accept(int $id): DataResponse { try { $transferOwnership = $this->mapper->getById($id); } catch (DoesNotExistException $e) { return new DataResponse([], Http::STATUS_NOT_FOUND); } if ($transferOwnership->getTargetUser() !== $this->userId) { return new DataResponse([], Http::STATUS_FORBIDDEN); } $notification = $this->notificationManager->createNotification(); $notification->setApp('files') ->setObject('transfer', (string)$id); $this->notificationManager->markProcessed($notification); $newTransferOwnership = new TransferOwnershipEntity(); $newTransferOwnership->setNodeName($transferOwnership->getNodeName()); $newTransferOwnership->setFileId($transferOwnership->getFileId()); $newTransferOwnership->setSourceUser($transferOwnership->getSourceUser()); $newTransferOwnership->setTargetUser($transferOwnership->getTargetUser()); $this->mapper->insert($newTransferOwnership); $this->jobList->add(TransferOwnership::class, [ 'id' => $newTransferOwnership->getId(), ]); return new DataResponse([], Http::STATUS_OK); } /** * @NoAdminRequired * * Reject an ownership transfer * * @param int $id ID of the ownership transfer * * @return DataResponse, array{}> * * 200: Ownership transfer rejected successfully * 403: Rejecting ownership transfer is not allowed * 404: Ownership transfer not found */ public function reject(int $id): DataResponse { try { $transferOwnership = $this->mapper->getById($id); } catch (DoesNotExistException $e) { return new DataResponse([], Http::STATUS_NOT_FOUND); } if ($transferOwnership->getTargetUser() !== $this->userId) { return new DataResponse([], Http::STATUS_FORBIDDEN); } $notification = $this->notificationManager->createNotification(); $notification->setApp('files') ->setObject('transfer', (string)$id); $this->notificationManager->markProcessed($notification); $notification = $this->notificationManager->createNotification(); $notification->setUser($transferOwnership->getSourceUser()) ->setApp($this->appName) ->setDateTime($this->timeFactory->getDateTime()) ->setSubject('transferownershipRequestDenied', [ 'sourceUser' => $transferOwnership->getSourceUser(), 'targetUser' => $transferOwnership->getTargetUser(), 'nodeName' => $transferOwnership->getNodeName() ]) ->setObject('transfer', (string)$transferOwnership->getId()); $this->notificationManager->notify($notification); $this->mapper->delete($transferOwnership); return new DataResponse([], Http::STATUS_OK); } }