src/MessageHandler/Query/Beauty/Offer/GetMastersHandler.php line 38

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Slivki\MessageHandler\Query\Beauty\Offer;
  7. use Slivki\Entity\GeoLocation;
  8. use Slivki\Message\Query\Beauty\Offer\GetMastersQuery;
  9. use Slivki\Repository\Beauty\Masters\BeautyMasterRepositoryInterface;
  10. use Slivki\Repository\Offer\OfferRepositoryInterface;
  11. use Slivki\Response\Beauty\Offer\Factory\MasterResponseFactory;
  12. use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
  14. use function array_map;
  16. final class GetMastersHandler implements MessageHandlerInterface
  17. {
  18.     private OfferRepositoryInterface $offerRepository;
  19.     private BeautyMasterRepositoryInterface $beautyMasterRepository;
  20.     private MasterResponseFactory $responseFactory;
  22.     public function __construct(
  23.         OfferRepositoryInterface $offerRepository,
  24.         BeautyMasterRepositoryInterface $beautyMasterRepository,
  25.         MasterResponseFactory $responseFactory
  26.     ) {
  27.         $this->offerRepository = $offerRepository;
  28.         $this->beautyMasterRepository = $beautyMasterRepository;
  29.         $this->responseFactory = $responseFactory;
  30.     }
  32.     public function __invoke(GetMastersQuery $query): array
  33.     {
  34.         $offer = $this->offerRepository->getById($query->getOfferId());
  36.         $geoLocationIds = array_map(
  37.             static fn (GeoLocation $geoLocation): int => $geoLocation->getID(),
  38.             $offer->getGeoLocations()->toArray(),
  39.         );
  41.         return array_map(
  42.             [$this->responseFactory, 'create'],
  43.             $this->beautyMasterRepository->findByGeoLocationIds($geoLocationIds),
  44.         );
  45.     }
  46. }