NNTmux / newznab-tmux

app/Services/Binaries/PartHandler.php

Spacing +1 added lines, -1 removed lines

@@ -151,7 +151,7 @@
      */
     public function hasPending(): bool
     {
-        return ! empty($this->parts);
+        return !empty($this->parts);
     }
 }
 

app/Services/Binaries/MissedPartHandler.php

Spacing +2 added lines, -2 removed lines

@@ -78,7 +78,7 @@ 
         }
 
         try {
-            DB::transaction(static function () use ($groupId, $sql) {
+            DB::transaction(static function() use ($groupId, $sql) {
                 DB::delete(rtrim($sql, ',').') AND groups_id = '.$groupId);
             }, 10);
         } catch (\Throwable $e) {
@@ -167,7 +167,7 @@ 
      */
     public function cleanupExhaustedParts(int $groupId): void
     {
-        DB::transaction(function () use ($groupId) {
+        DB::transaction(function() use ($groupId) {
             DB::delete(
                 sprintf(
                     'DELETE FROM missed_parts WHERE attempts >= %d AND groups_id = %d',

app/Services/Binaries/HeaderStorageTransaction.php

Spacing +5 added lines, -5 removed lines

@@ -132,7 +132,7 @@ 
     private function cleanupParts(): void
     {
         $numbers = $this->partHandler->getInsertedNumbers();
-        if (! empty($numbers)) {
+        if (!empty($numbers)) {
             $placeholders = implode(',', array_fill(0, \count($numbers), '?'));
             DB::statement("DELETE FROM parts WHERE number IN ({$placeholders})", $numbers);
         }
@@ -141,7 +141,7 @@ 
     private function cleanupBinaries(): void
     {
         $ids = $this->binaryHandler->getInsertedIds();
-        if (! empty($ids)) {
+        if (!empty($ids)) {
             $placeholders = implode(',', array_fill(0, \count($ids), '?'));
             DB::statement("DELETE FROM binaries WHERE id IN ({$placeholders})", $ids);
         }
@@ -153,9 +153,9 @@ 
         $allIds = $this->collectionHandler->getAllIds();
         $hashes = $this->collectionHandler->getBatchHashes();
 
-        $ids = ! empty($insertedIds) ? $insertedIds : $allIds;
+        $ids = !empty($insertedIds) ? $insertedIds : $allIds;
 
-        if (! empty($ids)) {
+        if (!empty($ids)) {
             $placeholders = implode(',', array_fill(0, \count($ids), '?'));
 
             // Remove parts and binaries referencing these collections, then collections
@@ -165,7 +165,7 @@ 
             );
             DB::statement("DELETE FROM binaries WHERE collections_id IN ({$placeholders})", $ids);
             DB::statement("DELETE FROM collections WHERE id IN ({$placeholders})", $ids);
-        } elseif (! empty($hashes)) {
+        } elseif (!empty($hashes)) {
             $placeholders = implode(',', array_fill(0, \count($hashes), '?'));
 
             DB::statement(

app/Services/Binaries/HeaderStorageService.php

Spacing +7 added lines, -7 removed lines

@@ -72,7 +72,7 @@ 
 
         // Process each header
         foreach ($headers as $header) {
-            if (! $this->processHeader($header, $groupMySQL, $transaction)) {
+            if (!$this->processHeader($header, $groupMySQL, $transaction)) {
                 if ($addToPartRepair && isset($header['Number'])) {
                     $this->failedInserts[] = $header['Number'];
                 }
@@ -81,20 +81,20 @@ 
 
         // Flush remaining parts
         if ($this->partHandler->hasPending()) {
-            if (! $this->partHandler->flush()) {
+            if (!$this->partHandler->flush()) {
                 $transaction->markError();
             }
         }
 
         // Flush binary aggregate updates
-        if (! $transaction->hasErrors()) {
-            if (! $this->binaryHandler->flushUpdates($this->config->binariesUpdateChunkSize)) {
+        if (!$transaction->hasErrors()) {
+            if (!$this->binaryHandler->flushUpdates($this->config->binariesUpdateChunkSize)) {
                 $transaction->markError();
             }
         }
 
         // Finish transaction
-        if (! $transaction->finish()) {
+        if (!$transaction->finish()) {
             // All failed
             if ($addToPartRepair) {
                 return array_unique(array_merge(
@@ -153,7 +153,7 @@ 
         }
 
         // Add part
-        if (! $this->partHandler->addPart($binaryId, $header)) {
+        if (!$this->partHandler->addPart($binaryId, $header)) {
             $transaction->markError();
 
             return false;
@@ -164,7 +164,7 @@ 
 
     private function getFileCount(string $subject): array
     {
-        if (! preg_match('/[[(\s](\d{1,5})(\/|[\s_]of[\s_]|-)(\d{1,5})[])[\s$:]/i', $subject, $fileCount)) {
+        if (!preg_match('/[[(\s](\d{1,5})(\/|[\s_]of[\s_]|-)(\d{1,5})[])[\s$:]/i', $subject, $fileCount)) {
             $fileCount[1] = $fileCount[3] = 0;
         }
 

app/Services/Binaries/HeaderParser.php

Spacing +4 added lines, -4 removed lines

@@ -52,20 +52,20 @@ 
 
         foreach ($headers as $header) {
             // Check if we got the article
-            if (! isset($header['Number'])) {
+            if (!isset($header['Number'])) {
                 continue;
             }
 
             // For part repair, only process missing parts
             if ($partRepair && $missingParts !== null) {
-                if (! \in_array($header['Number'], $missingParts, false)) {
+                if (!\in_array($header['Number'], $missingParts, false)) {
                     continue;
                 }
                 $headersRepaired[] = $header['Number'];
             }
 
             // Parse subject to get base name and part/total like "(12/45)"
-            if (! preg_match('/^\s*(?!"Usenet Index Post)(.+)\s+\((\d+)\/(\d+)\)/', $header['Subject'], $matches)) {
+            if (!preg_match('/^\s*(?!"Usenet Index Post)(.+)\s+\((\d+)\/(\d+)\)/', $header['Subject'], $matches)) {
                 $this->notYEnc++;
 
                 continue;
@@ -110,7 +110,7 @@ 
     public function flushBlacklistUpdates(): void
     {
         $ids = $this->blacklistService->getAndClearIdsToUpdate();
-        if (! empty($ids)) {
+        if (!empty($ids)) {
             $this->blacklistService->updateBlacklistUsage($ids);
         }
     }