TokenSqlDataMapper::getBaseQuery() - Code Metrics - abterphp/admin - Measure and Improve Code Quality continuously with Scrutinizer

TokenSqlDataMapper::getBaseQuery() A
last analyzed 2023-01-23 22:21 UTC

↳ Parent: TokenSqlDataMapper

Complexity

Conditions	1
Paths	1

Size

Total Lines	11
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	8
c	1
b	0
f	0
dl	0
loc	11
rs	10
cc	1
nc	1
nop	0

<?php

declare(strict_types=1);

namespace AbterPhp\Admin\Orm\DataMappers;

use AbterPhp\Admin\Domain\Entities\Token as Entity;
use AbterPhp\Framework\Domain\Entities\IStringerEntity;
use DateTimeImmutable;
use Exception;
use Opulence\Orm\DataMappers\SqlDataMapper;
use Opulence\Orm\OrmException;
use Opulence\QueryBuilders\Expression;
use Opulence\QueryBuilders\InvalidQueryException;
use Opulence\QueryBuilders\MySql\QueryBuilder;
use Opulence\QueryBuilders\SelectQuery;

/** @phan-file-suppress PhanTypeMismatchArgument */
class TokenSqlDataMapper extends SqlDataMapper implements ITokenDataMapper
{
    /**
     * @param IStringerEntity $entity
     */
    public function add($entity)
    {
        assert($entity instanceof Entity, new \InvalidArgumentException());

        $revokedAtTye = $entity->getRevokedAt() === null ? \PDO::PARAM_NULL : \PDO::PARAM_STR;

        $query = (new QueryBuilder())
            ->insert(
                'tokens',
                [
                    'id'            => [$entity->getId(), \PDO::PARAM_STR],
                    'api_client_id' => [$entity->getApiClientId(), \PDO::PARAM_STR],
                    'expires_at'    => [$entity->getExpiresAt(), \PDO::PARAM_STR],
                    'revoked_at'    => [$entity->getRevokedAt(), $revokedAtTye],
                ]
            );

        $statement = $this->writeConnection->prepare($query->getSql());
        $statement->bindValues($query->getParameters());
        $statement->execute();
    }

    /**
     * @param IStringerEntity $entity
     *
     * @throws InvalidQueryException
     */
    public function delete($entity)
    {
        assert($entity instanceof Entity, new \InvalidArgumentException());

        $query = (new QueryBuilder())
            ->update(
                'tokens',
                'tokens',
                ['deleted_at' => new Expression('NOW()')]
            )
            ->where('id = ?')
            ->addUnnamedPlaceholderValue($entity->getId(), \PDO::PARAM_STR);

        $statement = $this->writeConnection->prepare($query->getSql());
        $statement->bindValues($query->getParameters());
        $statement->execute();
    }

    /**
     * @return Entity[]
     * @throws OrmException
     */
    public function getAll(): array
    {
        $query = $this->getBaseQuery();

        $sql = $query->getSql();

        return $this->read($sql, [], self::VALUE_TYPE_ARRAY);

    }

    /**
     * @param int|string $id
     *
     * @return Entity|null
     * @throws OrmException
     */
    public function getById($id): ?Entity
    {
        $query = $this->getBaseQuery()->andWhere('tokens.id = :token_id');

        $sql    = $query->getSql();
        $params = ['token_id' => [$id, \PDO::PARAM_STR]];

        return $this->read($sql, $params, self::VALUE_TYPE_ENTITY, true);

    }

    /**
     * @param string $clientId
     *
     * @return Entity|null
     * @throws OrmException
     */
    public function getByClientId(string $clientId): ?Entity
    {
        $query = $this->getBaseQuery()->andWhere('tokens.api_client_id = :api_client_id');

        $sql    = $query->getSql();
        $params = ['api_client_id' => [$clientId, \PDO::PARAM_STR]];

        return $this->read($sql, $params, self::VALUE_TYPE_ENTITY, true);

    }

    /**
     * @param IStringerEntity $entity
     *
     * @throws InvalidQueryException
     */
    public function update($entity)
    {
        assert($entity instanceof Entity, new \InvalidArgumentException());

        $revokedAtTye = $entity->getRevokedAt() === null ? \PDO::PARAM_NULL : \PDO::PARAM_STR;

        $query = (new QueryBuilder())
            ->update(
                'tokens',
                'tokens',
                [
                    'api_client_id' => [$entity->getApiClientId(), \PDO::PARAM_STR],
                    'expires_at'    => [$entity->getExpiresAt(), \PDO::PARAM_STR],
                    'revoked_at'    => [$entity->getRevokedAt(), $revokedAtTye],
                ]
            )
            ->where('id = ?')
            ->addUnnamedPlaceholderValue($entity->getId(), \PDO::PARAM_STR);

        $statement = $this->writeConnection->prepare($query->getSql());
        $statement->bindValues($query->getParameters());
        $statement->execute();
    }

    /**
     * @param array $data
     *
     * @return Entity
     * @throws Exception
     */
    protected function loadEntity(array $data): Entity
    {
        $expiresAt = new DateTimeImmutable($data['expires_at']);
        $revokedAt = null;
        if (null !== $data['revoked_at']) {
            $revokedAt = new DateTimeImmutable($data['revoked_at']);
        }

        return new Entity(
            $data['id'],
            $data['api_client_id'],
            $expiresAt,
            $revokedAt
        );
    }

    /**
     * @return SelectQuery
     */
    private function getBaseQuery(): SelectQuery
    {
        return (new QueryBuilder())
            ->select(
                'tokens.id',
                'tokens.api_client_id',
                'tokens.expires_at',
                'tokens.revoked_at'
            )
            ->from('tokens')
            ->where('tokens.deleted_at IS NULL');
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace AbterPhp\Admin\Orm\DataMappers;
6
7			use AbterPhp\Admin\Domain\Entities\Token as Entity;
8			use AbterPhp\Framework\Domain\Entities\IStringerEntity;
9			use DateTimeImmutable;
10			use Exception;
11			use Opulence\Orm\DataMappers\SqlDataMapper;
12			use Opulence\Orm\OrmException;
13			use Opulence\QueryBuilders\Expression;
14			use Opulence\QueryBuilders\InvalidQueryException;
15			use Opulence\QueryBuilders\MySql\QueryBuilder;
16			use Opulence\QueryBuilders\SelectQuery;
17
18			/** @phan-file-suppress PhanTypeMismatchArgument */
19			class TokenSqlDataMapper extends SqlDataMapper implements ITokenDataMapper
20			{
21			/**
22			* @param IStringerEntity $entity
23			*/
24			public function add($entity)
25			{
26			assert($entity instanceof Entity, new \InvalidArgumentException());
27
28			$revokedAtTye = $entity->getRevokedAt() === null ? \PDO::PARAM_NULL : \PDO::PARAM_STR;
29
30			$query = (new QueryBuilder())
31			->insert(
32			'tokens',
33			[
34			'id' => [$entity->getId(), \PDO::PARAM_STR],
35			'api_client_id' => [$entity->getApiClientId(), \PDO::PARAM_STR],
36			'expires_at' => [$entity->getExpiresAt(), \PDO::PARAM_STR],
37			'revoked_at' => [$entity->getRevokedAt(), $revokedAtTye],
38			]
39			);
40
41			$statement = $this->writeConnection->prepare($query->getSql());
42			$statement->bindValues($query->getParameters());
43			$statement->execute();
44			}
45
46			/**
47			* @param IStringerEntity $entity
48			*
49			* @throws InvalidQueryException
50			*/
51			public function delete($entity)
52			{
53			assert($entity instanceof Entity, new \InvalidArgumentException());
54
55			$query = (new QueryBuilder())
56			->update(
57			'tokens',
58			'tokens',
59			['deleted_at' => new Expression('NOW()')]
60			)
61			->where('id = ?')
62			->addUnnamedPlaceholderValue($entity->getId(), \PDO::PARAM_STR);
63
64			$statement = $this->writeConnection->prepare($query->getSql());
65			$statement->bindValues($query->getParameters());
66			$statement->execute();
67			}
68
69			/**
70			* @return Entity[]
71			* @throws OrmException
72			*/
73			public function getAll(): array
74			{
75			$query = $this->getBaseQuery();
76
77			$sql = $query->getSql();
78
79			return $this->read($sql, [], self::VALUE_TYPE_ARRAY);
			0 ignored issues – show Bug Best Practice introduced 2019-05-27 00:20 UTC by Report Bug Copy Issue Report The expression `return $this->read($sql,...self::VALUE_TYPE_ARRAY)` could return the type `null` which is incompatible with the type-hinted return `array`. Consider adding an additional type-check to rule them out. Loading history...
80			}
81
82			/**
83			* @param int\|string $id
84			*
85			* @return Entity\|null
86			* @throws OrmException
87			*/
88			public function getById($id): ?Entity
89			{
90			$query = $this->getBaseQuery()->andWhere('tokens.id = :token_id');
91
92			$sql = $query->getSql();
93			$params = ['token_id' => [$id, \PDO::PARAM_STR]];
94
95			return $this->read($sql, $params, self::VALUE_TYPE_ENTITY, true);
			0 ignored issues – show Bug Best Practice introduced 2019-05-27 00:20 UTC by Report Bug Copy Issue Report The expression `return $this->read($sql,...ALUE_TYPE_ENTITY, true)` could return the type `array` which is incompatible with the type-hinted return `AbterPhp\Admin\Domain\Entities\Token\|null`. Consider adding an additional type-check to rule them out. Loading history...
96			}
97
98			/**
99			* @param string $clientId
100			*
101			* @return Entity\|null
102			* @throws OrmException
103			*/
104			public function getByClientId(string $clientId): ?Entity
105			{
106			$query = $this->getBaseQuery()->andWhere('tokens.api_client_id = :api_client_id');
107
108			$sql = $query->getSql();
109			$params = ['api_client_id' => [$clientId, \PDO::PARAM_STR]];
110
111			return $this->read($sql, $params, self::VALUE_TYPE_ENTITY, true);
			0 ignored issues – show Bug Best Practice introduced 2019-05-27 00:20 UTC by Report Bug Copy Issue Report The expression `return $this->read($sql,...ALUE_TYPE_ENTITY, true)` could return the type `array` which is incompatible with the type-hinted return `AbterPhp\Admin\Domain\Entities\Token\|null`. Consider adding an additional type-check to rule them out. Loading history...
112			}
113
114			/**
115			* @param IStringerEntity $entity
116			*
117			* @throws InvalidQueryException
118			*/
119			public function update($entity)
120			{
121			assert($entity instanceof Entity, new \InvalidArgumentException());
122
123			$revokedAtTye = $entity->getRevokedAt() === null ? \PDO::PARAM_NULL : \PDO::PARAM_STR;
124
125			$query = (new QueryBuilder())
126			->update(
127			'tokens',
128			'tokens',
129			[
130			'api_client_id' => [$entity->getApiClientId(), \PDO::PARAM_STR],
131			'expires_at' => [$entity->getExpiresAt(), \PDO::PARAM_STR],
132			'revoked_at' => [$entity->getRevokedAt(), $revokedAtTye],
133			]
134			)
135			->where('id = ?')
136			->addUnnamedPlaceholderValue($entity->getId(), \PDO::PARAM_STR);
137
138			$statement = $this->writeConnection->prepare($query->getSql());
139			$statement->bindValues($query->getParameters());
140			$statement->execute();
141			}
142
143			/**
144			* @param array $data
145			*
146			* @return Entity
147			* @throws Exception
148			*/
149			protected function loadEntity(array $data): Entity
150			{
151			$expiresAt = new DateTimeImmutable($data['expires_at']);
152			$revokedAt = null;
153			if (null !== $data['revoked_at']) {
154			$revokedAt = new DateTimeImmutable($data['revoked_at']);
155			}
156
157			return new Entity(
158			$data['id'],
159			$data['api_client_id'],
160			$expiresAt,
161			$revokedAt
162			);
163			}
164
165			/**
166			* @return SelectQuery
167			*/
168			private function getBaseQuery(): SelectQuery
169			{
170			return (new QueryBuilder())
171			->select(
172			'tokens.id',
173			'tokens.api_client_id',
174			'tokens.expires_at',
175			'tokens.revoked_at'
176			)
177			->from('tokens')
178			->where('tokens.deleted_at IS NULL');
179			}
180			}
181

abterphp / admin

TokenSqlDataMapper::getBaseQuery() A last analyzed 2023-01-23 22:21 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

TokenSqlDataMapper::getBaseQuery() A
last analyzed 2023-01-23 22:21 UTC