Subversion-Projekte lars-tiefland.laravel_shop

<?php

namespace Illuminate\Http\Client;

use Exception;

use GuzzleHttp\Client;

use GuzzleHttp\Cookie\CookieJar;

use GuzzleHttp\Exception\ConnectException;

use GuzzleHttp\Exception\RequestException;

use GuzzleHttp\Exception\TransferException;

use GuzzleHttp\HandlerStack;

use Illuminate\Contracts\Support\Arrayable;

use Illuminate\Http\Client\Events\ConnectionFailed;

use Illuminate\Http\Client\Events\RequestSending;

use Illuminate\Http\Client\Events\ResponseReceived;

use Illuminate\Support\Arr;

use Illuminate\Support\Collection;

use Illuminate\Support\Str;

use Illuminate\Support\Traits\Conditionable;

use Illuminate\Support\Traits\Macroable;

use JsonSerializable;

use Psr\Http\Message\MessageInterface;

use Psr\Http\Message\RequestInterface;

use RuntimeException;

use Symfony\Component\VarDumper\VarDumper;

class PendingRequest

{

    use Conditionable, Macroable;

    /**

     * The factory instance.

     *

     * @var \Illuminate\Http\Client\Factory|null

     */

    protected $factory;

    /**

     * The Guzzle client instance.

     *

     * @var \GuzzleHttp\Client

     */

    protected $client;

    /**

     * The Guzzle HTTP handler.

     *

     * @var callable

     */

    protected $handler;

    /**

     * The base URL for the request.

     *

     * @var string

     */

    protected $baseUrl = '';

    /**

     * The request body format.

     *

     * @var string

     */

    protected $bodyFormat;

    /**

     * The raw body for the request.

     *

     * @var string

     */

    protected $pendingBody;

    /**

     * The pending files for the request.

     *

     * @var array

     */

    protected $pendingFiles = [];

    /**

     * The request cookies.

     *

     * @var array

     */

    protected $cookies;

    /**

     * The transfer stats for the request.

     *

     * \GuzzleHttp\TransferStats

     */

    protected $transferStats;

    /**

     * The request options.

     *

     * @var array

     */

    protected $options = [];

    /**

     * A callback to run when throwing if a server or client error occurs.

     *

     * @var \Closure

     */

    protected $throwCallback;

    /**

     * A callback to check if an exception should be thrown when a server or client error occurs.

     *

     * @var \Closure

     */

    protected $throwIfCallback;

    /**

     * The number of times to try the request.

     *

     * @var int

     */

    protected $tries = 1;

    /**

     * The number of milliseconds to wait between retries.

     *

     * @var int

     */

    protected $retryDelay = 100;

    /**

     * Whether to throw an exception when all retries fail.

     *

     * @var bool

     */

    protected $retryThrow = true;

    /**

     * The callback that will determine if the request should be retried.

     *

     * @var callable|null

     */

    protected $retryWhenCallback = null;

    /**

     * The callbacks that should execute before the request is sent.

     *

     * @var \Illuminate\Support\Collection

     */

    protected $beforeSendingCallbacks;

    /**

     * The stub callables that will handle requests.

     *

     * @var \Illuminate\Support\Collection|null

     */

    protected $stubCallbacks;

    /**

     * Indicates that an exception should be thrown if any request is not faked.

     *

     * @var bool

     */

    protected $preventStrayRequests = false;

    /**

     * The middleware callables added by users that will handle requests.

     *

     * @var \Illuminate\Support\Collection

     */

    protected $middleware;

    /**

     * Whether the requests should be asynchronous.

     *

     * @var bool

     */

    protected $async = false;

    /**

     * The pending request promise.

     *

     * @var \GuzzleHttp\Promise\PromiseInterface

     */

    protected $promise;

    /**

     * The sent request object, if a request has been made.

     *

     * @var \Illuminate\Http\Client\Request|null

     */

    protected $request;

    /**

     * The Guzzle request options that are mergable via array_merge_recursive.

     *

     * @var array

     */

    protected $mergableOptions = [

        'cookies',

        'form_params',

        'headers',

        'json',

        'multipart',

        'query',

    ];

    /**

     * Create a new HTTP Client instance.

     *

     * @param  \Illuminate\Http\Client\Factory|null  $factory

     * @return void

     */

    public function __construct(Factory $factory = null)

    {

        $this->factory = $factory;

        $this->middleware = new Collection;

        $this->asJson();

        $this->options = [

            'connect_timeout' => 10,

            'http_errors' => false,

            'timeout' => 30,

        ];

        $this->beforeSendingCallbacks = collect([function (Request $request, array $options, PendingRequest $pendingRequest) {

            $pendingRequest->request = $request;

            $pendingRequest->cookies = $options['cookies'];

            $pendingRequest->dispatchRequestSendingEvent();

        }]);

    }

    /**

     * Set the base URL for the pending request.

     *

     * @param  string  $url

     * @return $this

     */

    public function baseUrl(string $url)

    {

        $this->baseUrl = $url;

        return $this;

    }

    /**

     * Attach a raw body to the request.

     *

     * @param  string  $content

     * @param  string  $contentType

     * @return $this

     */

    public function withBody($content, $contentType)

    {

        $this->bodyFormat('body');

        $this->pendingBody = $content;

        $this->contentType($contentType);

        return $this;

    }

    /**

     * Indicate the request contains JSON.

     *

     * @return $this

     */

    public function asJson()

    {

        return $this->bodyFormat('json')->contentType('application/json');

    }

    /**

     * Indicate the request contains form parameters.

     *

     * @return $this

     */

    public function asForm()

    {

        return $this->bodyFormat('form_params')->contentType('application/x-www-form-urlencoded');

    }

    /**

     * Attach a file to the request.

     *

     * @param  string|array  $name

     * @param  string|resource  $contents

     * @param  string|null  $filename

     * @param  array  $headers

     * @return $this

     */

    public function attach($name, $contents = '', $filename = null, array $headers = [])

    {

        if (is_array($name)) {

            foreach ($name as $file) {

                $this->attach(...$file);

            }

            return $this;

        }

        $this->asMultipart();

        $this->pendingFiles[] = array_filter([

            'name' => $name,

            'contents' => $contents,

            'headers' => $headers,

            'filename' => $filename,

        ]);

        return $this;

    }

    /**

     * Indicate the request is a multi-part form request.

     *

     * @return $this

     */

    public function asMultipart()

    {

        return $this->bodyFormat('multipart');

    }

    /**

     * Specify the body format of the request.

     *

     * @param  string  $format

     * @return $this

     */

    public function bodyFormat(string $format)

    {

        return tap($this, function () use ($format) {

            $this->bodyFormat = $format;

        });

    }

    /**

     * Specify the request's content type.

     *

     * @param  string  $contentType

     * @return $this

     */

    public function contentType(string $contentType)

    {

        return $this->withHeaders(['Content-Type' => $contentType]);

    }

    /**

     * Indicate that JSON should be returned by the server.

     *

     * @return $this

     */

    public function acceptJson()

    {

        return $this->accept('application/json');

    }

    /**

     * Indicate the type of content that should be returned by the server.

     *

     * @param  string  $contentType

     * @return $this

     */

    public function accept($contentType)

    {

        return $this->withHeaders(['Accept' => $contentType]);

    }

    /**

     * Add the given headers to the request.

     *

     * @param  array  $headers

     * @return $this

     */

    public function withHeaders(array $headers)

    {

        return tap($this, function () use ($headers) {

            $this->options = array_merge_recursive($this->options, [

                'headers' => $headers,

            ]);

        });

    }

    /**

     * Specify the basic authentication username and password for the request.

     *

     * @param  string  $username

     * @param  string  $password

     * @return $this

     */

    public function withBasicAuth(string $username, string $password)

    {

        return tap($this, function () use ($username, $password) {

            $this->options['auth'] = [$username, $password];

        });

    }

    /**

     * Specify the digest authentication username and password for the request.

     *

     * @param  string  $username

     * @param  string  $password

     * @return $this

     */

    public function withDigestAuth($username, $password)

    {

        return tap($this, function () use ($username, $password) {

            $this->options['auth'] = [$username, $password, 'digest'];

        });

    }

    /**

     * Specify an authorization token for the request.

     *

     * @param  string  $token

     * @param  string  $type

     * @return $this

     */

    public function withToken($token, $type = 'Bearer')

    {

        return tap($this, function () use ($token, $type) {

            $this->options['headers']['Authorization'] = trim($type.' '.$token);

        });

    }

    /**

     * Specify the user agent for the request.

     *

     * @param  string  $userAgent

     * @return $this

     */

    public function withUserAgent($userAgent)

    {

        return tap($this, function () use ($userAgent) {

            $this->options['headers']['User-Agent'] = trim($userAgent);

        });

    }

    /**

     * Specify the cookies that should be included with the request.

     *

     * @param  array  $cookies

     * @param  string  $domain

     * @return $this

     */

    public function withCookies(array $cookies, string $domain)

    {

        return tap($this, function () use ($cookies, $domain) {

            $this->options = array_merge_recursive($this->options, [

                'cookies' => CookieJar::fromArray($cookies, $domain),

            ]);

        });

    }

    /**

     * Specify the maximum number of redirects to allow.

     *

     * @param  int  $max

     * @return $this

     */

    public function maxRedirects(int $max)

    {

        return tap($this, function () use ($max) {

            $this->options['allow_redirects']['max'] = $max;

        });

    }

    /**

     * Indicate that redirects should not be followed.

     *

     * @return $this

     */

    public function withoutRedirecting()

    {

        return tap($this, function () {

            $this->options['allow_redirects'] = false;

        });

    }

    /**

     * Indicate that TLS certificates should not be verified.

     *

     * @return $this

     */

    public function withoutVerifying()

    {

        return tap($this, function () {

            $this->options['verify'] = false;

        });

    }

    /**

     * Specify the path where the body of the response should be stored.

     *

     * @param  string|resource  $to

     * @return $this

     */

    public function sink($to)

    {

        return tap($this, function () use ($to) {

            $this->options['sink'] = $to;

        });

    }

    /**

     * Specify the timeout (in seconds) for the request.

     *

     * @param  int  $seconds

     * @return $this

     */

    public function timeout(int $seconds)

    {

        return tap($this, function () use ($seconds) {

            $this->options['timeout'] = $seconds;

        });

    }

    /**

     * Specify the connect timeout (in seconds) for the request.

     *

     * @param  int  $seconds

     * @return $this

     */

    public function connectTimeout(int $seconds)

    {

        return tap($this, function () use ($seconds) {

            $this->options['connect_timeout'] = $seconds;

        });

    }

    /**

     * Specify the number of times the request should be attempted.

     *

     * @param  int  $times

     * @param  int  $sleepMilliseconds

     * @param  callable|null  $when

     * @param  bool  $throw

     * @return $this

     */

    public function retry(int $times, int $sleepMilliseconds = 0, ?callable $when = null, bool $throw = true)

    {

        $this->tries = $times;

        $this->retryDelay = $sleepMilliseconds;

        $this->retryThrow = $throw;

        $this->retryWhenCallback = $when;

        return $this;

    }

    /**

     * Replace the specified options on the request.

     *

     * @param  array  $options

     * @return $this

     */

    public function withOptions(array $options)

    {

        return tap($this, function () use ($options) {

            $this->options = array_replace_recursive(

                array_merge_recursive($this->options, Arr::only($options, $this->mergableOptions)),

                $options

            );

        });

    }

    /**

     * Add new middleware the client handler stack.

     *

     * @param  callable  $middleware

     * @return $this

     */

    public function withMiddleware(callable $middleware)

    {

        $this->middleware->push($middleware);

        return $this;

    }

    /**

     * Add a new "before sending" callback to the request.

     *

     * @param  callable  $callback

     * @return $this

     */

    public function beforeSending($callback)

    {

        return tap($this, function () use ($callback) {

            $this->beforeSendingCallbacks[] = $callback;

        });

    }

    /**

     * Throw an exception if a server or client error occurs.

     *

     * @param  callable|null  $callback

     * @return $this

     */

    public function throw(callable $callback = null)

    {

        $this->throwCallback = $callback ?: fn () => null;

        return $this;

    }

    /**

     * Throw an exception if a server or client error occurred and the given condition evaluates to true.

     *

     * @param  callable|bool  $condition

     * @param  callable|null  $throwCallback

     * @return $this

     */

    public function throwIf($condition)

    {

        if (is_callable($condition)) {

            $this->throwIfCallback = $condition;

        }

        return $condition ? $this->throw(func_get_args()[1] ?? null) : $this;

    }

    /**

     * Throw an exception if a server or client error occurred and the given condition evaluates to false.

     *

     * @param  bool  $condition

     * @return $this

     */

    public function throwUnless($condition)

    {

        return $this->throwIf(! $condition);

    }

    /**

     * Dump the request before sending.

     *

     * @return $this

     */

    public function dump()

    {

        $values = func_get_args();

        return $this->beforeSending(function (Request $request, array $options) use ($values) {

            foreach (array_merge($values, [$request, $options]) as $value) {

                VarDumper::dump($value);

            }

        });

    }

    /**

     * Dump the request before sending and end the script.

     *

     * @return $this

     */

    public function dd()

    {

        $values = func_get_args();

        return $this->beforeSending(function (Request $request, array $options) use ($values) {

            foreach (array_merge($values, [$request, $options]) as $value) {

                VarDumper::dump($value);

            }

            exit(1);

        });

    }

    /**

     * Issue a GET request to the given URL.

     *

     * @param  string  $url

     * @param  array|string|null  $query

     * @return \Illuminate\Http\Client\Response

     */

    public function get(string $url, $query = null)

    {

        return $this->send('GET', $url, func_num_args() === 1 ? [] : [

            'query' => $query,

        ]);

    }

    /**

     * Issue a HEAD request to the given URL.

     *

     * @param  string  $url

     * @param  array|string|null  $query

     * @return \Illuminate\Http\Client\Response

     */

    public function head(string $url, $query = null)

    {

        return $this->send('HEAD', $url, func_num_args() === 1 ? [] : [

            'query' => $query,

        ]);

    }

    /**

     * Issue a POST request to the given URL.

     *

     * @param  string  $url

     * @param  array  $data

     * @return \Illuminate\Http\Client\Response

     */

    public function post(string $url, $data = [])

    {

        return $this->send('POST', $url, [

            $this->bodyFormat => $data,

        ]);

    }

    /**

     * Issue a PATCH request to the given URL.

     *

     * @param  string  $url

     * @param  array  $data

     * @return \Illuminate\Http\Client\Response

     */

    public function patch($url, $data = [])

    {

        return $this->send('PATCH', $url, [

            $this->bodyFormat => $data,

        ]);

    }

    /**

     * Issue a PUT request to the given URL.

     *

     * @param  string  $url

     * @param  array  $data

     * @return \Illuminate\Http\Client\Response

     */

    public function put($url, $data = [])

    {

        return $this->send('PUT', $url, [

            $this->bodyFormat => $data,

        ]);

    }

    /**

     * Issue a DELETE request to the given URL.

     *

     * @param  string  $url

     * @param  array  $data

     * @return \Illuminate\Http\Client\Response

     */

    public function delete($url, $data = [])

    {

        return $this->send('DELETE', $url, empty($data) ? [] : [

            $this->bodyFormat => $data,

        ]);

    }

    /**

     * Send a pool of asynchronous requests concurrently.

     *

     * @param  callable  $callback

     * @return array

     */

    public function pool(callable $callback)

    {

        $results = [];

        $requests = tap(new Pool($this->factory), $callback)->getRequests();

        foreach ($requests as $key => $item) {

            $results[$key] = $item instanceof static ? $item->getPromise()->wait() : $item->wait();

        }

        return $results;

    }

    /**

     * Send the request to the given URL.

     *

     * @param  string  $method

     * @param  string  $url

     * @param  array  $options

     * @return \Illuminate\Http\Client\Response

     *

     * @throws \Exception

     */

    public function send(string $method, string $url, array $options = [])

    {

        if (! Str::startsWith($url, ['http://', 'https://'])) {

            $url = ltrim(rtrim($this->baseUrl, '/').'/'.ltrim($url, '/'), '/');

        }

        $options = $this->parseHttpOptions($options);

        [$this->pendingBody, $this->pendingFiles] = [null, []];

        if ($this->async) {

            return $this->makePromise($method, $url, $options);

        }

        $shouldRetry = null;

        return retry($this->tries ?? 1, function ($attempt) use ($method, $url, $options, &$shouldRetry) {

            try {

                return tap(new Response($this->sendRequest($method, $url, $options)), function ($response) use ($attempt, &$shouldRetry) {

                    $this->populateResponse($response);

                    $this->dispatchResponseReceivedEvent($response);

                    if (! $response->successful()) {

                        try {

                            $shouldRetry = $this->retryWhenCallback ? call_user_func($this->retryWhenCallback, $response->toException(), $this) : true;

                        } catch (Exception $exception) {

                            $shouldRetry = false;

                            throw $exception;

                        }

                        if ($this->throwCallback &&

                            ($this->throwIfCallback === null ||

                             call_user_func($this->throwIfCallback, $response))) {

                            $response->throw($this->throwCallback);

                        }

                        if ($attempt < $this->tries && $shouldRetry) {

                            $response->throw();

                        }

                        if ($this->tries > 1 && $this->retryThrow) {

                            $response->throw();

                        }

                    }

                });

            } catch (ConnectException $e) {

                $this->dispatchConnectionFailedEvent();

                throw new ConnectionException($e->getMessage(), 0, $e);

            }

        }, $this->retryDelay ?? 100, function ($exception) use (&$shouldRetry) {

            $result = $shouldRetry ?? ($this->retryWhenCallback ? call_user_func($this->retryWhenCallback, $exception, $this) : true);

            $shouldRetry = null;

            return $result;

        });

    }

    /**

     * Parse the given HTTP options and set the appropriate additional options.

     *

     * @param  array  $options

     * @return array

     */

    protected function parseHttpOptions(array $options)

    {

        if (isset($options[$this->bodyFormat])) {

            if ($this->bodyFormat === 'multipart') {

                $options[$this->bodyFormat] = $this->parseMultipartBodyFormat($options[$this->bodyFormat]);

            } elseif ($this->bodyFormat === 'body') {

                $options[$this->bodyFormat] = $this->pendingBody;

            }

            if (is_array($options[$this->bodyFormat])) {

                $options[$this->bodyFormat] = array_merge(

                    $options[$this->bodyFormat], $this->pendingFiles

                );

            }

        } else {

            $options[$this->bodyFormat] = $this->pendingBody;

        }

        return collect($options)->map(function ($value, $key) {

            if ($key === 'json' && $value instanceof JsonSerializable) {

                return $value;

            }

            return $value instanceof Arrayable ? $value->toArray() : $value;

        })->all();

    }

    /**

     * Parse multi-part form data.

     *

     * @param  array  $data

     * @return array|array[]

     */

    protected function parseMultipartBodyFormat(array $data)

    {

        return collect($data)->map(function ($value, $key) {

            return is_array($value) ? $value : ['name' => $key, 'contents' => $value];

        })->values()->all();

    }

    /**

     * Send an asynchronous request to the given URL.

     *

     * @param  string  $method

     * @param  string  $url

     * @param  array  $options

     * @return \GuzzleHttp\Promise\PromiseInterface

     */

    protected function makePromise(string $method, string $url, array $options = [])

    {

        return $this->promise = $this->sendRequest($method, $url, $options)

            ->then(function (MessageInterface $message) {

                return tap(new Response($message), function ($response) {

                    $this->populateResponse($response);

                    $this->dispatchResponseReceivedEvent($response);

                });

            })

            ->otherwise(function (TransferException $e) {

                return $e instanceof RequestException && $e->hasResponse() ? $this->populateResponse(new Response($e->getResponse())) : $e;

            });

    }

    /**

     * Send a request either synchronously or asynchronously.

     *

     * @param  string  $method

     * @param  string  $url

     * @param  array  $options

     * @return \Psr\Http\Message\MessageInterface|\GuzzleHttp\Promise\PromiseInterface

     *

     * @throws \Exception

     */

    protected function sendRequest(string $method, string $url, array $options = [])

    {

        $clientMethod = $this->async ? 'requestAsync' : 'request';

        $laravelData = $this->parseRequestData($method, $url, $options);

        return $this->buildClient()->$clientMethod($method, $url, $this->mergeOptions([

            'laravel_data' => $laravelData,

            'on_stats' => function ($transferStats) {

                $this->transferStats = $transferStats;

            },

        ], $options));

    }

    /**

     * Get the request data as an array so that we can attach it to the request for convenient assertions.

     *

     * @param  string  $method

     * @param  string  $url

     * @param  array  $options

     * @return array

     */

    protected function parseRequestData($method, $url, array $options)

    {

        if ($this->bodyFormat === 'body') {

            return [];

        }

        $laravelData = $options[$this->bodyFormat] ?? $options['query'] ?? [];

        $urlString = Str::of($url);

        if (empty($laravelData) && $method === 'GET' && $urlString->contains('?')) {

            $laravelData = (string) $urlString->after('?');

        }

        if (is_string($laravelData)) {

            parse_str($laravelData, $parsedData);

            $laravelData = is_array($parsedData) ? $parsedData : [];

        }

        if ($laravelData instanceof JsonSerializable) {

            $laravelData = $laravelData->jsonSerialize();

        }

        return is_array($laravelData) ? $laravelData : [];

    }

    /**

     * Populate the given response with additional data.

     *

     * @param  \Illuminate\Http\Client\Response  $response

     * @return \Illuminate\Http\Client\Response

     */

    protected function populateResponse(Response $response)

    {

        $response->cookies = $this->cookies;

        $response->transferStats = $this->transferStats;

        return $response;

    }

    /**

     * Build the Guzzle client.

     *

     * @return \GuzzleHttp\Client

     */

    public function buildClient()

    {

        return $this->client ?? $this->createClient($this->buildHandlerStack());

    }

    /**

     * Determine if a reusable client is required.

     *

     * @return bool

     */

    protected function requestsReusableClient()

    {

        return ! is_null($this->client) || $this->async;