CultuurNet\UDB3\MyOrganizers\ReadModel\Doctrine\DBALLookupService

Complexity

Total Complexity

4

Size/Duplication

Total Lines	83
Duplicated Lines	14.46 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
B	itemsOwnedByUser()	12	56	3

<?php

namespace CultuurNet\UDB3\MyOrganizers\ReadModel\Doctrine;

use CultuurNet\UDB3\Iri\IriGeneratorInterface;
use CultuurNet\UDB3\MyOrganizers\MyOrganizersLookupServiceInterface;
use CultuurNet\UDB3\MyOrganizers\PartOfCollection;
use Doctrine\DBAL\Connection;
use PDO;
use ValueObjects\Number\Natural;
use ValueObjects\StringLiteral\StringLiteral;

class DBALLookupService implements MyOrganizersLookupServiceInterface
{
    use DBALHelperTrait;

    /** @var StringLiteral */
    private $tableName;

    /**
     * @var IriGeneratorInterface
     */
    private $iriGenerator;

    /**
     * @param Connection $connection
     * @param StringLiteral $tableName
     */
    public function __construct(
        Connection $connection,
        StringLiteral $tableName,
        IriGeneratorInterface $iriGenerator
    ) {
        $this->connection = $connection;
        $this->tableName = $tableName;
        $this->iriGenerator = $iriGenerator;
    }

    public function itemsOwnedByUser(
        string $userId,
        Natural $limit,
        Natural $start
    ): PartOfCollection {
        $queryBuilder = $this->connection->createQueryBuilder();

        $expr = $this->connection->getExpressionBuilder();
        $itemIsOwnedByUser = $expr->eq(Columns::UID, $this->parameter(Columns::UID));

        $queryBuilder->select(Columns::ID)
            ->from($this->tableName->toNative())
            ->where($itemIsOwnedByUser)
            ->orderBy(Columns::UPDATED, 'DESC')
            ->setMaxResults($limit->toNative())
            ->setFirstResult($start->toNative());

        $queryBuilder->setParameter(Columns::UID, $userId);

        $parameters = $queryBuilder->getParameters();

        $results = $queryBuilder->execute();

        // @todo transform @id here to an object that has a full URL
        // when json-encoded
        $organizers = array_map(
            function ($resultRow) {
                return [
                    '@id' => $this->iriGenerator->iri($resultRow[Columns::ID]),
                    '@type' => 'Organizer',
                ];
            },
            $results->fetchAll(PDO::FETCH_ASSOC)
        );

        $itemCount = count($organizers);

        // We can skip an additional query to determine to total items count
        // if the amount of rows on the first page does not reach the limit.
        $onFirstPage = $queryBuilder->getFirstResult() === 0;
        $hasSinglePage = $itemCount < $queryBuilder->getMaxResults();
        if ($onFirstPage && $hasSinglePage) {

This code seems to be duplicated across your project.

            $totalItems = $itemCount;
        } else {
            $q = $this->connection->createQueryBuilder();

            $totalItems = $q->resetQueryParts()->select('COUNT(*) AS total')
                ->from($this->tableName->toNative())
                ->where($itemIsOwnedByUser)
                ->setParameters($parameters)
                ->execute()
                ->fetchColumn(0);
        }

        return new PartOfCollection($organizers, new Natural($totalItems));
    }
}