NNTmux / newznab-tmux

app/Services/Runners/BaseRunner.php

Spacing +11 added lines, -11 removed lines

@@ -135,7 +135,7 @@ 
     {
         $process = Process::fromShellCommandline($command);
         $process->setTimeout(1800);
-        $process->run(function ($type, $buffer) {
+        $process->run(function($type, $buffer) {
             if ($type === Process::ERR) {
                 echo $buffer;
             }
@@ -178,7 +178,7 @@ 
         $running = [];
         $queue = $tasks;
 
-        $startNext = function () use (&$queue, &$running, $timeout): ?string {
+        $startNext = function() use (&$queue, &$running, $timeout): ?string {
             if (empty($queue)) {
                 return null;
             }
@@ -202,7 +202,7 @@ 
                 try {
                     $results[$key] = $callable();
                 } catch (\Throwable $e) {
-                    \Log::error("Task {$key} failed: " . $e->getMessage());
+                    \Log::error("Task {$key} failed: ".$e->getMessage());
                     $results[$key] = '';
                 }
             }
@@ -231,7 +231,7 @@ 
                 try {
                     $results[$key] = $callable();
                 } catch (\Throwable $e) {
-                    \Log::error("Task {$key} failed: " . $e->getMessage());
+                    \Log::error("Task {$key} failed: ".$e->getMessage());
                     $results[$key] = '';
                 }
             }
@@ -256,7 +256,7 @@ 
         $running = [];
         $queue = $commands;
 
-        $startNext = function () use (&$queue, &$running, $timeout) {
+        $startNext = function() use (&$queue, &$running, $timeout) {
             if (empty($queue)) {
                 return;
             }
@@ -313,14 +313,14 @@ 
 
         $this->headerStart('postprocess: '.$desc, $total, $maxProcesses);
 
-        $startNext = function () use (&$queue, &$running, &$started) {
+        $startNext = function() use (&$queue, &$running, &$started) {
             if (empty($queue)) {
                 return;
             }
             $cmd = array_shift($queue);
             $proc = Process::fromShellCommandline($cmd);
             $proc->setTimeout((int) config('nntmux.multiprocessing_max_child_time', 1800));
-            $proc->start(function ($type, $buffer) {
+            $proc->start(function($type, $buffer) {
                 // Stream both STDOUT and STDERR
                 echo $buffer;
             });
@@ -329,14 +329,14 @@ 
         };
 
         // Prime initial processes
-        for ($i = 0; $i < $maxProcesses && ! empty($queue); $i++) {
+        for ($i = 0; $i < $maxProcesses && !empty($queue); $i++) {
             $startNext();
         }
 
         // Event loop
-        while (! empty($running)) {
+        while (!empty($running)) {
             foreach ($running as $key => $proc) {
-                if (! $proc->isRunning()) {
+                if (!$proc->isRunning()) {
                     // Print any remaining buffered output
                     $out = $proc->getIncrementalOutput();
                     $err = $proc->getIncrementalErrorOutput();
@@ -352,7 +352,7 @@ 
                         $this->colorCli->primary('Finished task #'.($total - $finished + 1).' for '.$desc);
                     }
                     // Start next from queue if available
-                    if (! empty($queue)) {
+                    if (!empty($queue)) {
                         $startNext();
                     }
                 }

app/Services/AdditionalProcessing/ArchiveExtractionService.php

Spacing +27 added lines, -27 removed lines

@@ -71,7 +71,7 @@ 
         }
 
         // Try ArchiveInfo for RAR/ZIP
-        if (! $this->archiveInfo->setData($compressedData, true)) {
+        if (!$this->archiveInfo->setData($compressedData, true)) {
             // Handle standalone video detection
             $videoType = $this->detectStandaloneVideo($compressedData);
             if ($videoType !== null) {
@@ -104,7 +104,7 @@ 
         }
 
         // Check for encryption
-        if (! empty($this->archiveInfo->isEncrypted)
+        if (!empty($this->archiveInfo->isEncrypted)
             || (isset($dataSummary['is_encrypted']) && (int) $dataSummary['is_encrypted'] !== 0)
         ) {
             if ($this->config->debugMode) {
@@ -126,7 +126,7 @@ 
 
         // Get file list
         $files = $this->archiveInfo->getArchiveFileList();
-        if (! is_array($files) || count($files) === 0) {
+        if (!is_array($files) || count($files) === 0) {
             return $result;
         }
 
@@ -207,14 +207,14 @@ 
             'passwordStatus' => ReleaseBrowseService::PASSWD_NONE,
         ];
 
-        if (! $this->config->sevenZipPath) {
+        if (!$this->config->sevenZipPath) {
             return $result;
         }
 
         // Try listing with external 7z binary
         $listed = $this->listSevenZipEntries($compressedData, $tmpPath);
-        if (! empty($listed)) {
-            if (! empty($listed[0]['__any_encrypted__'])) {
+        if (!empty($listed)) {
+            if (!empty($listed[0]['__any_encrypted__'])) {
                 return [
                     'success' => false,
                     'files' => [],
@@ -224,7 +224,7 @@ 
             }
 
             $files = $this->filterSevenZipFiles($listed);
-            if (! empty($files)) {
+            if (!empty($files)) {
                 return [
                     'success' => true,
                     'files' => $files,
@@ -237,7 +237,7 @@ 
 
         // Fallback: scan for filenames in raw data
         $scannedNames = $this->scanSevenZipFilenames($compressedData);
-        if (! empty($scannedNames)) {
+        if (!empty($scannedNames)) {
             $files = array_map(fn($name) => [
                 'name' => $name,
                 'size' => 0,
@@ -264,7 +264,7 @@ 
      */
     public function listSevenZipEntries(string $compressedData, string $tmpPath): array
     {
-        if (! $this->config->sevenZipPath) {
+        if (!$this->config->sevenZipPath) {
             return [];
         }
 
@@ -280,7 +280,7 @@ 
             $stderr = null;
             $ok = $this->execCommand($cmd, $exitCode, $stdout, $stderr);
 
-            if (! $ok || $exitCode !== 0 || empty($stdout)) {
+            if (!$ok || $exitCode !== 0 || empty($stdout)) {
                 // Try plain listing fallback
                 $plainResult = $this->listSevenZipPlain($tmpFile);
                 File::delete($tmpFile);
@@ -308,7 +308,7 @@ 
         $stderr = null;
         $ok = $this->execCommand($cmd, $exitCode, $stdout, $stderr);
 
-        if (! $ok || $exitCode !== 0 || empty($stdout)) {
+        if (!$ok || $exitCode !== 0 || empty($stdout)) {
             return [];
         }
 
@@ -398,7 +398,7 @@ 
         $filtered = [];
 
         foreach ($files as $entry) {
-            if (! empty($entry['__any_encrypted__'])) {
+            if (!empty($entry['__any_encrypted__'])) {
                 continue;
             }
 
@@ -408,7 +408,7 @@ 
             }
 
             $ext = strtolower(pathinfo($name, PATHINFO_EXTENSION));
-            if (! in_array($ext, $allowedExtensions, true)) {
+            if (!in_array($ext, $allowedExtensions, true)) {
                 continue;
             }
 
@@ -460,7 +460,7 @@ 
             }
             $candidate = trim($candidate, " .-\t\n\r");
             $lower = strtolower($candidate);
-            if (! isset($names[$lower])) {
+            if (!isset($names[$lower])) {
                 $names[$lower] = $candidate;
                 if (count($names) >= 80) {
                     break;
@@ -483,7 +483,7 @@ 
             'passwordStatus' => ReleaseBrowseService::PASSWD_NONE,
         ];
 
-        if ($this->config->extractUsingRarInfo || ! $this->config->sevenZipPath) {
+        if ($this->config->extractUsingRarInfo || !$this->config->sevenZipPath) {
             return $result;
         }
 
@@ -494,7 +494,7 @@ 
             $marker = $markerMap[$type] ?? $type;
 
             $extractDir = $tmpPath.'un7z/'.uniqid('', true).'/';
-            if (! File::isDirectory($extractDir)) {
+            if (!File::isDirectory($extractDir)) {
                 File::makeDirectory($extractDir, 0777, true, true);
             }
 
@@ -523,7 +523,7 @@ 
 
             File::delete($fileName);
 
-            if (! empty($files)) {
+            if (!empty($files)) {
                 return [
                     'success' => true,
                     'files' => $this->filterExtractedFiles($files),
@@ -553,7 +553,7 @@ 
             $name = $file['name'] ?? '';
             $ext = strtolower(pathinfo($name, PATHINFO_EXTENSION));
 
-            if (! in_array($ext, $allowedExtensions, true)) {
+            if (!in_array($ext, $allowedExtensions, true)) {
                 continue;
             }
 
@@ -635,14 +635,14 @@ 
      */
     public function sortFilesWithNfoPriority(array $files): array
     {
-        usort($files, function ($a, $b) {
+        usort($files, function($a, $b) {
             $aIsNfo = $this->isNfoFile($a['name'] ?? '');
             $bIsNfo = $this->isNfoFile($b['name'] ?? '');
 
-            if ($aIsNfo && ! $bIsNfo) {
+            if ($aIsNfo && !$bIsNfo) {
                 return -1;
             }
-            if (! $aIsNfo && $bIsNfo) {
+            if (!$aIsNfo && $bIsNfo) {
                 return 1;
             }
 
@@ -664,12 +664,12 @@ 
         try {
             if ($this->config->unrarPath) {
                 $unrarDir = $tmpPath.'unrar/';
-                if (! File::isDirectory($unrarDir)) {
+                if (!File::isDirectory($unrarDir)) {
                     File::makeDirectory($unrarDir, 0777, true, true);
                 }
             }
             $unzipDir = $tmpPath.'unzip/';
-            if (! File::isDirectory($unzipDir)) {
+            if (!File::isDirectory($unzipDir)) {
                 File::makeDirectory($unzipDir, 0777, true, true);
             }
         } catch (\Throwable $e) {
@@ -688,7 +688,7 @@ 
 
         switch ($dataSummary['main_type']) {
             case ArchiveInfo::TYPE_RAR:
-                if (! $this->config->extractUsingRarInfo && $this->config->unrarPath) {
+                if (!$this->config->extractUsingRarInfo && $this->config->unrarPath) {
                     $fileName = $tmpPath.uniqid('', true).'.rar';
                     File::put($fileName, $compressedData);
                     runCmd($killString.$this->config->unrarPath.'" e -ai -ep -c- -id -inul -kb -or -p- -r -y "'.$fileName.'" "'.$tmpPath.'unrar/"');
@@ -697,7 +697,7 @@ 
                 return 'r';
 
             case ArchiveInfo::TYPE_ZIP:
-                if (! $this->config->extractUsingRarInfo && $this->config->unzipPath) {
+                if (!$this->config->extractUsingRarInfo && $this->config->unzipPath) {
                     $fileName = $tmpPath.uniqid('', true).'.zip';
                     File::put($fileName, $compressedData);
                     runCmd($this->config->unzipPath.' -o "'.$fileName.'" -d "'.$tmpPath.'unzip/"');
@@ -736,7 +736,7 @@ 
         if ($len >= 188 * 5) {
             $isTs = true;
             for ($i = 0; $i < 5; $i++) {
-                if (! isset($data[188 * $i]) || $data[188 * $i] !== "\x47") {
+                if (!isset($data[188 * $i]) || $data[188 * $i] !== "\x47") {
                     $isTs = false;
                     break;
                 }
@@ -783,7 +783,7 @@ 
         ];
 
         $process = @proc_open($cmd, $descriptorSpec, $pipes, null, null, ['bypass_shell' => true]);
-        if (! is_resource($process)) {
+        if (!is_resource($process)) {
             $exitCode = -1;
             return false;
         }

app/Services/AdditionalProcessing/ReleaseFileManager.php

Spacing +11 added lines, -11 removed lines

@@ -56,7 +56,7 @@ 
             return false;
         }
 
-        if (! isset($file['name'])) {
+        if (!isset($file['name'])) {
             return false;
         }
 
@@ -116,7 +116,7 @@ 
             $file['crc32'] ?? ''
         );
 
-        if (! empty($added)) {
+        if (!empty($added)) {
             $context->addedFileInfo++;
 
             // Check for codec spam
@@ -126,7 +126,7 @@ 
                 }
                 $context->releaseHasPassword = true;
                 $context->passwordStatus = ReleaseBrowseService::PASSWD_RAR;
-            } elseif ($file['name'] !== '' && ! str_starts_with($file['name'], '.')) {
+            } elseif ($file['name'] !== '' && !str_starts_with($file['name'], '.')) {
                 // Run PreDB filename check
                 $context->release['filename'] = $file['name'];
                 $context->release['releases_id'] = $context->release->id;
@@ -177,12 +177,12 @@ 
         $passwordStatus = max([$context->passwordStatus]);
 
         // Set to no password if processing is off
-        if (! $processPasswords) {
+        if (!$processPasswords) {
             $context->releaseHasPassword = false;
         }
 
         // Update based on conditions
-        if (! $context->releaseHasPassword && $context->nzbHasCompressedFile && $releaseFilesCount === 0) {
+        if (!$context->releaseHasPassword && $context->nzbHasCompressedFile && $releaseFilesCount === 0) {
             Release::query()->where('id', $context->release->id)->update($updateRows);
         } else {
             $updateRows['passwordstatus'] = $processPasswords ? $passwordStatus : ReleaseBrowseService::PASSWD_NONE;
@@ -298,7 +298,7 @@ 
         $filesAdded = 0;
 
         foreach ($par2Info->getFileList() as $file) {
-            if (! isset($file['name'])) {
+            if (!isset($file['name'])) {
                 continue;
             }
 
@@ -329,7 +329,7 @@ 
             }
 
             // Try to get a new name
-            if (! $foundName) {
+            if (!$foundName) {
                 $context->release->textstring = $file['name'];
                 $context->release->releases_id = $context->release->id;
                 if ($this->nameFixingService->checkName($context->release, $this->config->echoCLI, 'PAR2, ', true, true)) {
@@ -393,10 +393,10 @@ 
         // Alternative NFO filenames
         $nfoPatterns = [
             '/^(?:file[_-]?id|readme|release|info(?:rmation)?|about|notes?)\.(?:txt|diz)$/i',
-            '/^00-[a-z0-9_-]+\.nfo$/i',           // Scene: 00-group.nfo
-            '/^0+-[a-z0-9_-]+\.nfo$/i',           // Scene variations
+            '/^00-[a-z0-9_-]+\.nfo$/i', // Scene: 00-group.nfo
+            '/^0+-[a-z0-9_-]+\.nfo$/i', // Scene variations
             '/^[a-z0-9_-]+-[a-z0-9_.-]+\.nfo$/i', // Scene: group-release.nfo
-            '/info\.txt$/i',                      // info.txt (common alternative)
+            '/info\.txt$/i', // info.txt (common alternative)
         ];
 
         $basename = basename($filename);
@@ -494,7 +494,7 @@ 
             } elseif ($this->config->debugMode) {
                 Log::debug('RarInfo: Ignored low-quality candidate "'.$candidate.'" from inner file name.');
             }
-        } elseif (! empty($dataSummary['archives'][$rarFileName[0]]['file_list'])) {
+        } elseif (!empty($dataSummary['archives'][$rarFileName[0]]['file_list'])) {
             // Try nested archive
             $archiveData = $dataSummary['archives'][$rarFileName[0]]['file_list'];
             $archiveFileName = array_column($archiveData, 'name');