ArangoDb\HttpHelper

Complexity

Total Complexity

18

Size/Duplication

Total Lines	98
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	parseMessage()	0	27	5
A	responseContentAsArray()	0	15	4
B	responseContentAsJson()	0	28	9

<?php
/**
 * Sandro Keil (https://sandro-keil.de)
 *
 * @link      http://github.com/sandrokeil/arangodb-php-client for the canonical source repository
 * @copyright Copyright (c) 2018-2019 Sandro Keil
 * @license   http://github.com/sandrokeil/arangodb-php-client/blob/master/LICENSE.md New BSD License
 */

declare(strict_types=1);

namespace ArangoDb;

use ArangoDb\Http\JsonStream;
use ArangoDb\Util\Json;
use Psr\Http\Message\ResponseInterface;

final class HttpHelper
{
    /**
     * Separator between header and body
     */
    private const BODY_SEPARATOR = "\r\n\r\n";

    /**
     * Splits the message in HTTP status code, headers and body.
     *
     * @param string $message
     * @return array Values are HTTP status code, PSR-7 headers and body
     */
    public static function parseMessage(string $message): array
    {
        $startLine = null;
        $headers = [];
        [$headerLines, $body] = explode(self::BODY_SEPARATOR, $message, 2);
        $headerLines = explode("\n", $headerLines);

        foreach ($headerLines as $header) {
            // Parse message headers
            if ($startLine === null) {
                $startLine = explode(' ', $header, 3);
                continue;
            }
            $parts = explode(':', $header, 2);
            $key = trim($parts[0]);
            $value = isset($parts[1]) ? trim($parts[1]) : '';

            if (! isset($headers[$key])) {
                $headers[$key] = [];
            }
            $headers[$key][] = $value;
        }

        return [
            (int) ($startLine[1] ?? 0),
            $headers,
            $body,
        ];
    }

    /**
     * @param ResponseInterface $response
     * @param string|null $key
     * @return string|bool|int|float|array|null
     */
    public static function responseContentAsJson(ResponseInterface $response, string $key = null)
    {
        $body = $response->getBody();

        if ($body instanceof JsonStream) {
            if ($key === null) {
                return $body->toJson();
            }
            $value = $body->toArray()[$key] ?? null;

            if (null === $value
                || is_bool($value)
                || is_int($value)
            ) {
                return $value;
            }
            return Json::encode($value);
        }
        if ($key === null) {
            return $body->getContents();
        }
        $value = Json::decode($body->getContents())[$key] ?? null;

        if ($value !== null && ! \is_scalar($value)) {
            $value = Json::encode($value);
        }

        return $value;
    }

    /**
     * @param ResponseInterface $response
     * @param string|null $key
     * @return string|bool|int|float|array|null
     */
    public static function responseContentAsArray(ResponseInterface $response, string $key = null)
    {
        $body = $response->getBody();

        if ($body instanceof JsonStream) {
            if ($key === null) {
                return $body->toArray();
            }
            return $body->toArray()[$key] ?? null;
        }
        if ($key === null) {
            return Json::decode($body->getContents());
        }

        return Json::decode($body->getContents())[$key] ?? null;
    }
}