From a21b5aa73e559e4eddc0d49c0e4786479cf62a6a 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): purge expired dumps on a scheduled task

---
 src/ScheduledTask/PurgeDumpsTask.php        | 18 ++++++++++
 src/ScheduledTask/PurgeDumpsTaskHandler.php | 38 +++++++++++++++++++++
 2 files changed, 56 insertions(+)
 create mode 100644 src/ScheduledTask/PurgeDumpsTask.php
 create mode 100644 src/ScheduledTask/PurgeDumpsTaskHandler.php

diff --git a/src/ScheduledTask/PurgeDumpsTask.php b/src/ScheduledTask/PurgeDumpsTask.php
new file mode 100644
index 0000000..c687d82
--- /dev/null
+++ b/src/ScheduledTask/PurgeDumpsTask.php
@@ -0,0 +1,18 @@
+<?php declare(strict_types=1);
+
+namespace AeonDumpManager\ScheduledTask;
+
+use Shopware\Core\Framework\MessageQueue\ScheduledTask\ScheduledTask;
+
+class PurgeDumpsTask extends ScheduledTask
+{
+    public static function getTaskName(): string
+    {
+        return 'aeon_dump_manager.purge_dumps_task';
+    }
+
+    public static function getDefaultInterval(): int
+    {
+        return 3600; // hourly
+    }
+}
diff --git a/src/ScheduledTask/PurgeDumpsTaskHandler.php b/src/ScheduledTask/PurgeDumpsTaskHandler.php
new file mode 100644
index 0000000..0a67d7a
--- /dev/null
+++ b/src/ScheduledTask/PurgeDumpsTaskHandler.php
@@ -0,0 +1,38 @@
+<?php declare(strict_types=1);
+
+namespace AeonDumpManager\ScheduledTask;
+
+use AeonDumpManager\Service\DumpJobStatusService;
+use AeonDumpManager\Service\DumpService;
+use Psr\Log\LoggerInterface;
+use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
+use Shopware\Core\Framework\MessageQueue\ScheduledTask\ScheduledTaskHandler;
+use Shopware\Core\System\SystemConfig\SystemConfigService;
+use Symfony\Component\Messenger\Attribute\AsMessageHandler;
+
+#[AsMessageHandler(handles: PurgeDumpsTask::class)]
+class PurgeDumpsTaskHandler extends ScheduledTaskHandler
+{
+    public function __construct(
+        EntityRepository $scheduledTaskRepository,
+        LoggerInterface $logger,
+        private readonly DumpService $dumpService,
+        private readonly DumpJobStatusService $jobStatus,
+        private readonly SystemConfigService $systemConfigService,
+    ) {
+        parent::__construct($scheduledTaskRepository, $logger);
+    }
+
+    public function run(): void
+    {
+        $retantionDays = $this->systemConfigService->getInt('AeonDumpManager.config.retantionDays');
+        if ($retantionDays <= 0) {
+            return; // 0 means unlimited — nothing to purge
+        }
+
+        $threshold = (new \DateTimeImmutable())->modify("-{$retantionDays} days");
+
+        $this->dumpService->purgeOlderThan($threshold);
+        $this->jobStatus->purgeOlderThan($threshold);
+    }
+}