Completed
Push — master ( 773920...14fe81 )
by Guillem
02:29
created

SwaggerSchemaFactory::createRequestDefinitions()   F

Complexity

Conditions 15
Paths 576

Size

Total Lines 82
Code Lines 50

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 51
CRAP Score 15

Importance

Changes 0
Metric Value
eloc 50
dl 0
loc 82
ccs 51
cts 51
cp 1
rs 2.3388
c 0
b 0
f 0
cc 15
nc 576
nop 1
crap 15

How to fix   Long Method    Complexity   

Long Method

Small methods make your code easier to understand, in particular if combined with a good name. Besides, if your method is small, finding a good name is usually much easier.

For example, if you find yourself adding comments to a method's body, this is usually a good sign to extract the commented part to a new method, and use the comment as a starting point when coming up with a good name for this new method.

Commonly applied refactorings include:

1
<?php
2
namespace ElevenLabs\Api\Factory;
3
4
use ElevenLabs\Api\Definition\RequestDefinition;
5
use ElevenLabs\Api\Definition\Parameter;
6
use ElevenLabs\Api\Definition\Parameters;
7
use ElevenLabs\Api\Definition\RequestDefinitions;
8
use ElevenLabs\Api\Definition\ResponseDefinition;
9
use ElevenLabs\Api\Schema;
10
use ElevenLabs\Api\JsonSchema\Uri\YamlUriRetriever;
11
use JsonSchema\RefResolver;
12
use JsonSchema\Uri\UriResolver;
13
use JsonSchema\Uri\UriRetriever;
14
use Symfony\Component\Yaml\Yaml;
15
16
/**
17
 * Create a schema definition from a Swagger file
18
 */
19
class SwaggerSchemaFactory implements SchemaFactory
20
{
21
    /**
22
     * @param string $schemaFile (must start with a scheme: file://, http:// or https://)
23
     *
24
     * @return Schema
25
     */
26 17
    public function createSchema($schemaFile)
27
    {
28 17
        $schema = $this->resolveSchemaFile($schemaFile);
29
30 16
        $host = isset($schema->host) ? $schema->host : null;
31 16
        $basePath = isset($schema->basePath) ? $schema->basePath : '';
32 16
        $schemes = isset($schema->schemes) ? $schema->schemes : ['http'];
33
34 16
        return new Schema(
35 16
            $this->createRequestDefinitions($schema),
36 13
            $basePath,
37 13
            $host,
38 13
            $schemes
39
        );
40
    }
41
42
    /**
43
     *
44
     * @param string $schemaFile
45
     *
46
     * @return object
47
     */
48 17
    protected function resolveSchemaFile($schemaFile)
49
    {
50 17
        $extension = pathinfo($schemaFile, PATHINFO_EXTENSION);
51 17
        switch ($extension) {
52 17
            case 'yml':
53 17
            case 'yaml':
54 1
                if (!class_exists(Yaml::class)) {
55
                    // @codeCoverageIgnoreStart
56
                    throw new \InvalidArgumentException(
57
                        'You need to require the "symfony/yaml" component in order to parse yml files'
58
                    );
59
                    // @codeCoverageIgnoreEnd
60
                }
61
62 1
                $uriRetriever = new YamlUriRetriever();
63 1
                break;
64 16
            case 'json':
65 15
                $uriRetriever = new UriRetriever();
66 15
                break;
67
            default:
68 1
                throw new \InvalidArgumentException(
69 1
                    sprintf(
70 1
                        'file "%s" does not provide a supported extension choose either json, yml or yaml',
71 1
                        $schemaFile
72
                    )
73
                );
74
        }
75
76 16
        $refResolver = new RefResolver(
77 16
            $uriRetriever,
78 16
            new UriResolver()
79
        );
80
81 16
        return $refResolver->resolve($schemaFile);
82
    }
83
84
    /**
85
     * @param \stdClass $schema
86
     * @return RequestDefinitions
87
     */
88 16
    protected function createRequestDefinitions(\stdClass $schema)
89
    {
90 16
        $definitions = [];
91 16
        $defaultConsumedContentTypes = [];
92 16
        $defaultProducedContentTypes = [];
93
94 16
        if (isset($schema->consumes)) {
95 1
            $defaultConsumedContentTypes = $schema->consumes;
96
        }
97 16
        if (isset($schema->produces)) {
98 1
            $defaultProducedContentTypes = $schema->produces;
99
        }
100
101 16
        $basePath = isset($schema->basePath) ? $schema->basePath : '';
102
103 16
        foreach ($schema->paths as $pathTemplate => $methods) {
104 16
            foreach ($methods as $method => $definition) {
105 16
                $method = strtoupper($method);
106 16
                $contentTypes = $defaultConsumedContentTypes;
107 16
                if (isset($definition->consumes)) {
108 9
                    $contentTypes = $definition->consumes;
109
                }
110
111 16
                if (!isset($definition->operationId)) {
112 1
                    throw new \LogicException(
113 1
                        sprintf(
114 1
                            'You need to provide an operationId for %s %s',
115 1
                            $method,
116 1
                            $pathTemplate
117
                        )
118
                    );
119
                }
120
121 15
                if (empty($contentTypes) && $this->containsBodyParametersLocations($definition)) {
122 12
                    $contentTypes = $this->guessSupportedContentTypes($definition, $pathTemplate);
123
                }
124
125 14
                if (!isset($definition->responses)) {
126 1
                    throw new \LogicException(
127 1
                        sprintf(
128 1
                            'You need to specify at least one response for %s %s',
129 1
                            $method,
130 1
                            $pathTemplate
131
                        )
132
                    );
133
                }
134
135 13
                if (!isset($definition->parameters)) {
136 2
                    $definition->parameters = [];
137
                }
138
139 13
                $requestParameters = [];
140 13
                foreach ($definition->parameters as $parameter) {
141 11
                    $requestParameters[] = $this->createParameter($parameter);
142
                }
143
144 13
                $responseContentTypes = $defaultProducedContentTypes;
145 13
                if (isset($definition->produces)) {
146 11
                    $responseContentTypes = $definition->produces;
147
                }
148
149 13
                $responseDefinitions = [];
150 13
                foreach ($definition->responses as $statusCode => $response) {
151 13
                    $responseDefinitions[] = $this->createResponseDefinition(
152 13
                        $statusCode,
153 13
                        $responseContentTypes,
154 13
                        $response
155
                    );
156
                }
157
158 13
                $definitions[] = new RequestDefinition(
159 13
                    $method,
160 13
                    $definition->operationId,
161 13
                    $basePath.$pathTemplate,
162 13
                    new Parameters($requestParameters),
163 13
                    $contentTypes,
164 13
                    $responseDefinitions
165
                );
166
            }
167
        }
168
169 13
        return new RequestDefinitions($definitions);
170
    }
171
172
    /**
173
     * @return bool
174
     */
175 14
    private function containsBodyParametersLocations(\stdClass $definition)
176
    {
177 14
        if (!isset($definition->parameters)) {
178 2
            return false;
179
        }
180
181 12
        foreach ($definition->parameters as $parameter) {
182 12
            if (isset($parameter->in) && \in_array($parameter->in, Parameter::BODY_LOCATIONS, true)) {
183 12
                return true;
184
            }
185
        }
186
187 9
        return false;
188
    }
189
190
    /**
191
     * @param \stdClass $definition
192
     * @param string $pathTemplate
193
     *
194
     * @return array
195
     */
196 12
    private function guessSupportedContentTypes(\stdClass $definition, $pathTemplate)
197
    {
198 12
        if (!isset($definition->parameters)) {
199
            return [];
200
        }
201
202 12
        $bodyLocations = [];
203 12
        foreach ($definition->parameters as $parameter) {
204 12
            if (isset($parameter->in) && \in_array($parameter->in, Parameter::BODY_LOCATIONS, true)) {
205 12
                $bodyLocations[] = $parameter->in;
206
            }
207
        }
208
209 12
        if (count($bodyLocations) > 1) {
210 1
            throw new \LogicException(
211 1
                sprintf(
212 1
                    'Parameters cannot have %s locations at the same time in %s',
213 1
                    implode(' and ', $bodyLocations),
214 1
                    $pathTemplate
215
                )
216
            );
217
        }
218
219 11
        if (count($bodyLocations) === 1) {
220 11
            return [Parameter::BODY_LOCATIONS_TYPES[current($bodyLocations)]];
221
        }
222
223
        return [];
224
    }
225
226 13
    protected function createResponseDefinition($statusCode, array $defaultProducedContentTypes, \stdClass $response)
227
    {
228 13
        $allowedContentTypes = $defaultProducedContentTypes;
229 13
        $parameters = [];
230 13
        if (isset($response->schema)) {
231 9
            $parameters[] = $this->createParameter((object) [
232 9
                'in' => 'body',
233 9
                'name' => 'body',
234
                'required' => true,
235 9
                'schema' => $response->schema
236
            ]);
237
        }
238
239 13
        if (isset($response->headers)) {
240 9
            foreach ($response->headers as $headerName => $schema) {
241 9
                $schema->in = 'header';
242 9
                $schema->name = $headerName;
243 9
                $schema->required = true;
244 9
                $parameters[] = $this->createParameter($schema);
245
            }
246
        }
247
248 13
        return new ResponseDefinition($statusCode, $allowedContentTypes, new Parameters($parameters));
249
    }
250
251
    /**
252
     * Create a Parameter from a swagger parameter
253
     *
254
     * @param \stdClass $parameter
255
     *
256
     * @return Parameter
257
     */
258 11
    protected function createParameter(\stdClass $parameter)
259
    {
260 11
        $parameter = get_object_vars($parameter);
261 11
        $location = $parameter['in'];
262 11
        $name = $parameter['name'];
263 11
        $schema = isset($parameter['schema']) ? $parameter['schema'] : new \stdClass();
264 11
        $required = isset($parameter['required']) ? $parameter['required'] : false;
265
266 11
        unset($parameter['in']);
267 11
        unset($parameter['name']);
268 11
        unset($parameter['required']);
269 11
        unset($parameter['schema']);
270
271
        // Every remaining parameter may be json schema properties
272 11
        foreach ($parameter as $key => $value) {
273 11
            $schema->{$key} = $value;
274
        }
275
276
        // It's not relevant to validate file type
277 11
        if (isset($schema->format) && $schema->format === 'file') {
278
            $schema = null;
279
        }
280
281 11
        return new Parameter($location, $name, $required, $schema);
282
    }
283
}
284