<?php

declare(strict_types=1);

namespace App\MessageHandler\Cron;

use App\Model\Message\Job\DatabaseCleanupJob;
use App\Services\DatabaseCleanup;
use Symfony\Component\Lock\LockFactory;

#[\Symfony\Component\Messenger\Attribute\AsMessageHandler]
final readonly class DatabaseCleanupJobHandler
{
    private \Symfony\Component\Lock\LockInterface $lock;

    public function __construct(private DatabaseCleanup $cleanup, private LockFactory $lockFactory)
    {
        $this->lock = $this->lockFactory->createLock('database-cleanup-cron');
    }

    public function __invoke(DatabaseCleanupJob $cleanupJob) : void
    {
        if (! $this->lock->acquire()) {
            return;
        }

        $this->cleanup->execute();

        $this->lock->release();
    }
}