Allow a delay when assigning callouts

src/DependencyInjection/Configuration.php

@@ -50,7 +50,16 @@ public function getConfigTreeBuilder(): TreeBuilder
                         'bottom_center',
                         'bottom_right',
                     ])
-                    ->scalarPrototype()
+                    ->scalarPrototype()->end()
+                ->end()
+                ->arrayNode('assignment')
+                    ->addDefaultsIfNotSet()
+                    ->children()
+                        ->integerNode('processing_delay')
+                            ->info('The delay in seconds when processing a callout. This is to avoid processing the same callout multiple times within a short interval')
+                            ->defaultValue(60)
+                            ->min(0)
+
         ;
 
         $this->addResourcesSection($rootNode);

src/DependencyInjection/SetonoSyliusCalloutExtension.php

@@ -21,6 +21,7 @@ public function load(array $configs, ContainerBuilder $container): void
          * @var array{
          *     elements: list<string>,
          *     positions: list<string>,
+         *     assignment: array{processing_delay: int},
          *     resources: array
          * } $config
          */
@@ -31,6 +32,7 @@ public function load(array $configs, ContainerBuilder $container): void
 
         $container->setParameter('setono_sylius_callout.elements', $config['elements']);
         $container->setParameter('setono_sylius_callout.positions', $config['positions']);
+        $container->setParameter('setono_sylius_callout.assignment.processing_delay', $config['assignment']['processing_delay']);
 
         $this->registerResources('setono_sylius_callout', SyliusResourceBundle::DRIVER_DOCTRINE_ORM, $config['resources'], $container);
     }

src/EventSubscriber/HandleCalloutUpdateSubscriber.php

@@ -11,6 +11,7 @@
 use Setono\SyliusCalloutPlugin\Model\CalloutRuleInterface;
 use Symfony\Component\EventDispatcher\EventSubscriberInterface;
 use Symfony\Component\Messenger\MessageBusInterface;
+use Symfony\Component\Messenger\Stamp\DelayStamp;
 
 /**
  * This subscriber listens for changes to callouts and callout rules
@@ -21,12 +22,14 @@ final class HandleCalloutUpdateSubscriber implements EventSubscriberInterface
     /**
      * The keys are the callout codes and the values are true
      *
-     * @var array<string, bool>
+     * @var array<string, CalloutInterface>
      */
     private array $calloutsToAssign = [];
 
-    public function __construct(private readonly MessageBusInterface $commandBus)
-    {
+    public function __construct(
+        private readonly MessageBusInterface $commandBus,
+        private readonly int $processingDelay,
+    ) {
     }
 
     public static function getSubscribedEvents(): array
@@ -47,7 +50,7 @@ public function prePersist(PrePersistEventArgs $event): void
             return;
         }
 
-        $this->calloutsToAssign[(string) $callout->getCode()] = true;
+        $this->calloutsToAssign[(string) $callout->getCode()] = $callout;
     }
 
     /**
@@ -91,7 +94,7 @@ private function preUpdateCallout(CalloutInterface $callout, PreUpdateEventArgs
             return;
         }
 
-        $this->calloutsToAssign[(string) $callout->getCode()] = true;
+        $this->calloutsToAssign[(string) $callout->getCode()] = $callout;
     }
 
     /**
@@ -108,19 +111,24 @@ private function preUpdateCalloutRule(CalloutRuleInterface $calloutRule, PreUpda
             return;
         }
 
-        $this->calloutsToAssign[(string) $callout->getCode()] = true;
+        $this->calloutsToAssign[(string) $callout->getCode()] = $callout;
     }
 
     /**
      * This is called when a callout is created or updated by Sylius.
-     * In the lifecycle this is the last method called and therefore we can safely dispatch the message here if needed
+     * In the lifecycle this is the last method called, and therefore we can safely dispatch the message here if needed
      */
     public function postUpdate(): void
     {
         if ([] === $this->calloutsToAssign) {
             return;
         }
 
-        $this->commandBus->dispatch(new AssignCallouts(array_keys($this->calloutsToAssign)));
+        $stamps = [];
+        if ($this->processingDelay > 0) {
+            $stamps[] = new DelayStamp($this->processingDelay * 1000);
+        }
+
+        $this->commandBus->dispatch(new AssignCallouts(array_values($this->calloutsToAssign)), $stamps);
     }
 }

src/Message/Command/AssignCallouts.php

@@ -11,7 +11,11 @@
  */
 final class AssignCallouts implements CommandInterface
 {
-    /** @var list<string> */
+    /**
+     * This is a list of arrays where the first element is the callout code and the second element is the version
+     *
+     * @var list<array{string, int|null}>
+     */
     public array $callouts = [];
 
     /**
@@ -20,7 +24,7 @@ final class AssignCallouts implements CommandInterface
     public function __construct(array $callouts = [])
     {
         foreach ($callouts as $callout) {
-            $this->callouts[] = $callout instanceof CalloutInterface ? (string) $callout->getCode() : $callout;
+            $this->callouts[] = $callout instanceof CalloutInterface ? [(string) $callout->getCode(), $callout->getVersion()] : [$callout, null];
         }
     }
 }

src/Message/Handler/AssignCalloutsHandler.php

@@ -11,8 +11,28 @@ final class AssignCalloutsHandler extends AbstractAssignCalloutsHandler
     public function __invoke(AssignCallouts $message): void
     {
         $callouts = [];
+
         if ([] !== $message->callouts) {
-            $callouts = $this->calloutRepository->findEnabled($message->callouts);
+            foreach ($message->callouts as $calloutShape) {
+                $callout = $this->calloutRepository->findOneByCode($calloutShape[0]);
+                if (null === $callout) {
+                    continue;
+                }
+
+                if (null !== $calloutShape[1] && $calloutShape[1] !== $callout->getVersion()) {
+                    continue;
+                }
+
+                if (!$callout->isEnabled()) {
+                    continue;
+                }
+
+                $callouts[] = $callout;
+            }
+
+            if ([] === $callouts) {
+                return;
+            }
         }
 
         $this->assign(callouts: $callouts);

src/Resources/config/services/event_subscriber.xml

@@ -12,6 +12,7 @@
         <service id="setono_sylius_callout.event_subscriber.handle_callout_update"
                  class="Setono\SyliusCalloutPlugin\EventSubscriber\HandleCalloutUpdateSubscriber">
             <argument type="service" id="setono_sylius_callout.command_bus"/>
+            <argument>%setono_sylius_callout.assignment.processing_delay%</argument>
 
             <tag name="doctrine.event_listener" event="prePersist"/>
             <tag name="doctrine.event_listener" event="preUpdate"/>

src/Resources/config/services/message.xml

@@ -13,12 +13,6 @@
             <argument>%sylius.model.product.class%</argument>
         </service>
 
-        <service id="setono_sylius_callout.message.handler.assign_callout"
-                 class="Setono\SyliusCalloutPlugin\Message\Handler\AssignCalloutHandler"
-                 parent="setono_sylius_callout.message.handler.abstract_assign_callouts">
-            <tag name="messenger.message_handler"/>
-        </service>
-
         <service id="setono_sylius_callout.message.handler.assign_callouts"
                  class="Setono\SyliusCalloutPlugin\Message\Handler\AssignCalloutsHandler"
                  parent="setono_sylius_callout.message.handler.abstract_assign_callouts">