* @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\Internal; use OCA\Social\Db\StreamRequest; use OCA\Social\Exceptions\ItemNotFoundException; use OCA\Social\Interfaces\IActivityPubInterface; use OCA\Social\Model\ActivityPub\ACore; use OCA\Social\Model\ActivityPub\Internal\SocialAppNotification; use OCA\Social\Service\ConfigService; use OCA\Social\Service\CurlService; use OCA\Social\Service\MiscService; class SocialAppNotificationInterface implements IActivityPubInterface { /** @var StreamRequest */ private $streamRequest; /** @var CurlService */ private $curlService; /** @var ConfigService */ private $configService; /** @var MiscService */ private $miscService; /** * NoteInterface constructor. * * @param StreamRequest $streamRequest * @param CurlService $curlService * @param ConfigService $configService * @param MiscService $miscService */ public function __construct( StreamRequest $streamRequest, CurlService $curlService, ConfigService $configService, MiscService $miscService ) { $this->streamRequest = $streamRequest; $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 { throw new ItemNotFoundException(); } /** * @param ACore $notification */ public function save(ACore $notification) { /** @var SocialAppNotification $notification */ if ($notification->getId() === '') { return; } $this->miscService->log('Generating notification: ' . json_encode($notification, JSON_UNESCAPED_SLASHES), 1); $this->streamRequest->save($notification); } /** * @param ACore $activity * @param ACore $item */ public function activity(Acore $activity, ACore $item) { } /** * @param ACore $item */ public function delete(ACore $item) { } }