mummert/meilisearch-bundle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

optimize cleaner

Browse Source
This commit is contained in:
Jürgen Mummert
2026-01-09 15:36:03 +01:00
parent 1f75418d9b
commit 4c1b4ac4b7
1 changed files with 14 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Command/MeilisearchFilesCleanupCommand.php
+14 -20
View File
@@ -3,7 +3,7 @@
namespace MummertMedia\ContaoMeilisearchBundle\Command; namespace MummertMedia\ContaoMeilisearchBundle\Command;
use Contao\CoreBundle\Framework\ContaoFramework; use Contao\CoreBundle\Framework\ContaoFramework;
use Contao\Database; use Doctrine\DBAL\Connection;
use Symfony\Component\Console\Command\Command; use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface; use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption; use Symfony\Component\Console\Input\InputOption;
@@ -13,6 +13,7 @@ class MeilisearchFilesCleanupCommand extends Command
{ {
public function __construct( public function __construct(
private readonly ContaoFramework $framework, private readonly ContaoFramework $framework,
private readonly Connection $connection,
) { ) {
parent::__construct(); parent::__construct();
} }
@@ -21,13 +22,13 @@ class MeilisearchFilesCleanupCommand extends Command
{ {
$this $this
->setName('meilisearch:files:cleanup') ->setName('meilisearch:files:cleanup')
->setDescription('Remove stale indexed files (PDF, DOCX, XLSX, PPTX) from tl_search_pdf') ->setDescription('Remove stale indexed files from tl_search_files')
->addOption( ->addOption(
'grace', 'grace',
null, null,
InputOption::VALUE_OPTIONAL, InputOption::VALUE_OPTIONAL,
'Grace period in seconds (files newer than now-grace are kept)', 'Grace period in seconds (files newer than now-grace are kept)',
86400 // 24 Stunden 86400
) )
->addOption( ->addOption(
'dry-run', 'dry-run',
@@ -49,10 +50,10 @@ class MeilisearchFilesCleanupCommand extends Command
$cutoff = time() - $grace; $cutoff = time() - $grace;
if ($dryRun) { if ($dryRun) {
$count = Database::getInstance() $count = $this->connection->fetchOne(
->prepare('SELECT COUNT(*) AS cnt FROM tl_search_pdf WHERE last_seen < ?') 'SELECT COUNT(*) FROM tl_search_files WHERE last_seen < ?',
->execute($cutoff) [$cutoff]
->cnt; );
$message = sprintf( $message = sprintf(
'[DRY-RUN] %d stale file(s) would be removed (last_seen < %s)', '[DRY-RUN] %d stale file(s) would be removed (last_seen < %s)',
@@ -63,14 +64,14 @@ class MeilisearchFilesCleanupCommand extends Command
$output->writeln('<comment>' . $message . '</comment>'); $output->writeln('<comment>' . $message . '</comment>');
$this->log($message); $this->log($message);
$this->log('Cleaner successfully stopped'); $this->log('Cleaner stopped (dry-run)');
return Command::SUCCESS; return Command::SUCCESS;
} }
$affected = Database::getInstance() $affected = $this->connection->executeStatement(
->prepare('DELETE FROM tl_search_pdf WHERE last_seen < ?') 'DELETE FROM tl_search_files WHERE last_seen < ?',
->execute($cutoff) [$cutoff]
->affectedRows; );
$message = sprintf( $message = sprintf(
'Removed %d stale file(s) (last_seen < %s)', 'Removed %d stale file(s) (last_seen < %s)',
@@ -92,15 +93,8 @@ class MeilisearchFilesCleanupCommand extends Command
} }
} }
/**
* Einheitliches Logging mit Zeitstempel
*/
private function log(string $message): void private function log(string $message): void
{ {
error_log(sprintf( error_log(sprintf('[%s] %s', date('Y-m-d H:i:s'), $message));
'[%s] %s',
date('Y-m-d H:i:s'),
$message
));
} }
} }