bundles/VehicleIngestBundle/Controller/AdController.php line 17

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace VehicleIngestBundle\Controller;
  7. use Pimcore\Controller\FrontendController;
  8. use Symfony\Component\HttpFoundation\Request;
  9. use Symfony\Component\HttpFoundation\Response;
  10. use Symfony\Component\Messenger\MessageBusInterface;
  11. use Symfony\Component\Routing\Annotation\Route;
  12. use VehicleIngestBundle\Message\IngestAdMessage;
  13. use VehicleIngestBundle\Persistence\VehicleLookup;
  14. use VehicleIngestBundle\Registry\AdIdRegistry;
  15. use VehicleIngestBundle\Service\ErrorResponseFactory;
  17. class AdController extends FrontendController
  18. {
  19.     public function __construct(
  20.         private AdIdRegistry $registry,
  21.         private MessageBusInterface $bus,
  22.         private ErrorResponseFactory $errors,
  23.         private VehicleLookup $lookup,
  24.     ) {
  25.     }
  27.     /**
  28.      * @Route("/seller-api/sellers/{sellerId}/ads", name="seller_api_ad_create", methods={"POST"})
  29.      */
  30.     public function createAction(Request $request, string $sellerId): Response
  31.     {
  32.         $raw = $request->getContent();
  33.         $data = json_decode($raw, true);
  34.         if (!is_array($data)) {
  35.             return $this->errors->keyed('body');
  36.         }
  38.         $requestId = $request->headers->get('X-Mobile-Insertion-Request-Id');
  39.         $adId = $this->registry->mint($requestId);
  41.         $this->bus->dispatch(new IngestAdMessage('upsert', $adId, $data, $sellerId, $requestId));
  43.         return new Response('', Response::HTTP_CREATED, [
  44.             'Location' => sprintf('/seller-api/sellers/%s/ads/%s', $sellerId, $adId),
  45.         ]);
  46.     }
  48.     /**
  49.      * @Route("/seller-api/sellers/{sellerId}/ads/{adId}", name="seller_api_ad_update", methods={"PUT"}, requirements={"adId"="\d+"})
  50.      */
  51.     public function updateAction(Request $request, string $sellerId, string $adId): Response
  52.     {
  53.         if (!$this->registry->exists($adId) && $this->lookup->byAdId($adId) === null) {
  54.             return new Response('', Response::HTTP_NOT_FOUND);
  55.         }
  57.         $data = json_decode($request->getContent(), true);
  58.         if (!is_array($data)) {
  59.             return $this->errors->keyed('body');
  60.         }
  62.         $this->bus->dispatch(new IngestAdMessage('upsert', $adId, $data, $sellerId, null));
  64.         return new Response('', Response::HTTP_OK);
  65.     }
  67.     /**
  68.      * @Route("/seller-api/sellers/{sellerId}/ads/{adId}", name="seller_api_ad_delete", methods={"DELETE"}, requirements={"adId"="\d+"})
  69.      */
  70.     public function deleteAction(string $sellerId, string $adId): Response
  71.     {
  72.         $this->bus->dispatch(new IngestAdMessage('delete', $adId, null, $sellerId, null));
  74.         return new Response('', Response::HTTP_NO_CONTENT);
  75.     }
  77.     /**
  78.      * @Route("/seller-api/sellers/{sellerId}/ads/{adId}", name="seller_api_ad_get", methods={"GET"}, requirements={"adId"="\d+"})
  79.      */
  80.     public function getAction(string $adId): Response
  81.     {
  82.         $exists = $this->registry->exists($adId) || $this->lookup->byAdId($adId) !== null;
  84.         return new Response('', $exists ? Response::HTTP_OK : Response::HTTP_NOT_FOUND);
  85.     }
  86. }