popstas / transmission-cli

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;
         }
@@ -100,7 +100,7 @@ 
             abs($columnNumber)
         )) - 1;
 
-        usort($rowsSorted, function ($first, $second) use ($columnIndex, $sortOrder) {
+        usort($rowsSorted, function($first, $second) use ($columnIndex, $sortOrder) {
             return $first[$columnIndex] > $second[$columnIndex] ? $sortOrder : $sortOrder * -1;
         });
 

src/WeburgClient.php

Spacing +7 added lines, -7 removed lines

@@ -51,7 +51,7 @@ 
     public function getSeriesTorrents($movieId, $hashes, $daysMax = 1, $allowedMisses = 0)
     {
         $torrentsUrls = [];
-        $timestampFrom = strtotime('-' . $daysMax . 'days');
+        $timestampFrom = strtotime('-'.$daysMax.'days');
 
         $hashes = array_reverse($hashes);
         foreach ($hashes as $hash) {
@@ -92,7 +92,7 @@ 
 
     public function getMovieUrl($movieId)
     {
-        return 'http://weburg.net/movies/info/' . $movieId;
+        return 'http://weburg.net/movies/info/'.$movieId;
     }
 
     /**
@@ -111,7 +111,7 @@ 
         ]);
 
         if ($res->getStatusCode() != 200) {
-            throw new \RuntimeException('Error ' . $res->getStatusCode() . 'while get url ' . $url);
+            throw new \RuntimeException('Error '.$res->getStatusCode().'while get url '.$url);
         }
 
         sleep($this->requestDelay);
@@ -147,7 +147,7 @@ 
         preg_match('/filename="(.*?)"/', $disposition[0], $res);
         $filename = $res[1];
 
-        $filePath = $torrentsDir . '/' . $filename;
+        $filePath = $torrentsDir.'/'.$filename;
         file_put_contents($filePath, $torrentBody);
 
         return $filePath;
@@ -174,8 +174,8 @@ 
     private function getMovieTorrentUrl($movieId, $hash = '')
     {
         return 'http://weburg.net/ajax/download/movie?'
-        . ($hash ? 'hash=' . $hash . '&' : '')
-        . 'obj_id=' . $movieId;
+        . ($hash ? 'hash='.$hash.'&' : '')
+        . 'obj_id='.$movieId;
     }
 
     private function getMovieInfo($body)
@@ -191,7 +191,7 @@ 
         ];
 
         foreach ($checks as $name => $regexp) {
-            preg_match('/' . $regexp . '/mis', $body, $res);
+            preg_match('/'.$regexp.'/mis', $body, $res);
             $info[$name] = count($res) ? $res[1] : null;
         }
 

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) {