RequestTranslator::doTranslation() - Code Metrics - Inspection of "fix using wrong exceptions" - Innmind/RestServerBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — develop ( 02617c...96603c )

by Baptiste

created 2017-09-30 11:55 UTC

RequestTranslator::doTranslation() B

↳ Parent: RequestTranslator

Complexity

Conditions	1
Paths	1

Size

Total Lines	24
Code Lines	17

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	17
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	24
ccs	17
cts	17
cp	1
rs	8.9713
c	0
b	0
f	0
cc	1
eloc	17
nc	1
nop	1
crap	1

<?php
declare(strict_types = 1);

namespace Innmind\Rest\ServerBundle\Translator;

use Innmind\Http\{
    Message\ServerRequest as ServerRequestInterface,
    Message\ServerRequest\ServerRequest,
    Message\Method\Method,
    Message\Environment\Environment,
    Message\Environment as EnvironmentInterface,
    Message\Cookies\Cookies,
    Message\Cookies as CookiesInterface,
    Message\Query\Query,
    Message\Query as QueryInterface,
    Message\Query\Parameter as QueryParameterInterface,
    Message\Query\Parameter\Parameter as QueryParameter,
    Message\Form\Form,
    Message\Form as FormInterface,
    Message\Form\Parameter as FormParameterInterface,
    Message\Form\Parameter\Parameter as FormParameter,
    Message\Files\Files,
    Message\Files as FilesInterface,
    File\File,
    File as FileInterface,
    File\Status as StatusInterface,
    File\Status\Ok as OkStatus,
    File\Status\ExceedsFormMaxFileSize as ExceedsFormMaxFileSizeStatus,
    File\Status\ExceedsIniMaxFileSize as ExceedsIniMaxFileSizeStatus,
    File\Status\NoTemporaryDirectory as NoTemporaryDirectoryStatus,
    File\Status\NotUploaded as NotUploadedStatus,
    File\Status\PartiallyUploaded as PartiallyUploadedStatus,
    File\Status\StoppedByExtension as StoppedByExtensionStatus,
    File\Status\WriteFailed as WriteFailedStatus,
    ProtocolVersion\ProtocolVersion,
    Headers\Headers,
    Headers as HeadersInterface,
    Header as HeaderInterface,
    Factory\HeaderFactory as HeaderFactoryInterface
};
use Innmind\Filesystem\MediaType\MediaType;
use Innmind\Stream\Readable\Stream;
use Innmind\Url\Url;
use Innmind\Immutable\{
    Map,
    Str
};
use Symfony\Component\HttpFoundation\{
    Request,
    HeaderBag,
    ParameterBag,
    FileBag,
    ServerBag
};

final class RequestTranslator
{
    private $transformed;
    private $headerFactory;

    public function __construct(HeaderFactoryInterface $headerFactory)
    {
        $this->transformed = new Map(
            Request::class,
            ServerRequestInterface::class
        );
        $this->headerFactory = $headerFactory;
    }

    public function translate(Request $request): ServerRequestInterface
    {
        if ($this->transformed->contains($request)) {
            return $this->transformed->get($request);
        }

        $serverRequest = $this->doTranslation($request);
        $this->transformed = $this->transformed->put(
            $request,
            $serverRequest
        );

        return $serverRequest;
    }

    private function doTranslation(Request $request): ServerRequestInterface
    {
        $protocol = (new Str($request->server->get('SERVER_PROTOCOL')))->capture(
            '~HTTP/(?<major>\d)\.(?<minor>\d)~'
        );

        return new ServerRequest(
            Url::fromString(
                $request->getSchemeAndHttpHost().'/'.ltrim($request->getPathInfo(), '/')
            ),
            new Method($request->getMethod()),
            new ProtocolVersion(
                (int) (string) $protocol['major'],
                (int) (string) $protocol['minor']
            ),
            $this->translateHeaders($request->headers),
            new Stream($request->getContent(true)),
            $this->translateEnvironment($request->server),
            $this->translateCookies($request->cookies),
            $this->translateQuery($request->query),
            $this->translateForm($request->request),
            $this->translateFiles($request->files)
        );
    }

    private function translateHeaders(HeaderBag $headerBag): HeadersInterface
    {
        $map = new Map('string', HeaderInterface::class);

        foreach ($headerBag as $name => $value) {
            $map = $map->put(
                $name,
                $this->headerFactory->make(
                    new Str($name),
                    new Str(implode(', ', $value))
                )
            );
        }

        return new Headers($map);
    }

    private function translateEnvironment(ServerBag $server): EnvironmentInterface
    {
        $map = new Map('string', 'scalar');

        foreach ($server as $key => $value) {
            if (!is_scalar($value)) {
                continue;
            }

            $map = $map->put($key, $value);
        }

        return new Environment($map);
    }

    private function translateCookies(ParameterBag $cookies): CookiesInterface
    {
        $map = new Map('string', 'scalar');

        foreach ($cookies as $key => $value) {
            $map = $map->put($key, $value);
        }

        return new Cookies($map);
    }

    private function translateQuery(ParameterBag $query): QueryInterface
    {
        $map = new Map('string', QueryParameterInterface::class);

        foreach ($query as $key => $value) {
            $map = $map->put(
                $key,
                new QueryParameter($key, $value)
            );
        }

        return new Query($map);
    }

    private function translateForm(ParameterBag $form): FormInterface
    {
        $map = new Map('scalar', FormParameterInterface::class);

        foreach ($form as $key => $value) {
            $map = $map->put(
                $key,
                $this->buildFormParameter($key, $value)
            );
        }

        return new Form($map);
    }

    private function buildFormParameter($name, $value): FormParameterInterface
    {
        if (!is_array($value)) {
            return new FormParameter((string) $name, $value);
        }

        $map = new Map('scalar', FormParameterInterface::class);

        foreach ($value as $key => $sub) {
            $map = $map->put(
                $key,
                $this->buildFormParameter($key, $sub)
            );
        }

        return new FormParameter((string) $name, $map);
    }

    private function translateFiles(FileBag $files): FilesInterface
    {
        $map = new Map('string', FileInterface::class);

        foreach ($files as $name => $file) {
            $map = $map->put(
                $name,
                new File(
                    $file->getClientOriginalName(),
                    new Stream(
                        fopen($file->getPathname(), 'r')
                    ),
                    $this->buildFileStatus($file->getError()),
                    MediaType::fromString((string) $file->getClientMimeType())
                )
            );
        }

        return new Files($map);
    }

    private function buildFileStatus(int $status): StatusInterface
    {
        switch ($status) {
            case UPLOAD_ERR_FORM_SIZE:
                return new ExceedsFormMaxFileSizeStatus;
            case UPLOAD_ERR_INI_SIZE:
                return new ExceedsIniMaxFileSizeStatus;
            case UPLOAD_ERR_NO_TMP_DIR:
                return new NoTemporaryDirectoryStatus;
            case UPLOAD_ERR_NO_FILE:
                return new NotUploadedStatus;
            case UPLOAD_ERR_OK:
                return new OkStatus;
            case UPLOAD_ERR_PARTIAL:
                return new PartiallyUploadedStatus;
            case UPLOAD_ERR_EXTENSION:
                return new StoppedByExtensionStatus;
            case UPLOAD_ERR_CANT_WRITE:
                return new WriteFailedStatus;
        }
    }
}


1		<?php
2		declare(strict_types = 1);
3
4		namespace Innmind\Rest\ServerBundle\Translator;
5
6		use Innmind\Http\{
7		Message\ServerRequest as ServerRequestInterface,
8		Message\ServerRequest\ServerRequest,
9		Message\Method\Method,
10		Message\Environment\Environment,
11		Message\Environment as EnvironmentInterface,
12		Message\Cookies\Cookies,
13		Message\Cookies as CookiesInterface,
14		Message\Query\Query,
15		Message\Query as QueryInterface,
16		Message\Query\Parameter as QueryParameterInterface,
17		Message\Query\Parameter\Parameter as QueryParameter,
18		Message\Form\Form,
19		Message\Form as FormInterface,
20		Message\Form\Parameter as FormParameterInterface,
21		Message\Form\Parameter\Parameter as FormParameter,
22		Message\Files\Files,
23		Message\Files as FilesInterface,
24		File\File,
25		File as FileInterface,
26		File\Status as StatusInterface,
27		File\Status\Ok as OkStatus,
28		File\Status\ExceedsFormMaxFileSize as ExceedsFormMaxFileSizeStatus,
29		File\Status\ExceedsIniMaxFileSize as ExceedsIniMaxFileSizeStatus,
30		File\Status\NoTemporaryDirectory as NoTemporaryDirectoryStatus,
31		File\Status\NotUploaded as NotUploadedStatus,
32		File\Status\PartiallyUploaded as PartiallyUploadedStatus,
33		File\Status\StoppedByExtension as StoppedByExtensionStatus,
34		File\Status\WriteFailed as WriteFailedStatus,
35		ProtocolVersion\ProtocolVersion,
36		Headers\Headers,
37		Headers as HeadersInterface,
38		Header as HeaderInterface,
39		Factory\HeaderFactory as HeaderFactoryInterface
40		};
41		use Innmind\Filesystem\MediaType\MediaType;
42		use Innmind\Stream\Readable\Stream;
43		use Innmind\Url\Url;
44		use Innmind\Immutable\{
45		Map,
46		Str
47		};
48		use Symfony\Component\HttpFoundation\{
49		Request,
50		HeaderBag,
51		ParameterBag,
52		FileBag,
53		ServerBag
54		};
55
56		final class RequestTranslator
57		{
58		private $transformed;
59		private $headerFactory;
60
61	3	public function __construct(HeaderFactoryInterface $headerFactory)
62		{
63	3	$this->transformed = new Map(
64	3	Request::class,
65	3	ServerRequestInterface::class
66		);
67	3	$this->headerFactory = $headerFactory;
68	3	}
69
70	2	public function translate(Request $request): ServerRequestInterface
71		{
72	2	if ($this->transformed->contains($request)) {
73		return $this->transformed->get($request);
74		}
75
76	2	$serverRequest = $this->doTranslation($request);
77	2	$this->transformed = $this->transformed->put(
78	2	$request,
79	2	$serverRequest
80		);
81
82	2	return $serverRequest;
83		}
84
85	2	private function doTranslation(Request $request): ServerRequestInterface
86		{
87	2	$protocol = (new Str($request->server->get('SERVER_PROTOCOL')))->capture(
88	2	'~HTTP/(?<major>\d)\.(?<minor>\d)~'
89		);
90
91	2	return new ServerRequest(
92	2	Url::fromString(
93	2	$request->getSchemeAndHttpHost().'/'.ltrim($request->getPathInfo(), '/')
94		),
95	2	new Method($request->getMethod()),
96	2	new ProtocolVersion(
97	2	(int) (string) $protocol['major'],
98	2	(int) (string) $protocol['minor']
99		),
100	2	$this->translateHeaders($request->headers),
101	2	new Stream($request->getContent(true)),
102	2	$this->translateEnvironment($request->server),
103	2	$this->translateCookies($request->cookies),
104	2	$this->translateQuery($request->query),
105	2	$this->translateForm($request->request),
106	2	$this->translateFiles($request->files)
107		);
108		}
109
110	2	private function translateHeaders(HeaderBag $headerBag): HeadersInterface
111		{
112	2	$map = new Map('string', HeaderInterface::class);
113
114	2	foreach ($headerBag as $name => $value) {
115	1	$map = $map->put(
116	1	$name,
117	1	$this->headerFactory->make(
118	1	new Str($name),
119	1	new Str(implode(', ', $value))
120		)
121		);
122		}
123
124	2	return new Headers($map);
125		}
126
127	2	private function translateEnvironment(ServerBag $server): EnvironmentInterface
128		{
129	2	$map = new Map('string', 'scalar');
130
131	2	foreach ($server as $key => $value) {
132	2	if (!is_scalar($value)) {
133		continue;
134		}
135
136	2	$map = $map->put($key, $value);
137		}
138
139	2	return new Environment($map);
140		}
141
142	2	private function translateCookies(ParameterBag $cookies): CookiesInterface
143		{
144	2	$map = new Map('string', 'scalar');
145
146	2	foreach ($cookies as $key => $value) {
147	1	$map = $map->put($key, $value);
148		}
149
150	2	return new Cookies($map);
151		}
152
153	2	private function translateQuery(ParameterBag $query): QueryInterface
154		{
155	2	$map = new Map('string', QueryParameterInterface::class);
156
157	2	foreach ($query as $key => $value) {
158	1	$map = $map->put(
159	1	$key,
160	1	new QueryParameter($key, $value)
161		);
162		}
163
164	2	return new Query($map);
165		}
166
167	2	private function translateForm(ParameterBag $form): FormInterface
168		{
169	2	$map = new Map('scalar', FormParameterInterface::class);
170
171	2	foreach ($form as $key => $value) {
172	1	$map = $map->put(
173	1	$key,
174	1	$this->buildFormParameter($key, $value)
175		);
176		}
177
178	2	return new Form($map);
179		}
180
181	1	private function buildFormParameter($name, $value): FormParameterInterface
182		{
183	1	if (!is_array($value)) {
184	1	return new FormParameter((string) $name, $value);
185		}
186
187		$map = new Map('scalar', FormParameterInterface::class);
188
189		foreach ($value as $key => $sub) {
190		$map = $map->put(
191		$key,
192		$this->buildFormParameter($key, $sub)
193		);
194		}
195
196		return new FormParameter((string) $name, $map);
197		}
198
199	2	private function translateFiles(FileBag $files): FilesInterface
200		{
201	2	$map = new Map('string', FileInterface::class);
202
203	2	foreach ($files as $name => $file) {
204	1	$map = $map->put(
205	1	$name,
206	1	new File(
207	1	$file->getClientOriginalName(),
208	1	new Stream(
209	1	fopen($file->getPathname(), 'r')
210		),
211	1	$this->buildFileStatus($file->getError()),
212	1	MediaType::fromString((string) $file->getClientMimeType())
213		)
214		);
215		}
216
217	2	return new Files($map);
218		}
219
220	1	private function buildFileStatus(int $status): StatusInterface
221		{
222		switch ($status) {
223	1	case UPLOAD_ERR_FORM_SIZE:
224		return new ExceedsFormMaxFileSizeStatus;
225	1	case UPLOAD_ERR_INI_SIZE:
226		return new ExceedsIniMaxFileSizeStatus;
227	1	case UPLOAD_ERR_NO_TMP_DIR:
228		return new NoTemporaryDirectoryStatus;
229	1	case UPLOAD_ERR_NO_FILE:
230		return new NotUploadedStatus;
231	1	case UPLOAD_ERR_OK:
232	1	return new OkStatus;
233		case UPLOAD_ERR_PARTIAL:
234		return new PartiallyUploadedStatus;
235		case UPLOAD_ERR_EXTENSION:
236		return new StoppedByExtensionStatus;
237		case UPLOAD_ERR_CANT_WRITE:
238		return new WriteFailedStatus;
239		}
240		}
241		}
242

Innmind / RestServerBundle

Push — develop ( 02617c...96603c )

RequestTranslator::doTranslation() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like