Stu\Orm\Repository\KnCommentArchivRepository

Complexity

Total Complexity

6

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	delete()	0	6	1
A	getByPost()	0	5	1
A	prototype()	0	3	1
A	truncateByUser()	0	11	1
A	getAmountByPost()	0	3	1
A	save()	0	6	1

<?php

declare(strict_types=1);

namespace Stu\Orm\Repository;

use Doctrine\ORM\EntityRepository;
use Stu\Orm\Entity\KnCommentArchiv;
use Stu\Orm\Entity\KnCommentArchivInterface;
use Stu\Orm\Entity\KnPostArchivInterface;

/**
 * @extends EntityRepository<KnCommentArchiv>
 */
final class KnCommentArchivRepository extends EntityRepository implements KnCommentArchivRepositoryInterface
{
    public function getByPost(int $postId): array
    {
        return $this->findBy(
            ['post_id' => $postId],
            ['id' => 'desc'],
        );
    }

    public function getAmountByPost(KnPostArchivInterface $post): int
    {
        return $this->count(['post_id' => $post, 'deleted' => null]);
    }

    public function prototype(): KnCommentArchivInterface
    {
        return new KnCommentArchiv();
    }

    public function save(KnCommentArchivInterface $comment): void
    {
        $em = $this->getEntityManager();

        $em->persist($comment);
        $em->flush();
    }

    public function delete(KnCommentArchivInterface $comment): void
    {
        $em = $this->getEntityManager();

        $em->remove($comment);
        $em->flush();
    }

    public function truncateByUser(int $userId): void
    {
        $this->getEntityManager()
            ->createQuery(
                sprintf(
                    'DELETE FROM %s c WHERE c.user_id = :userId',
                    KnCommentArchiv::class
                )
            )
            ->setParameters(['userId' => $userId])
            ->execute();
    }
}