zxcms/core/services/TransactionManager.php

<?php

namespace core\services;

use core\dispatchers\DeferredEventDispatcher;
use Exception;
use Yii;

class TransactionManager
{
    private DeferredEventDispatcher $dispatcher;

    public function __construct(DeferredEventDispatcher $dispatcher)
    {
        $this->dispatcher = $dispatcher;
    }

    /**
     * @param callable $function
     * @throws \yii\db\Exception
     */
    public function wrap(callable $function): void
    {
        $transaction = Yii::$app->db->beginTransaction();
        try {
            $this->dispatcher->defer();
            $function();
            $transaction->commit();
            $this->dispatcher->release();
        } catch (Exception $e) {
            $transaction->rollBack();
            $this->dispatcher->clean();
            throw $e;
        }
    }
}