123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151 |
- <?php
- namespace GuzzleHttp\Psr7;
- use InvalidArgumentException;
- use Psr\Http\Message\RequestInterface;
- use Psr\Http\Message\StreamInterface;
- use Psr\Http\Message\UriInterface;
- /**
- * PSR-7 request implementation.
- */
- class Request implements RequestInterface
- {
- use MessageTrait;
- /** @var string */
- private $method;
- /** @var null|string */
- private $requestTarget;
- /** @var UriInterface */
- private $uri;
- /**
- * @param string $method HTTP method
- * @param string|UriInterface $uri URI
- * @param array $headers Request headers
- * @param string|null|resource|StreamInterface $body Request body
- * @param string $version Protocol version
- */
- public function __construct(
- $method,
- $uri,
- array $headers = [],
- $body = null,
- $version = '1.1'
- ) {
- $this->assertMethod($method);
- if (!($uri instanceof UriInterface)) {
- $uri = new Uri($uri);
- }
- $this->method = strtoupper($method);
- $this->uri = $uri;
- $this->setHeaders($headers);
- $this->protocol = $version;
- if (!isset($this->headerNames['host'])) {
- $this->updateHostFromUri();
- }
- if ($body !== '' && $body !== null) {
- $this->stream = stream_for($body);
- }
- }
- public function getRequestTarget()
- {
- if ($this->requestTarget !== null) {
- return $this->requestTarget;
- }
- $target = $this->uri->getPath();
- if ($target == '') {
- $target = '/';
- }
- if ($this->uri->getQuery() != '') {
- $target .= '?' . $this->uri->getQuery();
- }
- return $target;
- }
- public function withRequestTarget($requestTarget)
- {
- if (preg_match('#\s#', $requestTarget)) {
- throw new InvalidArgumentException(
- 'Invalid request target provided; cannot contain whitespace'
- );
- }
- $new = clone $this;
- $new->requestTarget = $requestTarget;
- return $new;
- }
- public function getMethod()
- {
- return $this->method;
- }
- public function withMethod($method)
- {
- $this->assertMethod($method);
- $new = clone $this;
- $new->method = strtoupper($method);
- return $new;
- }
- public function getUri()
- {
- return $this->uri;
- }
- public function withUri(UriInterface $uri, $preserveHost = false)
- {
- if ($uri === $this->uri) {
- return $this;
- }
- $new = clone $this;
- $new->uri = $uri;
- if (!$preserveHost || !isset($this->headerNames['host'])) {
- $new->updateHostFromUri();
- }
- return $new;
- }
- private function updateHostFromUri()
- {
- $host = $this->uri->getHost();
- if ($host == '') {
- return;
- }
- if (($port = $this->uri->getPort()) !== null) {
- $host .= ':' . $port;
- }
- if (isset($this->headerNames['host'])) {
- $header = $this->headerNames['host'];
- } else {
- $header = 'Host';
- $this->headerNames['host'] = 'Host';
- }
- // Ensure Host is the first header.
- // See: http://tools.ietf.org/html/rfc7230#section-5.4
- $this->headers = [$header => [$host]] + $this->headers;
- }
- private function assertMethod($method)
- {
- if (!is_string($method) || $method === '') {
- throw new \InvalidArgumentException('Method must be a non-empty string.');
- }
- }
- }
|