[framework] order info is now asynchronously sent to Heureka after or…

…der is created (#2936)
shopsys · Dec 14, 2023 · eb6824b · eb6824b
2 parents c05e3c4 + 0ad3f81
commit eb6824b
Show file tree

Hide file tree

Showing 7 changed files with 26 additions and 3 deletions.
diff --git a/app/.env.test b/app/.env.test
@@ -11,3 +11,5 @@ GOPAY_EN_CLIENTSECRET=test-data
 GOPAY_CS_GOID=test-data
 GOPAY_CS_CLIENTID=test-data
 GOPAY_CS_CLIENTSECRET=test-data
+
+MESSENGER_TRANSPORT_DSN=in-memory://
diff --git a/app/config/packages/messenger.yaml b/app/config/packages/messenger.yaml
@@ -15,6 +15,20 @@ framework:
                         type: direct
                     queues:
                         example_queue: ~
+            placed_order_transport:
+                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
+                options:
+                    vhost: '%env(MESSENGER_TRANSPORT_VHOST)%'
+                    exchange:
+                        name: placed_order_exchange
+                        type: direct
+                    queues:
+                        placed_orders: ~
+                retry_strategy:
+                    max_retries: 5
+                    delay: 60000
+                    multiplier: 5
 
         routing:
             Shopsys\FrameworkBundle\Component\Messenger\ExampleMessage: example_transport
+            Shopsys\FrameworkBundle\Model\Order\Messenger\PlacedOrderMessage: placed_order_transport
diff --git a/app/config/packages/monolog.yaml b/app/config/packages/monolog.yaml
@@ -1,5 +1,5 @@
 monolog:
-    channels: ["cron", "slow"]
+    channels: ["cron", "queue", "slow"]
     handlers:
         sentry:
             type: stream
@@ -13,7 +13,7 @@ monolog:
                 VERBOSITY_VERBOSE: DEBUG
                 VERBOSITY_VERY_VERBOSE: DEBUG
                 VERBOSITY_DEBUG: DEBUG
-            channels: cron
+            channels: [cron, queue]
         cron_output:
             type: stream
             path: "%shopsys.log_stream%"

diff --git a/app/deploy/deploy-project.sh b/app/deploy/deploy-project.sh
@@ -119,6 +119,7 @@ function merge() {
     # <consumer-name>:<transport-names-separated-by-space>:<number-of-consumers>
     DEFAULT_CONSUMERS=(
         "example:example_transport:1"
+        "placed_order:placed_order_transport:1"
     )
 
     source "${BASE_PATH}/vendor/shopsys/deployment/deploy/functions.sh"

diff --git a/app/docker/php-fpm/consumer-entrypoint.sh b/app/docker/php-fpm/consumer-entrypoint.sh
@@ -4,4 +4,5 @@ TIME_LIMIT=${1:-60}
 
 php ./bin/console messenger:consume \
     example_transport \
+    placed_order_transport \
     --time-limit=$TIME_LIMIT
diff --git a/app/src/FrontendApi/Model/Order/PlaceOrderFacade.php b/app/src/FrontendApi/Model/Order/PlaceOrderFacade.php
@@ -16,6 +16,7 @@
 use Shopsys\FrameworkBundle\Model\Customer\User\CustomerUserFacade;
 use Shopsys\FrameworkBundle\Model\Newsletter\NewsletterFacade;
 use Shopsys\FrameworkBundle\Model\Order\Item\OrderProductFacade;
+use Shopsys\FrameworkBundle\Model\Order\Messenger\PlacedOrderMessageDispatcher;
 use Shopsys\FrameworkBundle\Model\Order\Order;
 use Shopsys\FrameworkBundle\Model\Order\OrderData;
 use Shopsys\FrameworkBundle\Model\Order\OrderFacade;
@@ -42,6 +43,7 @@ class PlaceOrderFacade extends BasePlaceOrderFacade
      * @param \Shopsys\FrameworkBundle\Component\Domain\Domain $domain
      * @param \App\Model\Customer\User\CurrentCustomerUser $currentCustomerUser
      * @param \App\Model\Customer\User\CustomerUserFacade $customerUserFacade
+     * @param \Shopsys\FrameworkBundle\Model\Order\Messenger\PlacedOrderMessageDispatcher $placedOrderMessageDispatcher
      * @param \App\Model\Order\PromoCode\PromoCodeLimitResolver $promoCodeLimitResolver
      * @param \App\Model\Customer\DeliveryAddressDataFactory $deliveryAddressDataFactory
      * @param \Shopsys\FrameworkBundle\Model\Customer\DeliveryAddressFactory $deliveryAddressFactory
@@ -57,6 +59,7 @@ public function __construct(
         Domain $domain,
         CurrentCustomerUser $currentCustomerUser,
         CustomerUserFacade $customerUserFacade,
+        PlacedOrderMessageDispatcher $placedOrderMessageDispatcher,
         private PromoCodeLimitResolver $promoCodeLimitResolver,
         private DeliveryAddressDataFactory $deliveryAddressDataFactory,
         private DeliveryAddressFactory $deliveryAddressFactory,
@@ -72,6 +75,7 @@ public function __construct(
             $domain,
             $currentCustomerUser,
             $customerUserFacade,
+            $placedOrderMessageDispatcher,
         );
     }
 
@@ -126,6 +130,8 @@ public function placeOrder(
             }
         }
 
+        $this->placedOrderMessageDispatcher->dispatchPlacedOrderMessage($order->getId());
+
         return $order;
     }
 

diff --git a/app/src/Model/Order/OrderFacade.php b/app/src/Model/Order/OrderFacade.php
@@ -64,7 +64,6 @@
  * @property \Shopsys\FrameworkBundle\Component\Domain\Domain $domain
  * @property \Shopsys\FrameworkBundle\Model\Transport\TransportPriceCalculation $transportPriceCalculation
  * @property \App\Model\Order\Item\OrderItemFactory $orderItemFactory
- * @method sendHeurekaOrderInfo(\App\Model\Order\Order $order, bool $disallowHeurekaVerifiedByCustomers)
  * @method prefillFrontOrderData(\App\Model\Order\FrontOrderData $orderData, \App\Model\Customer\User\CustomerUser $customerUser)
  * @method \App\Model\Order\Order[] getCustomerUserOrderList(\App\Model\Customer\User\CustomerUser $customerUser)
  * @method \App\Model\Order\Order[] getCustomerUserOrderLimitedList(\App\Model\Customer\User\CustomerUser $customerUser, int $limit, int $offset)