ServerRequestFactory.php in Zircon Profile 8.0

Namespace

Zend\Diactoros

File

vendor/zendframework/zend-diactoros/src/ServerRequestFactory.php

<?php

/**
 * Zend Framework (http://framework.zend.com/)
 *
 * @see       http://github.com/zendframework/zend-diactoros for the canonical source repository
 * @copyright Copyright (c) 2015 Zend Technologies USA Inc. (http://www.zend.com)
 * @license   https://github.com/zendframework/zend-diactoros/blob/master/LICENSE.md New BSD License
 */
namespace Zend\Diactoros;

use InvalidArgumentException;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Message\MessageInterface;
use Psr\Http\Message\UploadedFileInterface;
use stdClass;

/**
 * Class for marshaling a request object from the current PHP environment.
 *
 * Logic largely refactored from the ZF2 Zend\Http\PhpEnvironment\Request class.
 *
 * @copyright Copyright (c) 2005-2015 Zend Technologies USA Inc. (http://www.zend.com)
 * @license   http://framework.zend.com/license/new-bsd New BSD License
 */
abstract class ServerRequestFactory {

  /**
   * Function to use to get apache request headers; present only to simplify mocking.
   *
   * @var callable
   */
  private static $apacheRequestHeaders = 'apache_request_headers';

  /**
   * Create a request from the supplied superglobal values.
   *
   * If any argument is not supplied, the corresponding superglobal value will
   * be used.
   *
   * The ServerRequest created is then passed to the fromServer() method in
   * order to marshal the request URI and headers.
   *
   * @see fromServer()
   * @param array $server $_SERVER superglobal
   * @param array $query $_GET superglobal
   * @param array $body $_POST superglobal
   * @param array $cookies $_COOKIE superglobal
   * @param array $files $_FILES superglobal
   * @return ServerRequest
   * @throws InvalidArgumentException for invalid file values
   */
  public static function fromGlobals(array $server = null, array $query = null, array $body = null, array $cookies = null, array $files = null) {
    $server = static::normalizeServer($server ?: $_SERVER);
    $files = static::normalizeFiles($files ?: $_FILES);
    $headers = static::marshalHeaders($server);
    $request = new ServerRequest($server, $files, static::marshalUriFromServer($server, $headers), static::get('REQUEST_METHOD', $server, 'GET'), 'php://input', $headers);
    return $request
      ->withCookieParams($cookies ?: $_COOKIE)
      ->withQueryParams($query ?: $_GET)
      ->withParsedBody($body ?: $_POST);
  }

  /**
   * Access a value in an array, returning a default value if not found
   *
   * Will also do a case-insensitive search if a case sensitive search fails.
   *
   * @param string $key
   * @param array $values
   * @param mixed $default
   * @return mixed
   */
  public static function get($key, array $values, $default = null) {
    if (array_key_exists($key, $values)) {
      return $values[$key];
    }
    return $default;
  }

  /**
   * Search for a header value.
   *
   * Does a case-insensitive search for a matching header.
   *
   * If found, it is returned as a string, using comma concatenation.
   *
   * If not, the $default is returned.
   *
   * @param string $header
   * @param array $headers
   * @param mixed $default
   * @return string
   */
  public static function getHeader($header, array $headers, $default = null) {
    $header = strtolower($header);
    $headers = array_change_key_case($headers, CASE_LOWER);
    if (array_key_exists($header, $headers)) {
      $value = is_array($headers[$header]) ? implode(', ', $headers[$header]) : $headers[$header];
      return $value;
    }
    return $default;
  }

  /**
   * Marshal the $_SERVER array
   *
   * Pre-processes and returns the $_SERVER superglobal.
   *
   * @param array $server
   * @return array
   */
  public static function normalizeServer(array $server) {

    // This seems to be the only way to get the Authorization header on Apache
    $apacheRequestHeaders = self::$apacheRequestHeaders;
    if (isset($server['HTTP_AUTHORIZATION']) || !is_callable($apacheRequestHeaders)) {
      return $server;
    }
    $apacheRequestHeaders = $apacheRequestHeaders();
    if (isset($apacheRequestHeaders['Authorization'])) {
      $server['HTTP_AUTHORIZATION'] = $apacheRequestHeaders['Authorization'];
      return $server;
    }
    if (isset($apacheRequestHeaders['authorization'])) {
      $server['HTTP_AUTHORIZATION'] = $apacheRequestHeaders['authorization'];
      return $server;
    }
    return $server;
  }

  /**
   * Normalize uploaded files
   *
   * Transforms each value into an UploadedFileInterface instance, and ensures
   * that nested arrays are normalized.
   *
   * @param array $files
   * @return array
   * @throws InvalidArgumentException for unrecognized values
   */
  public static function normalizeFiles(array $files) {
    $normalized = [];
    foreach ($files as $key => $value) {
      if ($value instanceof UploadedFileInterface) {
        $normalized[$key] = $value;
        continue;
      }
      if (is_array($value) && isset($value['tmp_name'])) {
        $normalized[$key] = self::createUploadedFileFromSpec($value);
        continue;
      }
      if (is_array($value)) {
        $normalized[$key] = self::normalizeFiles($value);
        continue;
      }
      throw new InvalidArgumentException('Invalid value in files specification');
    }
    return $normalized;
  }

  /**
   * Marshal headers from $_SERVER
   *
   * @param array $server
   * @return array
   */
  public static function marshalHeaders(array $server) {
    $headers = [];
    foreach ($server as $key => $value) {
      if (strpos($key, 'HTTP_COOKIE') === 0) {

        // Cookies are handled using the $_COOKIE superglobal
        continue;
      }
      if ($value && strpos($key, 'HTTP_') === 0) {
        $name = strtr(substr($key, 5), '_', ' ');
        $name = strtr(ucwords(strtolower($name)), ' ', '-');
        $name = strtolower($name);
        $headers[$name] = $value;
        continue;
      }
      if ($value && strpos($key, 'CONTENT_') === 0) {
        $name = substr($key, 8);

        // Content-
        $name = 'Content-' . ($name == 'MD5' ? $name : ucfirst(strtolower($name)));
        $name = strtolower($name);
        $headers[$name] = $value;
        continue;
      }
    }
    return $headers;
  }

  /**
   * Marshal the URI from the $_SERVER array and headers
   *
   * @param array $server
   * @param array $headers
   * @return Uri
   */
  public static function marshalUriFromServer(array $server, array $headers) {
    $uri = new Uri('');

    // URI scheme
    $scheme = 'http';
    $https = self::get('HTTPS', $server);
    if ($https && 'off' !== $https || self::getHeader('x-forwarded-proto', $headers, false) === 'https') {
      $scheme = 'https';
    }
    if (!empty($scheme)) {
      $uri = $uri
        ->withScheme($scheme);
    }

    // Set the host
    $accumulator = (object) [
      'host' => '',
      'port' => null,
    ];
    self::marshalHostAndPortFromHeaders($accumulator, $server, $headers);
    $host = $accumulator->host;
    $port = $accumulator->port;
    if (!empty($host)) {
      $uri = $uri
        ->withHost($host);
      if (!empty($port)) {
        $uri = $uri
          ->withPort($port);
      }
    }

    // URI path
    $path = self::marshalRequestUri($server);
    $path = self::stripQueryString($path);

    // URI query
    $query = '';
    if (isset($server['QUERY_STRING'])) {
      $query = ltrim($server['QUERY_STRING'], '?');
    }
    return $uri
      ->withPath($path)
      ->withQuery($query);
  }

  /**
   * Marshal the host and port from HTTP headers and/or the PHP environment
   *
   * @param stdClass $accumulator
   * @param array $server
   * @param array $headers
   */
  public static function marshalHostAndPortFromHeaders(stdClass $accumulator, array $server, array $headers) {
    if (self::getHeader('host', $headers, false)) {
      self::marshalHostAndPortFromHeader($accumulator, self::getHeader('host', $headers));
      return;
    }
    if (!isset($server['SERVER_NAME'])) {
      return;
    }
    $accumulator->host = $server['SERVER_NAME'];
    if (isset($server['SERVER_PORT'])) {
      $accumulator->port = (int) $server['SERVER_PORT'];
    }
    if (!isset($server['SERVER_ADDR']) || !preg_match('/^\\[[0-9a-fA-F\\:]+\\]$/', $accumulator->host)) {
      return;
    }

    // Misinterpreted IPv6-Address
    // Reported for Safari on Windows
    self::marshalIpv6HostAndPort($accumulator, $server);
  }

  /**
   * Detect the base URI for the request
   *
   * Looks at a variety of criteria in order to attempt to autodetect a base
   * URI, including rewrite URIs, proxy URIs, etc.
   *
   * From ZF2's Zend\Http\PhpEnvironment\Request class
   * @copyright Copyright (c) 2005-2015 Zend Technologies USA Inc. (http://www.zend.com)
   * @license   http://framework.zend.com/license/new-bsd New BSD License
   *
   * @param array $server
   * @return string
   */
  public static function marshalRequestUri(array $server) {

    // IIS7 with URL Rewrite: make sure we get the unencoded url
    // (double slash problem).
    $iisUrlRewritten = self::get('IIS_WasUrlRewritten', $server);
    $unencodedUrl = self::get('UNENCODED_URL', $server, '');
    if ('1' == $iisUrlRewritten && !empty($unencodedUrl)) {
      return $unencodedUrl;
    }
    $requestUri = self::get('REQUEST_URI', $server);

    // Check this first so IIS will catch.
    $httpXRewriteUrl = self::get('HTTP_X_REWRITE_URL', $server);
    if ($httpXRewriteUrl !== null) {
      $requestUri = $httpXRewriteUrl;
    }

    // Check for IIS 7.0 or later with ISAPI_Rewrite
    $httpXOriginalUrl = self::get('HTTP_X_ORIGINAL_URL', $server);
    if ($httpXOriginalUrl !== null) {
      $requestUri = $httpXOriginalUrl;
    }
    if ($requestUri !== null) {
      return preg_replace('#^[^/:]+://[^/]+#', '', $requestUri);
    }
    $origPathInfo = self::get('ORIG_PATH_INFO', $server);
    if (empty($origPathInfo)) {
      return '/';
    }
    return $origPathInfo;
  }

  /**
   * Strip the query string from a path
   *
   * @param mixed $path
   * @return string
   */
  public static function stripQueryString($path) {
    if (($qpos = strpos($path, '?')) !== false) {
      return substr($path, 0, $qpos);
    }
    return $path;
  }

  /**
   * Marshal the host and port from the request header
   *
   * @param stdClass $accumulator
   * @param string|array $host
   * @return void
   */
  private static function marshalHostAndPortFromHeader(stdClass $accumulator, $host) {
    if (is_array($host)) {
      $host = implode(', ', $host);
    }
    $accumulator->host = $host;
    $accumulator->port = null;

    // works for regname, IPv4 & IPv6
    if (preg_match('|\\:(\\d+)$|', $accumulator->host, $matches)) {
      $accumulator->host = substr($accumulator->host, 0, -1 * (strlen($matches[1]) + 1));
      $accumulator->port = (int) $matches[1];
    }
  }

  /**
   * Marshal host/port from misinterpreted IPv6 address
   *
   * @param stdClass $accumulator
   * @param array $server
   */
  private static function marshalIpv6HostAndPort(stdClass $accumulator, array $server) {
    $accumulator->host = '[' . $server['SERVER_ADDR'] . ']';
    $accumulator->port = $accumulator->port ?: 80;
    if ($accumulator->port . ']' === substr($accumulator->host, strrpos($accumulator->host, ':') + 1)) {

      // The last digit of the IPv6-Address has been taken as port
      // Unset the port so the default port can be used
      $accumulator->port = null;
    }
  }

  /**
   * Create and return an UploadedFile instance from a $_FILES specification.
   *
   * If the specification represents an array of values, this method will
   * delegate to normalizeNestedFileSpec() and return that return value.
   *
   * @param array $value $_FILES struct
   * @return array|UploadedFileInterface
   */
  private static function createUploadedFileFromSpec(array $value) {
    if (is_array($value['tmp_name'])) {
      return self::normalizeNestedFileSpec($value);
    }
    return new UploadedFile($value['tmp_name'], $value['size'], $value['error'], $value['name'], $value['type']);
  }

  /**
   * Normalize an array of file specifications.
   *
   * Loops through all nested files and returns a normalized array of
   * UploadedFileInterface instances.
   *
   * @param array $files
   * @return UploadedFileInterface[]
   */
  private static function normalizeNestedFileSpec(array $files = []) {
    $normalizedFiles = [];
    foreach (array_keys($files['tmp_name']) as $key) {
      $spec = [
        'tmp_name' => $files['tmp_name'][$key],
        'size' => $files['size'][$key],
        'error' => $files['error'][$key],
        'name' => $files['name'][$key],
        'type' => $files['type'][$key],
      ];
      $normalizedFiles[$key] = self::createUploadedFileFromSpec($spec);
    }
    return $normalizedFiles;
  }

}

Classes

Name	Description
ServerRequestFactory	Class for marshaling a request object from the current PHP environment.