@@ -13,8 +13,7 @@ |
||
| 13 | 13 | public static function getTorrentAge($torrent) |
| 14 | 14 | { |
| 15 | 15 | $date = isset($torrent[Torrent\Get::DONE_DATE]) && $torrent[Torrent\Get::DONE_DATE] ? |
| 16 | - $torrent[Torrent\Get::DONE_DATE] : |
|
| 17 | - (isset($torrent[Torrent\Get::ADDED_DATE]) ? $torrent[Torrent\Get::ADDED_DATE] : 0); |
|
| 16 | + $torrent[Torrent\Get::DONE_DATE] : (isset($torrent[Torrent\Get::ADDED_DATE]) ? $torrent[Torrent\Get::ADDED_DATE] : 0); |
|
| 18 | 17 | return $date ? time() - $date : 0; |
| 19 | 18 | } |
| 20 | 19 | |
@@ -64,7 +64,7 @@ |
||
| 64 | 64 | } |
| 65 | 65 | } |
| 66 | 66 | |
| 67 | - $this->dryRun($input, $output, function () use ($influxDbClient, $points) { |
|
| 67 | + $this->dryRun($input, $output, function() use ($influxDbClient, $points) { |
|
| 68 | 68 | $influxDbClient->writePoints($points); |
| 69 | 69 | }, 'dry-run, don\'t really send points'); |
| 70 | 70 | } catch (\Exception $e) { |
@@ -43,7 +43,7 @@ |
||
| 43 | 43 | $obsoleteList = TorrentListUtils::getObsoleteTorrents($torrentList); |
| 44 | 44 | if (!empty($obsoleteList)) { |
| 45 | 45 | $output->writeln('<comment>Found obsolete torrents, ' |
| 46 | - . 'remove it using transmission-cli torrent-remove-duplicates</comment>'); |
|
| 46 | + . 'remove it using transmission-cli torrent-remove-duplicates</comment>'); |
|
| 47 | 47 | return 1; |
| 48 | 48 | } |
| 49 | 49 | } |
@@ -86,7 +86,7 @@ discard block |
||
| 86 | 86 | ); |
| 87 | 87 | } |
| 88 | 88 | |
| 89 | - $this->dryRun($input, $output, function () use ( |
|
| 89 | + $this->dryRun($input, $output, function() use ( |
|
| 90 | 90 | $input, |
| 91 | 91 | $output, |
| 92 | 92 | $weburgClient, |
@@ -155,10 +155,10 @@ discard block |
||
| 155 | 155 | $progress->start(); |
| 156 | 156 | |
| 157 | 157 | foreach ($moviesIds as $movieId) { |
| 158 | - $progress->setMessage('Check movie ' . $movieId . '...'); |
|
| 158 | + $progress->setMessage('Check movie '.$movieId.'...'); |
|
| 159 | 159 | $progress->advance(); |
| 160 | 160 | |
| 161 | - $downloadedLogfile = $downloadDir . '/' . $movieId; |
|
| 161 | + $downloadedLogfile = $downloadDir.'/'.$movieId; |
|
| 162 | 162 | |
| 163 | 163 | $isDownloaded = file_exists($downloadedLogfile); |
| 164 | 164 | if ($isDownloaded) { |
@@ -168,7 +168,7 @@ discard block |
||
| 168 | 168 | $movieInfo = $weburgClient->getMovieInfoById($movieId); |
| 169 | 169 | foreach (array_keys($movieInfo) as $infoField) { |
| 170 | 170 | if (!isset($movieInfo[$infoField])) { |
| 171 | - $logger->warning('Cannot find ' . $infoField . ' in movie ' . $movieId); |
|
| 171 | + $logger->warning('Cannot find '.$infoField.' in movie '.$movieId); |
|
| 172 | 172 | } |
| 173 | 173 | } |
| 174 | 174 | |
@@ -181,15 +181,15 @@ discard block |
||
| 181 | 181 | ); |
| 182 | 182 | |
| 183 | 183 | if ($isTorrentPopular) { |
| 184 | - $progress->setMessage('Download movie ' . $movieId . '...'); |
|
| 184 | + $progress->setMessage('Download movie '.$movieId.'...'); |
|
| 185 | 185 | |
| 186 | 186 | $movieUrls = $weburgClient->getMovieTorrentUrlsById($movieId); |
| 187 | 187 | $torrentsUrls = array_merge($torrentsUrls, $movieUrls); |
| 188 | - $logger->info('Download movie ' . $movieId . ': ' . $movieInfo['title']); |
|
| 188 | + $logger->info('Download movie '.$movieId.': '.$movieInfo['title']); |
|
| 189 | 189 | |
| 190 | 190 | file_put_contents( |
| 191 | 191 | $downloadedLogfile, |
| 192 | - date('Y-m-d H:i:s') . "\n" . implode("\n", $torrentsUrls) |
|
| 192 | + date('Y-m-d H:i:s')."\n".implode("\n", $torrentsUrls) |
|
| 193 | 193 | ); |
| 194 | 194 | } |
| 195 | 195 | } |
@@ -223,7 +223,7 @@ discard block |
||
| 223 | 223 | $progress->start(); |
| 224 | 224 | |
| 225 | 225 | foreach ($seriesIds as $seriesId) { |
| 226 | - $progress->setMessage('Check series ' . $seriesId . '...'); |
|
| 226 | + $progress->setMessage('Check series '.$seriesId.'...'); |
|
| 227 | 227 | $progress->advance(); |
| 228 | 228 | |
| 229 | 229 | $movieInfo = $weburgClient->getMovieInfoById($seriesId); |
@@ -250,18 +250,18 @@ discard block |
||
| 250 | 250 | |
| 251 | 251 | $movieId = $weburgClient->cleanMovieId($movieId); |
| 252 | 252 | if (!$movieId) { |
| 253 | - throw new \RuntimeException($movieId . ' seems not weburg movie ID or URL'); |
|
| 253 | + throw new \RuntimeException($movieId.' seems not weburg movie ID or URL'); |
|
| 254 | 254 | } |
| 255 | 255 | |
| 256 | 256 | $movieInfo = $weburgClient->getMovieInfoById($movieId); |
| 257 | - $logger->info('Search series ' . $movieId); |
|
| 257 | + $logger->info('Search series '.$movieId); |
|
| 258 | 258 | if (!empty($movieInfo['hashes'])) { |
| 259 | 259 | $seriesUrls = $weburgClient->getSeriesTorrents($movieId, $movieInfo['hashes'], $daysMax, $allowedMisses); |
| 260 | 260 | $torrentsUrls = array_merge($torrentsUrls, $seriesUrls); |
| 261 | 261 | |
| 262 | 262 | if (count($seriesUrls)) { |
| 263 | - $logger->info('Download series ' . $movieId . ': ' |
|
| 264 | - . $movieInfo['title'] . ' (' . count($seriesUrls) . ')'); |
|
| 263 | + $logger->info('Download series '.$movieId.': ' |
|
| 264 | + . $movieInfo['title'].' ('.count($seriesUrls).')'); |
|
| 265 | 265 | } |
| 266 | 266 | } else { |
| 267 | 267 | $torrentsUrls = array_merge($torrentsUrls, $weburgClient->getMovieTorrentUrlsById($movieId)); |
@@ -287,10 +287,10 @@ discard block |
||
| 287 | 287 | } |
| 288 | 288 | |
| 289 | 289 | if (!file_exists($torrentsDir)) { |
| 290 | - throw new \RuntimeException('Destination directory not exists: ' . $torrentsDir); |
|
| 290 | + throw new \RuntimeException('Destination directory not exists: '.$torrentsDir); |
|
| 291 | 291 | } |
| 292 | 292 | |
| 293 | - $downloadDir = $torrentsDir . '/downloaded'; |
|
| 293 | + $downloadDir = $torrentsDir.'/downloaded'; |
|
| 294 | 294 | if (!file_exists($downloadDir)) { |
| 295 | 295 | mkdir($downloadDir, 0777); |
| 296 | 296 | } |
@@ -321,7 +321,7 @@ discard block |
||
| 321 | 321 | ); |
| 322 | 322 | |
| 323 | 323 | $addInput = new ArrayInput($arguments); |
| 324 | - $output->writeln("\nAdd torrents to " . $host); |
|
| 324 | + $output->writeln("\nAdd torrents to ".$host); |
|
| 325 | 325 | $command->run($addInput, $output); |
| 326 | 326 | } |
| 327 | 327 | } |
@@ -60,7 +60,7 @@ discard block |
||
| 60 | 60 | |
| 61 | 61 | if (count($notExistsIds)) { |
| 62 | 62 | foreach ($notExistsIds as $notExistsId) { |
| 63 | - $output->writeln($notExistsId . ' not exists'); |
|
| 63 | + $output->writeln($notExistsId.' not exists'); |
|
| 64 | 64 | } |
| 65 | 65 | return 1; |
| 66 | 66 | } |
@@ -77,7 +77,7 @@ discard block |
||
| 77 | 77 | } |
| 78 | 78 | } |
| 79 | 79 | |
| 80 | - $this->dryRun($input, $output, function () use ($config, $torrentList, $client, $input, $output) { |
|
| 80 | + $this->dryRun($input, $output, function() use ($config, $torrentList, $client, $input, $output) { |
|
| 81 | 81 | $influxDbClient = $this->getApplication()->getInfluxDbClient( |
| 82 | 82 | $config->get('influxdb-host'), |
| 83 | 83 | $config->get('influxdb-port'), |
@@ -85,12 +85,12 @@ discard block |
||
| 85 | 85 | $config->get('influxdb-database') |
| 86 | 86 | ); |
| 87 | 87 | |
| 88 | - $lastDays = (int)$input->getOption('days') ? (int)$input->getOption('days') : 0; |
|
| 89 | - $limit = (int)$input->getOption('limit') ? (int)$input->getOption('limit') : 0; |
|
| 88 | + $lastDays = (int) $input->getOption('days') ? (int) $input->getOption('days') : 0; |
|
| 89 | + $limit = (int) $input->getOption('limit') ? (int) $input->getOption('limit') : 0; |
|
| 90 | 90 | |
| 91 | 91 | $torrentList = $client->getTorrentData(); |
| 92 | 92 | |
| 93 | - $torrentList = array_map(function ($torrent) { |
|
| 93 | + $torrentList = array_map(function($torrent) { |
|
| 94 | 94 | $torrent['age'] = TorrentUtils::getTorrentAgeInDays($torrent); |
| 95 | 95 | return $torrent; |
| 96 | 96 | }, $torrentList); |
@@ -102,7 +102,7 @@ discard block |
||
| 102 | 102 | |
| 103 | 103 | $transmissionHost = $config->get('transmission-host'); |
| 104 | 104 | |
| 105 | - $torrentList = array_map(function ($torrent) use ($influxDbClient, $transmissionHost, $lastDays) { |
|
| 105 | + $torrentList = array_map(function($torrent) use ($influxDbClient, $transmissionHost, $lastDays) { |
|
| 106 | 106 | $torrent['uploaded'] = $influxDbClient->getTorrentSum( |
| 107 | 107 | $torrent, |
| 108 | 108 | 'uploaded_last', |
@@ -132,7 +132,7 @@ discard block |
||
| 132 | 132 | TableUtils::printTable($tableData, $output); |
| 133 | 133 | |
| 134 | 134 | $freeSpace = $client->getFreeSpace(); |
| 135 | - $output->writeln('Free space: ' . TorrentUtils::getSizeInGb($freeSpace) . ' GB'); |
|
| 135 | + $output->writeln('Free space: '.TorrentUtils::getSizeInGb($freeSpace).' GB'); |
|
| 136 | 136 | |
| 137 | 137 | if ($input->getOption('rm')) { |
| 138 | 138 | return $this->removeTorrents($input, $output, $tableData['rows']); |
@@ -180,7 +180,7 @@ discard block |
||
| 180 | 180 | 'headers' => ['Name', 'Id', 'Age, days', 'Size, GB', 'Uploaded, GB', 'Per day, GB', 'Profit, %'], |
| 181 | 181 | 'rows' => $rows, |
| 182 | 182 | 'totals' => [ |
| 183 | - 'Total: ' . count($rows), |
|
| 183 | + 'Total: '.count($rows), |
|
| 184 | 184 | '', |
| 185 | 185 | '', |
| 186 | 186 | TorrentListUtils::sumArrayField($rows, 3), |
@@ -50,13 +50,13 @@ |
||
| 50 | 50 | |
| 51 | 51 | private function addFile(InputInterface $input, OutputInterface $output, TransmissionClient $client, $torrentFile) |
| 52 | 52 | { |
| 53 | - $this->dryRun($input, $output, function () use ($torrentFile, $client, $input, $output) { |
|
| 53 | + $this->dryRun($input, $output, function() use ($torrentFile, $client, $input, $output) { |
|
| 54 | 54 | $torrentAdded = $client->addTorrent($torrentFile); |
| 55 | 55 | if ($torrentAdded) { |
| 56 | 56 | if (isset($torrentAdded['duplicate'])) { |
| 57 | - $output->writeln($torrentFile . ' was not added. Probably it was added before.'); |
|
| 57 | + $output->writeln($torrentFile.' was not added. Probably it was added before.'); |
|
| 58 | 58 | } else { |
| 59 | - $output->writeln($torrentFile . ' added. Waiting for Transmission...'); |
|
| 59 | + $output->writeln($torrentFile.' added. Waiting for Transmission...'); |
|
| 60 | 60 | $client->waitForTransmission(10); |
| 61 | 61 | } |
| 62 | 62 | } |
@@ -45,7 +45,7 @@ |
||
| 45 | 45 | $command = $this->getApplication()->find($commandName); |
| 46 | 46 | $help = $command->getRawHelp(); |
| 47 | 47 | |
| 48 | - $output->writeln($help . "\n\n"); |
|
| 48 | + $output->writeln($help."\n\n"); |
|
| 49 | 49 | } |
| 50 | 50 | } |
| 51 | 51 | } |
@@ -43,13 +43,13 @@ discard block |
||
| 43 | 43 | $seriesId = $weburgClient->cleanMovieId($seriesArgument); |
| 44 | 44 | |
| 45 | 45 | if (!$seriesId) { |
| 46 | - $output->writeln($seriesArgument . ' seems not weburg series url'); |
|
| 46 | + $output->writeln($seriesArgument.' seems not weburg series url'); |
|
| 47 | 47 | return 1; |
| 48 | 48 | } |
| 49 | 49 | |
| 50 | 50 | $seriesList = $config->get('weburg-series-list'); |
| 51 | 51 | if (in_array($seriesId, $seriesList)) { |
| 52 | - $output->writeln($seriesId . ' already in list'); |
|
| 52 | + $output->writeln($seriesId.' already in list'); |
|
| 53 | 53 | return 0; |
| 54 | 54 | } |
| 55 | 55 | |
@@ -57,7 +57,7 @@ discard block |
||
| 57 | 57 | $config->set('weburg-series-list', $seriesList); |
| 58 | 58 | $config->saveConfigFile(); |
| 59 | 59 | |
| 60 | - $output->writeln('Series ' . $seriesId . ' added to list'); |
|
| 60 | + $output->writeln('Series '.$seriesId.' added to list'); |
|
| 61 | 61 | return 0; |
| 62 | 62 | } |
| 63 | 63 | } |
@@ -91,7 +91,7 @@ discard block |
||
| 91 | 91 | |
| 92 | 92 | $torrentList = $client->getTorrentData(); |
| 93 | 93 | |
| 94 | - $torrentList = array_map(function ($torrent) { |
|
| 94 | + $torrentList = array_map(function($torrent) { |
|
| 95 | 95 | $torrent['age'] = TorrentUtils::getTorrentAgeInDays($torrent); |
| 96 | 96 | return $torrent; |
| 97 | 97 | }, $torrentList); |
@@ -109,6 +109,6 @@ discard block |
||
| 109 | 109 | ); |
| 110 | 110 | |
| 111 | 111 | $freeSpace = $client->getFreeSpace(); |
| 112 | - $output->writeln('Free space: ' . TorrentUtils::getSizeInGb($freeSpace) . ' GB'); |
|
| 112 | + $output->writeln('Free space: '.TorrentUtils::getSizeInGb($freeSpace).' GB'); |
|
| 113 | 113 | } |
| 114 | 114 | } |