Aoe\Varnish\System\Http

Complexity

Total Complexity

8

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

30.76%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	request()	0	7	1
B	wait()	0	33	6

<?php
namespace Aoe\Varnish\System;

/***************************************************************
 *  Copyright notice
 *
 *  (c) 2018 AOE GmbH <dev@aoe.com>
 *
 *  All rights reserved
 *
 *  This script is part of the TYPO3 project. The TYPO3 project is
 *  free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 3 of the License, or
 *  (at your option) any later version.
 *
 *  The GNU General Public License can be found at
 *  http://www.gnu.org/copyleft/gpl.html.
 *
 *  This script is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  This copyright notice MUST APPEAR in all copies of the script!
 ***************************************************************/

use GuzzleHttp\Client;
use GuzzleHttp\Promise\PromiseInterface;
use GuzzleHttp\Psr7\Response;
use GuzzleHttp\RequestOptions;

class Http
{
    /**
     * @var Client
     */
    private $client;

    /**
     * @var PromiseInterface[]
     */
    private $promises = [];

    /**
     * @param Client $client
     */
    public function __construct(Client $client)
    {
        $this->client = $client;
    }

    /**
     * @param string $method
     * @param string $url
     * @param array $headers
     * @param integer $timeout
     */
    public function request($method, $url, $headers = [], $timeout = 0)
    {
        $this->promises[] = $this->client->requestAsync($method, $url, [
            RequestOptions::HEADERS => $headers,
            RequestOptions::TIMEOUT => $timeout
        ]);
    }

    /**
     * @return array
     * @throws \Exception|\Throwable
     */
    public function wait()
    {
        $phrases = [];
        $results = \GuzzleHttp\Promise\settle($this->promises)->wait();

The function GuzzleHttp\Promise\settle() has been deprecated with message: settle will be removed in guzzlehttp/promises:2.0. Use Utils::settle instead.

        foreach ($results as $result) {
            if ($result['state'] === 'fulfilled') {
                $response = $result['value'];
                if ($response instanceof Response) {
                    $phrases[] = [
                        'reason' => $response->getReasonPhrase(),
                        'success' => $response->getStatusCode() === 200
                    ];
                }
            } else {
                if ($result['state'] === 'rejected') {
                    $reason = $result['reason'];
                    if ($reason instanceof \Exception) {
                        $reason = $reason->getMessage();
                    }
                    $phrases[] = [
                        'reason' => $reason,
                        'success' => false
                    ];
                } else {
                    $phrases[] = [
                        'reason' => 'unknown exception',
                        'success' => false
                    ];
                }
            }
        }
        return $phrases;
    }
}