src/DataProvider/ValidationKycDataProvider.php line 38

Open in your IDE?
  1. <?php
  3. namespace App\DataProvider;
  5. use ApiPlatform\Core\Bridge\Doctrine\Orm\Extension\PaginationExtension;
  6. use ApiPlatform\Core\Bridge\Doctrine\Orm\Extension\QueryResultCollectionExtensionInterface;
  7. use ApiPlatform\Core\Bridge\Doctrine\Orm\Util\QueryNameGenerator;
  8. use ApiPlatform\Core\DataProvider\ContextAwareCollectionDataProviderInterface;
  9. use ApiPlatform\Core\DataProvider\RestrictedDataProviderInterface;
  10. use App\Repository\OrganizationRepository;
  11. use Evo\Infrastructure\MappingORM\Organization;
  12. use Symfony\Component\HttpFoundation\Request;
  13. use Symfony\Component\HttpFoundation\RequestStack;
  15. final class ValidationKycDataProvider implements ContextAwareCollectionDataProviderInterface, RestrictedDataProviderInterface
  16. {
  17.     private const OPERATION = 'validation_kyc';
  19.     private OrganizationRepository $orgaRepo;
  20.     private RequestStack $requestStack;
  21.     private PaginationExtension $paginationExtension;
  23.     public function __construct(
  24.         OrganizationRepository $orgaRepo,
  25.         RequestStack $requestStack,
  26.         PaginationExtension $paginationExtension
  27.     ) {
  28.         $this->orgaRepo = $orgaRepo;
  29.         $this->requestStack = $requestStack;
  30.         $this->paginationExtension = $paginationExtension;
  31.     }
  33.     public function supports(string $resourceClass, string $operationName = null, array $context = []): bool
  34.     {
  35.         return Organization::class === $resourceClass && self::OPERATION === $operationName;
  36.     }
  38.     public function getCollection(string $resourceClass, string $operationName = null, array $context = [])
  39.     {
  40.         $allStatus = [];
  41.         $request = $this->requestStack->getCurrentRequest();
  43.         if (!$request instanceof Request) {
  44.             return [];
  45.         }
  47.         $status = $request->attributes->get('status');
  49.         $allStatus[] = $status;
  51.         if (null !== $request->query->get('organization_status') && !empty($request->query->get('organization_status'))) {
  52.             foreach ($request->query->get('organization_status') as $orgaStatus) {
  53.                 $allStatus[] = $orgaStatus;
  54.             }
  55.         }
  57.         $queryBuilder = $this->orgaRepo->getOrgaToKYC($allStatus, true);
  59.         $this->paginationExtension->applyToCollection($queryBuilder, new QueryNameGenerator(), $resourceClass, $operationName, $context);
  61.         if ($this->paginationExtension instanceof QueryResultCollectionExtensionInterface
  62.             && $this->paginationExtension->supportsResult($resourceClass, $operationName, $context)) {
  63.             return $this->paginationExtension->getResult($queryBuilder, $resourceClass, $operationName, $context);
  64.         }
  66.         return $queryBuilder->getQuery()->getResult();
  67.     }
  68. }