Ray\AuraSqlModule\TransactionalInterceptor

Complexity

Total Complexity

5

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

43.75%

Importance

Changes	3
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	invoke()	0	21	4

<?php
/**
 * This file is part of the Ray.AuraSqlModule package
 *
 * @license http://opensource.org/licenses/MIT MIT
 */
namespace Ray\AuraSqlModule;

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

class TransactionalInterceptor implements MethodInterceptor
{
    /**
     * @var ExtendedPdoInterface
     */
    private $pdo;

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

    /**
     * {@inheritdoc}
     */
    public function invoke(MethodInvocation $invocation)
    {
        /* @var Transactional $transactional */
        $transactional = $invocation->getMethod()->getAnnotation(Transactional::class);

It seems like you code against a specific sub-type and not the parent class ReflectionMethod as the method getAnnotation() does only exist in the following sub-classes of ReflectionMethod: Ray\Aop\ReflectionMethod. Maybe you want to instanceof check for one of these explicitly?

        if (count($transactional->value) > 0) {

The property Ray\AuraSqlModule\Annotation\Transactional::$value has been deprecated.

            return (new PropTransaction)($invocation, $transactional);
        }
        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;
    }
}