AzuraCast/src/Controller/Api/Stations/Reports/RequestsController.php

<?php

declare(strict_types=1);

namespace App\Controller\Api\Stations\Reports;

use App\Container\EntityManagerAwareTrait;
use App\Controller\Api\Traits\CanSearchResults;
use App\Controller\Api\Traits\CanSortResults;
use App\Entity\Api\Status;
use App\Entity\Repository\StationRequestRepository;
use App\Entity\StationRequest;
use App\Http\Response;
use App\Http\ServerRequest;
use App\Paginator;
use App\Utilities\Types;
use Doctrine\Common\Collections\Order;
use Doctrine\ORM\AbstractQuery;
use Psr\Http\Message\ResponseInterface;

final class RequestsController
{
    use EntityManagerAwareTrait;
    use CanSortResults;
    use CanSearchResults;

    public function __construct(
        private readonly StationRequestRepository $requestRepo
    ) {
    }

    public function listAction(
        ServerRequest $request,
        Response $response
    ): ResponseInterface {
        $station = $request->getStation();

        $qb = $this->em->createQueryBuilder()
            ->select('sr, sm')
            ->from(StationRequest::class, 'sr')
            ->join('sr.track', 'sm')
            ->where('sr.station = :station')
            ->setParameter('station', $station);

        $type = Types::string($request->getParam('type', 'recent'));
        $qb = match ($type) {
            'history' => $qb->andWhere('sr.played_at != 0'),
            default => $qb->andWhere('sr.played_at = 0'),
        };

        $qb = $this->sortQueryBuilder(
            $request,
            $qb,
            [
                'name' => 'sm.title',
                'title' => 'sm.title',
                'artist' => 'sm.artist',
                'album' => 'sm.album',
                'genre' => 'sm.genre',
            ],
            'sr.timestamp',
            Order::Descending
        );

        $qb = $this->searchQueryBuilder(
            $request,
            $qb,
            [
                'sm.title',
                'sm.artist',
                'sm.album',
            ]
        );

        $query = $qb->getQuery()
            ->setHydrationMode(AbstractQuery::HYDRATE_ARRAY);

        $paginator = Paginator::fromQuery($query, $request);

        $router = $request->getRouter();

        $paginator->setPostprocessor(function ($row) use ($router) {
            $row['links'] = [];

            if (0 === $row['played_at']) {
                $row['links']['delete'] = $router->fromHere(
                    'api:stations:reports:requests:delete',
                    ['request_id' => $row['id']]
                );
            }

            return $row;
        });

        return $paginator->write($response);
    }

    public function deleteAction(
        ServerRequest $request,
        Response $response,
        array $params
    ): ResponseInterface {
        /** @var string $requestId */
        $requestId = $params['request_id'];

        $station = $request->getStation();
        $media = $this->requestRepo->getPendingRequest($requestId, $station);

        if ($media instanceof StationRequest) {
            $this->em->remove($media);
            $this->em->flush();
        }

        return $response->withJson(Status::deleted());
    }

    public function clearAction(
        ServerRequest $request,
        Response $response
    ): ResponseInterface {
        $station = $request->getStation();
        $this->requestRepo->clearPendingRequests($station);

        return $response->withJson(Status::deleted());
    }
}