Client::getMultipleRequest()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 14
Code Lines 9

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 10
CRAP Score 1

Importance

Changes 0
Metric Value
dl 0
loc 14
ccs 10
cts 10
cp 1
rs 9.4285
c 0
b 0
f 0
cc 1
eloc 9
nc 1
nop 1
crap 1
1
<?php
2
3
/**
4
 * MIT License
5
 *
6
 * Copyright (c) 2016 Bernardo Secades
7
 *
8
 * Permission is hereby granted, free of charge, to any person obtaining a copy
9
 * of this software and associated documentation files (the "Software"), to deal
10
 * in the Software without restriction, including without limitation the rights
11
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
12
 * copies of the Software, and to permit persons to whom the Software is
13
 * furnished to do so, subject to the following conditions:
14
 *
15
 * The above copyright notice and this permission notice shall be included in all
16
 * copies or substantial portions of the Software.
17
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
18
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
19
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
20
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
21
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
22
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
23
 * SOFTWARE.
24
 */
25
26
namespace BernardoSecades\Packagist\SecurityChecker\Api;
27
28
use BernardoSecades\Packagist\SecurityChecker\Exception\Packagist\PackagistConnectException;
29
use BernardoSecades\Packagist\SecurityChecker\ValueObject\Package;
30
use GuzzleHttp\Client as HttpClient;
31
use GuzzleHttp\ClientInterface;
32
use GuzzleHttp\Promise\Promise;
33
use GuzzleHttp\Promise\EachPromise;
34
use GuzzleHttp\Exception\ConnectException;
35
use Psr\Http\Message\ResponseInterface;
36
37
/**
38
 * @author bernardosecades <[email protected]>
39
 */
40
class Client
41
{
42
    const DEFAULT_PACKAGIST_URL = 'https://packagist.org';
43
44
    /** @var ClientInterface  */
45
    protected $httpClient;
46
47
    /** @var  string */
48
    protected $packagistUrl;
49
50
    /**
51
     * @param ClientInterface|null $httpClient
52
     * @param string               $packagistUrl
53
     */
54 10
    public function __construct(ClientInterface $httpClient = null, $packagistUrl = self::DEFAULT_PACKAGIST_URL)
55
    {
56 10
        $this->httpClient = null !== $httpClient ? $httpClient : new HttpClient();
57 10
        $this->packagistUrl = $packagistUrl;
58 10
    }
59
60
    /**
61
     * @param Promise[] $packages
62
     * @return array
63
     */
64 6
    public function getMultipleRequest(array $packages)
65 1
    {
66 6
        $promises = $this->getGuzzlePromises($packages);
0 ignored issues
show
Documentation introduced by
$packages is of type array<integer,object<GuzzleHttp\Promise\Promise>>, but the function expects a array<integer,object<Ber...r\ValueObject\Package>>.

It seems like the type of the argument is not accepted by the function/method which you are calling.

In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug.

We suggest to add an explicit type cast like in the following example:

function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
Loading history...
67 6
        $infoPackages = [];
68
        // Wait till all the requests are finished.
69 6
        (new EachPromise($promises, [
70 6
            'concurrency' => 10,
71
            'fulfilled' => function ($infoPackage) use (&$infoPackages) {
72 6
                $infoPackages[] = $infoPackage;
73 6
            },
74 6
        ]))->promise()->wait();
75
76 6
        return $infoPackages;
77
    }
78
79
    /**
80
     * @param string $packagistUrl
81
     */
82
    public function setPackagistUrl($packagistUrl)
83
    {
84
        $this->packagistUrl = $packagistUrl;
85
    }
86
87
    /**
88
     * @return string
89
     */
90 6
    public function getPackagistUrl()
91
    {
92 6
        return $this->packagistUrl;
93
    }
94
95
    /**
96
     * @param Package[] $packages
97
     * @return array              Array info packages, each element has ['packages'] data
98
     * @throws PackagistConnectException
99
     */
100 6
    protected function getGuzzlePromises(array $packages)
101
    {
102 6
        if (self::DEFAULT_PACKAGIST_URL !== $this->getPackagistUrl()) {
103
            try {
104
                $this->httpClient->get($this->getPackagistUrl().'/packages/list.json');
105
            } catch (ConnectException $exception) {
106
                $message = sprintf('Error connection: %s, only compatible with software https://github.com/composer/packagist', $this->getPackagistUrl());
107
                throw new PackagistConnectException($message, 0, $exception);
108
            }
109
        }
110
111 6
        $result = [];
112 6
        foreach ($packages as $package) {
113 6
            $result[] =  $this->httpClient->requestAsync('GET', $this->packagistUrl.'/p/'.$package->getName().'.json')
114 6
                ->then(function (ResponseInterface $response) {
115 6
                    return json_decode($response->getBody(), true);
116 6
                });
117 6
        }
118
119 6
        return $result;
120
    }
121
}
122