NNTmux / newznab-tmux

app/Services/ReleaseProcessingService.php

Spacing +33 added lines, -33 removed lines

@@ -109,7 +109,7 @@ 
     {
         if (!$this->settings->hasValidCompletion()) {
             cli()->error(
-                PHP_EOL . 'Invalid completion setting. Value must be between 0 and 100.'
+                PHP_EOL.'Invalid completion setting. Value must be between 0 and 100.'
             );
         }
     }
@@ -266,7 +266,7 @@ 
     {
         if ($where !== '') {
             DB::update(
-                'UPDATE releases SET categories_id = ?, iscategorized = 0 ' . $where,
+                'UPDATE releases SET categories_id = ?, iscategorized = 0 '.$where,
                 [Category::OTHER_MISC]
             );
         } else {
@@ -303,7 +303,7 @@ 
 
         $this->outputSubHeader('Categorizing Releases');
 
-        $query->chunkById(self::CATEGORIZE_CHUNK_SIZE, function ($releases) use ($categorizer, $type, &$categorized, $total): bool {
+        $query->chunkById(self::CATEGORIZE_CHUNK_SIZE, function($releases) use ($categorizer, $type, &$categorized, $total): bool {
             foreach ($releases as $release) {
                 $categoryResult = $categorizer->determineCategory(
                     $release->groups_id,
@@ -365,7 +365,7 @@ 
         $this->outputSubHeader('Calculating Collection Sizes');
 
         $updated = 0;
-        DB::transaction(function () use ($groupID, &$updated): void {
+        DB::transaction(function() use ($groupID, &$updated): void {
             $normalizedGroupId = $this->normalizeGroupId($groupID);
             $whereSql = $normalizedGroupId !== null
                 ? " AND c.groups_id = {$normalizedGroupId} "
@@ -419,7 +419,7 @@ 
                 continue;
             }
 
-            DB::transaction(function () use ($groupMinSize, $groupMinFiles, &$stats): void {
+            DB::transaction(function() use ($groupMinSize, $groupMinFiles, &$stats): void {
                 $effectiveMinSize = max($groupMinSize, $this->settings->minSizeToFormRelease);
                 if ($effectiveMinSize > 0) {
                     $stats['minSize'] += Collection::query()
@@ -489,7 +489,7 @@ 
         $total = $query->count();
 
         if ($total > 0) {
-            $query->chunkById(self::NZB_CHUNK_SIZE, function ($releases) use (&$nzbCount, $total): bool {
+            $query->chunkById(self::NZB_CHUNK_SIZE, function($releases) use (&$nzbCount, $total): bool {
                 foreach ($releases as $release) {
                     if ($this->nzb->writeNzbForReleaseId($release)) {
                         $nzbCount++;
@@ -684,7 +684,7 @@ 
      */
     private function runCollectionFileCheckStage1(int $groupID): void
     {
-        DB::transaction(static function () use ($groupID): void {
+        DB::transaction(static function() use ($groupID): void {
             $collectionsQuery = Collection::query()
                 ->select(['collections.id'])
                 ->join('binaries', 'binaries.collections_id', '=', 'collections.id')
@@ -708,7 +708,7 @@ 
      */
     private function runCollectionFileCheckStage2(int $groupID): void
     {
-        DB::transaction(static function () use ($groupID): void {
+        DB::transaction(static function() use ($groupID): void {
             $collectionsQuery = Collection::query()
                 ->select(['collections.id'])
                 ->join('binaries', 'binaries.collections_id', '=', 'collections.id')
@@ -726,7 +726,7 @@ 
                 ->update(['collections.filecheck' => CollectionFileCheckStatus::ZeroPart->value]);
         }, 10);
 
-        DB::transaction(static function () use ($groupID): void {
+        DB::transaction(static function() use ($groupID): void {
             $query = Collection::query()
                 ->where('filecheck', '=', CollectionFileCheckStatus::CompleteCollection->value);
 
@@ -743,7 +743,7 @@ 
      */
     private function runCollectionFileCheckStage3(string $whereSql): void
     {
-        DB::transaction(static function () use ($whereSql): void {
+        DB::transaction(static function() use ($whereSql): void {
             $sql = <<<SQL
                 UPDATE binaries b
                 INNER JOIN (
@@ -765,7 +765,7 @@ 
             ]);
         }, 10);
 
-        DB::transaction(static function () use ($whereSql): void {
+        DB::transaction(static function() use ($whereSql): void {
             $sql = <<<SQL
                 UPDATE binaries b
                 INNER JOIN (
@@ -793,7 +793,7 @@ 
      */
     private function runCollectionFileCheckStage4(string $whereSql): void
     {
-        DB::transaction(static function () use ($whereSql): void {
+        DB::transaction(static function() use ($whereSql): void {
             $sql = <<<SQL
                 UPDATE collections c
                 INNER JOIN (
@@ -821,7 +821,7 @@ 
      */
     private function runCollectionFileCheckStage5(int $groupId): void
     {
-        DB::transaction(static function () use ($groupId): void {
+        DB::transaction(static function() use ($groupId): void {
             $query = Collection::query()
                 ->whereIn('filecheck', [
                     CollectionFileCheckStatus::TempComplete->value,
@@ -841,7 +841,7 @@ 
      */
     private function runCollectionFileCheckStage6(string $whereSql): void
     {
-        DB::transaction(function () use ($whereSql): void {
+        DB::transaction(function() use ($whereSql): void {
             $sql = <<<SQL
                 UPDATE collections c
                 SET filecheck = ?, totalfiles = (SELECT COUNT(b.id) FROM binaries b WHERE b.collections_id = c.id)
@@ -925,7 +925,7 @@ 
                 if ($attempt >= self::MAX_RETRIES) {
                     if ($this->echoCLI) {
                         cli()->error(
-                            'Stuck collections delete failed after retries: ' . $e->getMessage()
+                            'Stuck collections delete failed after retries: '.$e->getMessage()
                         );
                     }
                     break;
@@ -947,7 +947,7 @@ 
             ->where('releases.groups_id', $groupId)
             ->join('usenet_groups', 'usenet_groups.id', '=', 'releases.groups_id')
             ->whereRaw(
-                'GREATEST(IFNULL(usenet_groups.minsizetoformrelease, 0), ?) > 0 ' .
+                'GREATEST(IFNULL(usenet_groups.minsizetoformrelease, 0), ?) > 0 '.
                 'AND releases.size < GREATEST(IFNULL(usenet_groups.minsizetoformrelease, 0), ?)',
                 [$this->settings->minSizeToFormRelease, $this->settings->minSizeToFormRelease]
             )
@@ -988,7 +988,7 @@ 
             ->where('releases.groups_id', $groupId)
             ->join('usenet_groups', 'usenet_groups.id', '=', 'releases.groups_id')
             ->whereRaw(
-                'GREATEST(IFNULL(usenet_groups.minfilestoformrelease, 0), ?) > 0 ' .
+                'GREATEST(IFNULL(usenet_groups.minfilestoformrelease, 0), ?) > 0 '.
                 'AND releases.totalpart < GREATEST(IFNULL(usenet_groups.minfilestoformrelease, 0), ?)',
                 [$this->settings->minFilesToFormRelease, $this->settings->minFilesToFormRelease]
             )
@@ -1012,7 +1012,7 @@ 
         Release::query()
             ->where('postdate', '<', $cutoff)
             ->select(['id', 'guid'])
-            ->chunkById(self::BATCH_SIZE, function ($releases) use (&$stats): bool {
+            ->chunkById(self::BATCH_SIZE, function($releases) use (&$stats): bool {
                 foreach ($releases as $release) {
                     $this->deleteSingleRelease($release);
                     $stats = $stats->increment('retention');
@@ -1032,12 +1032,12 @@ 
         Release::query()
             ->select(['id', 'guid'])
             ->where('passwordstatus', '=', Releases::PASSWD_RAR)
-            ->orWhereIn('id', function ($query): void {
+            ->orWhereIn('id', function($query): void {
                 $query->select('releases_id')
                     ->from('release_files')
                     ->where('passworded', '=', Releases::PASSWD_RAR);
             })
-            ->chunkById(self::BATCH_SIZE, function ($releases) use (&$stats): bool {
+            ->chunkById(self::BATCH_SIZE, function($releases) use (&$stats): bool {
                 foreach ($releases as $release) {
                     $this->deleteSingleRelease($release);
                     $stats = $stats->increment('password');
@@ -1079,7 +1079,7 @@ 
             ->where('completion', '<', $this->settings->completion)
             ->where('completion', '>', 0)
             ->select(['id', 'guid'])
-            ->chunkById(self::BATCH_SIZE, function ($releases) use (&$stats): bool {
+            ->chunkById(self::BATCH_SIZE, function($releases) use (&$stats): bool {
                 foreach ($releases as $release) {
                     $this->deleteSingleRelease($release);
                     $stats = $stats->increment('completion');
@@ -1103,7 +1103,7 @@ 
         Release::query()
             ->whereIn('categories_id', $categoryIds)
             ->select(['id', 'guid'])
-            ->chunkById(self::BATCH_SIZE, function ($releases) use (&$stats): bool {
+            ->chunkById(self::BATCH_SIZE, function($releases) use (&$stats): bool {
                 foreach ($releases as $release) {
                     $this->deleteSingleRelease($release);
                     $stats = $stats->increment('disabledCategory');
@@ -1127,7 +1127,7 @@ 
                 ->where('size', '<', (int) $category->minsize)
                 ->select(['id', 'guid'])
                 ->limit(1000)
-                ->chunkById(self::BATCH_SIZE, function ($releases) use (&$stats): bool {
+                ->chunkById(self::BATCH_SIZE, function($releases) use (&$stats): bool {
                     foreach ($releases as $release) {
                         $this->deleteSingleRelease($release);
                         $stats = $stats->increment('categoryMinSize');
@@ -1160,7 +1160,7 @@ 
                     static fn($join) => $join->on('releases.musicinfo_id', '=', 'mi.id')
                 )
                 ->select(['releases.id', 'releases.guid'])
-                ->chunkById(self::BATCH_SIZE, function ($releases) use (&$stats): bool {
+                ->chunkById(self::BATCH_SIZE, function($releases) use (&$stats): bool {
                     foreach ($releases as $release) {
                         $this->deleteSingleRelease($release);
                         $stats = $stats->increment('disabledGenre');
@@ -1181,7 +1181,7 @@ 
                 ->where('categories_id', Category::OTHER_MISC)
                 ->where('adddate', '<=', $cutoff)
                 ->select(['id', 'guid'])
-                ->chunkById(self::BATCH_SIZE, function ($releases) use (&$stats): bool {
+                ->chunkById(self::BATCH_SIZE, function($releases) use (&$stats): bool {
                     foreach ($releases as $release) {
                         $this->deleteSingleRelease($release);
                         $stats = $stats->increment('miscOther');
@@ -1197,7 +1197,7 @@ 
                 ->where('categories_id', Category::OTHER_HASHED)
                 ->where('adddate', '<=', $cutoff)
                 ->select(['id', 'guid'])
-                ->chunkById(self::BATCH_SIZE, function ($releases) use (&$stats): bool {
+                ->chunkById(self::BATCH_SIZE, function($releases) use (&$stats): bool {
                     foreach ($releases as $release) {
                         $this->deleteSingleRelease($release);
                         $stats = $stats->increment('miscHashed');
@@ -1230,7 +1230,7 @@ 
 
         echo PHP_EOL;
         cli()->header('NNTmux Release Processing');
-        cli()->info('Started: ' . now()->format('Y-m-d H:i:s'));
+        cli()->info('Started: '.now()->format('Y-m-d H:i:s'));
     }
 
     private function outputHeader(string $title): void
@@ -1322,7 +1322,7 @@ 
         }
 
         $percent = min(100, (int) (($current / $total) * 100));
-        echo "\r      {$action}: " . number_format($current) . '/' . number_format($total) . " ({$percent}%)   ";
+        echo "\r      {$action}: ".number_format($current).'/'.number_format($total)." ({$percent}%)   ";
 
         if ($current >= $total) {
             echo PHP_EOL;
@@ -1345,13 +1345,13 @@ 
         echo PHP_EOL;
         cli()->header('SUMMARY');
         cli()->header('-------');
-        cli()->primary('  Releases added: ' . number_format($releasesAdded));
-        cli()->primary('  NZBs created: ' . number_format($nzbsCreated));
+        cli()->primary('  Releases added: '.number_format($releasesAdded));
+        cli()->primary('  NZBs created: '.number_format($nzbsCreated));
         if ($dupes > 0) {
-            cli()->warning('  Duplicates skipped: ' . number_format($dupes));
+            cli()->warning('  Duplicates skipped: '.number_format($dupes));
         }
-        cli()->info('  Processing cycles: ' . number_format($iterations));
-        cli()->info('  Total time: ' . $this->formatElapsedTime($elapsed));
+        cli()->info('  Processing cycles: '.number_format($iterations));
+        cli()->info('  Total time: '.$this->formatElapsedTime($elapsed));
         echo PHP_EOL;
     }
 

app/Services/Tmux/Scripts/groupfixrelnames.php

Spacing +3 added lines, -3 removed lines

@@ -12,7 +12,7 @@ 
 
 require_once __DIR__.'/../../../../bootstrap/autoload.php';
 
-if (! isset($argv[1])) {
+if (!isset($argv[1])) {
     cli()->error('This script is not intended to be run manually, it is called from Multiprocessing.');
     exit(1);
 }
@@ -25,7 +25,7 @@ 
 
 switch ($type) {
     case 'standard':
-        if ($guidChar === null || $maxPerRun === null || ! is_numeric($maxPerRun)) {
+        if ($guidChar === null || $maxPerRun === null || !is_numeric($maxPerRun)) {
             cli()->error('Invalid arguments for standard type');
             exit(1);
         }
@@ -34,7 +34,7 @@ 
         break;
 
     case 'predbft':
-        if (! isset($maxPerRun) || ! is_numeric($maxPerRun) || ! isset($thread) || ! is_numeric($thread)) {
+        if (!isset($maxPerRun) || !is_numeric($maxPerRun) || !isset($thread) || !is_numeric($thread)) {
             cli()->error('Invalid arguments for predbft type');
             exit(1);
         }

app/Services/BookService.php

Spacing +9 added lines, -9 removed lines

@@ -159,8 +159,8 @@ 
 			%s
 			GROUP BY boo.id
 			ORDER BY %s %s',
-            \is_array($bookIDs) && ! empty($bookIDs) ? implode(',', $bookIDs) : -1,
-            \is_array($releaseIDs) && ! empty($releaseIDs) ? implode(',', $releaseIDs) : -1,
+            \is_array($bookIDs) && !empty($bookIDs) ? implode(',', $bookIDs) : -1,
+            \is_array($releaseIDs) && !empty($releaseIDs) ? implode(',', $releaseIDs) : -1,
             $catsrch,
             $order[0],
             $order[1]
@@ -237,7 +237,7 @@ 
     {
         $browseby = ' ';
         foreach ($this->getBrowseByOptions() as $bbk => $bbv) {
-            if (! empty($_REQUEST[$bbk])) {
+            if (!empty($_REQUEST[$bbk])) {
                 $bbs = stripslashes($_REQUEST[$bbk]);
                 $browseby .= ' AND boo.'.$bbv.' '.'LIKE '.escapeString('%'.$bbs.'%');
             }
@@ -404,7 +404,7 @@ 
                 return false;
             }
 
-            if (preg_match('/^([a-z0-9ü!]+ ){1,2}(N|Vol)?\d{1,4}([abc])?$|^([a-z0-9]+ ){1,2}(Jan( |unar|$)|Feb( |ruary|$)|Mar( |ch|$)|Apr( |il|$)|May(?![a-z0-9])|Jun([ e$])|Jul([ y$])|Aug( |ust|$)|Sep( |tember|$)|O([ck])t( |ober|$)|Nov( |ember|$)|De([cz])( |ember|$))/ui', $releasename) && ! preg_match('/Part \d+/i', $releasename)) {
+            if (preg_match('/^([a-z0-9ü!]+ ){1,2}(N|Vol)?\d{1,4}([abc])?$|^([a-z0-9]+ ){1,2}(Jan( |unar|$)|Feb( |ruary|$)|Mar( |ch|$)|Apr( |il|$)|May(?![a-z0-9])|Jun([ e$])|Jul([ y$])|Aug( |ust|$)|Sep( |tember|$)|O([ck])t( |ober|$)|Nov( |ember|$)|De([cz])( |ember|$))/ui', $releasename) && !preg_match('/Part \d+/i', $releasename)) {
                 if ($this->echooutput) {
                     cli()->headerOver('Changing category to magazines: ').cli()->primary($releasename);
                 }
@@ -412,14 +412,14 @@ 
 
                 return false;
             }
-            if (! empty($releasename) && ! preg_match('/^[a-z0-9]+$|^([0-9]+ ){1,}$|Part \d+/i', $releasename)) {
+            if (!empty($releasename) && !preg_match('/^[a-z0-9]+$|^([0-9]+ ){1,}$|Part \d+/i', $releasename)) {
                 return $releasename;
             }
 
             return false;
         }
         if ($releasetype === 'audiobook') {
-            if (! empty($releasename) && ! preg_match('/^[a-z0-9]+$|^([0-9]+ ){1,}$|Part \d+/i', $releasename)) {
+            if (!empty($releasename) && !preg_match('/^[a-z0-9]+$|^([0-9]+ ){1,}$|Part \d+/i', $releasename)) {
                 // we can skip category for audiobooks, since we already know it, so as long as the release name is valid return it so that it is postprocessed by amazon.  In the future, determining the type of audiobook could be added (Lecture or book), since we can skip lookups on lectures, but for now handle them all the same way
                 return $releasename;
             }
@@ -445,7 +445,7 @@ 
 
         $book = false;
         if ($bookInfo !== '') {
-            if (! $book) {
+            if (!$book) {
                 cli()->info('Fetching data from iTunes for '.$bookInfo);
                 $book = $this->fetchItunesBookProperties($bookInfo);
             } elseif ($amazdata !== null) {
@@ -552,13 +552,13 @@ 
             'salesrank' => '',
             'publisher' => '',
             'pages' => '',
-            'coverurl' => ! empty($iTunesBook['cover']) ? $iTunesBook['cover'] : '',
+            'coverurl' => !empty($iTunesBook['cover']) ? $iTunesBook['cover'] : '',
             'genre' => is_array($iTunesBook['genres']) ? implode(', ', $iTunesBook['genres']) : $iTunesBook['genre'],
             'overview' => strip_tags($iTunesBook['description'] ?? ''),
             'publishdate' => $iTunesBook['release_date'],
         ];
 
-        if (! empty($book['coverurl'])) {
+        if (!empty($book['coverurl'])) {
             $book['cover'] = 1;
         } else {
             $book['cover'] = 0;

app/Services/NNTP/NNTPService.php

Spacing +24 added lines, -24 removed lines

@@ -206,7 +206,7 @@ 
         ];
         $primaryConnections = $this->_tmux->getUSPConnections('primary', $primaryUSP);
         $alternateConnections = $this->_tmux->getUSPConnections('alternate', $alternateUSP);
-        if ($this->_isConnected() && (($alternate && $this->_currentServer === $this->_configAlternateServer && ($this->_primaryNntpConnections < $alternateConnections['alternate']['active'])) || (! $alternate && $this->_currentServer === $this->_configServer && ($this->_primaryNntpConnections < $primaryConnections['primary']['active'])))) {
+        if ($this->_isConnected() && (($alternate && $this->_currentServer === $this->_configAlternateServer && ($this->_primaryNntpConnections < $alternateConnections['alternate']['active'])) || (!$alternate && $this->_currentServer === $this->_configServer && ($this->_primaryNntpConnections < $primaryConnections['primary']['active'])))) {
             return true;
         }
 
@@ -215,7 +215,7 @@ 
         $ret = $connected = $cError = $aError = false;
 
         // Set variables to connect based on if we are using the alternate provider or not.
-        if (! $alternate) {
+        if (!$alternate) {
             $sslEnabled = $this->_configSsl;
             $this->_currentServer = $this->_configServer;
             $this->_currentPort = $this->_configPort;
@@ -241,19 +241,19 @@ 
             $authenticated = false;
 
             // If we are not connected, try to connect.
-            if (! $connected) {
+            if (!$connected) {
                 $ret = $this->connect($this->_currentServer, $sslEnabled, $this->_currentPort, 5, $socketTimeout);
             }
             // Check if we got an error while connecting.
             $cErr = self::isError($ret);
 
             // If no error, we are connected.
-            if (! $cErr) {
+            if (!$cErr) {
                 // Say that we are connected so we don't retry.
                 $connected = true;
                 // When there is no error it returns bool if we are allowed to post or not.
                 $this->_postingAllowed = $ret;
-            } elseif (! $cError) {
+            } elseif (!$cError) {
                 $cError = $ret->getMessage();
             }
 
@@ -263,7 +263,7 @@ 
             }
 
             // If we have no more retries and could not connect, return an error.
-            if ($retries === 0 && ! $connected) {
+            if ($retries === 0 && !$connected) {
                 $message =
                     'Cannot connect to server '.
                     $this->_currentServer.
@@ -288,9 +288,9 @@ 
                     $aErr = self::isError($ret2);
 
                     // If there was no error, then we are authenticated.
-                    if (! $aErr) {
+                    if (!$aErr) {
                         $authenticated = true;
-                    } elseif (! $aError) {
+                    } elseif (!$aError) {
                         $aError = $ret2->getMessage();
                     }
 
@@ -300,7 +300,7 @@ 
                     }
 
                     // If we ran out of retries, return an error.
-                    if ($retries === 0 && ! $authenticated) {
+                    if ($retries === 0 && !$authenticated) {
                         $message =
                             'Cannot authenticate to server '.
                             $this->_currentServer.
@@ -316,7 +316,7 @@ 
             // If we are connected and authenticated, try enabling compression if we have it enabled.
             if ($connected && $authenticated) {
                 // Check if we should use compression on the connection.
-                if (! $compression || ! $this->_configCompressedHeaders) {
+                if (!$compression || !$this->_configCompressedHeaders) {
                     $this->_compressionSupported = false;
                 }
 
@@ -379,7 +379,7 @@ 
      */
     public function enableCompression(): void
     {
-        if (! $this->_configCompressedHeaders) {
+        if (!$this->_configCompressedHeaders) {
             return;
         }
         $this->_enableCompression();
@@ -599,7 +599,7 @@ 
                 $message = $this->_getMessage($groupName, $wanted);
 
                 // Append the body to $body.
-                if (! self::isError($message)) {
+                if (!self::isError($message)) {
                     $body .= $message;
 
                     if ($messageSize === 0) {
@@ -608,7 +608,7 @@ 
 
                     // If there is an error try the alternate provider or return the PEAR error.
                 } elseif ($alternate) {
-                    if (! $aConnected) {
+                    if (!$aConnected) {
                         // Check if the current connected server is the alternate or not.
                         $aConnected = $this->_currentServer === $this->_configServer
                             ? $nntp->doConnect($this->_configCompressedHeaders, true)
@@ -697,7 +697,7 @@ 
                 return $body;
             }
             $msg = $this->_getMessageByMessageID($id);
-            if (! self::isError($msg)) {
+            if (!self::isError($msg)) {
                 $body .= $msg;
                 if ($messageSize === 0) {
                     $messageSize = strlen($msg);
@@ -707,7 +707,7 @@ 
             }
             // Primary failed, try alternate if requested
             if ($alternate) {
-                if (! $aConnected) {
+                if (!$aConnected) {
                     $aConnected = $this->_currentServer === $this->_configServer
                         ? $alt->doConnect($this->_configCompressedHeaders, true)
                         : $alt->doConnect();
@@ -765,7 +765,7 @@ 
         $bodyParts = [];
         $socket = $this->_socket;
 
-        while (! feof($socket)) {
+        while (!feof($socket)) {
             $line = fgets($socket, 8192);
             if ($line === false) {
                 return $this->throwError('Failed to read line from socket.', null);
@@ -855,7 +855,7 @@ 
         if ($this->_compressionEnabled) {
             return true;
         }
-        if (! $this->_compressionSupported) {
+        if (!$this->_compressionSupported) {
             return false;
         }
 
@@ -869,7 +869,7 @@ 
             return $response;
         }
         if ($response !== 290) {
-            if (! $secondTry) {
+            if (!$secondTry) {
                 // Retry.
                 $this->cmdQuit();
                 if ($this->_checkConnection()) {
@@ -929,7 +929,7 @@ 
         $dataParts = [];
         $socket = $this->_socket;
 
-        while (! feof($socket)) {
+        while (!feof($socket)) {
             // Did we find a possible ending ? (.\r\n)
             if ($possibleTerm) {
                 // Use stream_select for more efficient socket polling
@@ -954,7 +954,7 @@ 
                     $data = implode('', $dataParts);
                     $deComp = @gzuncompress(substr($data, 0, -3));
 
-                    if (! empty($deComp)) {
+                    if (!empty($deComp)) {
                         $bytesReceived = \strlen($data);
                         if ($this->_echo && $bytesReceived > 10240) {
                             cli()->primaryOver(
@@ -1028,7 +1028,7 @@ 
         }
 
         // Check if the last char is >, if not add it.
-        if (! str_ends_with($messageID, '>')) {
+        if (!str_ends_with($messageID, '>')) {
             $messageID .= '>';
         }
 
@@ -1055,7 +1055,7 @@ 
         }
 
         // Check if this is an article number or message-id.
-        if (! is_numeric($identifier)) {
+        if (!is_numeric($identifier)) {
             // It's a message-id so check if it has the triangular brackets.
             $identifier = $this->_formatMessageID($identifier);
         }
@@ -1072,7 +1072,7 @@ 
             $socket = $this->_socket;
 
             // Continue until connection is lost
-            while (! feof($socket)) {
+            while (!feof($socket)) {
                 // Retrieve and append up to 8192 characters from the server (larger buffer = fewer syscalls)
                 $line = fgets($socket, 8192);
 
@@ -1325,7 +1325,7 @@ 
      */
     public function _isConnected(bool $feOf = true): bool
     {
-        return is_resource($this->_socket) && (! $feOf || ! feof($this->_socket));
+        return is_resource($this->_socket) && (!$feOf || !feof($this->_socket));
     }
 
     /**

app/Services/AdultProcessing/AdultProcessingPipeline.php

Spacing +30 added lines, -30 removed lines

@@ -198,7 +198,7 @@ 
             }
 
             if ($this->echoOutput) {
-                cli()->header('Processing ' . $releaseCount . ' XXX releases using pipeline.');
+                cli()->header('Processing '.$releaseCount.' XXX releases using pipeline.');
             }
 
             // Process releases in batches for parallel processing
@@ -207,12 +207,12 @@ 
 
             foreach ($batches as $batchIndex => $batch) {
                 if ($this->echoOutput) {
-                    cli()->info('Processing batch ' . ($batchIndex + 1) . ' of ' . count($batches));
+                    cli()->info('Processing batch '.($batchIndex + 1).' of '.count($batches));
                 }
                 $this->processBatch($batch);
             }
         } catch (\Throwable $e) {
-            Log::error('processXXXReleases failed: ' . $e->getMessage(), [
+            Log::error('processXXXReleases failed: '.$e->getMessage(), [
                 'exception' => get_class($e),
                 'file' => $e->getFile(),
                 'line' => $e->getLine(),
@@ -220,7 +220,7 @@ 
             ]);
 
             if ($this->echoOutput) {
-                cli()->error('Error during processing: ' . $e->getMessage());
+                cli()->error('Error during processing: '.$e->getMessage());
             }
         }
 
@@ -251,7 +251,7 @@ 
                 $releaseId = (int) ($release['id'] ?? 0);
 
                 if ($releaseId <= 0) {
-                    Log::warning('Invalid release ID in batch: ' . json_encode($release));
+                    Log::warning('Invalid release ID in batch: '.json_encode($release));
                     $this->stats['failed']++;
                     continue;
                 }
@@ -260,14 +260,14 @@ 
                     $this->processReleaseItem($release);
                 } catch (\Throwable $e) {
                     // processReleaseItem should handle its own exceptions, but this is a fallback
-                    Log::error('Unexpected error in processBatch for release ' . $releaseId . ': ' . $e->getMessage());
+                    Log::error('Unexpected error in processBatch for release '.$releaseId.': '.$e->getMessage());
                     $this->stats['failed']++;
 
                     // Ensure the release is marked as processed to avoid infinite loop
                     try {
                         $this->updateReleaseXxxId($releaseId, -2);
                     } catch (\Throwable $updateError) {
-                        Log::error('Failed to update release ' . $releaseId . ' with error code: ' . $updateError->getMessage());
+                        Log::error('Failed to update release '.$releaseId.' with error code: '.$updateError->getMessage());
                     }
                 }
             }
@@ -308,7 +308,7 @@ 
                 $this->stats['processed']++;
             }
         } catch (\Throwable $e) {
-            Log::error('Async batch processing failed: ' . $e->getMessage());
+            Log::error('Async batch processing failed: '.$e->getMessage());
 
             // Mark all releases in batch as processed with error to avoid infinite loop
             foreach ($batch as $release) {
@@ -316,7 +316,7 @@ 
                 try {
                     Release::query()->where('id', $release['id'])->update(['xxxinfo_id' => -2]);
                 } catch (\Throwable $updateError) {
-                    Log::error('Failed to mark release ' . $release['id'] . ' as processed: ' . $updateError->getMessage());
+                    Log::error('Failed to mark release '.$release['id'].' as processed: '.$updateError->getMessage());
                 }
             }
         }
@@ -409,12 +409,12 @@ 
 
             if ($existingInfo !== null) {
                 if ($this->echoOutput) {
-                    cli()->info('Local match found for XXX Movie: ' . $cleanTitle);
+                    cli()->info('Local match found for XXX Movie: '.$cleanTitle);
                 }
                 $idCheck = (int) $existingInfo['id'];
             } else {
                 if ($this->echoOutput) {
-                    cli()->info('Looking up: ' . $cleanTitle);
+                    cli()->info('Looking up: '.$cleanTitle);
                     cli()->info('Local match not found, checking web!');
                 }
 
@@ -433,7 +433,7 @@ 
                 $this->stats['matched']++;
             }
         } catch (\Throwable $e) {
-            Log::error('Processing failed for release ' . $releaseId . ': ' . $e->getMessage(), [
+            Log::error('Processing failed for release '.$releaseId.': '.$e->getMessage(), [
                 'exception' => get_class($e),
                 'file' => $e->getFile(),
                 'line' => $e->getLine(),
@@ -444,7 +444,7 @@ 
             try {
                 $this->updateReleaseXxxId($releaseId, -2);
             } catch (\Throwable $updateError) {
-                Log::error('Failed to update release ' . $releaseId . ' after processing error: ' . $updateError->getMessage());
+                Log::error('Failed to update release '.$releaseId.' after processing error: '.$updateError->getMessage());
             }
             $this->stats['failed']++;
         }
@@ -477,7 +477,7 @@ 
                 'hotm' => 'HotMovies',
                 default => $providerName,
             };
-            cli()->primary('Fetching XXX info from: ' . $fromStr);
+            cli()->primary('Fetching XXX info from: '.$fromStr);
         }
 
         // Track provider usage
@@ -515,19 +515,19 @@ 
 
             // Update BoxCover
             if (!empty($mov['cover'])) {
-                $cover = $this->releaseImage->saveImage($xxxID . '-cover', $mov['cover'], $this->imgSavePath);
+                $cover = $this->releaseImage->saveImage($xxxID.'-cover', $mov['cover'], $this->imgSavePath);
             }
 
             // BackCover
             if (!empty($mov['backdrop'])) {
-                $backdrop = $this->releaseImage->saveImage($xxxID . '-backdrop', $mov['backdrop'], $this->imgSavePath, 1920, 1024);
+                $backdrop = $this->releaseImage->saveImage($xxxID.'-backdrop', $mov['backdrop'], $this->imgSavePath, 1920, 1024);
             }
 
             // Update existing record
             XxxInfo::query()->where('id', $check['id'])->update([
                 'title' => $mov['title'],
                 'tagline' => $mov['tagline'],
-                'plot' => "\x1f\x8b\x08\x00" . gzcompress($mov['plot']),
+                'plot' => "\x1f\x8b\x08\x00".gzcompress($mov['plot']),
                 'genre' => substr($mov['genre'], 0, 64),
                 'director' => $mov['director'],
                 'actors' => $mov['actors'],
@@ -544,7 +544,7 @@ 
             $xxxID = XxxInfo::query()->insertGetId([
                 'title' => $mov['title'],
                 'tagline' => $mov['tagline'],
-                'plot' => "\x1f\x8b\x08\x00" . gzcompress($mov['plot']),
+                'plot' => "\x1f\x8b\x08\x00".gzcompress($mov['plot']),
                 'genre' => substr($mov['genre'], 0, 64),
                 'director' => $mov['director'],
                 'actors' => $mov['actors'],
@@ -559,12 +559,12 @@ 
 
             // Update BoxCover
             if (!empty($mov['cover'])) {
-                $cover = $this->releaseImage->saveImage($xxxID . '-cover', $mov['cover'], $this->imgSavePath);
+                $cover = $this->releaseImage->saveImage($xxxID.'-cover', $mov['cover'], $this->imgSavePath);
             }
 
             // BackCover
             if (!empty($mov['backdrop'])) {
-                $backdrop = $this->releaseImage->saveImage($xxxID . '-backdrop', $mov['backdrop'], $this->imgSavePath, 1920, 1024);
+                $backdrop = $this->releaseImage->saveImage($xxxID.'-backdrop', $mov['backdrop'], $this->imgSavePath, 1920, 1024);
             }
 
             XxxInfo::whereId($xxxID)->update(['cover' => $cover, 'backdrop' => $backdrop]);
@@ -572,7 +572,7 @@ 
 
         if ($this->echoOutput) {
             cli()->primary(
-                ($xxxID !== false ? 'Added/updated XXX movie: ' . $mov['title'] : 'Nothing to update for XXX movie: ' . $mov['title']),
+                ($xxxID !== false ? 'Added/updated XXX movie: '.$mov['title'] : 'Nothing to update for XXX movie: '.$mov['title']),
                 true
             );
         }
@@ -618,7 +618,7 @@ 
      */
     protected function checkXXXInfoExists(string $releaseName): ?array
     {
-        $result = XxxInfo::query()->where('title', 'like', '%' . $releaseName . '%')->first(['id', 'title']);
+        $result = XxxInfo::query()->where('title', 'like', '%'.$releaseName.'%')->first(['id', 'title']);
         return $result ? $result->toArray() : null;
     }
 
@@ -648,9 +648,9 @@ 
         foreach ($arr as $value) {
             $res = Genre::query()->where('title', $value)->first(['id']);
             if ($res !== null) {
-                $ret .= ',' . $res['id'];
+                $ret .= ','.$res['id'];
             } else {
-                $ret .= ',' . $this->insertGenre($value);
+                $ret .= ','.$this->insertGenre($value);
             }
         }
 
@@ -682,12 +682,12 @@ 
         $name = '';
         $followingList = '[^\w]((2160|1080|480|720)(p|i)|AC3D|Directors([^\w]CUT)?|DD5\.1|(DVD|BD|BR)(Rip)?|BluRay|divx|HDTV|iNTERNAL|LiMiTED|(Real\.)?Proper|RE(pack|Rip)|Sub\.?(fix|pack)|Unrated|WEB-DL|(x|H)[ ._-]?264|xvid|[Dd][Ii][Ss][Cc](\d+|\s*\d+|\.\d+)|XXX|BTS|DirFix|Trailer|WEBRiP|NFO|(19|20)\d\d)[^\w]';
 
-        if (preg_match('/([^\w]{2,})?(?P<name>[\w .-]+?)' . $followingList . '/i', $releaseName, $hits)) {
+        if (preg_match('/([^\w]{2,})?(?P<name>[\w .-]+?)'.$followingList.'/i', $releaseName, $hits)) {
             $name = $hits['name'];
         }
 
         if ($name !== '') {
-            $name = preg_replace('/' . $followingList . '/i', ' ', $name);
+            $name = preg_replace('/'.$followingList.'/i', ' ', $name);
             $name = preg_replace('/\(.*?\)|[._-]/i', ' ', $name);
             $name = trim(preg_replace('/\s{2,}/', ' ', $name));
             $name = trim(preg_replace('/^Private\s(Specials|Blockbusters|Blockbuster|Sports|Gold|Lesbian|Movies|Classics|Castings|Fetish|Stars|Pictures|XXX|Private|Black\sLabel|Black)\s\d+/i', '', $name));
@@ -727,10 +727,10 @@ 
     protected function outputStats(): void
     {
         cli()->header("\n=== Adult Processing Statistics ===");
-        cli()->primary('Processed: ' . $this->stats['processed']);
-        cli()->primary('Matched: ' . $this->stats['matched']);
-        cli()->primary('Failed: ' . $this->stats['failed']);
-        cli()->primary('Skipped: ' . $this->stats['skipped']);
+        cli()->primary('Processed: '.$this->stats['processed']);
+        cli()->primary('Matched: '.$this->stats['matched']);
+        cli()->primary('Failed: '.$this->stats['failed']);
+        cli()->primary('Skipped: '.$this->stats['skipped']);
         cli()->primary(sprintf('Duration: %.2f seconds', $this->stats['duration']));
 
         if (!empty($this->stats['providers'])) {

app/Extensions/helper/helpers.php

Spacing +50 added lines, -51 removed lines

@@ -15,7 +15,7 @@ 
 use Symfony\Component\Process\Process;
 use Zip as ZipStream;
 
-if (! function_exists('getRawHtml')) {
+if (!function_exists('getRawHtml')) {
     /**
      * @param  bool  $cookie
      * @return bool|mixed|string
@@ -106,7 +106,7 @@ 
     }
 }
 
-if (! function_exists('makeFieldLinks')) {
+if (!function_exists('makeFieldLinks')) {
     /**
      * @return string
      *
@@ -136,7 +136,7 @@ 
     }
 }
 
-if (! function_exists('getUserBrowseOrder')) {
+if (!function_exists('getUserBrowseOrder')) {
     /**
      * @param  string  $orderBy
      */
@@ -162,7 +162,7 @@ 
     }
 }
 
-if (! function_exists('getUserBrowseOrdering')) {
+if (!function_exists('getUserBrowseOrdering')) {
     function getUserBrowseOrdering(): array
     {
         return [
@@ -192,7 +192,7 @@ 
     }
 }
 
-if (! function_exists('getSimilarName')) {
+if (!function_exists('getSimilarName')) {
     /**
      * @param  string  $name
      */
@@ -202,7 +202,7 @@ 
     }
 }
 
-if (! function_exists('human_filesize')) {
+if (!function_exists('human_filesize')) {
     /**
      * @param  int  $decimals
      */
@@ -215,7 +215,7 @@ 
     }
 }
 
-if (! function_exists('bcdechex')) {
+if (!function_exists('bcdechex')) {
     /**
      * @return string
      */
@@ -232,7 +232,7 @@ 
     }
 }
 
-if (! function_exists('runCmd')) {
+if (!function_exists('runCmd')) {
     /**
      * Run CLI command.
      *
@@ -260,7 +260,7 @@ 
     }
 }
 
-if (! function_exists('escapeString')) {
+if (!function_exists('escapeString')) {
 
     function escapeString($string): string
     {
@@ -268,7 +268,7 @@ 
     }
 }
 
-if (! function_exists('realDuration')) {
+if (!function_exists('realDuration')) {
 
     function realDuration($milliseconds): string
     {
@@ -278,7 +278,7 @@ 
     }
 }
 
-if (! function_exists('is_it_json')) {
+if (!function_exists('is_it_json')) {
     /**
      * @throws JsonException
      */
@@ -293,7 +293,7 @@ 
     }
 }
 
-if (! function_exists('getStreamingZip')) {
+if (!function_exists('getStreamingZip')) {
     /**
      * @throws Exception
      */
@@ -320,7 +320,7 @@ 
     }
 }
 
-if (! function_exists('release_flag')) {
+if (!function_exists('release_flag')) {
     // Function inspired by c0r3@newznabforums adds country flags on the browse page.
     /**
      * @param  string  $text  Text to match against.
@@ -457,7 +457,7 @@ 
     }
 }
 
-if (! function_exists('getReleaseCover')) {
+if (!function_exists('getReleaseCover')) {
     /**
      * Get the cover image URL for a release based on its type and ID
      *
@@ -470,7 +470,7 @@ 
         $coverId = null;
 
         // Helper function to get value from object or array
-        $getValue = function ($data, $key) {
+        $getValue = function($data, $key) {
             if (is_array($data)) {
                 return $data[$key] ?? null;
             } elseif (is_object($data)) {
@@ -489,25 +489,25 @@ 
         $xxxinfo_id = $getValue($release, 'xxxinfo_id');
         $anidbid = $getValue($release, 'anidbid');
 
-        if (! empty($imdbid) && $imdbid > 0) {
+        if (!empty($imdbid) && $imdbid > 0) {
             $coverType = 'movies';
             $coverId = str_pad($imdbid, 7, '0', STR_PAD_LEFT);
-        } elseif (! empty($musicinfo_id)) {
+        } elseif (!empty($musicinfo_id)) {
             $coverType = 'music';
             $coverId = $musicinfo_id;
-        } elseif (! empty($consoleinfo_id)) {
+        } elseif (!empty($consoleinfo_id)) {
             $coverType = 'console';
             $coverId = $consoleinfo_id;
-        } elseif (! empty($bookinfo_id)) {
+        } elseif (!empty($bookinfo_id)) {
             $coverType = 'book';
             $coverId = $bookinfo_id;
-        } elseif (! empty($gamesinfo_id)) {
+        } elseif (!empty($gamesinfo_id)) {
             $coverType = 'games';
             $coverId = $gamesinfo_id;
-        } elseif (! empty($xxxinfo_id)) {
+        } elseif (!empty($xxxinfo_id)) {
             $coverType = 'xxx';
             $coverId = $xxxinfo_id;
-        } elseif (! empty($anidbid) && $anidbid > 0) {
+        } elseif (!empty($anidbid) && $anidbid > 0) {
             $coverType = 'anime';
             $coverId = $anidbid;
         }
@@ -523,10 +523,10 @@ 
     }
 }
 
-if (! function_exists('sanitize')) {
+if (!function_exists('sanitize')) {
     function sanitize(array|string $phrases, array $doNotSanitize = []): string
     {
-        if (! is_array($phrases)) {
+        if (!is_array($phrases)) {
             $wordArray = explode(' ', str_replace('.', ' ', $phrases));
         } else {
             $wordArray = $phrases;
@@ -537,9 +537,9 @@ 
         foreach ($wordArray as $words) {
             $words = preg_split('/\s+/', $words);
             foreach ($words as $st) {
-                if (Str::startsWith($st, ['!', '+', '-', '?', '*']) && Str::length($st) > 1 && ! preg_match('/([!+?\-*]){2,}/', $st)) {
+                if (Str::startsWith($st, ['!', '+', '-', '?', '*']) && Str::length($st) > 1 && !preg_match('/([!+?\-*]){2,}/', $st)) {
                     $str = $st;
-                } elseif (Str::endsWith($st, ['+', '-', '?', '*']) && Str::length($st) > 1 && ! preg_match('/([!+?\-*]){2,}/', $st)) {
+                } elseif (Str::endsWith($st, ['+', '-', '?', '*']) && Str::length($st) > 1 && !preg_match('/([!+?\-*]){2,}/', $st)) {
                     $str = $st;
                 } else {
                     $str = Sanitizer::escape($st, $doNotSanitize);
@@ -554,7 +554,7 @@ 
     }
 }
 
-if (! function_exists('formatBytes')) {
+if (!function_exists('formatBytes')) {
     /**
      * Format bytes into human-readable file size.
      *
@@ -573,7 +573,7 @@ 
     }
 }
 
-if (! function_exists('csp_nonce')) {
+if (!function_exists('csp_nonce')) {
     /**
      * Generate a CSP nonce for inline scripts
      * This should be stored in the request and reused across the request lifecycle
@@ -590,7 +590,7 @@ 
     }
 }
 
-if (! function_exists('userDate')) {
+if (!function_exists('userDate')) {
     /**
      * Format a date/time string according to the authenticated user's timezone
      *
@@ -622,7 +622,7 @@ 
     }
 }
 
-if (! function_exists('userDateDiffForHumans')) {
+if (!function_exists('userDateDiffForHumans')) {
     /**
      * Format a date/time string as a human-readable diff according to the authenticated user's timezone
      *
@@ -653,7 +653,7 @@ 
     }
 }
 
-if (! function_exists('getAvailableTimezones')) {
+if (!function_exists('getAvailableTimezones')) {
     /**
      * Get a list of available timezones grouped by region
      *
@@ -683,7 +683,7 @@ 
     }
 }
 
-if (! function_exists('countryCode')) {
+if (!function_exists('countryCode')) {
     /**
      * Get a country code for a country name.
      *
@@ -702,7 +702,7 @@ 
     }
 }
 
-if (! function_exists('unzipGzipFile')) {
+if (!function_exists('unzipGzipFile')) {
     /**
      * Unzip a gzip file, return the output. Return false on error / empty.
      *
@@ -713,12 +713,12 @@ 
         $string = '';
         $gzFile = @gzopen($filePath, 'rb', 0);
         if ($gzFile) {
-            while (! gzeof($gzFile)) {
+            while (!gzeof($gzFile)) {
                 $temp = gzread($gzFile, 1024);
                 // Check for empty string.
                 // Without this the loop would be endless and consume 100% CPU.
                 // Do not set $string empty here, as the data might still be good.
-                if (! $temp) {
+                if (!$temp) {
                     break;
                 }
                 $string .= $temp;
@@ -730,7 +730,7 @@ 
     }
 }
 
-if (! function_exists('streamSslContextOptions')) {
+if (!function_exists('streamSslContextOptions')) {
     /**
      * Creates an array to be used with stream_context_create() to verify openssl certificates
      * when connecting to a tls or ssl connection when using stream functions (fopen/file_get_contents/etc).
@@ -746,13 +746,13 @@ 
 
         // Base options - either insecure (no certs configured) or configured
         $options = [
-            'verify_peer' => ! $forceIgnore && $hasCustomCerts && config('nntmux_ssl.ssl_verify_peer', false),
-            'verify_peer_name' => ! $forceIgnore && $hasCustomCerts && config('nntmux_ssl.ssl_verify_host', false),
+            'verify_peer' => !$forceIgnore && $hasCustomCerts && config('nntmux_ssl.ssl_verify_peer', false),
+            'verify_peer_name' => !$forceIgnore && $hasCustomCerts && config('nntmux_ssl.ssl_verify_host', false),
             'allow_self_signed' => $forceIgnore ? true : config('nntmux_ssl.ssl_allow_self_signed', true),
         ];
 
         // Add certificate paths if configured
-        if ($hasCustomCerts && ! $forceIgnore) {
+        if ($hasCustomCerts && !$forceIgnore) {
             if ($cafile !== '') {
                 $options['cafile'] = $cafile;
             }
@@ -762,7 +762,7 @@ 
         }
 
         // Additional security options for modern TLS
-        $options['crypto_method'] = STREAM_CRYPTO_METHOD_TLSv1_2_CLIENT | STREAM_CRYPTO_METHOD_TLSv1_3_CLIENT;
+        $options['crypto_method'] = STREAM_CRYPTO_METHOD_TLSv1_2_CLIENT|STREAM_CRYPTO_METHOD_TLSv1_3_CLIENT;
         $options['disable_compression'] = true; // Prevent CRIME attacks
         $options['SNI_enabled'] = true; // Enable Server Name Indication
 
@@ -773,7 +773,7 @@ 
     }
 }
 
-if (! function_exists('getCoverURL')) {
+if (!function_exists('getCoverURL')) {
     function getCoverURL(array $options = []): string
     {
         $defaults = [
@@ -785,22 +785,21 @@ 
         $fileSpecTemplate = '%s/%s%s';
         $fileSpec = '';
 
-        if (! empty($options['id']) && \in_array(
+        if (!empty($options['id']) && \in_array(
             $options['type'],
             ['anime', 'audio', 'audiosample', 'book', 'console', 'games', 'movies', 'music', 'preview', 'sample', 'tvrage', 'video', 'xxx'],
             false
         )
         ) {
             $fileSpec = sprintf($fileSpecTemplate, $options['type'], $options['id'], $options['suffix']);
-            $fileSpec = file_exists(storage_path('covers/').$fileSpec) ? $fileSpec :
-                sprintf($fileSpecTemplate, $options['type'], 'no', $options['suffix']);
+            $fileSpec = file_exists(storage_path('covers/').$fileSpec) ? $fileSpec : sprintf($fileSpecTemplate, $options['type'], 'no', $options['suffix']);
         }
 
         return $fileSpec;
     }
 }
 
-if (! function_exists('fileInfo')) {
+if (!function_exists('fileInfo')) {
     /**
      * Return file type/info using magic numbers.
      * Try using `file` program where available, fallback to using PHP's finfo class.
@@ -830,7 +829,7 @@ 
     }
 }
 
-if (! function_exists('cp437toUTF')) {
+if (!function_exists('cp437toUTF')) {
     /**
      * Convert Code page 437 chars to UTF.
      */
@@ -840,7 +839,7 @@ 
     }
 }
 
-if (! function_exists('imdb_trailers')) {
+if (!function_exists('imdb_trailers')) {
     /**
      * Fetches an embeddable video to a IMDB trailer from http://www.traileraddict.com.
      */
@@ -855,7 +854,7 @@ 
     }
 }
 
-if (! function_exists('showApiError')) {
+if (!function_exists('showApiError')) {
     function showApiError(int $errorCode = 900, string $errorText = '')
     {
         $errorHeader = 'HTTP 1.1 400 Bad Request';
@@ -940,7 +939,7 @@ 
     }
 }
 
-if (! function_exists('getRange')) {
+if (!function_exists('getRange')) {
     function getRange($tableName): \Illuminate\Contracts\Pagination\LengthAwarePaginator
     {
         $range = \Illuminate\Support\Facades\DB::table($tableName);
@@ -952,7 +951,7 @@ 
     }
 }
 
-if (! function_exists('isValidNewznabNzb')) {
+if (!function_exists('isValidNewznabNzb')) {
     /**
      * Validate if the content is a valid Newznab NZB file.
      *
@@ -986,7 +985,7 @@ 
     }
 }
 
-if (! function_exists('cli')) {
+if (!function_exists('cli')) {
     /**
      * Get the CLI helper instance for colored console output.
      *

app/Console/Commands/TmuxMonitorCommand.php

Spacing +1 added lines, -1 removed lines

@@ -92,7 +92,7 @@
         cli()->header('Resetting expired collections. This may take some time...');
 
         try {
-            DB::transaction(function () use ($delayTime) {
+            DB::transaction(function() use ($delayTime) {
                 Collection::query()
                     ->where('dateadded', '<', now()->subHours($delayTime))
                     ->update(['dateadded' => now()]);

app/Console/Commands/ReprocessTvRelease.php

Spacing +7 added lines, -7 removed lines

@@ -54,7 +54,7 @@ 
             [[
                 $release->id,
                 $release->guid,
-                mb_substr($release->searchname, 0, 60) . (strlen($release->searchname) > 60 ? '...' : ''),
+                mb_substr($release->searchname, 0, 60).(strlen($release->searchname) > 60 ? '...' : ''),
                 $release->videos_id,
                 $release->tv_episodes_id,
                 $release->categories_id,
@@ -81,14 +81,14 @@ 
 
             if ($result['matched']) {
                 cli()->primary('Successfully matched!');
-                $this->info('Provider: ' . ($result['provider'] ?? 'Unknown'));
-                $this->info('Video ID: ' . ($result['video_id'] ?? 'N/A'));
-                $this->info('Episode ID: ' . ($result['episode_id'] ?? 'N/A'));
+                $this->info('Provider: '.($result['provider'] ?? 'Unknown'));
+                $this->info('Video ID: '.($result['video_id'] ?? 'N/A'));
+                $this->info('Episode ID: '.($result['episode_id'] ?? 'N/A'));
             } else {
                 cli()->warning('No match found.');
-                $this->info('Status: ' . ($result['status'] ?? 'Unknown'));
+                $this->info('Status: '.($result['status'] ?? 'Unknown'));
                 if (isset($result['provider'])) {
-                    $this->info('Last provider tried: ' . $result['provider']);
+                    $this->info('Last provider tried: '.$result['provider']);
                 }
             }
 
@@ -110,7 +110,7 @@ 
             return self::SUCCESS;
         } catch (\Throwable $e) {
             Log::error($e->getTraceAsString());
-            $this->error('Error processing release: ' . $e->getMessage());
+            $this->error('Error processing release: '.$e->getMessage());
             if ($debug) {
                 $this->error($e->getTraceAsString());
             }

app/Console/Commands/TmuxStart.php

Spacing +4 added lines, -4 removed lines

@@ -50,7 +50,7 @@ 
             $this->layoutBuilder = new TmuxLayoutBuilder($this->sessionManager);
 
             // Check if tmux is installed
-            if (! $this->checkTmuxInstalled()) {
+            if (!$this->checkTmuxInstalled()) {
                 $this->error('❌ tmux is not installed');
 
                 return Command::FAILURE;
@@ -58,7 +58,7 @@ 
 
             // Check if session already exists
             if ($this->sessionManager->sessionExists()) {
-                if (! $this->option('force')) {
+                if (!$this->option('force')) {
                     $this->error("❌ Session '{$sessionName}' already exists");
                     if ($this->confirm('Would you like to restart it?', false)) {
                         $this->call('tmux:stop', ['--session' => $sessionName]);
@@ -81,7 +81,7 @@ 
             $this->info("