CurlRemoteFilesystem::getOptions() - Code Metrics - Inspection of "Fixed cacert option" - hirak/prestissimo - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#61)

by Hiraku

created 2016-02-28 07:37 UTC

CurlRemoteFilesystem::getOptions() A

↳ Parent: CurlRemoteFilesystem

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes	3
Bugs	0	Features	0

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

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

hirak / prestissimo

Pull Request — master (#61)

CurlRemoteFilesystem::getOptions() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like