# media-cloud-sync/1.4.2/includes/sdk/s3/Aws/Handler/Guzzle/GuzzleHandler.php

Media Cloud Sync, version 1.4.2. 63 lines.

- Page: https://pluginprobe.com/plugins/media-cloud-sync/1.4.2/code/includes/sdk/s3/Aws/Handler/Guzzle/GuzzleHandler.php
- Raw: https://pluginprobe.com/plugins/media-cloud-sync/1.4.2/raw/includes/sdk/s3/Aws/Handler/Guzzle/GuzzleHandler.php
- Modified: 2026-05-10T10:14:36+00:00

Line numbers below start at 1. Link to a line or a range by appending a fragment to the
page URL, for example `https://pluginprobe.com/plugins/media-cloud-sync/1.4.2/code/includes/sdk/s3/Aws/Handler/Guzzle/GuzzleHandler.php#L10-L20`.

```php
<?php

namespace Dudlewebs\WPMCS\s3\Aws\Handler\Guzzle;

use Exception;
use Dudlewebs\WPMCS\s3\GuzzleHttp\Exception\ConnectException;
use Dudlewebs\WPMCS\s3\GuzzleHttp\Exception\RequestException;
use Dudlewebs\WPMCS\s3\GuzzleHttp\Utils;
use Dudlewebs\WPMCS\s3\GuzzleHttp\Promise;
use Dudlewebs\WPMCS\s3\GuzzleHttp\Client;
use Dudlewebs\WPMCS\s3\GuzzleHttp\ClientInterface;
use Dudlewebs\WPMCS\s3\GuzzleHttp\TransferStats;
use Dudlewebs\WPMCS\s3\Psr\Http\Message\RequestInterface as Psr7Request;
/**
 * A request handler that sends PSR-7-compatible requests with Guzzle.
 */
class GuzzleHandler
{
    /** @var ClientInterface */
    private $client;
    /**
     * @param ClientInterface $client
     */
    public function __construct(?ClientInterface $client = null)
    {
        $this->client = $client ?: new Client();
    }
    /**
     * @param Psr7Request $request
     * @param array       $options
     *
     * @return Promise\Promise
     */
    public function __invoke(Psr7Request $request, array $options = [])
    {
        $request = $request->withHeader('User-Agent', $request->getHeaderLine('User-Agent') . ' ' . Utils::defaultUserAgent());
        return $this->client->sendAsync($request, $this->parseOptions($options))->otherwise(static function ($e) {
            $error = ['exception' => $e, 'connection_error' => $e instanceof ConnectException, 'response' => null];
            if ($e instanceof RequestException && $e->getResponse()) {
                $error['response'] = $e->getResponse();
            }
            return new Promise\RejectedPromise($error);
        });
    }
    private function parseOptions(array $options)
    {
        if (isset($options['http_stats_receiver'])) {
            $fn = $options['http_stats_receiver'];
            unset($options['http_stats_receiver']);
            $prev = isset($options['on_stats']) ? $options['on_stats'] : null;
            $options['on_stats'] = static function (TransferStats $stats) use($fn, $prev) {
                if (\is_callable($prev)) {
                    $prev($stats);
                }
                $transferStats = ['total_time' => $stats->getTransferTime()];
                $transferStats += $stats->getHandlerStats();
                $fn($transferStats);
            };
        }
        return $options;
    }
}

```