OpenStack\Common\Transport\RequestSerializer

Complexity

Total Complexity

20

Size/Duplication

Total Lines	63
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes	6
Bugs	1	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	2
B	serializeOptions()	0	18	5
B	stockOptions()	0	18	6
B	parseHeader()	0	15	7

<?php

namespace OpenStack\Common\Transport;

use function GuzzleHttp\uri_template;
use function GuzzleHttp\Psr7\build_query;
use function GuzzleHttp\Psr7\modify_request;

use OpenStack\Common\Api\Operation;
use OpenStack\Common\Api\Parameter;

class RequestSerializer
{
    private $jsonSerializer;

    public function __construct(JsonSerializer $jsonSerializer = null)
    {
        $this->jsonSerializer = $jsonSerializer ?: new JsonSerializer();
    }

    public function serializeOptions(Operation $operation, array $userValues = [])
    {
        $options = ['headers' => []];

        foreach ($userValues as $paramName => $paramValue) {
            if (null === ($schema = $operation->getParam($paramName))) {
                continue;
            }

            $this->stockOptions($schema, $paramName, $paramValue, $options);
        }

        if (!empty($options['json']) && ($key = $operation->getJsonKey())) {
            $options['json'] = [$key => $options['json']];
        }

        return $options;
    }

    private function stockOptions(Parameter $schema, $paramName, $paramValue, array &$options)
    {
        switch ($schema->getLocation()) {
            case 'query':
                $options['query'][$schema->getName()] = $paramValue;
                break;
            case 'header':
                $options['headers'] += $this->parseHeader($schema, $paramName, $paramValue);
                break;
            case 'json':
                $json = isset($options['json']) ? $options['json'] : [];
                $options['json'] = $this->jsonSerializer->stockJson($schema, $paramValue, $json);
                break;
            case 'raw':
                $options['body'] = $paramValue;
                break;
        }
    }

    private function parseHeader(Parameter $param, $name, $value)
    {
        if ($name == 'metadata' || $name == 'removeMetadata') {
            $headers = [];
            foreach ($value as $key => $keyVal) {
                $schema = $param->getItemSchema() ?: new Parameter(['prefix' => $param->getPrefix(), 'name' => $key]);
                $headers += $this->parseHeader($schema, $key, $keyVal);
            }
            return $headers;
        }

        return is_string($value) || is_numeric($value)
            ? [$param->getPrefix() . $param->getName() => $value]
            : [];
    }
}