* @copyright 2018, Maxence Lange * @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 . * */ namespace OCA\Social\Interfaces\Object; use OCA\Social\Db\NotesRequest; use OCA\Social\Exceptions\InvalidOriginException; use OCA\Social\Exceptions\ItemNotFoundException; use OCA\Social\Exceptions\NoteNotFoundException; use OCA\Social\Interfaces\IActivityPubInterface; use OCA\Social\Model\ActivityPub\ACore; use OCA\Social\Model\ActivityPub\Activity\Create; use OCA\Social\Model\ActivityPub\Object\Note; use OCA\Social\Service\ConfigService; use OCA\Social\Service\CurlService; use OCA\Social\Service\MiscService; class NoteInterface implements IActivityPubInterface { /** @var NotesRequest */ private $notesRequest; /** @var CurlService */ private $curlService; /** @var ConfigService */ private $configService; /** @var MiscService */ private $miscService; /** * NoteInterface constructor. * * @param NotesRequest $notesRequest * @param CurlService $curlService * @param ConfigService $configService * @param MiscService $miscService */ public function __construct( NotesRequest $notesRequest, CurlService $curlService, ConfigService $configService, MiscService $miscService ) { $this->notesRequest = $notesRequest; $this->curlService = $curlService; $this->configService = $configService; $this->miscService = $miscService; } /** * @param ACore $note */ public function processIncomingRequest(ACore $note) { } /** * @param ACore $item */ public function processResult(ACore $item) { } /** * @param string $id * * @return ACore * @throws ItemNotFoundException */ public function getItemById(string $id): ACore { try { return $this->notesRequest->getNoteById($id); } catch (NoteNotFoundException $e) { throw new ItemNotFoundException(); } } /** * @param ACore $note */ public function save(ACore $note) { /** @var Note $note */ try { $this->notesRequest->getNoteById($note->getId()); } catch (NoteNotFoundException $e) { $this->notesRequest->save($note); } } /** * @param ACore $activity * @param ACore $item * * @throws InvalidOriginException */ public function activity(Acore $activity, ACore $item) { /** @var Note $item */ if ($activity->getType() === Create::TYPE) { $activity->checkOrigin($item->getId()); $activity->checkOrigin($item->getAttributedTo()); $item->setActivityId($activity->getId()); $this->save($item); } } /** * @param ACore $item * * @throws InvalidOriginException */ public function delete(ACore $item) { $item->checkOrigin(($item->getId())); /** @var Note $item */ $this->notesRequest->deleteNoteById($item->getId()); } }