diff options
Diffstat (limited to 'lib/Interfaces/Activity/MoveInterface.php')
| -rw-r--r-- | lib/Interfaces/Activity/MoveInterface.php | 171 |
1 files changed, 0 insertions, 171 deletions
diff --git a/lib/Interfaces/Activity/MoveInterface.php b/lib/Interfaces/Activity/MoveInterface.php deleted file mode 100644 index cf61ff53..00000000 --- a/lib/Interfaces/Activity/MoveInterface.php +++ /dev/null @@ -1,171 +0,0 @@ -<?php - -declare(strict_types=1); - -/** - * Nextcloud - Social Support - * - * This file is licensed under the Affero General Public License version 3 or - * later. See the COPYING file. - * - * @author Maxence Lange <maxence@artificial-owl.com> - * @copyright 2022, Maxence Lange <maxence@artificial-owl.com> - * @license GNU AGPL version 3 or any later version - * - * This program is free software: you can redistribute it and/or modify - * it under the terms of the GNU Affero General Public License as - * published by the Free Software Foundation, either version 3 of the - * License, or (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU Affero General Public License for more details. - * - * You should have received a copy of the GNU Affero General Public License - * along with this program. If not, see <http://www.gnu.org/licenses/>. - * - */ - - -namespace OCA\Social\Interfaces\Activity; - -use OCA\Social\Db\ActionsRequest; -use OCA\Social\Db\CacheDocumentsRequest; -use OCA\Social\Db\FollowsRequest; -use OCA\Social\Db\StreamDestRequest; -use OCA\Social\Db\StreamRequest; -use OCA\Social\Exceptions\CacheActorDoesNotExistException; -use OCA\Social\Exceptions\InvalidOriginException; -use OCA\Social\Exceptions\StreamNotFoundException; -use OCA\Social\Interfaces\IActivityPubInterface; -use OCA\Social\Model\ActivityPub\ACore; -use OCA\Social\Model\ActivityPub\Actor\Person; -use OCA\Social\Service\CacheActorService; - -class MoveInterface extends AbstractActivityPubInterface implements IActivityPubInterface { - private ActionsRequest $actionsRequest; - private CacheDocumentsRequest $cacheDocumentsRequest; - private FollowsRequest $followsRequest; - private StreamRequest $streamRequest; - private StreamDestRequest $streamDestRequest; - private CacheActorService $cacheActorService; - - public function __construct( - ActionsRequest $actionsRequest, - CacheDocumentsRequest $cacheDocumentsRequest, - FollowsRequest $followsRequest, - StreamRequest $streamRequest, - StreamDestRequest $streamDestRequest, - CacheActorService $cacheActorService - ) { - $this->actionsRequest = $actionsRequest; - $this->cacheDocumentsRequest = $cacheDocumentsRequest; - $this->streamRequest = $streamRequest; - $this->streamDestRequest = $streamDestRequest; - $this->followsRequest = $followsRequest; - $this->cacheActorService = $cacheActorService; - } - - - /** - * @throws InvalidOriginException - */ - public function processIncomingRequest(ACore $item): void { - $item->checkOrigin($item->getId()); - $item->checkOrigin($item->getObjectId()); - $item->checkOrigin($item->getActorId()); - - try { - $old = $this->cacheActorService->getFromAccount($item->getActorId(), false); - } catch (CacheActorDoesNotExistException $e) { - return; - } - - $new = $this->cacheActorService->getFromAccount($item->getTarget()); - $this->moveAccount($old, $new); - } - - - public function moveAccount(Person $actor, Person $target): void { - $this->actionsRequest->moveAccount($actor->getId(), $target->getId()); - $this->cacheDocumentsRequest->moveAccount($actor->getId(), $target->getId()); - - $this->followsRequest->moveAccountFollowers($actor->getId(), $target); - $this->followsRequest->moveAccountFollowing($actor->getId(), $target); - - $this->updateStreamFromActor($actor, $target); - } - - - /** - * @param Person $actor - */ - private function updateStreamFromActor(Person $actor, Person $new): void { - // first, we delete all post generate by actor - $this->streamRequest->updateAuthor($actor->getId(), $new->getId()); - - // then we look for link to the actor as dest - foreach ($this->streamDestRequest->getRelatedToActor($actor) as $streamDest) { - if ($streamDest->getType() !== 'recipient') { - continue; - } - - try { - $stream = $this->streamRequest->getStream($streamDest->getStreamId()); - } catch (StreamNotFoundException $e) { - continue; - } - - // upgrading to[] and cc[] based on old actorId and followId with new uri - $changed = false; - switch ($streamDest->getSubtype()) { - case 'to': - if ($stream->getTo() === $actor->getId()) { - $stream->setTo($new->getId()); - $changed = true; - } - - foreach ( - [ - $actor->getId() => $new->getId(), - $actor->getFollowers() => $new->getFollowers(), - $actor->getFollowing() => $new->getFollowing() - ] as $itemId => $newId - ) { - $arr = $stream->getToArray(); - if (in_array($itemId, $arr)) { - $stream->setToArray(array_unique(array_merge(array_diff($arr, [$itemId]), [$newId]))); - $changed = true; - } - } - break; - - case 'cc': - $changed = false; - foreach ( - [ - $actor->getId() => $new->getId(), - $actor->getFollowers() => $new->getFollowers(), - $actor->getFollowing() => $new->getFollowing() - ] as $itemId => $newId - ) { - $arr = $stream->getCcArray(); - if (in_array($itemId, $arr)) { - $stream->setCcArray(array_unique(array_merge(array_diff($arr, [$itemId]), [$newId]))); - $changed = true; - } - } - break; - } - - if ($changed) { - $this->streamRequest->update($stream); - } - } - - $this->streamDestRequest->moveActor($actor->getId(), $new->getId()); - $this->streamDestRequest->moveActor($actor->getFollowing(), $new->getFollowing()); - $this->streamDestRequest->moveActor($actor->getFollowers(), $new->getFollowers()); - } -} |