Bone\BoneDoctrine\Middleware\CollectionPaginator

Complexity

Total Complexity

4

Size/Duplication

Total Lines	28
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	process()	0	17	3
A	__construct()	0	3	1

<?php

declare(strict_types=1);

namespace Bone\BoneDoctrine\Middleware;

use Doctrine\ORM\EntityManagerInterface;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;

abstract class CollectionPaginator implements MiddlewareInterface
{
    public function __construct(
        private EntityManagerInterface $entityManager,
    ) {}

    abstract public function getEntityClass(): string;
    abstract public function getWhereCriteria(): array;
    abstract public function getOrderByCriteria(): array;
    abstract public function getRequestAttributeName(): string;

    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        $params = $request->getQueryParams();
        $page = isset($params['page']) ? (int) $params['page'] : 1;
        $limit = isset($params['limit']) ? (int) $params['limit'] : 25;
        $offset = ($page *  $limit) - $limit;
        $entityClass = $this->getEntityClass();
        $whereCriteria = $this->getWhereCriteria();
        $orderByCriteria = $this->getWhereCriteria();
        $requestAttributeName = $this->getRequestAttributeName();
        $entities = $this->entityManager->getRepository($entityClass)->findBy($whereCriteria, $orderByCriteria, $limit, $offset);
        $request = $request->withAttribute($requestAttributeName, $entities);
        $request = $request->withAttribute('page', $page);
        $request = $request->withAttribute('totalPages', $page);
        $request = $request->withAttribute('totalRecords', $page);

        return $handler->handle($request);
    }
}