From 86069a51a3c0cf3d2cd4755eae8d1b69bf1e4b3d Mon Sep 17 00:00:00 2001
From: Haylan <code@arthurerlich.ch>
Date: Mon, 14 Sep 2026 22:00:26 +0200
Subject: [PATCH] feat(dump): run dump creation asynchronously via Messenger

---
 .../Handler/CreateDumpHandler.php             | 30 +++++++++++++++++++
 .../Message/CreateDumpMessage.php             | 17 +++++++++++
 2 files changed, 47 insertions(+)
 create mode 100644 src/MessageQueue/Handler/CreateDumpHandler.php
 create mode 100644 src/MessageQueue/Message/CreateDumpMessage.php

diff --git a/src/MessageQueue/Handler/CreateDumpHandler.php b/src/MessageQueue/Handler/CreateDumpHandler.php
new file mode 100644
index 0000000..256df68
--- /dev/null
+++ b/src/MessageQueue/Handler/CreateDumpHandler.php
@@ -0,0 +1,30 @@
+<?php declare(strict_types=1);
+
+namespace AeonDumpManager\MessageQueue\Handler;
+
+use AeonDumpManager\MessageQueue\Message\CreateDumpMessage;
+use AeonDumpManager\Service\DumpJobStatusService;
+use AeonDumpManager\Service\DumpService;
+use Symfony\Component\Messenger\Attribute\AsMessageHandler;
+
+#[AsMessageHandler]
+class CreateDumpHandler
+{
+    public function __construct(
+        private readonly DumpService $dumpService,
+        private readonly DumpJobStatusService $jobStatus,
+    ) {
+    }
+
+    public function __invoke(CreateDumpMessage $message): void
+    {
+        $jobId = $message->getJobId();
+        $this->jobStatus->markRunning($jobId);
+
+        try {
+            $this->dumpService->createAsync($jobId, $this->jobStatus);
+        } catch (\Throwable $exception) {
+            $this->jobStatus->markFailed($jobId, $exception->getMessage());
+        }
+    }
+}
diff --git a/src/MessageQueue/Message/CreateDumpMessage.php b/src/MessageQueue/Message/CreateDumpMessage.php
new file mode 100644
index 0000000..3931409
--- /dev/null
+++ b/src/MessageQueue/Message/CreateDumpMessage.php
@@ -0,0 +1,17 @@
+<?php declare(strict_types=1);
+
+namespace AeonDumpManager\MessageQueue\Message;
+
+use Shopware\Core\Framework\MessageQueue\AsyncMessageInterface;
+
+class CreateDumpMessage implements AsyncMessageInterface
+{
+    public function __construct(private readonly string $jobId)
+    {
+    }
+
+    public function getJobId(): string
+    {
+        return $this->jobId;
+    }
+}