vendor/ibexa/shipping/src/bundle/EventSubscriber/ShipmentCancellingSubscriber.php line 40

Open in your IDE?
  1. <?php
  3. /**
  4. * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5. * @license For full copyright and license information view LICENSE file distributed with this source code.
  6. */
  7. declare(strict_types=1);
  9. namespace Ibexa\Bundle\Shipping\EventSubscriber;
  11. use Ibexa\Contracts\OrderManagement\Event\BeforeCancelOrderEvent;
  12. use Ibexa\Contracts\OrderManagement\Value\Order\OrderInterface;
  13. use Ibexa\Contracts\Shipping\Shipment\Query\Criterion\Order as ShipmentOrderCriterion;
  14. use Ibexa\Contracts\Shipping\Shipment\ShipmentInterface;
  15. use Ibexa\Contracts\Shipping\Shipment\ShipmentQuery;
  16. use Ibexa\Contracts\Shipping\Shipment\ShipmentUpdateStruct;
  17. use Ibexa\Contracts\Shipping\ShipmentServiceInterface;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. final class ShipmentCancellingSubscriber implements EventSubscriberInterface
  21. {
  22. private ShipmentServiceInterface $shipmentService;
  24. public function __construct(ShipmentServiceInterface $shipmentService)
  25. {
  26. $this->shipmentService = $shipmentService;
  27. }
  29. public static function getSubscribedEvents(): array
  30. {
  31. return [
  32. BeforeCancelOrderEvent::class => 'cancelShipment',
  33. ];
  34. }
  36. /**
  37. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\UnauthorizedException
  38. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\BadStateException
  39. */
  40. public function cancelShipment(BeforeCancelOrderEvent $event): void
  41. {
  42. $shipment = $this->getOrderShipment($event->getOrder());
  43. if ($shipment === null || $shipment->getStatus() === 'cancelled') {
  44. return;
  45. }
  47. $this->shipmentService->updateShipment($shipment, new ShipmentUpdateStruct('cancel'));
  48. }
  50. private function getOrderShipment(OrderInterface $order): ?ShipmentInterface
  51. {
  52. $shipments = $this->shipmentService->findShipments(
  53. new ShipmentQuery(new ShipmentOrderCriterion($order))
  54. )->getShipments();
  56. return $shipments[0] ?? null;
  57. }
  58. }