AuraSqlConnectionInterceptor::invoke() - Code Metrics - Inspection of "Remove doctrine/annotations dependency" - Ray-Di/Ray.AuraSqlModule - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — 1.x (#78)

by Akihito

created 2025-11-08 14:47 UTC

AuraSqlConnectionInterceptor::invoke() A

↳ Parent: Project

Complexity

Conditions	1
Paths	1

Size

Total Lines	9
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	1

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	1
eloc	6
c	1
b	0
f	0
nc	1
nop	1
dl	0
loc	9
ccs	4
cts	4
cp	1
crap	1
rs	10

<?php

declare(strict_types=1);

namespace Ray\AuraSqlModule;

use Aura\Sql\ConnectionLocatorInterface;
use Aura\Sql\ExtendedPdoInterface;
use Override;
use Ray\Aop\MethodInterceptor;
use Ray\Aop\MethodInvocation;
use Ray\AuraSqlModule\Annotation\Read;
use ReflectionProperty;

use function in_array;

final readonly class AuraSqlConnectionInterceptor implements MethodInterceptor

{
    public const string PROP = 'pdo';

    /** @phpstan-param array<string> $readsMethods */
    public function __construct(
        private ConnectionLocatorInterface $connectionLocator,
        /** @var string[] */
        #[Read]
        private array $readsMethods
    ) {
    }

    /**
     * {@inheritDoc}
     */
    #[Override]
    public function invoke(MethodInvocation $invocation)
    {
        $connection = $this->getConnection($invocation);
        $object = $invocation->getThis();
        $ref = new ReflectionProperty($object, self::PROP);
        $ref->setValue($object, $connection);

        return $invocation->proceed();
    }

    /** @param MethodInvocation<object> $invocation */
    private function getConnection(MethodInvocation $invocation): ExtendedPdoInterface
    {
        $methodName = $invocation->getMethod()->name;
        if (in_array($methodName, $this->readsMethods, true)) {
            return $this->connectionLocator->getRead();
        }

        return $this->connectionLocator->getWrite();
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Ray\AuraSqlModule;
6
7		use Aura\Sql\ConnectionLocatorInterface;
8		use Aura\Sql\ExtendedPdoInterface;
9		use Override;
10		use Ray\Aop\MethodInterceptor;
11		use Ray\Aop\MethodInvocation;
12		use Ray\AuraSqlModule\Annotation\Read;
13		use ReflectionProperty;
14
15		use function in_array;
16
17		final readonly class AuraSqlConnectionInterceptor implements MethodInterceptor
		0 ignored issues – show Bug introduced 2025-11-08 15:01 UTC by Report Bug Copy Issue Report A parse error occurred: Syntax error, unexpected T_READONLY, expecting T_CLASS on line 17 at column 6 Loading history...
18		{
19		public const string PROP = 'pdo';
20
21		/** @phpstan-param array<string> $readsMethods */
22		public function __construct(
23		private ConnectionLocatorInterface $connectionLocator,
24		/** @var string[] */
25		#[Read]
26		private array $readsMethods
27		) {
28		}
29
30		/**
31		* {@inheritDoc}
32		*/
33		#[Override]
34		public function invoke(MethodInvocation $invocation)
35		{
36		$connection = $this->getConnection($invocation);
37		$object = $invocation->getThis();
38		$ref = new ReflectionProperty($object, self::PROP);
39	3	$ref->setValue($object, $connection);
40
41	3	return $invocation->proceed();
42	3	}
43	3
44	3	/** @param MethodInvocation<object> $invocation */
45		private function getConnection(MethodInvocation $invocation): ExtendedPdoInterface
46		{
47		$methodName = $invocation->getMethod()->name;
48		if (in_array($methodName, $this->readsMethods, true)) {
49	1	return $this->connectionLocator->getRead();
50		}
51	1
52	1	return $this->connectionLocator->getWrite();
53	1	}
54		}
55

Ray-Di / Ray.AuraSqlModule

Pull Request — 1.x (#78)

AuraSqlConnectionInterceptor::invoke() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like