Issues in Torrent.php (master) - Issues in master - iGusev/torrent - Measure and Improve Code Quality continuously with Scrutinizer

Issues (3)

Security Analysis no request data

Cross-Site Scripting

Cross-Site Scripting enables an attacker to inject code into the response of a web-request that is viewed by other users. It can for example be used to bypass access controls, or even to take over other users' accounts.

File Exposure

File Exposure allows an attacker to gain access to local files that he should not be able to access. These files can for example include database credentials, or other configuration files.

File Manipulation

File Manipulation enables an attacker to write custom data to files. This potentially leads to injection of arbitrary code on the server.

Object Injection

Object Injection enables an attacker to inject an object into PHP code, and can lead to arbitrary code execution, file exposure, or file manipulation attacks.

Code Injection

Code Injection enables an attacker to execute arbitrary code on the server.

Response Splitting

Response Splitting can be used to send arbitrary responses.

File Inclusion

File Inclusion enables an attacker to inject custom files into PHP's file loading mechanism, either explicitly passed to include, or for example via PHP's auto-loading mechanism.

Command Injection

Command Injection enables an attacker to inject a shell command that is execute with the privileges of the web-server. This can be used to expose sensitive data, or gain access of your server.

SQL Injection

SQL Injection enables an attacker to execute arbitrary SQL code on your database server gaining access to user data, or manipulating user data.

XPath Injection

XPath Injection enables an attacker to modify the parts of XML document that are read. If that XML document is for example used for authentication, this can lead to further vulnerabilities similar to SQL Injection.

LDAP Injection

LDAP Injection enables an attacker to inject LDAP statements potentially granting permission to run unauthorized queries, or modify content inside the LDAP tree.

Header Injection

Other Vulnerability

This category comprises other attack vectors such as manipulating the PHP runtime, loading custom extensions, freezing the runtime, or similar.

Regex Injection

Regex Injection enables an attacker to execute arbitrary code in your PHP process.

XML Injection

XML Injection enables an attacker to read files on your local filesystem including configuration files, or can be abused to freeze your web-server process.

Variable Injection

Variable Injection enables an attacker to overwrite program variables with custom data, and can lead to further vulnerabilities.

Unfortunately, the security analysis is currently not available for your project. If you are a non-commercial open-source project, please contact support to gain access.

src/Torrent.php (3 issues)

Labels

Severity

Upgrade to new PHP Analysis Engine

These results are based on our legacy PHP analysis, consider migrating to our new PHP analysis engine instead. Learn more

<?php

namespace League\Torrent;

use League\Torrent\Helper\Decoder;
use League\Torrent\Helper\Encoder;
use League\Torrent\Helper\FileSystem;

/**
 * Class Torrent
 *
 * @package League\Torrent
 */
class Torrent
{
    /**
     * Optional comment
     *
     * @var string
     */
    public $comment;

    /**
     *
     * @var string
     */
    public $announce;

    /**
     *
     * @var string
     */
    protected $createdBy;

    /**
     *
     * @var int
     */
    protected $creationDate;

    /**
     * Info about the file(s) in the torrent
     *
     * @var array
     */
    public $info;

    /**
     * @param null $data
     * @param array $meta
     * @param int $piece_length
     *
     * @throws Exception
     */
    public function __construct($data = null, $meta = array(), $piece_length = 256)
    {
        if (is_null($data)) {
            return false;

        }
        if ($piece_length < 32 || $piece_length > 4096) {
            throw new Exception('Invalid piece lenth, must be between 32 and 4096');
        }
        if ($this->build($data, $piece_length * 1024)) {
            $this->touch();
        } else {
            $meta = array_merge($meta, Decoder::decode($data));
        }
        foreach ($meta as $key => $value) {
            $this->{$key} = $value;
        }
    }

    public static function createFromTorrentFile($filename, $meta = array())
    {
        return self::setMeta(new self(), file_get_contents($filename), $meta);
    }

    public static function createFromUrl($url, $meta = array())
    {
        if (!FileSystem::url_exists($url)) {
            throw new \InvalidArgumentException('Url is not valud');
        }

        return self::setMeta(new self(), FileSystem::downloadTorrent($url), $meta);
    }

    public static function createFromFilesList(array $list, $meta = array())
    {
        $instance = new self;
        if ($instance->build($list, 256 * 1024)) {
            $instance->touch();
        }

        return self::setMeta($instance, '', $meta);
    }

    public static function setMeta($instance, $data = '', $meta = array())
    {
        if (strlen($data)) {
            $meta = array_merge($meta, (array) Decoder::decodeData($data));
        }

        foreach ($meta as $key => $value) {
            $instance->{$key} = $value;
        }

        return $instance;
    }

    /**
     * @return string
     */
    public function __toString()
    {
        return Encoder::encode(get_object_vars($this));
    }

    /**
     * @param null $announce
     *
     * @return array|mixed|null|string
     */
    public function announce($announce = null)
    {
        if (is_null($announce)) {
            return !isset($this->{'announce-list'}) ?
                isset($this->announce) ? $this->announce : null :
                $this->{'announce-list'};
        }
        $this->touch();
        if (is_string($announce) && isset($this->announce)) {
            return $this->{'announce-list'} = self::announce_list(isset($this->{'announce-list'}) ? $this->{'announce-list'} : $this->announce,
                $announce);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        }
        unset($this->{'announce-list'});
        if (is_array($announce) || is_object($announce)) {
            if (($this->announce = self::first_announce($announce)) && count($announce) > 1) {
                return $this->{'announce-list'} = self::announce_list($announce);
            } else {
                return $this->announce;
            }
        }
        if (!isset($this->announce) && $announce) {
            return $this->announce = (string) $announce;
        }
        unset($this->announce);
    }

    /**
     *
     * @return null|string
     */
    public function getComment()
    {
        return $this->comment;
    }

    /**
     * @param null $comment
     *
     */
    public function setComment($comment)
    {
        $this->touch($this->comment = (string) $comment);
    }

    /**
     *
     * @return string|null
     */
    public function getName()
    {
        return isset($this->info['name']) ? $this->info['name'] : null;
    }

    /**
     * @param string $name
     *
     * @return null|string
     */
    public function setName($name)
    {
        $this->touch($this->info['name'] = (string) $name);
    }

    /**
     * @param null $private
     *
     * @return bool|null
     */
    public function isPrivate($private = null)
    {
        return is_null($private) ?
            !empty($this->info['private']) :
            $this->touch($this->info['private'] = $private ? 1 : 0);
    }

    /**
     * @param null $urls
     *
     * @return null
     */
    public function urlList($urls = null)
    {
        return is_null($urls) ?
            isset($this->{'url-list'}) ? $this->{'url-list'} : null :
            $this->touch($this->{'url-list'} = is_string($urls) ? $urls : (array) $urls);
    }

    /**
     * @param null $urls
     *
     * @return null
     */
    public function httpSeeds($urls = null)
    {
        return is_null($urls) ?
            isset($this->httpseeds) ? $this->httpseeds : null :
class MyClass { }

$x = new MyClass();
$x->foo = true;
            $this->touch($this->httpseeds = (array) $urls);
    }

    /**
     * @return null
     */
    public function piece_length()
    {
        return isset($this->info['piece length']) ?
            $this->info['piece length'] :
            null;
    }

    /**
     * @return null|string
     */
    public function hash_info()
    {
        return isset($this->info) ? sha1(Encoder::encode($this->info)) : null;
    }

    /**
     *
     * @return array
     */
    public function content()
    {
        $files = array();
        if ($this->isOneFile()) {
            $files[$this->info['name']] = $this->info['length'];

        } else {
            foreach ((array) $this->info['files'] as $file) {
                $files[FileSystem::path($file['path'], $this->info['name'])] = $file['length'];
            }
        }

        return $files;
    }


    private function isOneFile()
    {
        return isset($this->info['length'], $this->info['name']);
    }

    /**
     * @return array
     */
    public function offset()
    {
        $files = array();
        $size = 0;
        if ($this->isOneFile()) {
            $files[$this->info['name']] = array(
                'startpiece' => 0,
                'offset' => 0,
                'size' => $this->info['length'],
                'endpiece' => floor($this->info['length'] / $this->info['piece length'])
            );
        } else {
            foreach ((array) $this->info['files'] as $file) {
                $files[FileSystem::path($file['path'], $this->info['name'])] = array(
                    'startpiece' => floor($size / $this->info['piece length']),
                    'offset' => fmod($size, $this->info['piece length']),
                    'size' => $size += $file['length'],
                    'endpiece' => floor($size / $this->info['piece length'])
                );
            }
        }

        return $files;
    }

    /**
     *
     * @return int
     */
    public function getSize()
    {
        $size = 0;

        if ($this->isOneFile()) {
            return $this->info['length'];
        } else {
            foreach ((array) $this->info['files'] as $file) {
                $size += $file['length'];
            }
        }

        return $size;
    }


    /**
     * @param null $announce
     * @param null $hash_info
     * @param int $timeout
     *
     * @return array|bool
     *
     * @throws Exception
     */
    public function scrape($announce = null, $hash_info = null, $timeout = FileSystem::timeout)
    {
        $packed_hash = urlencode(pack('H*', $hash_info ? $hash_info : $this->hash_info()));
        $handles = $scrape = array();
        if (!function_exists('curl_multi_init')) {
            throw new Exception('Install CURL with "curl_multi_init" enabled');
        }
        $curl = curl_multi_init();
        foreach ((array) ($announce ? $announce : $this->announce()) as $tier) {
            foreach ((array) $tier as $tracker) {
                $tracker = str_ireplace(array('udp://', '/announce', ':80/'), array(
                    'http://',
                    '/scrape',
                    '/'
                ), $tracker);
                if (isset($handles[$tracker])) {
                    continue;
                }
                $handles[$tracker] = curl_init($tracker . '?info_hash=' . $packed_hash);
                curl_setopt($handles[$tracker], CURLOPT_RETURNTRANSFER, true);
                curl_setopt($handles[$tracker], CURLOPT_TIMEOUT, $timeout);
                curl_multi_add_handle($curl, $handles[$tracker]);
            }
        }
        do {
            while (($state = curl_multi_exec($curl, $running)) == CURLM_CALL_MULTI_PERFORM) {
                ;
            }
            if ($state != CURLM_OK) {
                continue;
            }
            while ($done = curl_multi_info_read($curl)) {
                $info = curl_getinfo($done['handle']);
                $tracker = explode('?', $info['url'], 2);
                $tracker = array_shift($tracker);
                if (empty($info['http_code'])) {
                    $scrape[$tracker] = 'Tracker request timeout (' . $timeout . 's)';
                    continue;
                } elseif ($info['http_code'] != 200) {
                    $scrape[$tracker] = 'Tracker request failed (' . $info['http_code'] . ' code)';
                    continue;
                }
                $data = curl_multi_getcontent($done['handle']);
                $stats = Decoder::decodeData($data);
                curl_multi_remove_handle($curl, $done['handle']);
                $scrape[$tracker] = empty($stats['files']) ?
                    'Empty scrape data' :
                    array_shift($stats['files']) + (empty($stats['flags']) ? array() : $stats['flags']);
            }
        } while ($running);
        curl_multi_close($curl);
        return $scrape;
    }

    /**
     * @param string $filename
     *
     * @return string
     */
    public function saveToFile($filename = null)
    {
        return file_put_contents($filename, Encoder::encode(get_object_vars($this)));
    }

    /**
     *
     * @return string
     */
    public function save()
    {
        return file_put_contents($this->info['name'] . '.torrent', Encoder::encode(get_object_vars($this)));
    }

    /**
     * @param bool $html
     *
     * @return string
     */
    public function magnet($html = true)
    {
        $ampersand = $html ? '&amp;' : '&';
        return sprintf(
            'magnet:?xt=urn:btih:%2$s%1$sdn=%3$s%1$sxl=%4$d%1$str=%5$s',
            $ampersand,
            $this->hash_info(),
            urlencode($this->getName()),
            $this->getSize(),
            implode($ampersand . 'tr=', FileSystem::untier($this->announce()))
        );
    }


    /**
     * @param $data
     * @param integer $piece_length
     *
     * @return array|bool
     */
    protected function build($data, $piece_length)
    {
        if (is_null($data)) {
            return false;
        } elseif (is_array($data) && FileSystem::is_list($data)) {
            return $this->info = $this->files($data, $piece_length);
        } elseif (is_dir($data)) {
            return $this->info = $this->folder($data, $piece_length);
        } elseif (
            (is_file($data) && !FileSystem::isTorrent(file_get_contents($data)))
            || (FileSystem::url_exists($data) && !FileSystem::isTorrent(FileSystem::downloadTorrent($data)))
        ) {
            return $this->info = $this->file($data, $piece_length);
        }

        return false;
    }

    /**
     * @param null $void
     *
     * @return null
     */
    protected function touch($void = null)
    {
        $this->createdBy = 'League\Torrent Class - http://github.com/iGusev/torrent';
        $this->creationDate = time();
        return $void;
    }

    /**
     * @param $announce
     * @param array $merge
     *
     * @return array
     */
    protected static function announce_list($announce, $merge = array())
    {
        return array_map(create_function('$a', 'return (array) $a;'), array_merge((array) $announce, (array) $merge));
    }

    /**
     * @param $announce
     *
     * @return array|mixed
     */
    protected static function first_announce($announce)
    {
        while (is_array($announce)) {
            $announce = reset($announce);
        }
        return $announce;
    }

    /**
     * @param $handle
     * @param $piece_length
     * @param bool $last
     *
     * @return bool|string
     *
     * @throws Exception
     */
    private function pieces($handle, $piece_length, $last = true)
    {
        static $piece, $length;
        if (empty($length)) {
            $length = $piece_length;
        }
        $pieces = null;
        while (!feof($handle)) {
            if (($length = strlen($piece .= fread($handle, $length))) == $piece_length) {
                $pieces .= FileSystem::pack($piece);
            } elseif (($length = $piece_length - $length) < 0) {
                throw new Exception('Invalid piece length!');
            }
        }
        fclose($handle);
        return $pieces . ($last && $piece ? FileSystem::pack($piece) : null);
    }

    /**
     * @param $file
     * @param $piece_length
     *
     * @return array|bool
     */
    protected function file($file, $piece_length)
    {

        if (FileSystem::is_url($file)) {
            $this->urlList($file);
        }
        $path = explode(DIRECTORY_SEPARATOR, $file);
        return array(
            'length' => FileSystem::filesize($file),
            'name' => end($path),
            'piece length' => $piece_length,
            'pieces' => $this->pieces(self::fopen($file), $piece_length)
        );
    }

    /**
     * @param $files
     * @param $piece_length
     *
     * @return array
     *
     * @throws Exception
     */
    protected function files($files, $piece_length)
    {
        if (!FileSystem::is_url(current($files))) {
            $files = array_map('realpath', $files);
        }
        sort($files);
        usort($files,
            create_function('$a,$b', 'return strrpos($a,DIRECTORY_SEPARATOR)-strrpos($b,DIRECTORY_SEPARATOR);'));
        $first = current($files);
        $root = dirname($first);
        if ($url = FileSystem::is_url($first)) {
            $this->urlList(dirname($root) . DIRECTORY_SEPARATOR);
        }
        $path = explode(DIRECTORY_SEPARATOR, dirname($url ? $first : realpath($first)));
        $pieces = null;
        $info_files = array();
        $count = count($files) - 1;
        foreach ($files as $i => $file) {
            if ($path != array_intersect_assoc($file_path = explode(DIRECTORY_SEPARATOR, $file), $path)) {
                throw new Exception('Files must be in the same folder: "' . $file . '" discarded');
            }
            $pieces .= $this->pieces(self::fopen($file), $piece_length, $count == $i);
            $info_files[] = array(
                'length' => FileSystem::filesize($file),
                'path' => array_values(array_diff($file_path, $path))
            );
        }
        return array(
            'files' => $info_files,
            'name' => end($path),
            'piece length' => $piece_length,
            'pieces' => $pieces
        );
    }

    /**
     * @param $dir
     * @param $piece_length
     *
     * @return array
     */
    protected function folder($dir, $piece_length)
    {
        return $this->files(FileSystem::scandir($dir), $piece_length);
    }

    /**
     * @param $filename
     *
     * @return bool|resource
     *
     * @throws Exception
     */
    public static function fopen($filename)
    {
        if (!$handle = fopen($filename, 'r')) {
            throw new Exception('Failed to open file: "' . $filename . '"');
        }

        return $handle;
    }


}


1			<?php
2
3			namespace League\Torrent;
4
5			use League\Torrent\Helper\Decoder;
6			use League\Torrent\Helper\Encoder;
7			use League\Torrent\Helper\FileSystem;
8
9			/**
10			* Class Torrent
11			*
12			* @package League\Torrent
13			*/
14			class Torrent
15			{
16			/**
17			* Optional comment
18			*
19			* @var string
20			*/
21			public $comment;
22
23			/**
24			*
25			* @var string
26			*/
27			public $announce;
28
29			/**
30			*
31			* @var string
32			*/
33			protected $createdBy;
34
35			/**
36			*
37			* @var int
38			*/
39			protected $creationDate;
40
41			/**
42			* Info about the file(s) in the torrent
43			*
44			* @var array
45			*/
46			public $info;
47
48			/**
49			* @param null $data
50			* @param array $meta
51			* @param int $piece_length
52			*
53			* @throws Exception
54			*/
55			public function __construct($data = null, $meta = array(), $piece_length = 256)
56			{
57			if (is_null($data)) {
58			return false;
			0 ignored issues – show Bug introduced 2016-01-05 23:14 UTC by Report Bug Copy Issue Report Show Similar Issues like this Constructors do not have meaningful return values, anything that is returned from here is discarded. Are you sure this is correct? Loading history...
59			}
60			if ($piece_length < 32 \|\| $piece_length > 4096) {
61			throw new Exception('Invalid piece lenth, must be between 32 and 4096');
62			}
63			if ($this->build($data, $piece_length * 1024)) {
64			$this->touch();
65			} else {
66			$meta = array_merge($meta, Decoder::decode($data));
67			}
68			foreach ($meta as $key => $value) {
69			$this->{$key} = $value;
70			}
71			}
72
73			public static function createFromTorrentFile($filename, $meta = array())
74			{
75			return self::setMeta(new self(), file_get_contents($filename), $meta);
76			}
77
78			public static function createFromUrl($url, $meta = array())
79			{
80			if (!FileSystem::url_exists($url)) {
81			throw new \InvalidArgumentException('Url is not valud');
82			}
83
84			return self::setMeta(new self(), FileSystem::downloadTorrent($url), $meta);
85			}
86
87			public static function createFromFilesList(array $list, $meta = array())
88			{
89			$instance = new self;
90			if ($instance->build($list, 256 * 1024)) {
91			$instance->touch();
92			}
93
94			return self::setMeta($instance, '', $meta);
95			}
96
97			public static function setMeta($instance, $data = '', $meta = array())
98			{
99			if (strlen($data)) {
100			$meta = array_merge($meta, (array) Decoder::decodeData($data));
101			}
102
103			foreach ($meta as $key => $value) {
104			$instance->{$key} = $value;
105			}
106
107			return $instance;
108			}
109
110			/**
111			* @return string
112			*/
113			public function __toString()
114			{
115			return Encoder::encode(get_object_vars($this));
116			}
117
118			/**
119			* @param null $announce
120			*
121			* @return array\|mixed\|null\|string
122			*/
123			public function announce($announce = null)
124			{
125			if (is_null($announce)) {
126			return !isset($this->{'announce-list'}) ?
127			isset($this->announce) ? $this->announce : null :
128			$this->{'announce-list'};
129			}
130			$this->touch();
131			if (is_string($announce) && isset($this->announce)) {
132			return $this->{'announce-list'} = self::announce_list(isset($this->{'announce-list'}) ? $this->{'announce-list'} : $this->announce,
133			$announce);
			0 ignored issues – show Documentation introduced 2016-01-05 23:14 UTC by Report Bug Copy Issue Report Show Similar Issues like this `$announce` is of type `string`, but the function expects a `array`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
134			}
135			unset($this->{'announce-list'});
136			if (is_array($announce) \|\| is_object($announce)) {
137			if (($this->announce = self::first_announce($announce)) && count($announce) > 1) {
138			return $this->{'announce-list'} = self::announce_list($announce);
139			} else {
140			return $this->announce;
141			}
142			}
143			if (!isset($this->announce) && $announce) {
144			return $this->announce = (string) $announce;
145			}
146			unset($this->announce);
147			}
148
149			/**
150			*
151			* @return null\|string
152			*/
153			public function getComment()
154			{
155			return $this->comment;
156			}
157
158			/**
159			* @param null $comment
160			*
161			*/
162			public function setComment($comment)
163			{
164			$this->touch($this->comment = (string) $comment);
165			}
166
167			/**
168			*
169			* @return string\|null
170			*/
171			public function getName()
172			{
173			return isset($this->info['name']) ? $this->info['name'] : null;
174			}
175
176			/**
177			* @param string $name
178			*
179			* @return null\|string
180			*/
181			public function setName($name)
182			{
183			$this->touch($this->info['name'] = (string) $name);
184			}
185
186			/**
187			* @param null $private
188			*
189			* @return bool\|null
190			*/
191			public function isPrivate($private = null)
192			{
193			return is_null($private) ?
194			!empty($this->info['private']) :
195			$this->touch($this->info['private'] = $private ? 1 : 0);
196			}
197
198			/**
199			* @param null $urls
200			*
201			* @return null
202			*/
203			public function urlList($urls = null)
204			{
205			return is_null($urls) ?
206			isset($this->{'url-list'}) ? $this->{'url-list'} : null :
207			$this->touch($this->{'url-list'} = is_string($urls) ? $urls : (array) $urls);
208			}
209
210			/**
211			* @param null $urls
212			*
213			* @return null
214			*/
215			public function httpSeeds($urls = null)
216			{
217			return is_null($urls) ?
218			isset($this->httpseeds) ? $this->httpseeds : null :
			0 ignored issues – show Bug introduced 2016-01-05 23:14 UTC by Report Bug Copy Issue Report Show Similar Issues like this The property `httpseeds` does not exist. Did you maybe forget to declare it? In PHP it is possible to write to properties without declaring them. For example, the following is perfectly valid PHP code: class MyClass { } $x = new MyClass(); $x->foo = true; Generally, it is a good practice to explictly declare properties to avoid accidental typos and provide IDE auto-completion: class MyClass { public $foo; } $x = new MyClass(); $x->foo = true; Loading history...
219			$this->touch($this->httpseeds = (array) $urls);
220			}
221
222			/**
223			* @return null
224			*/
225			public function piece_length()
226			{
227			return isset($this->info['piece length']) ?
228			$this->info['piece length'] :
229			null;
230			}
231
232			/**
233			* @return null\|string
234			*/
235			public function hash_info()
236			{
237			return isset($this->info) ? sha1(Encoder::encode($this->info)) : null;
238			}
239
240			/**
241			*
242			* @return array
243			*/
244			public function content()
245			{
246			$files = array();
247			if ($this->isOneFile()) {
248			$files[$this->info['name']] = $this->info['length'];
249
250			} else {
251			foreach ((array) $this->info['files'] as $file) {
252			$files[FileSystem::path($file['path'], $this->info['name'])] = $file['length'];
253			}
254			}
255
256			return $files;
257			}
258
259
260			private function isOneFile()
261			{
262			return isset($this->info['length'], $this->info['name']);
263			}
264
265			/**
266			* @return array
267			*/
268			public function offset()
269			{
270			$files = array();
271			$size = 0;
272			if ($this->isOneFile()) {
273			$files[$this->info['name']] = array(
274			'startpiece' => 0,
275			'offset' => 0,
276			'size' => $this->info['length'],
277			'endpiece' => floor($this->info['length'] / $this->info['piece length'])
278			);
279			} else {
280			foreach ((array) $this->info['files'] as $file) {
281			$files[FileSystem::path($file['path'], $this->info['name'])] = array(
282			'startpiece' => floor($size / $this->info['piece length']),
283			'offset' => fmod($size, $this->info['piece length']),
284			'size' => $size += $file['length'],
285			'endpiece' => floor($size / $this->info['piece length'])
286			);
287			}
288			}
289
290			return $files;
291			}
292
293			/**
294			*
295			* @return int
296			*/
297			public function getSize()
298			{
299			$size = 0;
300
301			if ($this->isOneFile()) {
302			return $this->info['length'];
303			} else {
304			foreach ((array) $this->info['files'] as $file) {
305			$size += $file['length'];
306			}
307			}
308
309			return $size;
310			}
311
312
313			/**
314			* @param null $announce
315			* @param null $hash_info
316			* @param int $timeout
317			*
318			* @return array\|bool
319			*
320			* @throws Exception
321			*/
322			public function scrape($announce = null, $hash_info = null, $timeout = FileSystem::timeout)
323			{
324			$packed_hash = urlencode(pack('H*', $hash_info ? $hash_info : $this->hash_info()));
325			$handles = $scrape = array();
326			if (!function_exists('curl_multi_init')) {
327			throw new Exception('Install CURL with "curl_multi_init" enabled');
328			}
329			$curl = curl_multi_init();
330			foreach ((array) ($announce ? $announce : $this->announce()) as $tier) {
331			foreach ((array) $tier as $tracker) {
332			$tracker = str_ireplace(array('udp://', '/announce', ':80/'), array(
333			'http://',
334			'/scrape',
335			'/'
336			), $tracker);
337			if (isset($handles[$tracker])) {
338			continue;
339			}
340			$handles[$tracker] = curl_init($tracker . '?info_hash=' . $packed_hash);
341			curl_setopt($handles[$tracker], CURLOPT_RETURNTRANSFER, true);
342			curl_setopt($handles[$tracker], CURLOPT_TIMEOUT, $timeout);
343			curl_multi_add_handle($curl, $handles[$tracker]);
344			}
345			}
346			do {
347			while (($state = curl_multi_exec($curl, $running)) == CURLM_CALL_MULTI_PERFORM) {
348			;
349			}
350			if ($state != CURLM_OK) {
351			continue;
352			}
353			while ($done = curl_multi_info_read($curl)) {
354			$info = curl_getinfo($done['handle']);
355			$tracker = explode('?', $info['url'], 2);
356			$tracker = array_shift($tracker);
357			if (empty($info['http_code'])) {
358			$scrape[$tracker] = 'Tracker request timeout (' . $timeout . 's)';
359			continue;
360			} elseif ($info['http_code'] != 200) {
361			$scrape[$tracker] = 'Tracker request failed (' . $info['http_code'] . ' code)';
362			continue;
363			}
364			$data = curl_multi_getcontent($done['handle']);
365			$stats = Decoder::decodeData($data);
366			curl_multi_remove_handle($curl, $done['handle']);
367			$scrape[$tracker] = empty($stats['files']) ?
368			'Empty scrape data' :
369			array_shift($stats['files']) + (empty($stats['flags']) ? array() : $stats['flags']);
370			}
371			} while ($running);
372			curl_multi_close($curl);
373			return $scrape;
374			}
375
376			/**
377			* @param string $filename
378			*
379			* @return string
380			*/
381			public function saveToFile($filename = null)
382			{
383			return file_put_contents($filename, Encoder::encode(get_object_vars($this)));
384			}
385
386			/**
387			*
388			* @return string
389			*/
390			public function save()
391			{
392			return file_put_contents($this->info['name'] . '.torrent', Encoder::encode(get_object_vars($this)));
393			}
394
395			/**
396			* @param bool $html
397			*
398			* @return string
399			*/
400			public function magnet($html = true)
401			{
402			$ampersand = $html ? '&' : '&';
403			return sprintf(
404			'magnet:?xt=urn:btih:%2$s%1$sdn=%3$s%1$sxl=%4$d%1$str=%5$s',
405			$ampersand,
406			$this->hash_info(),
407			urlencode($this->getName()),
408			$this->getSize(),
409			implode($ampersand . 'tr=', FileSystem::untier($this->announce()))
410			);
411			}
412
413
414			/**
415			* @param $data
416			* @param integer $piece_length
417			*
418			* @return array\|bool
419			*/
420			protected function build($data, $piece_length)
421			{
422			if (is_null($data)) {
423			return false;
424			} elseif (is_array($data) && FileSystem::is_list($data)) {
425			return $this->info = $this->files($data, $piece_length);
426			} elseif (is_dir($data)) {
427			return $this->info = $this->folder($data, $piece_length);
428			} elseif (
429			(is_file($data) && !FileSystem::isTorrent(file_get_contents($data)))
430			\|\| (FileSystem::url_exists($data) && !FileSystem::isTorrent(FileSystem::downloadTorrent($data)))
431			) {
432			return $this->info = $this->file($data, $piece_length);
433			}
434
435			return false;
436			}
437
438			/**
439			* @param null $void
440			*
441			* @return null
442			*/
443			protected function touch($void = null)
444			{
445			$this->createdBy = 'League\Torrent Class - http://github.com/iGusev/torrent';
446			$this->creationDate = time();
447			return $void;
448			}
449
450			/**
451			* @param $announce
452			* @param array $merge
453			*
454			* @return array
455			*/
456			protected static function announce_list($announce, $merge = array())
457			{
458			return array_map(create_function('$a', 'return (array) $a;'), array_merge((array) $announce, (array) $merge));
459			}
460
461			/**
462			* @param $announce
463			*
464			* @return array\|mixed
465			*/
466			protected static function first_announce($announce)
467			{
468			while (is_array($announce)) {
469			$announce = reset($announce);
470			}
471			return $announce;
472			}
473
474			/**
475			* @param $handle
476			* @param $piece_length
477			* @param bool $last
478			*
479			* @return bool\|string
480			*
481			* @throws Exception
482			*/
483			private function pieces($handle, $piece_length, $last = true)
484			{
485			static $piece, $length;
486			if (empty($length)) {
487			$length = $piece_length;
488			}
489			$pieces = null;
490			while (!feof($handle)) {
491			if (($length = strlen($piece .= fread($handle, $length))) == $piece_length) {
492			$pieces .= FileSystem::pack($piece);
493			} elseif (($length = $piece_length - $length) < 0) {
494			throw new Exception('Invalid piece length!');
495			}
496			}
497			fclose($handle);
498			return $pieces . ($last && $piece ? FileSystem::pack($piece) : null);
499			}
500
501			/**
502			* @param $file
503			* @param $piece_length
504			*
505			* @return array\|bool
506			*/
507			protected function file($file, $piece_length)
508			{
509
510			if (FileSystem::is_url($file)) {
511			$this->urlList($file);
512			}
513			$path = explode(DIRECTORY_SEPARATOR, $file);
514			return array(
515			'length' => FileSystem::filesize($file),
516			'name' => end($path),
517			'piece length' => $piece_length,
518			'pieces' => $this->pieces(self::fopen($file), $piece_length)
519			);
520			}
521
522			/**
523			* @param $files
524			* @param $piece_length
525			*
526			* @return array
527			*
528			* @throws Exception
529			*/
530			protected function files($files, $piece_length)
531			{
532			if (!FileSystem::is_url(current($files))) {
533			$files = array_map('realpath', $files);
534			}
535			sort($files);
536			usort($files,
537			create_function('$a,$b', 'return strrpos($a,DIRECTORY_SEPARATOR)-strrpos($b,DIRECTORY_SEPARATOR);'));
538			$first = current($files);
539			$root = dirname($first);
540			if ($url = FileSystem::is_url($first)) {
541			$this->urlList(dirname($root) . DIRECTORY_SEPARATOR);
542			}
543			$path = explode(DIRECTORY_SEPARATOR, dirname($url ? $first : realpath($first)));
544			$pieces = null;
545			$info_files = array();
546			$count = count($files) - 1;
547			foreach ($files as $i => $file) {
548			if ($path != array_intersect_assoc($file_path = explode(DIRECTORY_SEPARATOR, $file), $path)) {
549			throw new Exception('Files must be in the same folder: "' . $file . '" discarded');
550			}
551			$pieces .= $this->pieces(self::fopen($file), $piece_length, $count == $i);
552			$info_files[] = array(
553			'length' => FileSystem::filesize($file),
554			'path' => array_values(array_diff($file_path, $path))
555			);
556			}
557			return array(
558			'files' => $info_files,
559			'name' => end($path),
560			'piece length' => $piece_length,
561			'pieces' => $pieces
562			);
563			}
564
565			/**
566			* @param $dir
567			* @param $piece_length
568			*
569			* @return array
570			*/
571			protected function folder($dir, $piece_length)
572			{
573			return $this->files(FileSystem::scandir($dir), $piece_length);
574			}
575
576			/**
577			* @param $filename
578			*
579			* @return bool\|resource
580			*
581			* @throws Exception
582			*/
583			public static function fopen($filename)
584			{
585			if (!$handle = fopen($filename, 'r')) {
586			throw new Exception('Failed to open file: "' . $filename . '"');
587			}
588
589			return $handle;
590			}
591
592
593			}
594

iGusev / torrent

Issues (3)

Security Analysis no request data

src/Torrent.php (3 issues)

Labels

Severity

Introduced By

Upgrade to new PHP Analysis Engine

Duplication Side-by-Side

Filter issues like