popstas / transmission-cli

src/InfluxDbClient.php

Spacing +6 added lines, -6 removed lines

@@ -90,10 +90,10 @@ 
         try {
             $databaseExists = $database->exists();
         } catch (ConnectException $e) {
-            throw new \RuntimeException('InfluxDb connection error: ' . $e->getMessage());
+            throw new \RuntimeException('InfluxDb connection error: '.$e->getMessage());
         }
         if (!$databaseExists) {
-            $this->log('info', 'Database ' . $this->databaseName . ' not exists, creating');
+            $this->log('info', 'Database '.$this->databaseName.' not exists, creating');
             $database->create(null, false);
         }
 
@@ -171,7 +171,7 @@ 
             $points[] = $this->buildPoint($torrent, $transmissionHost);
         }
         $isSuccess = $this->writePoints($points);
-        $this->log('info', 'InfluxDB write ' . ($isSuccess ? 'success' : 'failed'));
+        $this->log('info', 'InfluxDB write '.($isSuccess ? 'success' : 'failed'));
         return $isSuccess;
     }
 
@@ -187,15 +187,15 @@ 
         $where = [];
 
         if (isset($torrent[Torrent\Get::NAME])) {
-            $where[] = "torrent_name = '" . $torrent[Torrent\Get::NAME] . "'";
+            $where[] = "torrent_name = '".$torrent[Torrent\Get::NAME]."'";
         }
 
         if ($transmissionHost) {
-            $where[] = "host = '" . $transmissionHost . "'";
+            $where[] = "host = '".$transmissionHost."'";
         }
 
         if ($lastDays) {
-            $fromTimestamp = strtotime('-' . $lastDays . ' days');
+            $fromTimestamp = strtotime('-'.$lastDays.' days');
             $fromDate = date('c', $fromTimestamp);
             $where[] = "time >= '$fromDate'";
         }

src/Command/Command.php

Spacing +3 added lines, -3 removed lines

@@ -60,7 +60,7 @@ 
                 $config->loadConfigFile();
             } catch (\RuntimeException $e) {
                 $logger->critical($e->getMessage());
-                $this->setCode(function () {
+                $this->setCode(function() {
                     return 1;
                 });
                 return;
@@ -73,7 +73,7 @@ 
         $firstTransmission = $config->get('transmission')[0];
         $vars = ['host', 'port', 'user', 'password'];
         foreach ($vars as $var) {
-            $configName = 'transmission-' . $var;
+            $configName = 'transmission-'.$var;
             $config->set($configName, $this->getInputOption($input, $configName, $firstTransmission[$var]));
         }
 
@@ -103,7 +103,7 @@ 
 
         $connect = ['host' => $host, 'port' => $port, 'user' => $user, 'password' => $password];
 
-        $baseUri = 'http://' . $connect['host'] . ':' . $connect['port'] . '/transmission/rpc';
+        $baseUri = 'http://'.$connect['host'].':'.$connect['port'].'/transmission/rpc';
         $httpClient = new GuzzleHttp\Client(['base_uri' => $baseUri]);
 
         $api = new API\RpcClient($httpClient, $connect['user'], $connect['password'], $logger);

src/TransmissionClient.php

Spacing +2 added lines, -2 removed lines

@@ -44,8 +44,8 @@
             ];
         }
 
-        $cleanedIds = array_map(function ($torrentId) {
-            return (int)$torrentId;
+        $cleanedIds = array_map(function($torrentId) {
+            return (int) $torrentId;
         }, $ids);
 
         $this->getSessionId();

src/Command/TorrentRemoveDuplicates.php

Spacing +3 added lines, -3 removed lines

@@ -60,7 +60,7 @@ 
             }
         }
 
-        $this->dryRun($input, $output, function () use ($client, $obsoleteList, $config, $input, $output) {
+        $this->dryRun($input, $output, function() use ($client, $obsoleteList, $config, $input, $output) {
             $influxDbClient = $this->getApplication()->getInfluxDbClient(
                 $config->get('influxdb-host'),
                 $config->get('influxdb-port'),
@@ -73,10 +73,10 @@ 
 
             $client->removeTorrents($obsoleteList);
             $names = TorrentListUtils::getArrayField($obsoleteList, Torrent\Get::NAME);
-            $output->writeln('Removed torrents:' . implode(', ', $names));
+            $output->writeln('Removed torrents:'.implode(', ', $names));
         }, 'dry-run, don\'t really remove');
 
-        $output->writeln('Found and deleted ' . count($obsoleteList) . ' obsolete torrents from transmission.');
+        $output->writeln('Found and deleted '.count($obsoleteList).' obsolete torrents from transmission.');
         return 0;
     }
 }

src/Helpers/TorrentListUtils.php

Spacing +4 added lines, -4 removed lines

@@ -87,7 +87,7 @@ 
         $data['rows'] = TableUtils::limitRows($data['rows'], $limit);
 
         $data['totals'] = [
-            'Total: ' . count($data['rows']),
+            'Total: '.count($data['rows']),
             '',
             '',
             self::sumArrayField($data['rows'], 3),
@@ -104,7 +104,7 @@ 
         $obsolete = [];
 
         foreach ($torrentList as $torrent) {
-            $key = $torrent[Torrent\Get::NAME] . '_' . $torrent[Torrent\Get::DOWNLOAD_DIR];
+            $key = $torrent[Torrent\Get::NAME].'_'.$torrent[Torrent\Get::DOWNLOAD_DIR];
             $sameNamesAndDirectory[$key][$torrent[Torrent\Get::ID]] = $torrent;
         }
 
@@ -158,8 +158,8 @@ 
 
     private static function getFilesArray($torrent)
     {
-        return array_map(function ($file) {
-            return $file['length'] . '_' . $file['name'];
+        return array_map(function($file) {
+            return $file['length'].'_'.$file['name'];
         }, $torrent[Torrent\Get::FILES]);
     }
 }

src/Command/StatsSend.php

Indentation +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
             $obsoleteList = TorrentListUtils::getObsoleteTorrents($torrentList);
             if (!empty($obsoleteList)) {
                 $output->writeln('<comment>Found obsolete torrents, '
-                                 . 'remove it using transmission-cli torrent-remove-duplicates</comment>');
+                                    . 'remove it using transmission-cli torrent-remove-duplicates</comment>');
                 TorrentListUtils::printTorrentsTable($obsoleteList, $output);
                 return 1;
             }

Spacing +1 added lines, -1 removed lines

@@ -75,7 +75,7 @@
 
             $points[] = $influxDbClient->buildStatus($torrentList, $transmissionHost);
 
-            $this->dryRun($input, $output, function () use ($influxDbClient, $points) {
+            $this->dryRun($input, $output, function() use ($influxDbClient, $points) {
                 $influxDbClient->writePoints($points);
             }, 'dry-run, don\'t really send points');
         } catch (\Exception $e) {

src/Command/WeburgDownload.php

Spacing +21 added lines, -21 removed lines

@@ -87,7 +87,7 @@ 
                 );
             }
 
-            $this->dryRun($input, $output, function () use (
+            $this->dryRun($input, $output, function() use (
                 $input,
                 $output,
                 $weburgClient,
@@ -161,10 +161,10 @@ 
         $progress->start();
 
         foreach ($moviesIds as $movieId) {
-            $progress->setMessage('Check movie ' . $movieId . '...');
+            $progress->setMessage('Check movie '.$movieId.'...');
             $progress->advance();
 
-            $downloadedLogfile = $downloadDir . '/' . $movieId;
+            $downloadedLogfile = $downloadDir.'/'.$movieId;
 
             $isDownloaded = file_exists($downloadedLogfile);
             if ($isDownloaded) {
@@ -174,7 +174,7 @@ 
             $movieInfo = $weburgClient->getMovieInfoById($movieId);
             foreach (array_keys($movieInfo) as $infoField) {
                 if (!isset($movieInfo[$infoField])) {
-                    $logger->warning('Cannot find ' . $infoField . ' in movie ' . $movieId);
+                    $logger->warning('Cannot find '.$infoField.' in movie '.$movieId);
                 }
             }
 
@@ -187,15 +187,15 @@ 
             );
 
             if ($isTorrentPopular) {
-                $progress->setMessage('Download movie ' . $movieId . '...');
+                $progress->setMessage('Download movie '.$movieId.'...');
 
                 $movieUrls = $weburgClient->getMovieTorrentUrlsById($movieId);
                 $torrentsUrls = array_merge($torrentsUrls, $movieUrls);
-                $logger->info('Download movie ' . $movieId . ': ' . $movieInfo['title']);
+                $logger->info('Download movie '.$movieId.': '.$movieInfo['title']);
 
                 file_put_contents(
                     $downloadedLogfile,
-                    date('Y-m-d H:i:s') . "\n" . implode("\n", $torrentsUrls)
+                    date('Y-m-d H:i:s')."\n".implode("\n", $torrentsUrls)
                 );
             }
         }
@@ -229,7 +229,7 @@ 
         $progress->start();
 
         foreach ($seriesIds as $seriesId) {
-            $progress->setMessage('Check series ' . $seriesId . '...');
+            $progress->setMessage('Check series '.$seriesId.'...');
             $progress->advance();
 
             $movieInfo = $weburgClient->getMovieInfoById($seriesId);
@@ -256,18 +256,18 @@ 
 
         $movieId = $weburgClient->cleanMovieId($movieId);
         if (!$movieId) {
-            throw new \RuntimeException($movieId . ' seems not weburg movie ID or URL');
+            throw new \RuntimeException($movieId.' seems not weburg movie ID or URL');
         }
 
         $movieInfo = $weburgClient->getMovieInfoById($movieId);
-        $logger->info('Search series ' . $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) . ')');
+                $logger->info('Download series '.$movieId.': '
+                    . $movieInfo['title'].' ('.count($seriesUrls).')');
             }
         } else {
             $torrentsUrls = array_merge($torrentsUrls, $weburgClient->getMovieTorrentUrlsById($movieId));
@@ -293,10 +293,10 @@ 
         }
 
         if (!file_exists($torrentsDir)) {
-            throw new \RuntimeException('Destination directory not exists: ' . $torrentsDir);
+            throw new \RuntimeException('Destination directory not exists: '.$torrentsDir);
         }
 
-        $downloadDir = $torrentsDir . '/downloaded';
+        $downloadDir = $torrentsDir.'/downloaded';
         if (!file_exists($downloadDir)) {
             mkdir($downloadDir, 0777);
         }
@@ -312,24 +312,24 @@ 
         $whitelist = $config->get('download-filename-whitelist');
         $blacklist = $config->get('download-filename-blacklist');
 
-        $torrentFiles = array_filter($torrentFiles, function ($torrentFile) use ($whitelist, $blacklist, $logger) {
+        $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);
+                    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));
+                    $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);
+                    if (preg_match('/'.$black.'/i', $torrentFile)) {
+                        $logger->info($torrentFile.' matched blacklist: '.$black);
                         return false;
                     }
                 }
@@ -364,7 +364,7 @@ 
             );
 
             $addInput = new ArrayInput($arguments);
-            $output->writeln("\nAdd torrents to " . $host);
+            $output->writeln("\nAdd torrents to ".$host);
             $command->run($addInput, $output);
         }
     }

src/Helpers/TableUtils.php

Spacing +4 added lines, -4 removed lines

@@ -60,10 +60,10 @@ 
     {
         $filters = self::parseFilters($filters);
 
-        return array_filter($rows, function ($row) use ($filters) {
+        return array_filter($rows, function($row) use ($filters) {
             foreach ($filters as $columnKey => $filter) {
                 if (!isset($row[$columnKey])) {
-                    throw new \RuntimeException('Column ' . $columnKey . ' not exists, cannot filter');
+                    throw new \RuntimeException('Column '.$columnKey.' not exists, cannot filter');
                 }
                 $columnValue = $row[$columnKey];
 
@@ -80,7 +80,7 @@ 
         if ((isset($filter['min']) && $value <= $filter['min']) ||
             (isset($filter['max']) && $value >= $filter['max']) ||
             (isset($filter['equals']) && $value != $filter['equals']) ||
-            (isset($filter['regex']) && !preg_match('/' . $filter['regex'] . '/i', $value))
+            (isset($filter['regex']) && !preg_match('/'.$filter['regex'].'/i', $value))
         ) {
             return false;
         }
@@ -107,7 +107,7 @@ 
         );
         $columnIndex--;
 
-        usort($rowsSorted, function ($first, $second) use ($columnIndex, $sortOrder) {
+        usort($rowsSorted, function($first, $second) use ($columnIndex, $sortOrder) {
             return $first[$columnIndex] > $second[$columnIndex] ? $sortOrder : $sortOrder * -1;
         });