* @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\CacheDocumentsRequest; use OCA\Social\Exceptions\CacheDocumentDoesNotExistException; use OCA\Social\Exceptions\InvalidOriginException; use OCA\Social\Exceptions\ItemNotFoundException; use OCA\Social\Interfaces\IActivityPubInterface; use OCA\Social\Model\ActivityPub\ACore; use OCA\Social\Model\ActivityPub\Actor\Person; use OCA\Social\Model\ActivityPub\Object\Document; use OCA\Social\Service\MiscService; class DocumentInterface implements IActivityPubInterface { /** @var CacheDocumentsRequest */ protected $cacheDocumentsRequest; /** @var MiscService */ protected $miscService; /** * DocumentInterface constructor. * * @param CacheDocumentsRequest $cacheDocumentsRequest * @param MiscService $miscService */ public function __construct( CacheDocumentsRequest $cacheDocumentsRequest, MiscService $miscService ) { $this->cacheDocumentsRequest = $cacheDocumentsRequest; $this->miscService = $miscService; } /** * @param ACore $activity * @param ACore $item * * @throws InvalidOriginException */ public function activity(Acore $activity, ACore $item) { if ($activity->getType() === Person::TYPE) { $activity->checkOrigin($item->getId()); } } /** * @param ACore $item */ public function processIncomingRequest(ACore $item) { } /** * @param ACore $item */ public function processResult(ACore $item) { } /** * @param ACore $item * * @return ACore * @throws ItemNotFoundException */ public function getItem(ACore $item): ACore { throw new ItemNotFoundException(); } /** * @param string $id * * @return ACore * @throws ItemNotFoundException */ public function getItemById(string $id): ACore { throw new ItemNotFoundException(); } /** * @param ACore $item */ public function save(ACore $item) { /** @var Document $item */ if (!$item->isRoot()) { $item->setParentId( $item->getParent() ->getId() ); } try { $this->cacheDocumentsRequest->getById($item->getId()); $this->cacheDocumentsRequest->update($item); } catch (CacheDocumentDoesNotExistException $e) { if (!$this->cacheDocumentsRequest->isDuplicate($item)) { $this->cacheDocumentsRequest->save($item); } } } /** * @param ACore $item */ public function update(ACore $item) { } /** * @param ACore $item */ public function delete(ACore $item) { // $this->cacheDocumentsRequest->delete($item); } /** * @param ACore $item * @param string $source */ public function event(ACore $item, string $source) { } }