Chris@0: <?php
Chris@0: /**
Chris@0:  * @see       http://github.com/zendframework/zend-diactoros for the canonical source repository
Chris@0:  * @copyright Copyright (c) 2017 Zend Technologies USA Inc. (http://www.zend.com)
Chris@0:  * @license   https://github.com/zendframework/zend-diactoros/blob/master/LICENSE.md New BSD License
Chris@0:  */
Chris@0: 
Chris@0: namespace Zend\Diactoros\Request;
Chris@0: 
Chris@0: use Psr\Http\Message\RequestInterface;
Chris@0: use UnexpectedValueException;
Chris@0: use Zend\Diactoros\Request;
Chris@0: use Zend\Diactoros\Stream;
Chris@0: 
Chris@16: use function sprintf;
Chris@16: 
Chris@0: /**
Chris@0:  * Serialize or deserialize request messages to/from arrays.
Chris@0:  *
Chris@0:  * This class provides functionality for serializing a RequestInterface instance
Chris@0:  * to an array, as well as the reverse operation of creating a Request instance
Chris@0:  * from an array representing a message.
Chris@0:  */
Chris@0: final class ArraySerializer
Chris@0: {
Chris@0:     /**
Chris@0:      * Serialize a request message to an array.
Chris@0:      *
Chris@0:      * @param RequestInterface $request
Chris@0:      * @return array
Chris@0:      */
Chris@0:     public static function toArray(RequestInterface $request)
Chris@0:     {
Chris@0:         return [
Chris@0:             'method'           => $request->getMethod(),
Chris@0:             'request_target'   => $request->getRequestTarget(),
Chris@0:             'uri'              => (string) $request->getUri(),
Chris@0:             'protocol_version' => $request->getProtocolVersion(),
Chris@0:             'headers'          => $request->getHeaders(),
Chris@0:             'body'             => (string) $request->getBody(),
Chris@0:         ];
Chris@0:     }
Chris@0: 
Chris@0:     /**
Chris@0:      * Deserialize a request array to a request instance.
Chris@0:      *
Chris@0:      * @param array $serializedRequest
Chris@0:      * @return Request
Chris@0:      * @throws UnexpectedValueException when cannot deserialize response
Chris@0:      */
Chris@0:     public static function fromArray(array $serializedRequest)
Chris@0:     {
Chris@0:         try {
Chris@0:             $uri             = self::getValueFromKey($serializedRequest, 'uri');
Chris@0:             $method          = self::getValueFromKey($serializedRequest, 'method');
Chris@0:             $body            = new Stream('php://memory', 'wb+');
Chris@0:             $body->write(self::getValueFromKey($serializedRequest, 'body'));
Chris@0:             $headers         = self::getValueFromKey($serializedRequest, 'headers');
Chris@0:             $requestTarget   = self::getValueFromKey($serializedRequest, 'request_target');
Chris@0:             $protocolVersion = self::getValueFromKey($serializedRequest, 'protocol_version');
Chris@0: 
Chris@0:             return (new Request($uri, $method, $body, $headers))
Chris@0:                 ->withRequestTarget($requestTarget)
Chris@0:                 ->withProtocolVersion($protocolVersion);
Chris@0:         } catch (\Exception $exception) {
Chris@0:             throw new UnexpectedValueException('Cannot deserialize request', null, $exception);
Chris@0:         }
Chris@0:     }
Chris@0: 
Chris@0:     /**
Chris@0:      * @param array $data
Chris@0:      * @param string $key
Chris@0:      * @param string $message
Chris@0:      * @return mixed
Chris@0:      * @throws UnexpectedValueException
Chris@0:      */
Chris@0:     private static function getValueFromKey(array $data, $key, $message = null)
Chris@0:     {
Chris@0:         if (isset($data[$key])) {
Chris@0:             return $data[$key];
Chris@0:         }
Chris@0:         if ($message === null) {
Chris@0:             $message = sprintf('Missing "%s" key in serialized request', $key);
Chris@0:         }
Chris@0:         throw new UnexpectedValueException($message);
Chris@0:     }
Chris@0: }