Ray\AuraSqlModule\TransactionalInterceptor

Complexity

Total Complexity

6

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Importance

Changes	6
Bugs	2	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	invoke()	0	25	5

<?php

declare(strict_types=1);

namespace Ray\AuraSqlModule;

use Aura\Sql\ExtendedPdoInterface;
use PDOException;
use Ray\Aop\MethodInterceptor;
use Ray\Aop\MethodInvocation;
use Ray\Aop\ReflectionMethod;
use Ray\AuraSqlModule\Annotation\Transactional;
use Ray\AuraSqlModule\Exception\RollbackException;

use function assert;
use function count;
use function is_array;

class TransactionalInterceptor implements MethodInterceptor
{
    private ?ExtendedPdoInterface $pdo;

    public function __construct(?ExtendedPdoInterface $pdo = null)
    {
        $this->pdo = $pdo;
    }

    /**
     * {@inheritDoc}
     */
    public function invoke(MethodInvocation $invocation)
    {
        $method = $invocation->getMethod();
        assert($method instanceof ReflectionMethod);
        $transactional = $method->getAnnotation(Transactional::class);
        assert($transactional instanceof Transactional);
        if (is_array($transactional->value) && count((array) $transactional->value) > 1) {
            return (new PropTransaction())($invocation, $transactional);

The class Ray\AuraSqlModule\PropTransaction has been deprecated.

        }

        if (! $this->pdo instanceof ExtendedPdoInterface) {
            return $invocation->proceed();
        }

        try {
            $this->pdo->beginTransaction();
            $result = $invocation->proceed();
            $this->pdo->commit();
        } catch (PDOException $e) {
            $this->pdo->rollBack();

            throw new RollbackException($e->getMessage(), 0, $e);
        }

        return $result;
    }
}