ChangeSetParser::handleData() - Code Metrics - Inspection of "WIP: Batch processor improvments" - Algo-Web/POData - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#255)

by Christopher

created 2020-05-08 12:28 UTC

ChangeSetParser::handleData() B

↳ Parent: ChangeSetParser

Complexity

Conditions	9
Paths	26

Size

Total Lines	46
Code Lines	35

Duplication

Lines	0
Ratio	0 %

Importance

Changes	4
Bugs	1	Features	0

Metric	Value
cc	9
eloc	35
c	4
b	1
f	0
nc	26
nop	0
dl	0
loc	46
rs	8.0555

<?php

declare(strict_types=1);

namespace POData\BatchProcessor;

use Exception;
use Illuminate\Support\Str;
use POData\BaseService;
use POData\Common\ODataException;
use POData\Common\UrlFormatException;
use POData\OperationContext\HTTPRequestMethod;
use POData\OperationContext\ServiceHost;
use POData\OperationContext\Web\IncomingRequest;
use POData\OperationContext\Web\WebOperationContext;

/**
 * Class ChangeSetParser.
 * @package POData\BatchProcessor
 */
class ChangeSetParser implements IBatchParser
{
    protected $data;
    protected $changeSetBoundary;
    /**
     * @var WebOperationContext[]
     */
    protected $rawRequests = [];
    protected $service;
    protected $contentIDToLocationLookup = [];

    /**
     * ChangeSetParser constructor.
     * @param BaseService $service
     * @param $body
     */
    public function __construct(BaseService $service, $body)
    {
        $this->service = $service;
        $this->data               = trim(str_replace("\r", '', $body)); // removes windows specific character
    }

    /**
     * @return mixed
     */
    public function getBoundary()
    {
        return $this->changeSetBoundary;
    }

    /**
     * @throws ODataException
     * @throws UrlFormatException
     * @throws Exception
     */
    public function process()
    {
        $raw = $this->getRawRequests();
        foreach ($raw as $contentID => &$workingObject) {
            foreach ($this->contentIDToLocationLookup as $lookupID => $location) {
                if (0 > $lookupID) {
                    continue;
                }
                $workingObject->incomingRequest()->applyContentID($lookupID, $location);
            }

            $this->processSubRequest($workingObject);
            if (HTTPRequestMethod::GET() != $workingObject->incomingRequest()->getMethod() &&
                !Str::contains($workingObject->incomingRequest()->getRawUrl(), '/$links/')) {
                if (null === $workingObject->outgoingResponse()->getHeaders()['Location']) {
                    $msg = 'Location header not set in subrequest response for ' . $workingObject->RequestVerb
                        . ' request url ' . $workingObject->RequestURL;
                    throw new \Exception($msg);
                }
                $this->contentIDToLocationLookup[$contentID] = $workingObject->outgoingResponse()->getHeaders()['Location'];
            }
        }
    }

    /**
     * @return array
     */
    public function getRawRequests()
    {
        return $this->rawRequests;
    }

    /**
     * @param $newContext
     * @throws ODataException
     * @throws UrlFormatException
     */
    protected function processSubRequest(&$newContext)
    {
        $newHost    = new ServiceHost($newContext);
        $oldHost = $this->getService()->getHost();
        $this->getService()->setHost($newHost);
        $this->getService()->handleRequest();
        $this->getService()->setHost($oldHost);
    }

    /**
     * @return BaseService
     */
    public function getService()
    {
        return $this->service;
    }

    /**
     * @return string
     */
    public function getResponse()
    {
        $ODataEOL = $this->getService()->getConfiguration()->getLineEndings();

        $response = '';
        $splitter = false === $this->changeSetBoundary ?
            '' :
            '--' . $this->changeSetBoundary . $ODataEOL;
        $raw = $this->getRawRequests();
        foreach ($raw as $contentID => &$workingObject) {
            $headers = $workingObject->outgoingResponse()->getHeaders();
            $response .= $splitter;

            $response .= 'Content-Type: application/http' . $ODataEOL;
            $response .= 'Content-Transfer-Encoding: binary' . $ODataEOL;
            $response .= $ODataEOL;
            $response .= 'HTTP/1.1 ' . $headers['Status'] . $ODataEOL;
            $response .= 'Content-ID: ' . $contentID . $ODataEOL;

            foreach ($headers as $headerName => $headerValue) {
                if (null !== $headerValue) {
                    $response .= $headerName . ': ' . $headerValue . $ODataEOL;
                }
            }
            $response .= $ODataEOL;
            $response .= $workingObject->outgoingResponse()->getStream();
        }
        $response .= trim($splitter);
        $response .= false === $this->changeSetBoundary ?
            $ODataEOL :
            '--' . $ODataEOL;
        $response = 'Content-Length: ' .
            strlen($response) .
            $ODataEOL .
            $ODataEOL .
            $response;
        $response = false === $this->changeSetBoundary ?
            $response :
            'Content-Type: multipart/mixed; boundary=' .
            $this->changeSetBoundary .
            $ODataEOL .
            $response;
        return $response;
    }

    public function handleData()
    {
        list($headerBlock, $contentBlock) = explode("\n\n", $this->getData(), 2);
        $headers = self::parse_headers ($headerBlock);
        $this->changeSetBoundary = $headers['Content-Type']['boundary'];
        $prefix  = 'HTTP_';
        $matches = array_filter(explode('--' . $this->changeSetBoundary, $contentBlock));
        $contentIDinit = -1;
        foreach ($matches as $match) {
            if ('--' === trim($match)) {
                continue;
            }

            list($RequestParams, $requestHeaders, $RequestBody) = explode("\n\n", $match);
            $RequestBody = trim($RequestBody);
            $requestHeadersArray = self::parse_headers($requestHeaders);
            list($RequesetType, $RequestPath, $RequestProticol) = explode(" ", $requestHeadersArray['default'], 3);
            $contentID = array_key_exists('Content-ID', $requestHeadersArray) ? $requestHeadersArray['Content-ID'] : $contentIDinit;
            $inboundRequestHeaders = [];
            $skip = true;
            foreach(explode("\n", $requestHeaders) as $headerLine){
                if($skip){
                    $skip = false;
                    continue;
                }
                list($key, $value) = explode(':', $headerLine);
                $name = strtr(strtoupper(trim($key)), '-', '_');
                $value = trim($value);
                $name = substr($name, 0, strlen($prefix)) === $prefix || $name == 'CONTENT_TYPE' ? $name : $prefix . $name;
                $inboundRequestHeaders[$name] = $value;
            }
            $this->rawRequests[$contentID] = new WebOperationContext(
                new IncomingRequest(
                    new HTTPRequestMethod($RequesetType),
                    [],
                    [],
                    $inboundRequestHeaders,
                    null,
                    $RequestBody,
                    $RequestPath
                )
            );
            if ($contentIDinit == $contentID) {
                $contentIDinit--;
            }
            continue;
        }
    }

    /**
     * @return string
     */
    public function getData()
    {
        return $this->data;
    }


    private static function parse_headers($headers, $splitter = "\n", $assignmentChar = ':')
    {
        $results = [];
        foreach (array_filter(explode($splitter, trim($headers))) as $line) {

            list ($key, $value) = strpos($line,$assignmentChar) !== false ? explode($assignmentChar, $line, 2) : ['default', $line];
            $key = trim($key);
            $value = trim($value);
            if(strpos($value, ';') !== false){
                $value = self::parse_headers($value,';','=');
            }
            if (isset($results[$key])) {
                if (is_array($results[$key])) {
                    $results[$key][] = $value;
                }else {
                    $results[$key] = [$results[$key], $value];
                }
            } else {
                $results[$key] = $value;
            }
        }
        return $results;
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace POData\BatchProcessor;
6
7			use Exception;
8			use Illuminate\Support\Str;
9			use POData\BaseService;
10			use POData\Common\ODataException;
11			use POData\Common\UrlFormatException;
12			use POData\OperationContext\HTTPRequestMethod;
13			use POData\OperationContext\ServiceHost;
14			use POData\OperationContext\Web\IncomingRequest;
15			use POData\OperationContext\Web\WebOperationContext;
16
17			/**
18			* Class ChangeSetParser.
19			* @package POData\BatchProcessor
20			*/
21			class ChangeSetParser implements IBatchParser
22			{
23			protected $data;
24			protected $changeSetBoundary;
25			/**
26			* @var WebOperationContext[]
27			*/
28			protected $rawRequests = [];
29			protected $service;
30			protected $contentIDToLocationLookup = [];
31
32			/**
33			* ChangeSetParser constructor.
34			* @param BaseService $service
35			* @param $body
36			*/
37			public function __construct(BaseService $service, $body)
38			{
39			$this->service = $service;
40			$this->data = trim(str_replace("\r", '', $body)); // removes windows specific character
41			}
42
43			/**
44			* @return mixed
45			*/
46			public function getBoundary()
47			{
48			return $this->changeSetBoundary;
49			}
50
51			/**
52			* @throws ODataException
53			* @throws UrlFormatException
54			* @throws Exception
55			*/
56			public function process()
57			{
58			$raw = $this->getRawRequests();
59			foreach ($raw as $contentID => &$workingObject) {
60			foreach ($this->contentIDToLocationLookup as $lookupID => $location) {
61			if (0 > $lookupID) {
62			continue;
63			}
64			$workingObject->incomingRequest()->applyContentID($lookupID, $location);
65			}
66
67			$this->processSubRequest($workingObject);
68			if (HTTPRequestMethod::GET() != $workingObject->incomingRequest()->getMethod() &&
69			!Str::contains($workingObject->incomingRequest()->getRawUrl(), '/$links/')) {
70			if (null === $workingObject->outgoingResponse()->getHeaders()['Location']) {
71			$msg = 'Location header not set in subrequest response for ' . $workingObject->RequestVerb
72			. ' request url ' . $workingObject->RequestURL;
73			throw new \Exception($msg);
74			}
75			$this->contentIDToLocationLookup[$contentID] = $workingObject->outgoingResponse()->getHeaders()['Location'];
76			}
77			}
78			}
79
80			/**
81			* @return array
82			*/
83			public function getRawRequests()
84			{
85			return $this->rawRequests;
86			}
87
88			/**
89			* @param $newContext
90			* @throws ODataException
91			* @throws UrlFormatException
92			*/
93			protected function processSubRequest(&$newContext)
94			{
95			$newHost = new ServiceHost($newContext);
96			$oldHost = $this->getService()->getHost();
97			$this->getService()->setHost($newHost);
98			$this->getService()->handleRequest();
99			$this->getService()->setHost($oldHost);
100			}
101
102			/**
103			* @return BaseService
104			*/
105			public function getService()
106			{
107			return $this->service;
108			}
109
110			/**
111			* @return string
112			*/
113			public function getResponse()
114			{
115			$ODataEOL = $this->getService()->getConfiguration()->getLineEndings();
116
117			$response = '';
118			$splitter = false === $this->changeSetBoundary ?
119			'' :
120			'--' . $this->changeSetBoundary . $ODataEOL;
121			$raw = $this->getRawRequests();
122			foreach ($raw as $contentID => &$workingObject) {
123			$headers = $workingObject->outgoingResponse()->getHeaders();
124			$response .= $splitter;
125
126			$response .= 'Content-Type: application/http' . $ODataEOL;
127			$response .= 'Content-Transfer-Encoding: binary' . $ODataEOL;
128			$response .= $ODataEOL;
129			$response .= 'HTTP/1.1 ' . $headers['Status'] . $ODataEOL;
130			$response .= 'Content-ID: ' . $contentID . $ODataEOL;
131
132			foreach ($headers as $headerName => $headerValue) {
133			if (null !== $headerValue) {
134			$response .= $headerName . ': ' . $headerValue . $ODataEOL;
135			}
136			}
137			$response .= $ODataEOL;
138			$response .= $workingObject->outgoingResponse()->getStream();
139			}
140			$response .= trim($splitter);
141			$response .= false === $this->changeSetBoundary ?
142			$ODataEOL :
143			'--' . $ODataEOL;
144			$response = 'Content-Length: ' .
145			strlen($response) .
146			$ODataEOL .
147			$ODataEOL .
148			$response;
149			$response = false === $this->changeSetBoundary ?
150			$response :
151			'Content-Type: multipart/mixed; boundary=' .
152			$this->changeSetBoundary .
153			$ODataEOL .
154			$response;
155			return $response;
156			}
157
158			public function handleData()
159			{
160			list($headerBlock, $contentBlock) = explode("\n\n", $this->getData(), 2);
161			$headers = self::parse_headers ($headerBlock);
162			$this->changeSetBoundary = $headers['Content-Type']['boundary'];
163			$prefix = 'HTTP_';
164			$matches = array_filter(explode('--' . $this->changeSetBoundary, $contentBlock));
165			$contentIDinit = -1;
166			foreach ($matches as $match) {
167			if ('--' === trim($match)) {
168			continue;
169			}
170
171			list($RequestParams, $requestHeaders, $RequestBody) = explode("\n\n", $match);
172			$RequestBody = trim($RequestBody);
173			$requestHeadersArray = self::parse_headers($requestHeaders);
174			list($RequesetType, $RequestPath, $RequestProticol) = explode(" ", $requestHeadersArray['default'], 3);
175			$contentID = array_key_exists('Content-ID', $requestHeadersArray) ? $requestHeadersArray['Content-ID'] : $contentIDinit;
176			$inboundRequestHeaders = [];
177			$skip = true;
178			foreach(explode("\n", $requestHeaders) as $headerLine){
179			if($skip){
180			$skip = false;
181			continue;
182			}
183			list($key, $value) = explode(':', $headerLine);
184			$name = strtr(strtoupper(trim($key)), '-', '_');
185			$value = trim($value);
186			$name = substr($name, 0, strlen($prefix)) === $prefix \|\| $name == 'CONTENT_TYPE' ? $name : $prefix . $name;
187			$inboundRequestHeaders[$name] = $value;
188			}
189			$this->rawRequests[$contentID] = new WebOperationContext(
190			new IncomingRequest(
191			new HTTPRequestMethod($RequesetType),
192			[],
193			[],
194			$inboundRequestHeaders,
195			null,
196			$RequestBody,
197			$RequestPath
198			)
199			);
200			if ($contentIDinit == $contentID) {
201			$contentIDinit--;
202			}
203			continue;
204			}
205			}
206
207			/**
208			* @return string
209			*/
210			public function getData()
211			{
212			return $this->data;
213			}
214
215
216			private static function parse_headers($headers, $splitter = "\n", $assignmentChar = ':')
217			{
218			$results = [];
219			foreach (array_filter(explode($splitter, trim($headers))) as $line) {
220
221			list ($key, $value) = strpos($line,$assignmentChar) !== false ? explode($assignmentChar, $line, 2) : ['default', $line];
222			$key = trim($key);
223			$value = trim($value);
224			if(strpos($value, ';') !== false){
225			$value = self::parse_headers($value,';','=');
226			}
227			if (isset($results[$key])) {
228			if (is_array($results[$key])) {
229			$results[$key][] = $value;
230			}else {
231			$results[$key] = [$results[$key], $value];
232			}
233			} else {
234			$results[$key] = $value;
235			}
236			}
237			return $results;
238			}
239			}
240

Algo-Web / POData

Pull Request — master (#255)

ChangeSetParser::handleData() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like