FileRangeProccessor::sendMultipleRangePart() - Code Metrics - Inspection of "调整：发送文件" - dxkite/suda - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — dev ( 8d29ef...4c25c4 )

by 世昌

created 2019-07-10 14:53 UTC

FileRangeProccessor::sendMultipleRangePart() A

↳ Parent: FileRangeProccessor

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	1
eloc	2
c	1
b	0
f	0
nc	1
nop	2
dl	0
loc	4
rs	10

<?php

namespace suda\application\processor;

use Exception;
use function explode;
use function is_array;
use function md5;
use function rtrim;
use SplFileObject;
use function strpos;
use function substr;
use suda\framework\Request;
use suda\framework\Response;
use suda\application\Application;
use suda\framework\response\MimeType;
use suda\framework\http\stream\DataStream;
use function uniqid;

/**
 * 响应
 */
class FileRangeProccessor implements RequestProcessor
{
    /**
     * 文件路径
     *
     * @var SplFileObject
     */
    protected $file;

    /**
     * MIME
     *
     * @var string
     */
    protected $mime;

    public function __construct($file)
    {
        $this->file = $file instanceof SplFileObject ? $file : new SplFileObject($file);
        $this->mime = MimeType::getMimeType($this->file->getExtension());
    }

    /**
     * 处理文件请求
     *
     * @param Application $application
     * @param Request $request
     * @param Response $response
     * @return void
     * @throws Exception
     */
    public function onRequest(Application $application, Request $request, Response $response)
    {
        $ranges = $this->getRanges($request);
        $response->setHeader('accept-ranges', 'bytes');
        if ($request->getMethod() !== 'GET' || $ranges === false) {
            $response->status(400);
        } elseif (is_array($ranges)) {

            $this->sendFileRanges($response, $ranges);
        } else {
            $response->setHeader('content-type', $this->mime);
            $response->sendFile($this->file->getRealPath());
        }
    }

    protected function sendFileRanges(Response $response, array $ranges)
    {
        if (count($ranges) === 1) {
            $response->status(206);
            $range = $ranges[0];
            $response->setHeader('content-type', $this->mime);
            $response->setHeader('content-range', $this->getRangeHeader($range));
            $this->sendFileByRange($response, $range);
        } else {
            $response->status(206);
            $this->sendMultipleFileByRange($response, $ranges);
        }
    }

    /**
     * 发送多Range
     *
     * @param Response $response
     * @param array $ranges
     * @return void
     */
    protected function sendMultipleFileByRange(Response $response, array $ranges)
    {
        $separates = 'multiple_range_' . base64_encode(md5(uniqid(), true));
        $response->setHeader('content-type', 'multipart/byteranges; boundary=' . $separates);
        foreach ($ranges as $range) {
            $response->write('--' . $separates . "\r\n");
            $this->sendMultipleRangePart($response, $range);
            $this->sendFileByRange($response, $range);
            $response->write("\r\n");
        }
    }


    /**
     * 发送范围数据
     *
     * @param Response $response
     * @param array $range
     * @return void
     */
    protected function sendFileByRange(Response $response, array $range)
    {
        // [start,end] = $end - $start + 1
        $response->write(new DataStream($this->file, $range['start'], $range['end'] - $range['start'] + 1));
    }

    /**
     * 获取Range描述
     *
     * @param Request $request
     * @return array|bool|null
     */
    protected function getRanges(Request $request)
    {
        $ranges = $this->parseRangeHeader($request);
        if (is_array($ranges)) {
            return $this->parseRanges($ranges);
        } elseif ($ranges === false) {
            return false;
        }
        return null;
    }

    /**
     * 写Range头
     *
     * @param Response $response
     * @param array $range
     * @return void
     */
    protected function sendMultipleRangePart(Response $response, array $range)
    {
        $response->write('Content-Type: ' . $this->mime . "\r\n");
        $response->write('Content-Range: ' . $this->getRangeHeader($range) . "\r\n\r\n");
    }

    /**
     * 生成Range头
     *
     * @param array $range
     * @return string
     */
    protected function getRangeHeader(array $range): string
    {
        return sprintf('bytes %d-%d/%d', $range['start'], $range['end'], $this->file->getSize());
    }

    /**
     * 获取Range描述
     *
     * @param Request $request
     * @return array|bool|null
     */
    protected function parseRangeHeader(Request $request)
    {
        $range = $request->getHeader('range', null);
        if (is_string($range)) {
            $range = trim($range);
            if (strpos($range, 'bytes=') !== 0) {
                return false;
            }
            $rangesFrom = substr($range, strlen('bytes='));
            return explode(',', $rangesFrom);
        }
        return null;
    }

    /**
     * 处理范围
     *
     * @param array $ranges
     * @return array|bool
     */
    protected function parseRanges(array $ranges)
    {
        $range = [];
        foreach ($ranges as $value) {
            if (($r = $this->parseRange($value)) !== null) {
                $range[] = $r;
            } else {
                return false;
            }
        }
        return $range;
    }

    /**
     * 处理Range
     *
     * @param string $range
     * @return array
     */
    protected function parseRange(string $range): ?array
    {
        $range = trim($range);
        if (strrpos($range, '-') === strlen($range) - 1) {
            return [
                'start' => intval(rtrim($range, '-')),
                'end' => $this->file->getSize() - 1,
            ];
        } elseif (strpos($range, '-') !== false) {
            list($start, $end) = explode('-', $range, 2);
            $length = intval($end - $start);
            if ($length <= 0) {
                return ['start' => intval($start), 'end' => $this->file->getSize() - 1];
            }
            return ['start' => intval($start), 'end' => intval($end)];
        }
        return null;
    }
}


1			<?php
2
3			namespace suda\application\processor;
4
5			use Exception;
6			use function explode;
7			use function is_array;
8			use function md5;
9			use function rtrim;
10			use SplFileObject;
11			use function strpos;
12			use function substr;
13			use suda\framework\Request;
14			use suda\framework\Response;
15			use suda\application\Application;
16			use suda\framework\response\MimeType;
17			use suda\framework\http\stream\DataStream;
18			use function uniqid;
19
20			/**
21			* 响应
22			*/
23			class FileRangeProccessor implements RequestProcessor
24			{
25			/**
26			* 文件路径
27			*
28			* @var SplFileObject
29			*/
30			protected $file;
31
32			/**
33			* MIME
34			*
35			* @var string
36			*/
37			protected $mime;
38
39			public function __construct($file)
40			{
41			$this->file = $file instanceof SplFileObject ? $file : new SplFileObject($file);
42			$this->mime = MimeType::getMimeType($this->file->getExtension());
43			}
44
45			/**
46			* 处理文件请求
47			*
48			* @param Application $application
49			* @param Request $request
50			* @param Response $response
51			* @return void
52			* @throws Exception
53			*/
54			public function onRequest(Application $application, Request $request, Response $response)
55			{
56			$ranges = $this->getRanges($request);
57			$response->setHeader('accept-ranges', 'bytes');
58			if ($request->getMethod() !== 'GET' \|\| $ranges === false) {
59			$response->status(400);
60			} elseif (is_array($ranges)) {
			0 ignored issues – show introduced 2019-07-10 14:56 UTC by Report Bug Copy Issue Report The condition `is_array($ranges)` is always `true`. Loading history...
61			$this->sendFileRanges($response, $ranges);
62			} else {
63			$response->setHeader('content-type', $this->mime);
64			$response->sendFile($this->file->getRealPath());
65			}
66			}
67
68			protected function sendFileRanges(Response $response, array $ranges)
69			{
70			if (count($ranges) === 1) {
71			$response->status(206);
72			$range = $ranges[0];
73			$response->setHeader('content-type', $this->mime);
74			$response->setHeader('content-range', $this->getRangeHeader($range));
75			$this->sendFileByRange($response, $range);
76			} else {
77			$response->status(206);
78			$this->sendMultipleFileByRange($response, $ranges);
79			}
80			}
81
82			/**
83			* 发送多Range
84			*
85			* @param Response $response
86			* @param array $ranges
87			* @return void
88			*/
89			protected function sendMultipleFileByRange(Response $response, array $ranges)
90			{
91			$separates = 'multiple_range_' . base64_encode(md5(uniqid(), true));
92			$response->setHeader('content-type', 'multipart/byteranges; boundary=' . $separates);
93			foreach ($ranges as $range) {
94			$response->write('--' . $separates . "\r\n");
95			$this->sendMultipleRangePart($response, $range);
96			$this->sendFileByRange($response, $range);
97			$response->write("\r\n");
98			}
99			}
100
101
102			/**
103			* 发送范围数据
104			*
105			* @param Response $response
106			* @param array $range
107			* @return void
108			*/
109			protected function sendFileByRange(Response $response, array $range)
110			{
111			// [start,end] = $end - $start + 1
112			$response->write(new DataStream($this->file, $range['start'], $range['end'] - $range['start'] + 1));
113			}
114
115			/**
116			* 获取Range描述
117			*
118			* @param Request $request
119			* @return array\|bool\|null
120			*/
121			protected function getRanges(Request $request)
122			{
123			$ranges = $this->parseRangeHeader($request);
124			if (is_array($ranges)) {
125			return $this->parseRanges($ranges);
126			} elseif ($ranges === false) {
127			return false;
128			}
129			return null;
130			}
131
132			/**
133			* 写Range头
134			*
135			* @param Response $response
136			* @param array $range
137			* @return void
138			*/
139			protected function sendMultipleRangePart(Response $response, array $range)
140			{
141			$response->write('Content-Type: ' . $this->mime . "\r\n");
142			$response->write('Content-Range: ' . $this->getRangeHeader($range) . "\r\n\r\n");
143			}
144
145			/**
146			* 生成Range头
147			*
148			* @param array $range
149			* @return string
150			*/
151			protected function getRangeHeader(array $range): string
152			{
153			return sprintf('bytes %d-%d/%d', $range['start'], $range['end'], $this->file->getSize());
154			}
155
156			/**
157			* 获取Range描述
158			*
159			* @param Request $request
160			* @return array\|bool\|null
161			*/
162			protected function parseRangeHeader(Request $request)
163			{
164			$range = $request->getHeader('range', null);
165			if (is_string($range)) {
166			$range = trim($range);
167			if (strpos($range, 'bytes=') !== 0) {
168			return false;
169			}
170			$rangesFrom = substr($range, strlen('bytes='));
171			return explode(',', $rangesFrom);
172			}
173			return null;
174			}
175
176			/**
177			* 处理范围
178			*
179			* @param array $ranges
180			* @return array\|bool
181			*/
182			protected function parseRanges(array $ranges)
183			{
184			$range = [];
185			foreach ($ranges as $value) {
186			if (($r = $this->parseRange($value)) !== null) {
187			$range[] = $r;
188			} else {
189			return false;
190			}
191			}
192			return $range;
193			}
194
195			/**
196			* 处理Range
197			*
198			* @param string $range
199			* @return array
200			*/
201			protected function parseRange(string $range): ?array
202			{
203			$range = trim($range);
204			if (strrpos($range, '-') === strlen($range) - 1) {
205			return [
206			'start' => intval(rtrim($range, '-')),
207			'end' => $this->file->getSize() - 1,
208			];
209			} elseif (strpos($range, '-') !== false) {
210			list($start, $end) = explode('-', $range, 2);
211			$length = intval($end - $start);
212			if ($length <= 0) {
213			return ['start' => intval($start), 'end' => $this->file->getSize() - 1];
214			}
215			return ['start' => intval($start), 'end' => intval($end)];
216			}
217			return null;
218			}
219			}
220

dxkite / suda

Push — dev ( 8d29ef...4c25c4 )

FileRangeProccessor::sendMultipleRangePart() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like