Configuration du mailer + messages asynchrones

.env

@@ -69,3 +69,6 @@ S3_ACCESS_KEY=""
 S3_SECRET_KEY=""
 S3_BUCKET=""
 S3_ENDPOINT=""
+
+MAILER_SENDER=[email protected]
+MAILER_DSN=smtp://mailer:1025

Procfile

@@ -1,2 +1,3 @@
 web: bin/run
+worker: php bin/console messenger:consume async
 postdeploy: make scalingo-postdeploy

composer.json

@@ -29,6 +29,7 @@
         "symfony/framework-bundle": "7.2.*",
         "symfony/http-client": "7.2.*",
         "symfony/lock": "7.2.*",
+        "symfony/mailer": "7.2.*",
         "symfony/messenger": "7.2.*",
         "symfony/mime": "7.2.*",
         "symfony/monolog-bundle": "^3.8",

config/packages/mailer.yaml

@@ -0,0 +1,7 @@
+framework:
+    mailer:
+        dsn: '%env(MAILER_DSN)%'
+        envelope:
+            sender: '%env(MAILER_SENDER)%'
+        headers:
+            From: 'DiaLog <%env(MAILER_SENDER)%>'

config/packages/messenger.yaml

@@ -13,19 +13,16 @@ framework:
                     - validation
 
         transports:
-            # https://symfony.com/doc/current/messenger.html#transport-configuration
-            # async: '%env(MESSENGER_TRANSPORT_DSN)%'
-            # failed: 'doctrine://default?queue_name=failed'
-            # sync: 'sync://'
-
+            async:
+                dsn: "%env(REDIS_URL)%/messages"
+                retry_strategy:
+                    max_retries: 3
+                    delay: 1000
         routing:
-            # Route your messages to the transports
-            # 'App\Message\YourMessage': async
+            'App\Application\AsyncCommandInterface': async
 
-# when@test:
-#    framework:
-#        messenger:
-#            transports:
-#                # replace with your transport name here (e.g., my_transport: 'in-memory://')
-#                # For more Messenger testing tools, see https://github.com/zenstruck/messenger-test
-#                async: 'in-memory://'
+when@test:
+   framework:
+       messenger:
+           transports:
+               async: 'sync://'

docker-compose.yml

@@ -27,6 +27,17 @@ services:
       - database
       - redis
 
+  php_worker:
+    build:
+      context: ./docker/php
+    command: 'bin/console messenger:consume async --time-limit=300 --memory-limit=256M --limit=50'
+    restart: always
+    volumes:
+      - ./:/var/www/dialog
+    depends_on:
+      - database
+      - redis
+
   nginx:
     image: nginx:stable-alpine
     ports:
@@ -68,3 +79,9 @@ services:
       # Allow accessing host ports from this container via host.docker.internal on Linux
       # https://stackoverflow.com/a/43541732
       - host.docker.internal:host-gateway
+
+  mailer:
+    image: schickling/mailcatcher
+    ports:
+      - 1025:1025
+      - 1080:1080

src/Application/AsyncCommandInterface.php

@@ -0,0 +1,9 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Application;
+
+interface AsyncCommandInterface
+{
+}

src/Infrastructure/Adapter/CommandBus.php

@@ -4,6 +4,7 @@
 
 namespace App\Infrastructure\Adapter;
 
+use App\Application\AsyncCommandInterface;
 use App\Application\CommandBusInterface;
 use App\Application\CommandInterface;
 use Symfony\Component\Messenger\Exception\HandlerFailedException;
@@ -35,4 +36,13 @@ public function handle(CommandInterface $command): mixed
             throw $previous;
         }
     }
+
+    /**
+     * Use whenever you want to execute a command async,
+     * but **please ensure the Messenger routing is correct**.
+     */
+    public function dispatchAsync(AsyncCommandInterface $message): void
+    {
+        $this->messageBus->dispatch($message);
+    }
 }

symfony.lock

@@ -246,6 +246,18 @@
             "config/packages/lock.yaml"
         ]
     },
+    "symfony/mailer": {
+        "version": "7.2",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "4.3",
+            "ref": "09051cfde49476e3c12cd3a0e44289ace1c75a4f"
+        },
+        "files": [
+            "config/packages/mailer.yaml"
+        ]
+    },
     "symfony/messenger": {
         "version": "6.1",
         "recipe": {