Stu\Orm\Repository\PrivateMessageRepository

Complexity

Total Complexity

12

Size/Duplication

Total Lines	125
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	getNewAmountByFolder()	0	6	1
A	getAmountByFolder()	0	5	1
A	getByUserAndFolder()	0	11	1
A	setDeleteTimestampByFolder()	0	11	1
A	save()	0	8	2
A	prototype()	0	3	1
A	getOrderedCorrepondence()	0	28	1
A	getByReceiver()	0	4	1
A	getBySender()	0	4	1
A	truncateAllPrivateMessages()	0	8	1
A	unsetAllInboxReferences()	0	9	1

<?php

declare(strict_types=1);

namespace Stu\Orm\Repository;

use Doctrine\ORM\EntityRepository;
use Stu\Orm\Entity\PrivateMessage;
use Stu\Orm\Entity\PrivateMessageFolder;
use Stu\Orm\Entity\PrivateMessageFolderInterface;
use Stu\Orm\Entity\PrivateMessageInterface;
use Stu\Orm\Entity\UserInterface;

/**
 * @extends EntityRepository<PrivateMessage>
 */
final class PrivateMessageRepository extends EntityRepository implements PrivateMessageRepositoryInterface
{
    public function prototype(): PrivateMessageInterface
    {
        return new PrivateMessage();
    }

    public function save(PrivateMessageInterface $post, bool $doFlush = false): void
    {
        $em = $this->getEntityManager();

        $em->persist($post);

        if ($doFlush) {
            $em->flush();
        }
    }

    public function getOrderedCorrepondence(
        int $senderUserId,
        int $recipientUserId,
        array $specialIds,
        int $limit
    ): array {
        return $this->getEntityManager()
            ->createQuery(
                sprintf(
                    'SELECT pm FROM %s pm
                    JOIN %s pmf
                    WITH pm.cat_id = pmf.id
                    WHERE ((pm.send_user = :sendUserId AND pm.recip_user = :recipUserId) OR
                        (pm.send_user = :recipUserId AND pm.recip_user = :sendUserId))
                    AND pmf.special in (:specialIds)
                    AND pm.deleted IS NULL
                    ORDER BY pm.date DESC',
                    PrivateMessage::class,
                    PrivateMessageFolder::class
                )
            )
            ->setParameters([
                'sendUserId' => $senderUserId,
                'recipUserId' => $recipientUserId,
                'specialIds' => $specialIds
            ])
            ->setMaxResults($limit)
            ->getResult();
    }

    public function getBySender(UserInterface $user): array
    {
        return $this->findBy(
            ['send_user' => $user->getId()]
        );
    }

    public function getByReceiver(UserInterface $user): array
    {
        return $this->findBy(
            ['recip_user' => $user->getId()]
        );
    }

    public function getByUserAndFolder(
        int $userId,
        int $folderId,
        int $offset,
        int $limit
    ): array {
        return $this->findBy(
            ['recip_user' => $userId, 'cat_id' => $folderId, 'deleted' => null],
            ['date' => 'desc', 'id' => 'desc'],
            $limit,
            $offset
        );
    }

    public function getAmountByFolder(PrivateMessageFolderInterface $privateMessageFolder): int
    {
        return $this->count([
            'category' => $privateMessageFolder,
            'deleted' => null
        ]);
    }

    public function getNewAmountByFolder(PrivateMessageFolderInterface $privateMessageFolder): int
    {
        return $this->count([
            'category' => $privateMessageFolder,
            'new' => 1,
            'deleted' => null
        ]);
    }

    public function setDeleteTimestampByFolder(int $folderId, int $timestamp): void
    {
        $this->getEntityManager()->createQuery(
            sprintf(
                'UPDATE %s pm SET pm.deleted = :timestamp WHERE pm.cat_id = :folderId',
                PrivateMessage::class
            )
        )->setParameters([
            'folderId' => $folderId,
            'timestamp' => $timestamp
        ])->execute();
    }

    public function unsetAllInboxReferences(): void
    {
        $this->getEntityManager()->createQuery(
            sprintf(
                'UPDATE %s pm
                SET pm.inbox_pm_id = null',
                PrivateMessage::class
            )
        )->execute();
    }

    public function truncateAllPrivateMessages(): void
    {
        $this->getEntityManager()->createQuery(
            sprintf(
                'DELETE FROM %s pm',
                PrivateMessage::class
            )
        )->execute();
    }
}