From 2d768e8b52e26c595647b2603dcd68253ced5bb9 Mon Sep 17 00:00:00 2001
From: thibaud-leclere <thibaud.leclere@gmail.com>
Date: Sun, 29 Mar 2026 10:18:35 +0200
Subject: [PATCH] feat: add Messenger messages for import processing

---
 config/packages/messenger.yaml          |  4 ++--
 src/Message/ImportFilmsBatchMessage.php | 14 ++++++++++++++
 src/Message/ProcessImportMessage.php    | 12 ++++++++++++
 3 files changed, 28 insertions(+), 2 deletions(-)
 create mode 100644 src/Message/ImportFilmsBatchMessage.php
 create mode 100644 src/Message/ProcessImportMessage.php

diff --git a/config/packages/messenger.yaml b/config/packages/messenger.yaml
index 270f3c7..eeff082 100644
--- a/config/packages/messenger.yaml
+++ b/config/packages/messenger.yaml
@@ -25,5 +25,5 @@ framework:
             Symfony\Component\Notifier\Message\ChatMessage: async
             Symfony\Component\Notifier\Message\SmsMessage: async
 
-            # Route your messages to the transports
-            # 'App\Message\YourMessage': async
+            App\Message\ProcessImportMessage: async
+            App\Message\ImportFilmsBatchMessage: async
diff --git a/src/Message/ImportFilmsBatchMessage.php b/src/Message/ImportFilmsBatchMessage.php
new file mode 100644
index 0000000..e9eb32a
--- /dev/null
+++ b/src/Message/ImportFilmsBatchMessage.php
@@ -0,0 +1,14 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Message;
+
+readonly class ImportFilmsBatchMessage
+{
+    public function __construct(
+        public int $importId,
+        public int $offset,
+        public int $limit,
+    ) {}
+}
diff --git a/src/Message/ProcessImportMessage.php b/src/Message/ProcessImportMessage.php
new file mode 100644
index 0000000..fe9dc48
--- /dev/null
+++ b/src/Message/ProcessImportMessage.php
@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Message;
+
+readonly class ProcessImportMessage
+{
+    public function __construct(
+        public int $importId,
+    ) {}
+}