ResponsePlugin::assembly() - Code Metrics - Inspection of "change(internal): 按场景对微信插件进行分类，优化相关代码 (#909)" - yansongda/pay - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( d1dcd3...a849c7 )

by Songda

created 2023-12-31 10:00 UTC

ResponsePlugin::assembly() A

↳ Parent: ResponsePlugin

Complexity

Conditions	1
Paths	1

Size

Total Lines	12
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	5
c	0
b	0
f	0
dl	0
loc	12
rs	10
cc	1
nc	1
nop	2

<?php

declare(strict_types=1);

namespace Yansongda\Pay\Plugin\Wechat;

use Closure;
use Psr\Http\Message\MessageInterface;
use Psr\Http\Message\ResponseInterface;
use Yansongda\Pay\Contract\PluginInterface;
use Yansongda\Pay\Exception\Exception;
use Yansongda\Pay\Exception\InvalidResponseException;
use Yansongda\Pay\Logger;
use Yansongda\Pay\Rocket;
use Yansongda\Supports\Collection;

class ResponsePlugin implements PluginInterface
{
    /**
     * @throws InvalidResponseException
     */
    public function assembly(Rocket $rocket, Closure $next): Rocket
    {
        /* @var Rocket $rocket */
        $rocket = $next($rocket);

        Logger::debug('[Wechat][ResponsePlugin] 插件开始装载', ['rocket' => $rocket]);

        $rocket->setDestination($this->validateResponse($rocket));

        Logger::info('[Wechat][ResponsePlugin] 插件装载完毕', ['rocket' => $rocket]);

        return $rocket;
    }

    /**
     * @throws InvalidResponseException
     */
    protected function validateResponse(Rocket $rocket): null|array|Collection|MessageInterface
    {
        $response = $rocket->getDestination();

        if ($response instanceof ResponseInterface
            && ($response->getStatusCode() < 200 || $response->getStatusCode() >= 300)) {
            throw new InvalidResponseException(Exception::RESPONSE_CODE_WRONG);
        }

        return $response;
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Yansongda\Pay\Plugin\Wechat;
6
7			use Closure;
8			use Psr\Http\Message\MessageInterface;
9			use Psr\Http\Message\ResponseInterface;
10			use Yansongda\Pay\Contract\PluginInterface;
11			use Yansongda\Pay\Exception\Exception;
12			use Yansongda\Pay\Exception\InvalidResponseException;
13			use Yansongda\Pay\Logger;
14			use Yansongda\Pay\Rocket;
15			use Yansongda\Supports\Collection;
16
17			class ResponsePlugin implements PluginInterface
18			{
19			/**
20			* @throws InvalidResponseException
21			*/
22			public function assembly(Rocket $rocket, Closure $next): Rocket
23			{
24			/* @var Rocket $rocket */
25			$rocket = $next($rocket);
26
27			Logger::debug('[Wechat][ResponsePlugin] 插件开始装载', ['rocket' => $rocket]);
28
29			$rocket->setDestination($this->validateResponse($rocket));
30
31			Logger::info('[Wechat][ResponsePlugin] 插件装载完毕', ['rocket' => $rocket]);
32
33			return $rocket;
34			}
35
36			/**
37			* @throws InvalidResponseException
38			*/
39			protected function validateResponse(Rocket $rocket): null\|array\|Collection\|MessageInterface
40			{
41			$response = $rocket->getDestination();
42
43			if ($response instanceof ResponseInterface
44			&& ($response->getStatusCode() < 200 \|\| $response->getStatusCode() >= 300)) {
45			throw new InvalidResponseException(Exception::RESPONSE_CODE_WRONG);
46			}
47
48			return $response;
49			}
50			}
51

yansongda / pay

Push — master ( d1dcd3...a849c7 )

ResponsePlugin::assembly() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like