Implement report notifications

migrations/Version20240515122858.php

@@ -0,0 +1,30 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+final class Version20240515122858 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return 'Add the report field for notifications';
+    }
+
+    public function up(Schema $schema): void
+    {
+        $this->addSql('ALTER TABLE notification ADD report_id INT DEFAULT NULL');
+        $this->addSql('ALTER TABLE notification ADD CONSTRAINT FK_BF5476CA4BD2A4C0 FOREIGN KEY (report_id) REFERENCES report (id) ON DELETE CASCADE NOT DEFERRABLE INITIALLY IMMEDIATE');
+        $this->addSql('CREATE INDEX IDX_BF5476CA4BD2A4C0 ON notification (report_id)');
+    }
+
+    public function down(Schema $schema): void
+    {
+        $this->addSql('ALTER TABLE notification DROP CONSTRAINT FK_BF5476CA4BD2A4C0');
+        $this->addSql('DROP INDEX IDX_BF5476CA4BD2A4C0');
+        $this->addSql('ALTER TABLE notification DROP report_id');
+    }
+}

src/Controller/Admin/AdminReportController.php

@@ -5,6 +5,7 @@
 namespace App\Controller\Admin;
 
 use App\Controller\AbstractController;
+use App\Repository\NotificationRepository;
 use App\Repository\ReportRepository;
 use Symfony\Component\ExpressionLanguage\Expression;
 use Symfony\Component\HttpFoundation\Request;
@@ -15,6 +16,7 @@ class AdminReportController extends AbstractController
 {
     public function __construct(
         private readonly ReportRepository $repository,
+        private readonly NotificationRepository $notificationRepository,
     ) {
     }
 
@@ -24,6 +26,7 @@ public function __invoke(Request $request, string $status): Response
         $page = (int) $request->get('p', 1);
 
         $reports = $this->repository->findAllPaginated($page, $status);
+        $this->notificationRepository->markReportNotificationsAsRead($this->getUserOrThrow());
 
         return $this->render(
             'admin/reports.html.twig',

src/Controller/Api/Notification/NotificationBaseApi.php

@@ -5,8 +5,21 @@
 namespace App\Controller\Api\Notification;
 
 use App\Controller\Api\BaseApi;
+use App\DTO\EntryCommentResponseDto;
+use App\DTO\EntryResponseDto;
+use App\DTO\PostCommentResponseDto;
+use App\DTO\PostResponseDto;
+use App\Entity\Contracts\ReportInterface;
+use App\Entity\Entry;
+use App\Entity\EntryComment;
 use App\Entity\Notification;
+use App\Entity\Post;
+use App\Entity\PostComment;
+use App\Entity\ReportApprovedNotification;
+use App\Entity\ReportCreatedNotification;
+use App\Entity\ReportRejectedNotification;
 use App\Factory\MessageFactory;
+use GraphQL\Exception\ArgumentException;
 use Symfony\Contracts\Service\Attribute\Required;
 use Symfony\Contracts\Translation\TranslatorInterface;
 
@@ -110,8 +123,34 @@ protected function serializeNotification(Notification $dto)
                 $ban = $dto->getSubject();
                 $toReturn['subject'] = $this->magazineFactory->createBanDto($ban);
                 break;
+            case 'report_created_notification':
+                /** @var ReportCreatedNotification $n */
+                $n = $dto;
+                $toReturn['reason'] = $n->report->reason;
+                // no break
+            case 'report_rejected_notification':
+            case 'report_approved_notification':
+                /** @var ReportCreatedNotification|ReportRejectedNotification|ReportApprovedNotification $n */
+                $n = $dto;
+                $toReturn['subject'] = $this->createResponseDtoForReport($n->report->getSubject());
+                $toReturn['reportId'] = $n->report->getId();
+                break;
         }
 
         return $toReturn;
     }
+
+    private function createResponseDtoForReport(ReportInterface $subject): EntryCommentResponseDto|EntryResponseDto|PostCommentResponseDto|PostResponseDto
+    {
+        if ($subject instanceof Entry) {
+            return $this->entryFactory->createResponseDto($subject, $this->tagLinkRepository->getTagsOfEntry($subject));
+        } elseif ($subject instanceof EntryComment) {
+            return $this->entryCommentFactory->createResponseDto($subject, $this->tagLinkRepository->getTagsOfEntryComment($subject));
+        } elseif ($subject instanceof Post) {
+            return $this->postFactory->createResponseDto($subject, $this->tagLinkRepository->getTagsOfPost($subject));
+        } elseif ($subject instanceof PostComment) {
+            return $this->postCommentFactory->createResponseDto($subject, $this->tagLinkRepository->getTagsOfPostComment($subject));
+        }
+        throw new ArgumentException("cannot work with: '".\get_class($subject)."'");
+    }
 }

src/Controller/Magazine/Panel/MagazineReportController.php

@@ -8,6 +8,7 @@
 use App\Entity\Magazine;
 use App\Entity\Report;
 use App\Repository\MagazineRepository;
+use App\Repository\NotificationRepository;
 use App\Service\ReportManager;
 use Symfony\Bridge\Doctrine\Attribute\MapEntity;
 use Symfony\Component\HttpFoundation\Request;
@@ -18,6 +19,7 @@ class MagazineReportController extends AbstractController
 {
     public function __construct(
         private readonly MagazineRepository $repository,
+        private readonly NotificationRepository $notificationRepository,
         private readonly ReportManager $reportManager
     ) {
     }
@@ -27,6 +29,7 @@ public function __construct(
     public function reports(Magazine $magazine, Request $request, string $status): Response
     {
         $reports = $this->repository->findReports($magazine, $this->getPageNb($request), status: $status);
+        $this->notificationRepository->markReportNotificationsInMagazineAsRead($this->getUserOrThrow(), $magazine);
 
         return $this->render(
             'magazine/panel/reports.html.twig',

src/Controller/ReportController.php

@@ -63,9 +63,9 @@ private function getForm(ReportDto $dto, ReportInterface $subject): FormInterfac
 
     private function handleReportRequest(ReportDto $dto, Request $request): Response
     {
+        $reportError = false;
         try {
             $this->manager->report($dto, $this->getUserOrThrow());
-            $reportError = false;
             $responseMessage = $this->translator->trans('subject_reported');
         } catch (SubjectHasBeenReportedException $exception) {
             $reportError = true;

src/Controller/User/Profile/UserReportsController.php

@@ -6,6 +6,7 @@
 
 use App\Controller\AbstractController;
 use App\Repository\MagazineRepository;
+use App\Repository\NotificationRepository;
 use App\Repository\ReportRepository;
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Response;
@@ -17,6 +18,7 @@ class UserReportsController extends AbstractController
 
     public function __construct(
         private readonly ReportRepository $repository,
+        private readonly NotificationRepository $notificationRepository,
     ) {
     }
 
@@ -25,6 +27,7 @@ public function __invoke(MagazineRepository $repository, Request $request, strin
     {
         $user = $this->getUserOrThrow();
         $reports = $this->repository->findByUserPaginated($user, $this->getPageNb($request), status: $status);
+        $this->notificationRepository->markOwnReportNotificationsAsRead($this->getUserOrThrow());
 
         return $this->render(
             'user/settings/reports.html.twig',

src/Entity/Notification.php

@@ -39,6 +39,9 @@
     'post_comment_mentioned' => 'PostCommentMentionedNotification',
     'message' => 'MessageNotification',
     'ban' => 'MagazineBanNotification',
+    'report_created' => 'ReportCreatedNotification',
+    'report_approved' => 'ReportApprovedNotification',
+    'report_rejected' => 'ReportRejectedNotification',
 ])]
 abstract class Notification
 {

src/Entity/ReportApprovedNotification.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Entity;
+
+use Doctrine\ORM\Mapping\Entity;
+use Doctrine\ORM\Mapping\JoinColumn;
+use Doctrine\ORM\Mapping\ManyToOne;
+
+#[Entity]
+class ReportApprovedNotification extends Notification
+{
+    #[ManyToOne(targetEntity: Report::class)]
+    #[JoinColumn(nullable: true, onDelete: 'CASCADE')]
+    public ?Report $report = null;
+
+    public function __construct(User $receiver, Report $report)
+    {
+        parent::__construct($receiver);
+
+        $this->report = $report;
+    }
+
+    public function getType(): string
+    {
+        return 'report_approved_notification';
+    }
+}

src/Entity/ReportCreatedNotification.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Entity;
+
+use Doctrine\ORM\Mapping\Entity;
+use Doctrine\ORM\Mapping\JoinColumn;
+use Doctrine\ORM\Mapping\ManyToOne;
+
+#[Entity]
+class ReportCreatedNotification extends Notification
+{
+    #[ManyToOne(targetEntity: Report::class)]
+    #[JoinColumn(nullable: true, onDelete: 'CASCADE')]
+    public ?Report $report = null;
+
+    public function __construct(User $receiver, Report $report)
+    {
+        parent::__construct($receiver);
+
+        $this->report = $report;
+    }
+
+    public function getType(): string
+    {
+        return 'report_created_notification';
+    }
+}

src/Entity/ReportRejectedNotification.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Entity;
+
+use Doctrine\ORM\Mapping\Entity;
+use Doctrine\ORM\Mapping\JoinColumn;
+use Doctrine\ORM\Mapping\ManyToOne;
+
+#[Entity]
+class ReportRejectedNotification extends Notification
+{
+    #[ManyToOne(targetEntity: Report::class)]
+    #[JoinColumn(nullable: true, onDelete: 'CASCADE')]
+    public ?Report $report = null;
+
+    public function __construct(User $receiver, Report $report)
+    {
+        parent::__construct($receiver);
+
+        $this->report = $report;
+    }
+
+    public function getType(): string
+    {
+        return 'report_rejected_notification';
+    }
+}

src/EventSubscriber/ReportApprovedSubscriber.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\EventSubscriber;
+
+use App\Event\Report\ReportApprovedEvent;
+use App\Service\Notification\ReportNotificationManager;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+
+class ReportApprovedSubscriber implements EventSubscriberInterface
+{
+    public function __construct(
+        private readonly ReportNotificationManager $notificationManager,
+    ) {
+    }
+
+    public function onReportApproved(ReportApprovedEvent $reportedEvent): void
+    {
+        $this->notificationManager->sendReportApprovedNotification($reportedEvent->report);
+    }
+
+    public static function getSubscribedEvents(): array
+    {
+        return [
+            ReportApprovedEvent::class => 'onReportApproved',
+        ];
+    }
+}

src/EventSubscriber/ReportRejectedSubscriber.php

@@ -0,0 +1,29 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\EventSubscriber;
+
+use App\Event\Report\ReportRejectedEvent;
+use App\Service\Notification\ReportNotificationManager;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+
+class ReportRejectedSubscriber implements EventSubscriberInterface
+{
+    public function __construct(
+        private readonly ReportNotificationManager $notificationManager,
+    ) {
+    }
+
+    public function onReportRejected(ReportRejectedEvent $reportedEvent): void
+    {
+        $this->notificationManager->sendReportRejectedNotification($reportedEvent->report);
+    }
+
+    public static function getSubscribedEvents(): array
+    {
+        return [
+            ReportRejectedEvent::class => 'onReportRejected',
+        ];
+    }
+}

src/EventSubscriber/SubjectReportedSubscriber.php

@@ -6,6 +6,7 @@
 
 use App\Event\Report\SubjectReportedEvent;
 use App\Message\ActivityPub\Outbox\FlagMessage;
+use App\Service\Notification\ReportNotificationManager;
 use Psr\Log\LoggerInterface;
 use Symfony\Component\EventDispatcher\EventSubscriberInterface;
 use Symfony\Component\Messenger\MessageBusInterface;
@@ -15,12 +16,14 @@ class SubjectReportedSubscriber implements EventSubscriberInterface
     public function __construct(
         private readonly MessageBusInterface $bus,
         private readonly LoggerInterface $logger,
+        private readonly ReportNotificationManager $notificationManager,
     ) {
     }
 
     public function onSubjectReported(SubjectReportedEvent $reportedEvent): void
     {
         $this->logger->debug($reportedEvent->report->reported->username.' was reported for '.$reportedEvent->report->reason);
+        $this->notificationManager->sendReportCreatedNotification($reportedEvent->report);
         if (!$reportedEvent->report->magazine->apId and 'random' !== $reportedEvent->report->magazine->name) {
             return;
         }