CurlRemoteFilesystem::processHeader() - Code Metrics - Inspection of "(WIP)Improve scrutinizer score" - hirak/prestissimo - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#44)

by Hiraku

created 2016-02-06 15:29 UTC

CurlRemoteFilesystem::processHeader() A

↳ Parent: CurlRemoteFilesystem

Complexity

Conditions	1
Paths	1

Size

Total Lines	5
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes	1
Bugs	1	Features	0

Metric	Value
c	1
b	1
f	0
dl	0
loc	5
ccs	0
cts	0
cp	0
rs	9.4285
cc	1
eloc	3
nc	1
nop	2
crap	2

<?php
/*
 * hirak/prestissimo
 * @author Hiraku NAKANO
 * @license MIT https://github.com/hirak/prestissimo
 */
namespace Hirak\Prestissimo;

use Composer\Config as CConfig;
use Composer\IO;
use Composer\Downloader;
use Composer\Util;

/**
 * yet another implementation about Composer\Util\RemoteFilesystem
 * non thread safe
 */
class CurlRemoteFilesystem extends Util\RemoteFilesystem
{
    protected $io;
    protected $config;
    protected $options;

    protected $retryAuthFailure = true;

    protected $pluginConfig;

    private $_lastHeaders = array();

    // global flags
    private $_retry = false;

    /** @var Aspects\JoinPoint */
    public $onPreDownload;

    /** @var Aspects\JoinPoint */
    public $onPostDownload;

    /**
     * @param IO\IOInterface $io
     * @param CConfig $config
     * @param array $options
     */
    public function __construct(IO\IOInterface $io, CConfig $config, array $options = array())
    {
        $this->io = $io;
        $this->config = $config;
        $this->options = $options;
    }

    public function setPluginConfig(array $pluginConfig)
    {
        $this->pluginConfig = $pluginConfig;
    }

    /**
     * Copy the remote file in local.
     *
     * @param string $origin    host/domain text
     * @param string $fileUrl   targeturl
     * @param string $fileName  the local filename
     * @param bool   $progress  Display the progression
     * @param array  $options   Additional context options
     *
     * @return bool true
     */
    public function copy($origin, $fileUrl, $fileName, $progress = true, $options = array())
    {
        $that = $this; // for PHP5.3

        return $this->fetch($origin, $fileUrl, $progress, $options, function($ch, $request) use ($that, $fileName) {
            $outputFile = new OutputFile($fileName);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, false);
            curl_setopt($ch, CURLOPT_FILE, $outputFile->getPointer());

            list(, $response) = $result = $that->exec($ch, $request);

            curl_setopt($ch, CURLOPT_FILE, STDOUT);

            if (200 === $response->info['http_code']) {
                $outputFile->setSuccess();
            }

            return $result;
        });
    }

    /**
     * Get the content.
     *
     * @param string $origin The origin URL
     * @param string $fileUrl   The file URL
     * @param bool   $progress  Display the progression
     * @param array  $options   Additional context options
     *
     * @return bool|string The content
     */
    public function getContents($origin, $fileUrl, $progress = true, $options = array())
    {
        $that = $this; // for PHP5.3

        return $this->fetch($origin, $fileUrl, $progress, $options, function($ch, $request) use ($that) {
            // This order is important.
            curl_setopt($ch, CURLOPT_FILE, STDOUT);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

            return $that->exec($ch, $request);
        });
    }

    /**
     * @param string $origin
     * @param string $fileUrl
     * @param boolean $progress
     * @param \Closure $exec
     */
    protected function fetch($origin, $fileUrl, $progress, $options, $exec)
    {
        do {
            $this->_retry = false;

            $request = Factory::getHttpGetRequest($origin, $fileUrl, $this->io, $this->config, $this->pluginConfig);
            $this->onPreDownload = Factory::getPreEvent($request);
            $this->onPostDownload = Factory::getPostEvent($request);

            $options += $this->options;
            $request->processRFSOption($options);

            if ($this->io->isDebug()) {
                $this->io->write('Downloading ' . $fileUrl);
            }

            if ($progress) {
                $this->io->write("    Downloading: <comment>Connecting...</comment>", false);
                $request->curlOpts[CURLOPT_NOPROGRESS] = false;
                $request->curlOpts[CURLOPT_PROGRESSFUNCTION] = array($this, 'progress');
            } else {
                $request->curlOpts[CURLOPT_NOPROGRESS] = true;
                $request->curlOpts[CURLOPT_PROGRESSFUNCTION] = null;
            }

            $this->onPreDownload->notify();

            $opts = $request->getCurlOpts();
            $ch = Factory::getConnection($origin, isset($opts[CURLOPT_USERPWD]));

            curl_setopt_array($ch, $opts);

            list($execStatus,) = $exec($ch, $request);
        } while ($this->_retry);

        if ($progress) {
            $this->io->overwrite("    Downloading: <comment>100%</comment>");
        }

        return $execStatus;
    }

    /**
     * Retrieve the options set in the constructor
     *
     * @return array Options
     */
    public function getOptions()
    {
        return $this->options;
    }

    /**
     * Returns the headers of the last request
     *
     * @return array
     */
    public function getLastHeaders()
    {
        return $this->_lastHeaders;
    }

    /**
     * @internal
     * @param resource $ch
     * @param Aspects\HttpGetRequest $request
     * @return array {int, Aspects\HttpGetResponse}
     */
    public function exec($ch, Aspects\HttpGetRequest $request)
    {
        $this->_lastHeaders = array();
        curl_setopt($ch, CURLOPT_HEADERFUNCTION, array($this, 'processHeader'));
        $execStatus = curl_exec($ch);

        $response = new Aspects\HttpGetResponse(
            curl_errno($ch),
            curl_error($ch),
            curl_getinfo($ch)
        );
        $this->onPostDownload->setResponse($response);
        $this->onPostDownload->notify();

        if ($response->needAuth()) {
            $this->promptAuth($request, $response);
        }

        return array($execStatus, $response);
    }

    /**
     * @internal
     */
    public function progress()
    {
        // @codeCoverageIgnoreStart
        if (PHP_VERSION_ID >= 50500) {
            list(, $downBytesMax, $downBytes,,) = func_get_args();
        } else {
            list($downBytesMax, $downBytes,,) = func_get_args();
        }
        // @codeCoverageIgnoreEnd

        if ($downBytesMax <= 0 || $downBytesMax < $downBytes) {
            return 0;
        }

        $progression = intval($downBytes / $downBytesMax * 100);
        $this->io->overwrite("    Downloading: <comment>$progression%</comment>", false);
        return 0;
    }

    /**
     * @internal
     * @param resource $ch
     * @param string $header
     * @return int
     */
    public function processHeader($ch, $header)
    {
        $this->_lastHeaders[] = trim($header);
        return strlen($header);
    }

    protected function promptAuth(Aspects\HttpGetRequest $req, Aspects\HttpGetResponse $res)
    {
        $this->_retry = $req->promptAuth($res, $this->config, $this->io);
    }
}


1		<?php
2		/*
3		* hirak/prestissimo
4		* @author Hiraku NAKANO
5		* @license MIT https://github.com/hirak/prestissimo
6		*/
7		namespace Hirak\Prestissimo;
8
9		use Composer\Config as CConfig;
10		use Composer\IO;
11		use Composer\Downloader;
12		use Composer\Util;
13
14		/**
15		* yet another implementation about Composer\Util\RemoteFilesystem
16		* non thread safe
17		*/
18		class CurlRemoteFilesystem extends Util\RemoteFilesystem
19		{
20		protected $io;
21		protected $config;
22		protected $options;
23
24		protected $retryAuthFailure = true;
25
26		protected $pluginConfig;
27
28		private $_lastHeaders = array();
29
30		// global flags
31		private $_retry = false;
32
33		/** @var Aspects\JoinPoint */
34		public $onPreDownload;
35
36		/** @var Aspects\JoinPoint */
37		public $onPostDownload;
38
39		/**
40		* @param IO\IOInterface $io
41		* @param CConfig $config
42		* @param array $options
43		*/
44		public function __construct(IO\IOInterface $io, CConfig $config, array $options = array())
45	8	{
46		$this->io = $io;
47	8	$this->config = $config;
48	8	$this->options = $options;
49	8	}
50	8
51		public function setPluginConfig(array $pluginConfig)
52	8	{
53		$this->pluginConfig = $pluginConfig;
54	8	}
55	8
56		/**
57		* Copy the remote file in local.
58		*
59		* @param string $origin host/domain text
60		* @param string $fileUrl targeturl
61		* @param string $fileName the local filename
62		* @param bool $progress Display the progression
63		* @param array $options Additional context options
64		*
65		* @return bool true
66		*/
67		public function copy($origin, $fileUrl, $fileName, $progress = true, $options = array())
68	4	{
69		$that = $this; // for PHP5.3
70	4
71		return $this->fetch($origin, $fileUrl, $progress, $options, function($ch, $request) use ($that, $fileName) {
72		$outputFile = new OutputFile($fileName);
73	4	curl_setopt($ch, CURLOPT_RETURNTRANSFER, false);
74	4	curl_setopt($ch, CURLOPT_FILE, $outputFile->getPointer());
75	4
76		list(, $response) = $result = $that->exec($ch, $request);
77	4
78		curl_setopt($ch, CURLOPT_FILE, STDOUT);
79	2
80		if (200 === $response->info['http_code']) {
81	2	$outputFile->setSuccess();
82	1	}
83	1
84		return $result;
85	2	});
86	4	}
87
88		/**
89		* Get the content.
90		*
91		* @param string $origin The origin URL
92		* @param string $fileUrl The file URL
93		* @param bool $progress Display the progression
94		* @param array $options Additional context options
95		*
96		* @return bool\|string The content
97		*/
98		public function getContents($origin, $fileUrl, $progress = true, $options = array())
99	1	{
100		$that = $this; // for PHP5.3
101	1
102		return $this->fetch($origin, $fileUrl, $progress, $options, function($ch, $request) use ($that) {
103	1	// This order is important.
104		curl_setopt($ch, CURLOPT_FILE, STDOUT);
105	1	curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
106	1
107		return $that->exec($ch, $request);
108	1	});
109	1	}
110
111		/**
112		* @param string $origin
113		* @param string $fileUrl
114		* @param boolean $progress
115		* @param \Closure $exec
116		*/
117		protected function fetch($origin, $fileUrl, $progress, $options, $exec)
118	5	{
119		do {
120		$this->_retry = false;
121	5
122		$request = Factory::getHttpGetRequest($origin, $fileUrl, $this->io, $this->config, $this->pluginConfig);
123	5	$this->onPreDownload = Factory::getPreEvent($request);
124	5	$this->onPostDownload = Factory::getPostEvent($request);
125	5
126	5	$options += $this->options;
127	5	$request->processRFSOption($options);
128	5
129	5	if ($this->io->isDebug()) {
130	5	$this->io->write('Downloading ' . $fileUrl);
131		}
132
133		if ($progress) {
134	5	$this->io->write(" Downloading: <comment>Connecting...</comment>", false);
135		$request->curlOpts[CURLOPT_NOPROGRESS] = false;
136	5	$request->curlOpts[CURLOPT_PROGRESSFUNCTION] = array($this, 'progress');
137		} else {
138		$request->curlOpts[CURLOPT_NOPROGRESS] = true;
139	5	$request->curlOpts[CURLOPT_PROGRESSFUNCTION] = null;
140		}
141
142		$this->onPreDownload->notify();
143	5
144		$opts = $request->getCurlOpts();
145		$ch = Factory::getConnection($origin, isset($opts[CURLOPT_USERPWD]));
146
147	5	curl_setopt_array($ch, $opts);
148	4
149	4	list($execStatus,) = $exec($ch, $request);
150	4	} while ($this->_retry);
151	4
152	1	if ($progress) {
153	1	$this->io->overwrite(" Downloading: <comment>100%</comment>");
154		}
155
156	5	return $execStatus;
157		}
158	5
159	5	/**
160		* Retrieve the options set in the constructor
161	5	*
162		* @return array Options
163		*/
164	5	public function getOptions()
165		{
166		return $this->options;
167	5	}
168
169		/**
170		* Returns the headers of the last request
171	5	*
172		* @return array
173	5	*/
174	3	public function getLastHeaders()
175		{
176	3	return $this->_lastHeaders;
177	2	}
178	2
179		/**
180	3	* @internal
181		* @param resource $ch
182		* @param Aspects\HttpGetRequest $request
183		* @return array {int, Aspects\HttpGetResponse}
184		*/
185		public function exec($ch, Aspects\HttpGetRequest $request)
186		{
187		$this->_lastHeaders = array();
188	1	curl_setopt($ch, CURLOPT_HEADERFUNCTION, array($this, 'processHeader'));
189		$execStatus = curl_exec($ch);
190	1
191		$response = new Aspects\HttpGetResponse(
192		curl_errno($ch),
193		curl_error($ch),
194		curl_getinfo($ch)
195		);
196		$this->onPostDownload->setResponse($response);
197		$this->onPostDownload->notify();
198	1
199		if ($response->needAuth()) {
200	1	$this->promptAuth($request, $response);
201		}
202
203		return array($execStatus, $response);
204		}
205
206		/**
207		* @internal
208		*/
209	5	public function progress()
210		{
211	5	// @codeCoverageIgnoreStart
212	5	if (PHP_VERSION_ID >= 50500) {
213	5	list(, $downBytesMax, $downBytes,,) = func_get_args();
214		} else {
215	5	list($downBytesMax, $downBytes,,) = func_get_args();
216	5	}
217	5	// @codeCoverageIgnoreEnd
218	5
219	5	if ($downBytesMax <= 0 \|\| $downBytesMax < $downBytes) {
220	5	return 0;
221	5	}
222
223	5	$progression = intval($downBytes / $downBytesMax * 100);
224	3	$this->io->overwrite(" Downloading: <comment>$progression%</comment>", false);
225	1	return 0;
226		}
227	3
228		/**
229		* @internal
230		* @param resource $ch
231		* @param string $header
232		* @return int
233	4	*/
234		public function processHeader($ch, $header)
235		{
236		$this->_lastHeaders[] = trim($header);
237		return strlen($header);
238		}
239
240		protected function promptAuth(Aspects\HttpGetRequest $req, Aspects\HttpGetResponse $res)
241		{
242		$this->_retry = $req->promptAuth($res, $this->config, $this->io);
243	4	}
244		}
245

hirak / prestissimo

Pull Request — master (#44)

CurlRemoteFilesystem::processHeader() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like