Bone\BoneDoctrine\Middleware\ApiCollectionPaginator

Complexity

Total Complexity

7

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
B	process()	0	67	6
A	__construct()	0	4	1

<?php

declare(strict_types=1);

namespace Bone\BoneDoctrine\Middleware;

use Doctrine\Common\Collections\ArrayCollection;
use Doctrine\ORM\EntityManagerInterface;
use JMS\Serializer\SerializerInterface;

The type JMS\Serializer\SerializerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Laminas\Diactoros\Response\JsonResponse;

The type Laminas\Diactoros\Response\JsonResponse was not found. Maybe you did not declare it correctly or list all dependencies?

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;

use Symfony\Component\Serializer\Serializer;

The type Symfony\Component\Serializer\Serializer was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Serializer\Encoder\JsonEncoder;

The type Symfony\Component\Serializer\Encoder\JsonEncoder was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Serializer\Normalizer\ObjectNormalizer;

The type Symfony\Component\Serializer\Normalizer\ObjectNormalizer was not found. Maybe you did not declare it correctly or list all dependencies?

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

    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();

The assignment to $requestAttributeName is dead and can be removed.

        $entities = $this->entityManager->getRepository($entityClass)->findBy($whereCriteria, $orderByCriteria, $limit, $offset);
        $totalRecords = $this->entityManager->getRepository($entityClass)->count($whereCriteria);
        $totalPages = (int) ceil($totalRecords / $limit);
        $uri = $request->getUri();

        $hal = [
            '_links' => [
                'self' => [
                    'href' => $uri->getScheme() . '://' . $uri->getHost() . $uri->getPath(),
                ],
                'first' => [
                    'href' => $uri->getScheme() . '://' . $uri->getHost() . $uri->getPath(),
                ],
            ],
        ];

        if ($page !== 1) {
            $hal['_links']['prev'] = [
                'href' => $uri->getScheme() . '://' . $uri->getHost() . $uri->getPath() . '?page=' . ($page - 1),
            ];
        }

        if ($page !== $totalPages) {
            $hal['_links']['next'] = [
                'href' => $uri->getScheme() . '://' . $uri->getHost() . $uri->getPath() . '?page=' . ($page + 1),
            ];
        }

        $hal['_links']['last'] = [
            'href' => $uri->getScheme() . '://' . $uri->getHost() . $uri->getPath() . '?page=' . $totalPages,
        ];

        $hal['_embedded'] = [];

        $encoders = [new JsonEncoder()];
        $normalizers = [new ObjectNormalizer()];
        $serializer = new Serializer($normalizers, $encoders);

//        foreach ($entities as $entity) {
            $hal['_embedded'][] = $serializer->serialize($entities, 'json'); //$entity->toArray();
//        }

        $hal['totalPages'] = $totalPages;
        $hal['totalRecords'] = $totalRecords;
        /** @todo add _self links for entities in collection */
        foreach ($hal['_embedded'] as $key => $value) {
            $hal['_embedded'][$key]['_links'] = [
                'self' => [
                    'href' => $uri->getScheme() . '://' . $uri->getHost() . $uri->getPath() . '/' . $value['id'],
                ],
            ];
        }

        $response = new JsonResponse($hal);
        $response = $response->withHeader('Content-Type', 'application/hal+json');

        return $response;
    }
}