AddRadarPlugin::getHeaders()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 5
Code Lines 3

Duplication

Lines 0
Ratio 0 %

Importance

Changes 1
Bugs 0 Features 0
Metric Value
cc 1
eloc 3
c 1
b 0
f 0
nc 1
nop 0
dl 0
loc 5
rs 10
1
<?php
2
3
declare(strict_types=1);
4
5
namespace Yansongda\Pay\Plugin\Unipay;
6
7
use Closure;
8
use GuzzleHttp\Psr7\Request;
9
use Yansongda\Artful\Contract\PluginInterface;
10
use Yansongda\Artful\Exception\ContainerException;
11
use Yansongda\Artful\Exception\InvalidParamsException;
12
use Yansongda\Artful\Exception\ServiceNotFoundException;
13
use Yansongda\Artful\Logger;
14
use Yansongda\Artful\Rocket;
15
16
use function Yansongda\Artful\get_radar_method;
17
use function Yansongda\Pay\get_provider_config;
18
use function Yansongda\Pay\get_unipay_body;
19
use function Yansongda\Pay\get_unipay_url;
20
21
class AddRadarPlugin implements PluginInterface
22
{
23
    /**
24
     * @throws ContainerException
25
     * @throws ServiceNotFoundException
26
     * @throws InvalidParamsException
27
     */
28
    public function assembly(Rocket $rocket, Closure $next): Rocket
29
    {
30
        Logger::debug('[Unipay][AddRadarPlugin] 插件开始装载', ['rocket' => $rocket]);
31
32
        $params = $rocket->getParams();
33
        $config = get_provider_config('unipay', $params);
34
        $payload = $rocket->getPayload();
35
36
        $rocket->setRadar(new Request(
37
            get_radar_method($payload) ?? 'POST',
38
            get_unipay_url($config, $payload),
39
            $this->getHeaders(),
40
            get_unipay_body($payload),
41
        ));
42
43
        Logger::info('[Unipay][AddRadarPlugin] 插件装载完毕', ['rocket' => $rocket]);
44
45
        return $next($rocket);
46
    }
47
48
    protected function getHeaders(): array
49
    {
50
        return [
51
            'User-Agent' => 'yansongda/pay-v3',
52
            'Content-Type' => 'application/x-www-form-urlencoded;charset=utf-8',
53
        ];
54
    }
55
}
56