bundles/VehicleIngestBundle/Controller/LeasingController.php line 23

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\IngestLeasingMessage;
  13. use VehicleIngestBundle\Service\ErrorResponseFactory;
  15. /**
  16.  * Accept-and-enqueue only: this controller's job is purely to satisfy the mobile.de seller-api
  17.  * contract (200 on PUT, 204 on DELETE) so the automedia exporter doesn't error on the leasing
  18.  * sub-resource, and to hand the payload off to Messenger. The actual persistence (mapping onto
  19.  * the vehicle's `Leasing` objectbrick + filterRate) happens asynchronously in
  20.  * IngestLeasingMessageHandler/LeasingMapper (Plan 3, Task 5) - kept off the request path so a
  21.  * slow/delayed leasing push never blocks the automedia exporter's ack.
  22.  */
  23. class LeasingController extends FrontendController
  24. {
  25.     public function __construct(
  26.         private MessageBusInterface $bus,
  27.         private ErrorResponseFactory $errors,
  28.     ) {
  29.     }
  31.     /**
  32.      * @Route("/seller-api/sellers/{sellerId}/ads/{adId}/leasing", name="seller_api_ad_leasing_put", methods={"PUT"}, requirements={"adId"="\d+"})
  33.      */
  34.     public function putLeasingAction(Request $request, string $adId): Response
  35.     {
  36.         $data = json_decode($request->getContent(), true);
  37.         if (!is_array($data)) {
  38.             return $this->errors->keyed('body');
  39.         }
  41.         $this->bus->dispatch(new IngestLeasingMessage($adId, 'upsert', $data));
  43.         return new Response('', Response::HTTP_OK);
  44.     }
  46.     /**
  47.      * @Route("/seller-api/sellers/{sellerId}/ads/{adId}/leasing", name="seller_api_ad_leasing_delete", methods={"DELETE"}, requirements={"adId"="\d+"})
  48.      */
  49.     public function deleteLeasingAction(string $adId): Response
  50.     {
  51.         $this->bus->dispatch(new IngestLeasingMessage($adId, 'delete', null));
  53.         return new Response('', Response::HTTP_NO_CONTENT);
  54.     }
  55. }