WeburgDownload::configure() - Code Metrics - Inspection of "feat: weburg-download --limit" - popstas/transmission-cli - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( ceb518...f28846 )

by Stanislav

created 2019-03-02 09:36 UTC

WeburgDownload::configure() A

↳ Parent: WeburgDownload

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	48
rs	9.1344
c	0
b	0
f	0
cc	1
nc	1
nop	0

<?php

namespace Popstas\Transmission\Console\Command;

use Popstas\Transmission\Console\WeburgClient;
use Symfony\Component\Console\Helper\ProgressBar;
use Symfony\Component\Console\Input\ArrayInput;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

class WeburgDownload extends Command
{
    protected function configure()
    {
        parent::configure();
        $this
            ->setName('weburg-download')
            ->setAliases(['wd'])
            ->setDescription('Download torrents from weburg.net')
            ->addOption('download-torrents-dir', null, InputOption::VALUE_OPTIONAL, 'Torrents destination directory')
            ->addOption('days', null, InputOption::VALUE_OPTIONAL, 'Max age of series torrent')
            ->addOption('popular', null, InputOption::VALUE_NONE, 'Download only popular')
            ->addOption('series', null, InputOption::VALUE_NONE, 'Download only tracked series')
            ->addOption('query', null, InputOption::VALUE_OPTIONAL, 'Search and download movie from Weburg')
            ->addOption('movies-url', null, InputOption::VALUE_OPTIONAL, 'URL with movies on Weburg')
            ->addOption('limit', null, InputOption::VALUE_OPTIONAL, 'Limit torrent list')
            ->addOption('yes', 'y', InputOption::VALUE_NONE, 'Don\'t ask confirmation')
            ->addArgument('movie-id', null, 'Movie ID or URL')
            ->setHelp(<<<EOT
## Download torrents from Weburg.net

You can automatically download popular torrents from http://weburg.net/movies/new out of the box, use command:
```
transmission-cli weburg-download --download-torrents-dir=/path/to/torrents/directory [--limit=10]
```

or define `download-torrents-dir` in config and just:
```
transmission-cli weburg-download
```

You can automatically download new series, for add series to tracked list see `transmission-cli weburg-series-add`.
It is pretty simple:
```
transmission-cli weburg-series-add http://weburg.net/series/info/12345
```

After that command `weburg-download` also will download series from list for last day.
If you don't want to download popular torrents, but only new series, use command:
```
transmission-cli weburg-download --download-torrents-dir=/path/to/torrents/directory --series
```

## Add downloaded torrents to Transmission

After download all torrents, command call `torrent-add` command for each transmission-host from config.
If was defined `--transmission-host` option, then `torrent-add` will called only for this host.
EOT
            );
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $config = $this->getApplication()->getConfig();
        $weburgClient = $this->getApplication()->getWeburgClient();

        try {
            list($torrentsDir, $downloadDir) = $this->getTorrentsDirectory($input);

            $daysMax = $config->overrideConfig($input, 'days', 'weburg-series-max-age');
            $allowedMisses = $config->get('weburg-series-allowed-misses');

            $movieArgument = $input->getArgument('movie-id');
            if (isset($movieArgument)) {
                $torrentsUrls = $this->getMovieTorrentsUrls(
                    $weburgClient,
                    $movieArgument,
                    $daysMax,
                    $allowedMisses
                );
            } else {
                $torrentsUrls = $this->getTorrentsUrls(
                    $input,
                    $output,
                    $weburgClient,
                    $downloadDir,
                    $daysMax,
                    $allowedMisses
                );
            }

            $this->dryRun($input, $output, function () use (
                $input,
                $output,
                $weburgClient,
                $torrentsDir,
                $torrentsUrls
            ) {
                if (empty($torrentsUrls)) {
                    $output->writeln("\nNo torrents for download");
                    return;
                }

                $limit = $input->getOption('limit');
                if ($limit && count($torrentsUrls) > $limit) {
                    $output->writeln("\nLimit list from " . count($torrentsUrls) . " to $limit");
                    $torrentsUrls = array_slice($torrentsUrls, 0, $limit);
$x = 1;
$callable = function() use ($x) {
    $x = 2; // Not visible in outer scope. If you would like this, how
            // about using a different variable name than $x?
};

$callable();
var_dump($x); // integer(1)
                }

                $downloadedFiles = [];
                foreach ($torrentsUrls as $torrentUrl) {
                    $downloadedFiles[] = $weburgClient->downloadTorrent($torrentUrl, $torrentsDir);
                }

                $downloadedFiles = $this->filterByLists($downloadedFiles);
                if (!empty($downloadedFiles)) {
                    $this->addTorrents($input, $output, $downloadedFiles);
                } else {
                    $output->writeln("\nAll torrents filtered by black/whitelists");
                }
            }, 'dry-run, don\'t really download');
        } catch (\RuntimeException $e) {
            $output->writeln($e->getMessage());
            return 1;
        }

        return 0;
    }

    private function getTorrentsUrls(
        InputInterface $input,
        OutputInterface $output,
        WeburgClient $weburgClient,
        $downloadDir,
        $daysMax,
        $allowedMisses
    ) {
        $torrentsUrls = [];

        if ($input->getOption('query')) {
            $torrentsUrls = array_merge(
                $torrentsUrls,
                $this->getTorrentsUrlByQuery($output, $weburgClient, $downloadDir, $input->getOption('query'))
            );
        }

        if (!$input->getOption('popular') && !$input->getOption('series') && !$input->getOption('query')) {
            $input->setOption('popular', true);
            $input->setOption('series', true);
        }

        if ($input->getOption('popular')) {
            $moviesUrl = $input->getOption('movies-url');
            $torrentsUrls = array_merge(
                $torrentsUrls,
                $this->getPopularTorrentsUrls($output, $weburgClient, $downloadDir, $moviesUrl)
            );
        }

        if ($input->getOption('series')) {
            $torrentsUrls = array_merge(
                $torrentsUrls,
                $this->getTrackedSeriesUrls($output, $weburgClient, $daysMax, $allowedMisses)
            );
        }

        return $torrentsUrls;
    }

    public function getTorrentsUrlByQuery(OutputInterface $output, WeburgClient $weburgClient, $downloadDir, $query)
    {
        $torrentsUrls = [];

        $logger = $this->getApplication()->getLogger();

        $movieId = $weburgClient->getMovieIdByQuery($query);
        if (!$movieId) {
            $output->writeln("\nNot found any for query $query");
        }

        $downloadedLogfile = $downloadDir . '/' . $movieId;

        $isDownloaded = file_exists($downloadedLogfile);
        if ($isDownloaded) {
            $output->writeln("\nMovie $query was downloaded before");
        }

        $movieInfo = $weburgClient->getMovieInfoById($movieId);
        foreach (array_keys($movieInfo) as $infoField) {

            if (!isset($movieInfo[$infoField])) {
                $logger->warning('Cannot find ' . $infoField . ' in movie ' . $movieId);
            }
        }

        $movieUrls = $weburgClient->getMovieTorrentUrlsById($movieId);
        $torrentsUrls = array_merge($torrentsUrls, $movieUrls);
        $logger->info('Download movie ' . $movieId . ': ' . $movieInfo['title']);

        file_put_contents(
            $downloadedLogfile,
            date('Y-m-d H:i:s') . "\n" . implode("\n", $torrentsUrls)
        );

        return $torrentsUrls;
    }

    public function getPopularTorrentsUrls(
        OutputInterface $output,
        WeburgClient $weburgClient,
        $downloadDir,
        $moviesUrl = null
    ) {
        $torrentsUrls = [];

        $config = $this->getApplication()->getConfig();
        $logger = $this->getApplication()->getLogger();

        $moviesIds = $weburgClient->getMoviesIds($moviesUrl);

        $output->writeln("\nDownloading popular torrents");

        $progress = new ProgressBar($output, count($moviesIds));
        $progress->start();

        foreach ($moviesIds as $movieId) {
            $progress->setMessage('Check movie ' . $movieId . '...');
            $progress->advance();

            $downloadedLogfile = $downloadDir . '/' . $movieId;

            $isDownloaded = file_exists($downloadedLogfile);
            if ($isDownloaded) {
                continue;
            }

            $movieInfo = $weburgClient->getMovieInfoById($movieId);
            foreach (array_keys($movieInfo) as $infoField) {

                if (!isset($movieInfo[$infoField])) {
                    $logger->warning('Cannot find ' . $infoField . ' in movie ' . $movieId);
                }
            }

            $isTorrentPopular = $weburgClient->isTorrentPopular(
                $movieInfo,
                $config->get('download-comments-min'),
                $config->get('download-imdb-min'),
                $config->get('download-kinopoisk-min'),
                $config->get('download-votes-min')
            );

            if ($isTorrentPopular) {
                $progress->setMessage('Download movie ' . $movieId . '...');

                $movieUrls = $weburgClient->getMovieTorrentUrlsById($movieId);
                $torrentsUrls = array_merge($torrentsUrls, $movieUrls);
                $logger->info('Download movie ' . $movieId . ': ' . $movieInfo['title']);

                file_put_contents(
                    $downloadedLogfile,
                    date('Y-m-d H:i:s') . "\n" . implode("\n", $torrentsUrls)
                );
            }
        }

        $progress->finish();

        return $torrentsUrls;
    }

    /**
     * @param OutputInterface $output
     * @param WeburgClient $weburgClient
     * @param $daysMax
     * @param $allowedMisses
     * @return array
     */
    public function getTrackedSeriesUrls(OutputInterface $output, WeburgClient $weburgClient, $daysMax, $allowedMisses)
    {
        $torrentsUrls = [];

        $config = $this->getApplication()->getConfig();

        $seriesList = $config->get('weburg-series-list');
        if (!$seriesList) {
            return [];
        }

        $output->writeln("\nDownloading tracked series");

        $progress = new ProgressBar($output, count($seriesList));
        $progress->start();

        foreach ($seriesList as $seriesItem) {
            if (is_array($seriesItem)) {
                $seriesId = $seriesItem['id'];
                $seriesTitle = isset($seriesItem['title']) && $seriesItem['title'] ? $seriesItem['title'] : $seriesId;
            } else {
                $seriesId = $seriesTitle = $seriesItem;
            }
            $progress->setMessage('Check series ' . $seriesTitle . '...');
            $progress->advance();

            $movieInfo = $weburgClient->getMovieInfoById($seriesId);
            $seriesUrls = $weburgClient->getSeriesTorrents($seriesId, $movieInfo['hashes'], $daysMax, $allowedMisses);
            $torrentsUrls = array_merge($torrentsUrls, $seriesUrls);
        }

        $progress->finish();

        return $torrentsUrls;
    }

    /**
     * @param WeburgClient $weburgClient
     * @param $movieId
     * @param $daysMax
     * @param $allowedMisses
     * @return array
     */
    public function getMovieTorrentsUrls(WeburgClient $weburgClient, $movieId, $daysMax, $allowedMisses)
    {
        $torrentsUrls = [];
        $logger = $this->getApplication()->getLogger();

        $movieId = $weburgClient->cleanMovieId($movieId);
        if (!$movieId) {
            throw new \RuntimeException($movieId . ' seems not weburg movie ID or URL');
        }

        $movieInfo = $weburgClient->getMovieInfoById($movieId);
        $logger->info('Search series ' . $movieId);
        if (!empty($movieInfo['hashes'])) {
            $seriesUrls = $weburgClient->getSeriesTorrents($movieId, $movieInfo['hashes'], $daysMax, $allowedMisses);
            $torrentsUrls = array_merge($torrentsUrls, $seriesUrls);

            if (count($seriesUrls)) {
                $logger->info('Download series ' . $movieId . ': '
                    . $movieInfo['title'] . ' (' . count($seriesUrls) . ')');
            }
        } else {
            $torrentsUrls = array_merge($torrentsUrls, $weburgClient->getMovieTorrentUrlsById($movieId));
        }

        return $torrentsUrls;
    }

    /**
     * @param InputInterface $input
     * @return array
     * @throws \RuntimeException
     */
    private function getTorrentsDirectory(InputInterface $input)
    {
        $config = $this->getApplication()->getConfig();

        $torrentsDir = $config->overrideConfig($input, 'download-torrents-dir');
        if (!$torrentsDir) {
            throw new \RuntimeException('Destination directory not defined. '
                . 'Use command with --download-torrents-dir=/path/to/dir parameter '
                . 'or define destination directory \'download-torrents-dir\' in config file.');
        }

        if (!file_exists($torrentsDir)) {
            throw new \RuntimeException('Destination directory not exists: ' . $torrentsDir);
        }

        $downloadDir = $torrentsDir . '/downloaded';
        if (!file_exists($downloadDir)) {
            mkdir($downloadDir, 0777);
        }

        return [$torrentsDir, $downloadDir];
    }

    private function filterByLists(array $torrentFiles)
    {
        $config = $this->getApplication()->getConfig();
        $logger = $this->getApplication()->getLogger();

        $whitelist = $config->get('download-filename-whitelist');
        $blacklist = $config->get('download-filename-blacklist');

        $torrentFiles = array_filter($torrentFiles, function ($torrentFile) use ($whitelist, $blacklist, $logger) {
            if (!empty($whitelist)) {
                $matched = false;
                foreach ($whitelist as $white) {
                    if (preg_match('/' . $white . '/i', $torrentFile)) {
                        $logger->info($torrentFile . ' matched whitelist: ' . $white);
                        $matched = true;
                    }
                }
                if (!$matched) {
                    $logger->info($torrentFile . ' not matched any whitelist: ' . implode(', ', $whitelist));
                    return false;
                }
            }
            if (!empty($blacklist)) {
                foreach ($blacklist as $black) {
                    if (preg_match('/' . $black . '/i', $torrentFile)) {
                        $logger->info($torrentFile . ' matched blacklist: ' . $black);
                        return false;
                    }
                }
            }
            return true;
        });
        return $torrentFiles;
    }

    private function addTorrents(InputInterface $input, OutputInterface $output, array $torrentFiles)
    {
        $config = $this->getApplication()->getConfig();
        $hosts = [];

        if (empty($input->getOption('transmission-host'))) {
            $transmissionConnects = $config->get('transmission');
            foreach ($transmissionConnects as $transmissionConnect) {
                $hosts[] = $transmissionConnect['host'];
            }
        } else {
            $hosts[] = $config->get('transmission-host');
        }

        foreach ($hosts as $host) {
            $command = $this->getApplication()->find('torrent-add');
            $arguments = array(
                'command'             => 'torrent-add',
                'torrent-files'       => $torrentFiles,
                '--transmission-host' => $host,
                '--yes'               => $input->getOption('yes'),
                '--dry-run'           => $input->getOption('dry-run'),
            );

            $addInput = new ArrayInput($arguments);
            $output->writeln("\nAdd " . count($torrentFiles) . " torrents to " . $host);
            $command->run($addInput, $output);
        }
    }
}


Push — master ( ceb518...f28846 )

WeburgDownload::configure() A

Complexity

Size

Duplication

Importance

Change not visible in outer-scope

Change visible in outer-scope

1		<?php
2
3		namespace Popstas\Transmission\Console\Command;
4
5		use Popstas\Transmission\Console\WeburgClient;
6		use Symfony\Component\Console\Helper\ProgressBar;
7		use Symfony\Component\Console\Input\ArrayInput;
8		use Symfony\Component\Console\Input\InputInterface;
9		use Symfony\Component\Console\Input\InputOption;
10		use Symfony\Component\Console\Output\OutputInterface;
11
12		class WeburgDownload extends Command
13		{
14		protected function configure()
15		{
16		parent::configure();
17		$this
18		->setName('weburg-download')
19		->setAliases(['wd'])
20		->setDescription('Download torrents from weburg.net')
21		->addOption('download-torrents-dir', null, InputOption::VALUE_OPTIONAL, 'Torrents destination directory')
22		->addOption('days', null, InputOption::VALUE_OPTIONAL, 'Max age of series torrent')
23		->addOption('popular', null, InputOption::VALUE_NONE, 'Download only popular')
24		->addOption('series', null, InputOption::VALUE_NONE, 'Download only tracked series')
25		->addOption('query', null, InputOption::VALUE_OPTIONAL, 'Search and download movie from Weburg')
26		->addOption('movies-url', null, InputOption::VALUE_OPTIONAL, 'URL with movies on Weburg')
27		->addOption('limit', null, InputOption::VALUE_OPTIONAL, 'Limit torrent list')
28		->addOption('yes', 'y', InputOption::VALUE_NONE, 'Don\'t ask confirmation')
29		->addArgument('movie-id', null, 'Movie ID or URL')
30		->setHelp(<<<EOT
31		## Download torrents from Weburg.net
32
33		You can automatically download popular torrents from http://weburg.net/movies/new out of the box, use command:
34		```
35		transmission-cli weburg-download --download-torrents-dir=/path/to/torrents/directory [--limit=10]
36		```
37
38		or define `download-torrents-dir` in config and just:
39		```
40		transmission-cli weburg-download
41		```
42
43		You can automatically download new series, for add series to tracked list see `transmission-cli weburg-series-add`.
44		It is pretty simple:
45		```
46		transmission-cli weburg-series-add http://weburg.net/series/info/12345
47		```
48
49		After that command `weburg-download` also will download series from list for last day.
50		If you don't want to download popular torrents, but only new series, use command:
51		```
52		transmission-cli weburg-download --download-torrents-dir=/path/to/torrents/directory --series
53		```
54
55		## Add downloaded torrents to Transmission
56
57		After download all torrents, command call `torrent-add` command for each transmission-host from config.
58		If was defined `--transmission-host` option, then `torrent-add` will called only for this host.
59		EOT
60		);
61		}
62
63		protected function execute(InputInterface $input, OutputInterface $output)
64		{
65		$config = $this->getApplication()->getConfig();
66		$weburgClient = $this->getApplication()->getWeburgClient();
67
68		try {
69		list($torrentsDir, $downloadDir) = $this->getTorrentsDirectory($input);
70
71		$daysMax = $config->overrideConfig($input, 'days', 'weburg-series-max-age');
72		$allowedMisses = $config->get('weburg-series-allowed-misses');
73
74		$movieArgument = $input->getArgument('movie-id');
75		if (isset($movieArgument)) {
76		$torrentsUrls = $this->getMovieTorrentsUrls(
77		$weburgClient,
78		$movieArgument,
79		$daysMax,
80		$allowedMisses
81		);
82		} else {
83		$torrentsUrls = $this->getTorrentsUrls(
84		$input,
85		$output,
86		$weburgClient,
87		$downloadDir,
88		$daysMax,
89		$allowedMisses
90		);
91		}
92
93		$this->dryRun($input, $output, function () use (
94		$input,
95		$output,
96		$weburgClient,
97		$torrentsDir,
98		$torrentsUrls
99		) {
100		if (empty($torrentsUrls)) {
101		$output->writeln("\nNo torrents for download");
102		return;
103		}
104
105		$limit = $input->getOption('limit');
106		if ($limit && count($torrentsUrls) > $limit) {
107		$output->writeln("\nLimit list from " . count($torrentsUrls) . " to $limit");
108		$torrentsUrls = array_slice($torrentsUrls, 0, $limit);
		0 ignored issues – show Bug introduced 2019-03-02 09:37 UTC by Report Bug Copy Issue Report Consider using a different name than the imported variable `$torrentsUrls`, or did you forget to import by reference? It seems like you are assigning to a variable which was imported through a `use` statement which was not imported by reference. For clarity, we suggest to use a different name or import by reference depending on whether you would like to have the change visibile in outer-scope. Change not visible in outer-scope $x = 1; $callable = function() use ($x) { $x = 2; // Not visible in outer scope. If you would like this, how // about using a different variable name than $x? }; $callable(); var_dump($x); // integer(1) Change visible in outer-scope $x = 1; $callable = function() use (&$x) { $x = 2; }; $callable(); var_dump($x); // integer(2) Loading history...
109		}
110
111		$downloadedFiles = [];
112		foreach ($torrentsUrls as $torrentUrl) {
113		$downloadedFiles[] = $weburgClient->downloadTorrent($torrentUrl, $torrentsDir);
114		}
115
116		$downloadedFiles = $this->filterByLists($downloadedFiles);
117		if (!empty($downloadedFiles)) {
118		$this->addTorrents($input, $output, $downloadedFiles);
119		} else {
120		$output->writeln("\nAll torrents filtered by black/whitelists");
121		}
122		}, 'dry-run, don\'t really download');
123		} catch (\RuntimeException $e) {
124		$output->writeln($e->getMessage());
125		return 1;
126		}
127
128		return 0;
129		}
130
131		private function getTorrentsUrls(
132		InputInterface $input,
133		OutputInterface $output,
134		WeburgClient $weburgClient,
135		$downloadDir,
136		$daysMax,
137		$allowedMisses
138		) {
139		$torrentsUrls = [];
140
141		if ($input->getOption('query')) {
142		$torrentsUrls = array_merge(
143		$torrentsUrls,
144		$this->getTorrentsUrlByQuery($output, $weburgClient, $downloadDir, $input->getOption('query'))
145		);
146		}
147
148		if (!$input->getOption('popular') && !$input->getOption('series') && !$input->getOption('query')) {
149		$input->setOption('popular', true);
150		$input->setOption('series', true);
151		}
152
153		if ($input->getOption('popular')) {
154		$moviesUrl = $input->getOption('movies-url');
155		$torrentsUrls = array_merge(
156		$torrentsUrls,
157		$this->getPopularTorrentsUrls($output, $weburgClient, $downloadDir, $moviesUrl)
158		);
159		}
160
161		if ($input->getOption('series')) {
162		$torrentsUrls = array_merge(
163		$torrentsUrls,
164		$this->getTrackedSeriesUrls($output, $weburgClient, $daysMax, $allowedMisses)
165		);
166		}
167
168		return $torrentsUrls;
169		}
170
171		public function getTorrentsUrlByQuery(OutputInterface $output, WeburgClient $weburgClient, $downloadDir, $query)
172		{
173		$torrentsUrls = [];
174
175		$logger = $this->getApplication()->getLogger();
176
177		$movieId = $weburgClient->getMovieIdByQuery($query);
178		if (!$movieId) {
179		$output->writeln("\nNot found any for query $query");
180		}
181
182		$downloadedLogfile = $downloadDir . '/' . $movieId;
183
184		$isDownloaded = file_exists($downloadedLogfile);
185		if ($isDownloaded) {
186		$output->writeln("\nMovie $query was downloaded before");
187		}
188
189		$movieInfo = $weburgClient->getMovieInfoById($movieId);
190	View Code Duplication	foreach (array_keys($movieInfo) as $infoField) {
		0 ignored issues – show Duplication introduced 2019-03-01 16:17 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
191		if (!isset($movieInfo[$infoField])) {
192		$logger->warning('Cannot find ' . $infoField . ' in movie ' . $movieId);
193		}
194		}
195
196		$movieUrls = $weburgClient->getMovieTorrentUrlsById($movieId);
197		$torrentsUrls = array_merge($torrentsUrls, $movieUrls);
198		$logger->info('Download movie ' . $movieId . ': ' . $movieInfo['title']);
199
200		file_put_contents(
201		$downloadedLogfile,
202		date('Y-m-d H:i:s') . "\n" . implode("\n", $torrentsUrls)
203		);
204
205		return $torrentsUrls;
206		}
207
208		public function getPopularTorrentsUrls(
209		OutputInterface $output,
210		WeburgClient $weburgClient,
211		$downloadDir,
212		$moviesUrl = null
213		) {
214		$torrentsUrls = [];
215
216		$config = $this->getApplication()->getConfig();
217		$logger = $this->getApplication()->getLogger();
218
219		$moviesIds = $weburgClient->getMoviesIds($moviesUrl);
220
221		$output->writeln("\nDownloading popular torrents");
222
223		$progress = new ProgressBar($output, count($moviesIds));
224		$progress->start();
225
226		foreach ($moviesIds as $movieId) {
227		$progress->setMessage('Check movie ' . $movieId . '...');
228		$progress->advance();
229
230		$downloadedLogfile = $downloadDir . '/' . $movieId;
231
232		$isDownloaded = file_exists($downloadedLogfile);
233		if ($isDownloaded) {
234		continue;
235		}
236
237		$movieInfo = $weburgClient->getMovieInfoById($movieId);
238	View Code Duplication	foreach (array_keys($movieInfo) as $infoField) {
		0 ignored issues – show Duplication introduced 2019-03-01 16:17 UTC by Report Bug Copy Issue Report This code seems to be duplicated across your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
239		if (!isset($movieInfo[$infoField])) {
240		$logger->warning('Cannot find ' . $infoField . ' in movie ' . $movieId);
241		}
242		}
243
244		$isTorrentPopular = $weburgClient->isTorrentPopular(
245		$movieInfo,
246		$config->get('download-comments-min'),
247		$config->get('download-imdb-min'),
248		$config->get('download-kinopoisk-min'),
249		$config->get('download-votes-min')
250		);
251
252		if ($isTorrentPopular) {
253		$progress->setMessage('Download movie ' . $movieId . '...');
254
255		$movieUrls = $weburgClient->getMovieTorrentUrlsById($movieId);
256		$torrentsUrls = array_merge($torrentsUrls, $movieUrls);
257		$logger->info('Download movie ' . $movieId . ': ' . $movieInfo['title']);
258
259		file_put_contents(
260		$downloadedLogfile,
261		date('Y-m-d H:i:s') . "\n" . implode("\n", $torrentsUrls)
262		);
263		}
264		}
265
266		$progress->finish();
267
268		return $torrentsUrls;
269		}
270
271		/**
272		* @param OutputInterface $output
273		* @param WeburgClient $weburgClient
274		* @param $daysMax
275		* @param $allowedMisses
276		* @return array
277		*/
278		public function getTrackedSeriesUrls(OutputInterface $output, WeburgClient $weburgClient, $daysMax, $allowedMisses)
279		{
280		$torrentsUrls = [];
281
282		$config = $this->getApplication()->getConfig();
283
284		$seriesList = $config->get('weburg-series-list');
285		if (!$seriesList) {
286		return [];
287		}
288
289		$output->writeln("\nDownloading tracked series");
290
291		$progress = new ProgressBar($output, count($seriesList));
292		$progress->start();
293
294		foreach ($seriesList as $seriesItem) {
295		if (is_array($seriesItem)) {
296		$seriesId = $seriesItem['id'];
297		$seriesTitle = isset($seriesItem['title']) && $seriesItem['title'] ? $seriesItem['title'] : $seriesId;
298		} else {
299		$seriesId = $seriesTitle = $seriesItem;
300		}
301		$progress->setMessage('Check series ' . $seriesTitle . '...');
302		$progress->advance();
303
304		$movieInfo = $weburgClient->getMovieInfoById($seriesId);
305		$seriesUrls = $weburgClient->getSeriesTorrents($seriesId, $movieInfo['hashes'], $daysMax, $allowedMisses);
306		$torrentsUrls = array_merge($torrentsUrls, $seriesUrls);
307		}
308
309		$progress->finish();
310
311		return $torrentsUrls;
312		}
313
314		/**
315		* @param WeburgClient $weburgClient
316		* @param $movieId
317		* @param $daysMax
318		* @param $allowedMisses
319		* @return array
320		*/
321		public function getMovieTorrentsUrls(WeburgClient $weburgClient, $movieId, $daysMax, $allowedMisses)
322		{
323		$torrentsUrls = [];
324		$logger = $this->getApplication()->getLogger();
325
326		$movieId = $weburgClient->cleanMovieId($movieId);
327		if (!$movieId) {
328		throw new \RuntimeException($movieId . ' seems not weburg movie ID or URL');
329		}
330
331		$movieInfo = $weburgClient->getMovieInfoById($movieId);
332		$logger->info('Search series ' . $movieId);
333		if (!empty($movieInfo['hashes'])) {
334		$seriesUrls = $weburgClient->getSeriesTorrents($movieId, $movieInfo['hashes'], $daysMax, $allowedMisses);
335		$torrentsUrls = array_merge($torrentsUrls, $seriesUrls);
336
337		if (count($seriesUrls)) {
338		$logger->info('Download series ' . $movieId . ': '
339		. $movieInfo['title'] . ' (' . count($seriesUrls) . ')');
340		}
341		} else {
342		$torrentsUrls = array_merge($torrentsUrls, $weburgClient->getMovieTorrentUrlsById($movieId));
343		}
344
345		return $torrentsUrls;
346		}
347
348		/**
349		* @param InputInterface $input
350		* @return array
351		* @throws \RuntimeException
352		*/
353		private function getTorrentsDirectory(InputInterface $input)
354		{
355		$config = $this->getApplication()->getConfig();
356
357		$torrentsDir = $config->overrideConfig($input, 'download-torrents-dir');
358		if (!$torrentsDir) {
359		throw new \RuntimeException('Destination directory not defined. '
360		. 'Use command with --download-torrents-dir=/path/to/dir parameter '
361		. 'or define destination directory \'download-torrents-dir\' in config file.');
362		}
363
364		if (!file_exists($torrentsDir)) {
365		throw new \RuntimeException('Destination directory not exists: ' . $torrentsDir);
366		}
367
368		$downloadDir = $torrentsDir . '/downloaded';
369		if (!file_exists($downloadDir)) {
370		mkdir($downloadDir, 0777);
371		}
372
373		return [$torrentsDir, $downloadDir];
374		}
375
376		private function filterByLists(array $torrentFiles)
377		{
378		$config = $this->getApplication()->getConfig();
379		$logger = $this->getApplication()->getLogger();
380
381		$whitelist = $config->get('download-filename-whitelist');
382		$blacklist = $config->get('download-filename-blacklist');
383
384		$torrentFiles = array_filter($torrentFiles, function ($torrentFile) use ($whitelist, $blacklist, $logger) {
385		if (!empty($whitelist)) {
386		$matched = false;
387		foreach ($whitelist as $white) {
388		if (preg_match('/' . $white . '/i', $torrentFile)) {
389		$logger->info($torrentFile . ' matched whitelist: ' . $white);
390		$matched = true;
391		}
392		}
393		if (!$matched) {
394		$logger->info($torrentFile . ' not matched any whitelist: ' . implode(', ', $whitelist));
395		return false;
396		}
397		}
398		if (!empty($blacklist)) {
399		foreach ($blacklist as $black) {
400		if (preg_match('/' . $black . '/i', $torrentFile)) {
401		$logger->info($torrentFile . ' matched blacklist: ' . $black);
402		return false;
403		}
404		}
405		}
406		return true;
407		});
408		return $torrentFiles;
409		}
410
411		private function addTorrents(InputInterface $input, OutputInterface $output, array $torrentFiles)
412		{
413		$config = $this->getApplication()->getConfig();
414		$hosts = [];
415
416		if (empty($input->getOption('transmission-host'))) {
417		$transmissionConnects = $config->get('transmission');
418		foreach ($transmissionConnects as $transmissionConnect) {
419		$hosts[] = $transmissionConnect['host'];
420		}
421		} else {
422		$hosts[] = $config->get('transmission-host');
423		}
424
425		foreach ($hosts as $host) {
426		$command = $this->getApplication()->find('torrent-add');
427		$arguments = array(
428		'command' => 'torrent-add',
429		'torrent-files' => $torrentFiles,
430		'--transmission-host' => $host,
431		'--yes' => $input->getOption('yes'),
432		'--dry-run' => $input->getOption('dry-run'),
433		);
434
435		$addInput = new ArrayInput($arguments);
436		$output->writeln("\nAdd " . count($torrentFiles) . " torrents to " . $host);
437		$command->run($addInput, $output);
438		}
439		}
440		}
441

popstas / transmission-cli

Push — master ( ceb518...f28846 )

WeburgDownload::configure() A

Complexity

Size

Duplication

Importance

Change not visible in outer-scope

Change visible in outer-scope

Duplication Side-by-Side

Filter issues like