TransactionalExecutor.php

<?php

declare(strict_types=1);

namespace App\Transactional;

use Illuminate\{
    Database\DatabaseManager,
};

class TransactionalExecutor
{
    private DatabaseManager $databaseManager;
    private array $pendingCallbacks = [];

    public function __construct(DatabaseManager $databaseManager)
    {
        $this->databaseManager = $databaseManager;
    }

    public function execute(callable $callback): void
    {
        if (!$this->databaseManager->transactionLevel()) {
            $callback();

            return;
        }

        $this->pendingCallbacks[] = \Closure::fromCallable($callback);
    }

    public function forget(): void
    {
        $this->pendingCallbacks = [];
    }

    public function handleTransactionCommit(): void
    {
        $callbacks = collect($this->pendingCallbacks);
        $this->forget();

        $callbacks->reverse()->each->__invoke();
    }

    public function handleTransactionRollback(): void
    {
        $this->forget();
    }
}