feat: add cleanup for inactive redirects

tinect · Jul 8, 2024 · 004e08b · 004e08b
1 parent f6ec01f
commit 004e08b
Show file tree

Hide file tree

Showing 2 changed files with 68 additions and 0 deletions.
diff --git a/src/Resources/config/config.xml b/src/Resources/config/config.xml
@@ -14,6 +14,20 @@
             <defaultValue>30</defaultValue>
         </input-field>
 
+        <input-field type="int">
+            <name>deleteInactiveEntriesAfterDays</name>
+            <label>Delete inactive redirects after x days</label>
+            <label lang="de-DE">Inaktive Weiterleitungen löschen, die älter als X Tage sind</label>
+            <defaultValue>30</defaultValue>
+        </input-field>
+
+        <input-field type="int">
+            <name>deleteInactiveEntriesCount</name>
+            <label>Delete inactive redirects with less than x count</label>
+            <label lang="de-DE">Inaktive Weiterleitungen löschen, die weniger als X Aufrufe haben</label>
+            <defaultValue>2</defaultValue>
+        </input-field>
+
         <input-field type="bool">
             <name>saveIpAddresses</name>
             <label>Save IP addresses</label>

diff --git a/src/Task/CleanupTaskHandler.php b/src/Task/CleanupTaskHandler.php
@@ -12,6 +12,7 @@
 use Shopware\Core\Framework\MessageQueue\ScheduledTask\ScheduledTaskHandler;
 use Shopware\Core\System\SystemConfig\SystemConfigService;
 use Symfony\Component\Messenger\Attribute\AsMessageHandler;
+use Tinect\Redirects\Content\Redirect\RedirectDefinition;
 use Tinect\Redirects\Content\Redirect\RedirectRequestDefinition;
 
 #[AsMessageHandler(handles: CleanupTask::class)]
@@ -27,6 +28,12 @@ public function __construct(
     }
 
     public function run(): void
+    {
+        $this->cleanupRequests();
+        $this->cleanupInactiveRedirects();
+    }
+
+    private function cleanupRequests(): void
     {
         $days = $this->configService->getInt('TinectRedirects.config.deleteRequestsAfterDays');
 
@@ -67,4 +74,51 @@ public function run(): void
             `count` = (SELECT COUNT(*) FROM tinect_redirects_redirect_request WHERE tinect_redirects_redirect_request.tinect_redirects_redirect_id = tinect_redirects_redirect.id)
         ');
     }
+
+    private function cleanupInactiveRedirects(): void
+    {
+        $days = $this->configService->getInt('TinectRedirects.config.deleteInactiveEntriesAfterDays');
+
+        if ($days === 0) {
+            $days = 30;
+        }
+
+        $count = $this->configService->getInt('TinectRedirects.config.deleteInactiveEntriesCount');
+
+        if ($count === 0) {
+            $count = 2;
+        }
+
+        $time = new \DateTime();
+        $time->modify(sprintf('-%s days', $days));
+
+        $query = $this->connection->createQueryBuilder();
+
+        $query->select('id');
+        $query->from(RedirectDefinition::ENTITY_NAME);
+        $query->where('`active` = 0');
+        $query->andWhere('`count` < :count');
+        $query->andWhere(
+            $query->expr()->lte(
+                'created_at',
+                $query->createNamedParameter($time->format(Defaults::STORAGE_DATE_TIME_FORMAT))
+            )
+        );
+        $query->setParameter('count', $count);
+
+        $ids = $query->executeQuery()->fetchFirstColumn();
+
+        if (\count($ids) === 0) {
+            return;
+        }
+
+        $deleteQuery = $this->connection->createQueryBuilder();
+        $deleteQuery->delete(RedirectDefinition::ENTITY_NAME);
+        $deleteQuery->where('id IN (:ids)');
+
+        foreach (\array_chunk($ids, 1000) as $chunk) {
+            $deleteQuery->setParameter('ids', $chunk, ArrayParameterType::STRING);
+            $deleteQuery->executeQuery();
+        }
+    }
 }