<?php
|
|
/*
|
* This file is part of the overtrue/wechat.
|
*
|
* (c) overtrue <i@overtrue.me>
|
*
|
* This source file is subject to the MIT license that is bundled
|
* with this source code in the file LICENSE.
|
*/
|
|
namespace EasyWeChat\Kernel\Traits;
|
|
use GuzzleHttp\Client;
|
use GuzzleHttp\ClientInterface;
|
use GuzzleHttp\HandlerStack;
|
use Psr\Http\Message\ResponseInterface;
|
|
/**
|
* Trait HasHttpRequests.
|
*
|
* @author overtrue <i@overtrue.me>
|
*/
|
trait HasHttpRequests
|
{
|
use ResponseCastable;
|
|
/**
|
* @var \GuzzleHttp\ClientInterface
|
*/
|
protected $httpClient;
|
|
/**
|
* @var array
|
*/
|
protected $middlewares = [];
|
|
/**
|
* @var \GuzzleHttp\HandlerStack
|
*/
|
protected $handlerStack;
|
|
/**
|
* @var array
|
*/
|
protected static $defaults = [
|
'curl' => [
|
CURLOPT_IPRESOLVE => CURL_IPRESOLVE_V4,
|
],
|
];
|
|
/**
|
* Set guzzle default settings.
|
*
|
* @param array $defaults
|
*/
|
public static function setDefaultOptions($defaults = [])
|
{
|
self::$defaults = $defaults;
|
}
|
|
/**
|
* Return current guzzle default settings.
|
*
|
* @return array
|
*/
|
public static function getDefaultOptions(): array
|
{
|
return self::$defaults;
|
}
|
|
/**
|
* Set GuzzleHttp\Client.
|
*
|
* @param \GuzzleHttp\ClientInterface $httpClient
|
*
|
* @return $this
|
*/
|
public function setHttpClient(ClientInterface $httpClient)
|
{
|
$this->httpClient = $httpClient;
|
|
return $this;
|
}
|
|
/**
|
* Return GuzzleHttp\ClientInterface instance.
|
*
|
* @return ClientInterface
|
*/
|
public function getHttpClient(): ClientInterface
|
{
|
if (!($this->httpClient instanceof ClientInterface)) {
|
if (property_exists($this, 'app') && $this->app['http_client']) {
|
$this->httpClient = $this->app['http_client'];
|
} else {
|
$this->httpClient = new Client(['handler' => HandlerStack::create($this->getGuzzleHandler())]);
|
}
|
}
|
|
return $this->httpClient;
|
}
|
|
/**
|
* Add a middleware.
|
*
|
* @param callable $middleware
|
* @param string $name
|
*
|
* @return $this
|
*/
|
public function pushMiddleware(callable $middleware, string $name = null)
|
{
|
if (!is_null($name)) {
|
$this->middlewares[$name] = $middleware;
|
} else {
|
array_push($this->middlewares, $middleware);
|
}
|
|
return $this;
|
}
|
|
/**
|
* Return all middlewares.
|
*
|
* @return array
|
*/
|
public function getMiddlewares(): array
|
{
|
return $this->middlewares;
|
}
|
|
/**
|
* Make a request.
|
*
|
* @param string $url
|
* @param string $method
|
* @param array $options
|
*
|
* @return \Psr\Http\Message\ResponseInterface
|
*
|
* @throws \GuzzleHttp\Exception\GuzzleException
|
*/
|
public function request($url, $method = 'GET', $options = []): ResponseInterface
|
{
|
$method = strtoupper($method);
|
|
$options = array_merge(self::$defaults, $options, ['handler' => $this->getHandlerStack()]);
|
|
$options = $this->fixJsonIssue($options);
|
|
if (property_exists($this, 'baseUri') && !is_null($this->baseUri)) {
|
$options['base_uri'] = $this->baseUri;
|
}
|
|
$response = $this->getHttpClient()->request($method, $url, $options);
|
$response->getBody()->rewind();
|
|
return $response;
|
}
|
|
/**
|
* @param \GuzzleHttp\HandlerStack $handlerStack
|
*
|
* @return $this
|
*/
|
public function setHandlerStack(HandlerStack $handlerStack)
|
{
|
$this->handlerStack = $handlerStack;
|
|
return $this;
|
}
|
|
/**
|
* Build a handler stack.
|
*
|
* @return \GuzzleHttp\HandlerStack
|
*/
|
public function getHandlerStack(): HandlerStack
|
{
|
if ($this->handlerStack) {
|
return $this->handlerStack;
|
}
|
|
$this->handlerStack = HandlerStack::create($this->getGuzzleHandler());
|
|
foreach ($this->middlewares as $name => $middleware) {
|
$this->handlerStack->push($middleware, $name);
|
}
|
|
return $this->handlerStack;
|
}
|
|
/**
|
* @param array $options
|
*
|
* @return array
|
*/
|
protected function fixJsonIssue(array $options): array
|
{
|
if (isset($options['json']) && is_array($options['json'])) {
|
$options['headers'] = array_merge($options['headers'] ?? [], ['Content-Type' => 'application/json']);
|
|
if (empty($options['json'])) {
|
$options['body'] = \GuzzleHttp\json_encode($options['json'], JSON_FORCE_OBJECT);
|
} else {
|
$options['body'] = \GuzzleHttp\json_encode($options['json'], JSON_UNESCAPED_UNICODE);
|
}
|
|
unset($options['json']);
|
}
|
|
return $options;
|
}
|
|
/**
|
* Get guzzle handler.
|
*
|
* @return callable
|
*/
|
protected function getGuzzleHandler()
|
{
|
if (property_exists($this, 'app') && isset($this->app['guzzle_handler'])) {
|
return is_string($handler = $this->app->raw('guzzle_handler'))
|
? new $handler()
|
: $handler;
|
}
|
|
return \GuzzleHttp\choose_handler();
|
}
|
}
|
