PrivateMessageRepository::unsetAllInboxReferences() - Code Metrics - Inspection of "messenger style inbox" - st-universe/core - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — dev ( 4c76dc...4abd48 )

by Janko

created 2024-12-27 19:58 UTC

unsetAllInboxReferences() A

↳ Parent: PrivateMessageRepository

Complexity

Conditions	1
Paths	1

Size

Total Lines	10
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

Metric	Value
cc	1
eloc	7
nc	1
nop	0
dl	0
loc	10
ccs	0
cts	8
cp	0
crap	2
rs	10
c	0
b	0
f	0

<?php

declare(strict_types=1);

namespace Stu\Orm\Repository;

use Doctrine\ORM\EntityRepository;
use Override;
filter:
    dependency_paths: ["lib/*"]
use Stu\Module\Game\Component\GameComponentEnum;
use Stu\Module\Message\Lib\PrivateMessageFolderTypeEnum;
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
{
    #[Override]
    public function prototype(): PrivateMessageInterface
    {
        return new PrivateMessage();
    }

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

        $em->persist($post);

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

    #[Override]
    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();
    }

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

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

    #[Override]
    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
        );
    }

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

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

    #[Override]
    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();
    }

    #[Override]
    public function hasRecentMessage(UserInterface $user): bool
    {
        return $this->getEntityManager()->createQuery(
            sprintf(
                'SELECT count(pm.id)
                    FROM %s pm
                    WHERE pm.receivingUser = :user
                    AND pm.new = :true
                    AND pm.date > :threshold',
                PrivateMessage::class
            )
        )
            ->setParameters([
                'user' => $user,
                'threshold' => time() - GameComponentEnum::PM->getRefreshIntervalInSeconds(),
                'true' => true
            ])
            ->getSingleScalarResult() > 0;
    }

    #[Override]
    public function getConversations(UserInterface $user): array
    {
        return $this->getEntityManager()->createQuery(
            sprintf(
                'SELECT pm FROM %1$s pm
                JOIN %2$s pmf
                WITH pm.cat_id = pmf.id
                LEFT JOIN %1$s inbox
                WITH pm.inbox_pm_id = inbox.id
                LEFT JOIN %2$s pmfinbox
                WITH inbox.cat_id = pmfinbox.id
                WHERE pmf.special in (:main, :out)
                AND (pmfinbox.special is null or pmfinbox.special = :main)
                AND pm.receivingUser = :user
                AND pm.deleted IS NULL
                AND  NOT EXISTS (SELECT pm2.id FROM %1$s pm2
                                    WHERE pm2.send_user = pm.send_user
                                    AND pm2.cat_id = pm.cat_id 
                                    AND pm2.recip_user = pm.recip_user 
                                    AND pm2.date > pm.date)
                ORDER BY pm.id DESC',
                PrivateMessage::class,
                PrivateMessageFolder::class
            )
        )
            ->setParameters([
                'user' => $user,
                'main' => PrivateMessageFolderTypeEnum::SPECIAL_MAIN,
                'out' => PrivateMessageFolderTypeEnum::SPECIAL_PMOUT
            ])
            ->getResult();
    }

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

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


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Stu\Orm\Repository;
6
7		use Doctrine\ORM\EntityRepository;
8		use Override;
		0 ignored issues – show Bug introduced 2024-07-04 06:34 UTC by Report Bug Copy Issue Report The type `Override` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
9		use Stu\Module\Game\Component\GameComponentEnum;
10		use Stu\Module\Message\Lib\PrivateMessageFolderTypeEnum;
11		use Stu\Orm\Entity\PrivateMessage;
12		use Stu\Orm\Entity\PrivateMessageFolder;
13		use Stu\Orm\Entity\PrivateMessageFolderInterface;
14		use Stu\Orm\Entity\PrivateMessageInterface;
15		use Stu\Orm\Entity\UserInterface;
16
17		/**
18		* @extends EntityRepository<PrivateMessage>
19		*/
20		final class PrivateMessageRepository extends EntityRepository implements PrivateMessageRepositoryInterface
21		{
22		#[Override]
23		public function prototype(): PrivateMessageInterface
24		{
25		return new PrivateMessage();
26		}
27
28		#[Override]
29		public function save(PrivateMessageInterface $post, bool $doFlush = false): void
30		{
31		$em = $this->getEntityManager();
32
33		$em->persist($post);
34
35		if ($doFlush) {
36		$em->flush();
37		}
38		}
39
40		#[Override]
41		public function getOrderedCorrepondence(
42		int $senderUserId,
43		int $recipientUserId,
44		array $specialIds,
45		int $limit
46		): array {
47		return $this->getEntityManager()
48		->createQuery(
49		sprintf(
50		'SELECT pm FROM %s pm
51		JOIN %s pmf
52		WITH pm.cat_id = pmf.id
53		WHERE ((pm.send_user = :sendUserId AND pm.recip_user = :recipUserId) OR
54		(pm.send_user = :recipUserId AND pm.recip_user = :sendUserId))
55		AND pmf.special in (:specialIds)
56		AND pm.deleted IS NULL
57		ORDER BY pm.date DESC',
58		PrivateMessage::class,
59		PrivateMessageFolder::class
60		)
61		)
62		->setParameters([
63		'sendUserId' => $senderUserId,
64		'recipUserId' => $recipientUserId,
65		'specialIds' => $specialIds
66		])
67		->setMaxResults($limit)
68		->getResult();
69		}
70
71		#[Override]
72		public function getBySender(UserInterface $user): array
73		{
74		return $this->findBy(
75		['send_user' => $user->getId()]
76		);
77		}
78
79		#[Override]
80		public function getByReceiver(UserInterface $user): array
81		{
82		return $this->findBy(
83		['recip_user' => $user->getId()]
84		);
85		}
86
87	1	#[Override]
88		public function getByUserAndFolder(
89		int $userId,
90		int $folderId,
91		int $offset,
92		int $limit
93		): array {
94	1	return $this->findBy(
95	1	['recip_user' => $userId, 'cat_id' => $folderId, 'deleted' => null],
96	1	['date' => 'desc', 'id' => 'desc'],
97	1	$limit,
98	1	$offset
99	1	);
100		}
101
102	3	#[Override]
103		public function getAmountByFolder(PrivateMessageFolderInterface $privateMessageFolder): int
104		{
105	3	return $this->count([
106	3	'category' => $privateMessageFolder,
107	3	'deleted' => null
108	3	]);
109		}
110
111	6	#[Override]
112		public function getNewAmountByFolder(PrivateMessageFolderInterface $privateMessageFolder): int
113		{
114	6	return $this->count([
115	6	'category' => $privateMessageFolder,
116	6	'new' => 1,
117	6	'deleted' => null
118	6	]);
119		}
120
121		#[Override]
122		public function setDeleteTimestampByFolder(int $folderId, int $timestamp): void
123		{
124		$this->getEntityManager()->createQuery(
125		sprintf(
126		'UPDATE %s pm SET pm.deleted = :timestamp WHERE pm.cat_id = :folderId',
127		PrivateMessage::class
128		)
129		)->setParameters([
130		'folderId' => $folderId,
131		'timestamp' => $timestamp
132		])->execute();
133		}
134
135	184	#[Override]
136		public function hasRecentMessage(UserInterface $user): bool
137		{
138	184	return $this->getEntityManager()->createQuery(
139	184	sprintf(
140	184	'SELECT count(pm.id)
141		FROM %s pm
142		WHERE pm.receivingUser = :user
143		AND pm.new = :true
144	184	AND pm.date > :threshold',
145	184	PrivateMessage::class
146	184	)
147	184	)
148	184	->setParameters([
149	184	'user' => $user,
150	184	'threshold' => time() - GameComponentEnum::PM->getRefreshIntervalInSeconds(),
151	184	'true' => true
152	184	])
153	184	->getSingleScalarResult() > 0;
154		}
155
156		#[Override]
157		public function getConversations(UserInterface $user): array
158		{
159		return $this->getEntityManager()->createQuery(
160		sprintf(
161		'SELECT pm FROM %1$s pm
162		JOIN %2$s pmf
163		WITH pm.cat_id = pmf.id
164		LEFT JOIN %1$s inbox
165		WITH pm.inbox_pm_id = inbox.id
166		LEFT JOIN %2$s pmfinbox
167		WITH inbox.cat_id = pmfinbox.id
168		WHERE pmf.special in (:main, :out)
169		AND (pmfinbox.special is null or pmfinbox.special = :main)
170		AND pm.receivingUser = :user
171		AND pm.deleted IS NULL
172		AND NOT EXISTS (SELECT pm2.id FROM %1$s pm2
173		WHERE pm2.send_user = pm.send_user
174		AND pm2.cat_id = pm.cat_id
175		AND pm2.recip_user = pm.recip_user
176		AND pm2.date > pm.date)
177		ORDER BY pm.id DESC',
178		PrivateMessage::class,
179		PrivateMessageFolder::class
180		)
181		)
182		->setParameters([
183		'user' => $user,
184		'main' => PrivateMessageFolderTypeEnum::SPECIAL_MAIN,
185		'out' => PrivateMessageFolderTypeEnum::SPECIAL_PMOUT
186		])
187		->getResult();
188		}
189
190		#[Override]
191		public function unsetAllInboxReferences(): void
192		{
193		$this->getEntityManager()->createQuery(
194		sprintf(
195		'UPDATE %s pm
196		SET pm.inbox_pm_id = null',
197		PrivateMessage::class
198		)
199		)->execute();
200		}
201
202		#[Override]
203		public function truncateAllPrivateMessages(): void
204		{
205		$this->getEntityManager()->createQuery(
206		sprintf(
207		'DELETE FROM %s pm',
208		PrivateMessage::class
209		)
210		)->execute();
211		}
212		}
213

st-universe / core

Push — dev ( 4c76dc...4abd48 )

unsetAllInboxReferences() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like