feat(mail) : MailMessage entity + repository

src/Entity/MailMessage.php

@@ -0,0 +1,238 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Entity;
+
+use App\Repository\MailMessageRepository;
+use DateTimeImmutable;
+use Doctrine\ORM\Mapping as ORM;
+
+#[ORM\Entity(repositoryClass: MailMessageRepository::class)]
+#[ORM\Table(name: 'mail_message')]
+#[ORM\UniqueConstraint(name: 'uq_mail_message_folder_uid', columns: ['folder_id', 'uid'])]
+#[ORM\Index(columns: ['sent_at'], name: 'idx_mail_message_sent_at')]
+#[ORM\Index(columns: ['is_read'], name: 'idx_mail_message_is_read')]
+class MailMessage
+{
+    #[ORM\Id]
+    #[ORM\GeneratedValue]
+    #[ORM\Column]
+    private ?int $id = null;
+
+    #[ORM\Column(length: 500, unique: true)]
+    private string $messageId;
+
+    #[ORM\ManyToOne(targetEntity: MailFolder::class)]
+    #[ORM\JoinColumn(name: 'folder_id', referencedColumnName: 'id', nullable: false, onDelete: 'CASCADE')]
+    private MailFolder $folder;
+
+    #[ORM\Column]
+    private int $uid;
+
+    #[ORM\Column(length: 500, nullable: true)]
+    private ?string $subject = null;
+
+    #[ORM\Column(length: 255)]
+    private string $fromAddress;
+
+    #[ORM\Column(length: 255, nullable: true)]
+    private ?string $fromName = null;
+
+    #[ORM\Column(type: 'json')]
+    private array $toAddresses = [];
+
+    #[ORM\Column(type: 'json', nullable: true)]
+    private ?array $ccAddresses = null;
+
+    #[ORM\Column(type: 'datetimetz_immutable')]
+    private DateTimeImmutable $sentAt;
+
+    #[ORM\Column(type: 'boolean')]
+    private bool $isRead = false;
+
+    #[ORM\Column(type: 'boolean')]
+    private bool $isFlagged = false;
+
+    #[ORM\Column(type: 'boolean')]
+    private bool $hasAttachments = false;
+
+    #[ORM\Column(type: 'text', nullable: true)]
+    private ?string $snippet = null;
+
+    #[ORM\Column(type: 'datetimetz_immutable')]
+    private DateTimeImmutable $syncedAt;
+
+    public function getId(): ?int
+    {
+        return $this->id;
+    }
+
+    public function getMessageId(): string
+    {
+        return $this->messageId;
+    }
+
+    public function setMessageId(string $messageId): static
+    {
+        $this->messageId = $messageId;
+
+        return $this;
+    }
+
+    public function getFolder(): MailFolder
+    {
+        return $this->folder;
+    }
+
+    public function setFolder(MailFolder $folder): static
+    {
+        $this->folder = $folder;
+
+        return $this;
+    }
+
+    public function getUid(): int
+    {
+        return $this->uid;
+    }
+
+    public function setUid(int $uid): static
+    {
+        $this->uid = $uid;
+
+        return $this;
+    }
+
+    public function getSubject(): ?string
+    {
+        return $this->subject;
+    }
+
+    public function setSubject(?string $subject): static
+    {
+        $this->subject = $subject;
+
+        return $this;
+    }
+
+    public function getFromAddress(): string
+    {
+        return $this->fromAddress;
+    }
+
+    public function setFromAddress(string $fromAddress): static
+    {
+        $this->fromAddress = $fromAddress;
+
+        return $this;
+    }
+
+    public function getFromName(): ?string
+    {
+        return $this->fromName;
+    }
+
+    public function setFromName(?string $fromName): static
+    {
+        $this->fromName = $fromName;
+
+        return $this;
+    }
+
+    public function getToAddresses(): array
+    {
+        return $this->toAddresses;
+    }
+
+    public function setToAddresses(array $toAddresses): static
+    {
+        $this->toAddresses = $toAddresses;
+
+        return $this;
+    }
+
+    public function getCcAddresses(): ?array
+    {
+        return $this->ccAddresses;
+    }
+
+    public function setCcAddresses(?array $ccAddresses): static
+    {
+        $this->ccAddresses = $ccAddresses;
+
+        return $this;
+    }
+
+    public function getSentAt(): DateTimeImmutable
+    {
+        return $this->sentAt;
+    }
+
+    public function setSentAt(DateTimeImmutable $sentAt): static
+    {
+        $this->sentAt = $sentAt;
+
+        return $this;
+    }
+
+    public function isRead(): bool
+    {
+        return $this->isRead;
+    }
+
+    public function setIsRead(bool $isRead): static
+    {
+        $this->isRead = $isRead;
+
+        return $this;
+    }
+
+    public function isFlagged(): bool
+    {
+        return $this->isFlagged;
+    }
+
+    public function setIsFlagged(bool $isFlagged): static
+    {
+        $this->isFlagged = $isFlagged;
+
+        return $this;
+    }
+
+    public function hasAttachments(): bool
+    {
+        return $this->hasAttachments;
+    }
+
+    public function setHasAttachments(bool $hasAttachments): static
+    {
+        $this->hasAttachments = $hasAttachments;
+
+        return $this;
+    }
+
+    public function getSnippet(): ?string
+    {
+        return $this->snippet;
+    }
+
+    public function setSnippet(?string $snippet): static
+    {
+        $this->snippet = $snippet;
+
+        return $this;
+    }
+
+    public function getSyncedAt(): DateTimeImmutable
+    {
+        return $this->syncedAt;
+    }
+
+    public function setSyncedAt(DateTimeImmutable $syncedAt): static
+    {
+        $this->syncedAt = $syncedAt;
+
+        return $this;
+    }
+}

src/Repository/MailMessageRepository.php

@@ -0,0 +1,57 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Repository;
+
+use App\Entity\MailFolder;
+use App\Entity\MailMessage;
+use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
+use Doctrine\Persistence\ManagerRegistry;
+
+class MailMessageRepository extends ServiceEntityRepository
+{
+    public function __construct(ManagerRegistry $registry)
+    {
+        parent::__construct($registry, MailMessage::class);
+    }
+
+    public function findByMessageId(string $messageId): ?MailMessage
+    {
+        return $this->findOneBy(['messageId' => $messageId]);
+    }
+
+    public function findByFolderAndUid(MailFolder $folder, int $uid): ?MailMessage
+    {
+        return $this->findOneBy(['folder' => $folder, 'uid' => $uid]);
+    }
+
+    /**
+     * @return list<MailMessage>
+     */
+    public function findByFolderPaginated(MailFolder $folder, int $limit, int $offset): array
+    {
+        return $this->createQueryBuilder('m')
+            ->andWhere('m.folder = :folder')
+            ->setParameter('folder', $folder)
+            ->orderBy('m.sentAt', 'DESC')
+            ->addOrderBy('m.id', 'DESC')
+            ->setMaxResults($limit)
+            ->setFirstResult($offset)
+            ->getQuery()
+            ->getResult()
+        ;
+    }
+
+    public function countUnreadByFolder(MailFolder $folder): int
+    {
+        return (int) $this->createQueryBuilder('m')
+            ->select('COUNT(m.id)')
+            ->andWhere('m.folder = :folder')
+            ->andWhere('m.isRead = false')
+            ->setParameter('folder', $folder)
+            ->getQuery()
+            ->getSingleScalarResult()
+        ;
+    }
+}