NNTmux / newznab-tmux

app/Services/AdultProcessing/Pipes/AdePipe.php

Spacing +4 added lines, -4 removed lines

@@ -83,7 +83,7 @@ 
         // Initialize session with age verification cookies
         $this->initializeSession();
 
-        $searchUrl = self::BASE_URL . self::SEARCH_URL . rawurlencode($movie);
+        $searchUrl = self::BASE_URL.self::SEARCH_URL.rawurlencode($movie);
         $response = $this->fetchHtml($searchUrl, $this->cookie);
 
         if ($response === false) {
@@ -119,7 +119,7 @@ 
                         $highestSimilarity = $similarity;
                         $bestMatch = [
                             'title' => trim($title),
-                            'url' => str_starts_with($url, 'http') ? $url : self::BASE_URL . $url,
+                            'url' => str_starts_with($url, 'http') ? $url : self::BASE_URL.$url,
                         ];
                     }
                 }
@@ -196,7 +196,7 @@ 
 
         if ($trailersResponse !== false) {
             if (preg_match("/([\"|'])(?P<swf>[^\"']+.swf)([\"|'])/i", $trailersResponse, $hits)) {
-                $res['trailers']['url'] = self::BASE_URL . trim(trim($hits['swf']), '"');
+                $res['trailers']['url'] = self::BASE_URL.trim(trim($hits['swf']), '"');
 
                 if (preg_match('#(?:streamID:\s\")(?P<streamid>[0-9A-Z]+)(?:\")#', $trailersResponse, $hits)) {
                     $res['trailers']['streamid'] = trim($hits['streamid']);
@@ -387,7 +387,7 @@ 
             usleep(300000); // 300ms delay
 
         } catch (\Exception $e) {
-            \Illuminate\Support\Facades\Log::debug('ADE session initialization: ' . $e->getMessage());
+            \Illuminate\Support\Facades\Log::debug('ADE session initialization: '.$e->getMessage());
         }
     }
 }

app/Services/AdultProcessing/Pipes/AbstractAdultProviderPipe.php

Spacing +22 added lines, -22 removed lines

@@ -177,7 +177,7 @@ 
         if (isset(self::$lastRequestTime[$providerName])) {
             $elapsed = $now - self::$lastRequestTime[$providerName];
             if ($elapsed < $this->rateLimitDelay) {
-                usleep((int)(($this->rateLimitDelay - $elapsed) * 1000));
+                usleep((int) (($this->rateLimitDelay - $elapsed) * 1000));
             }
         }
 
@@ -250,12 +250,12 @@ 
             return null;
         }
 
-        $cacheKey = 'adult_search_' . $this->getName() . '_' . md5(strtolower($movie));
+        $cacheKey = 'adult_search_'.$this->getName().'_'.md5(strtolower($movie));
         $cached = Cache::get($cacheKey);
 
         if ($cached !== null) {
             if ($this->echoOutput) {
-                $this->getColorCli()->info('Using cached result for: ' . $movie);
+                $this->getColorCli()->info('Using cached result for: '.$movie);
             }
             return $cached;
         }
@@ -272,7 +272,7 @@ 
             return;
         }
 
-        $cacheKey = 'adult_search_' . $this->getName() . '_' . md5(strtolower($movie));
+        $cacheKey = 'adult_search_'.$this->getName().'_'.md5(strtolower($movie));
         Cache::put($cacheKey, $result, now()->addMinutes($this->cacheDuration));
     }
 
@@ -321,7 +321,7 @@ 
 
                 // Check for common error pages
                 if ($this->isErrorPage($body)) {
-                    Log::warning('Received error page from ' . $this->getName() . ': ' . $url);
+                    Log::warning('Received error page from '.$this->getName().': '.$url);
                     if ($attempt < $this->maxRetries) {
                         usleep($this->retryDelay * 1000);
                         continue;
@@ -342,7 +342,7 @@ 
                         $this->httpClient = null;
                         $this->cookieJar = null;
 
-                        Log::info('Refreshed age verification cookies for ' . $this->getName() . ', retrying...');
+                        Log::info('Refreshed age verification cookies for '.$this->getName().', retrying...');
                         continue;
                     }
 
@@ -356,7 +356,7 @@ 
 
             } catch (ConnectException $e) {
                 $lastException = $e;
-                Log::warning('Connection failed for ' . $this->getName() . ' (attempt ' . $attempt . '): ' . $e->getMessage());
+                Log::warning('Connection failed for '.$this->getName().' (attempt '.$attempt.'): '.$e->getMessage());
 
                 if ($attempt < $this->maxRetries) {
                     usleep($this->retryDelay * 1000 * $attempt); // Exponential backoff
@@ -367,11 +367,11 @@ 
 
                 // Don't retry on 4xx client errors (except 429 rate limit)
                 if ($statusCode >= 400 && $statusCode < 500 && $statusCode !== 429) {
-                    Log::error('HTTP ' . $statusCode . ' for ' . $this->getName() . ': ' . $url);
+                    Log::error('HTTP '.$statusCode.' for '.$this->getName().': '.$url);
                     return false;
                 }
 
-                Log::warning('Request failed for ' . $this->getName() . ' (attempt ' . $attempt . '): ' . $e->getMessage());
+                Log::warning('Request failed for '.$this->getName().' (attempt '.$attempt.'): '.$e->getMessage());
 
                 if ($attempt < $this->maxRetries) {
                     // Longer delay for rate limit errors
@@ -380,7 +380,7 @@ 
                 }
             } catch (\Exception $e) {
                 $lastException = $e;
-                Log::error('Unexpected error for ' . $this->getName() . ': ' . $e->getMessage());
+                Log::error('Unexpected error for '.$this->getName().': '.$e->getMessage());
 
                 if ($attempt < $this->maxRetries) {
                     usleep($this->retryDelay * 1000);
@@ -389,7 +389,7 @@ 
         }
 
         if ($lastException) {
-            Log::error('All retry attempts failed for ' . $this->getName() . ': ' . $lastException->getMessage());
+            Log::error('All retry attempts failed for '.$this->getName().': '.$lastException->getMessage());
         }
 
         return false;
@@ -474,7 +474,7 @@ 
         ];
 
         foreach ($contentIndicators as $pattern) {
-            if (preg_match('/' . $pattern . '/is', $html)) {
+            if (preg_match('/'.$pattern.'/is', $html)) {
                 return false; // This is a content page, not an age verification page
             }
         }
@@ -533,7 +533,7 @@ 
         // Re-initialize cookies from the manager and retry
         if ($this->cookieJar) {
             // The manager already handles setting cookies, but let's ensure they're fresh
-            Log::info('Attempting to handle age verification for ' . $this->getName() . ' with domain: ' . $domain);
+            Log::info('Attempting to handle age verification for '.$this->getName().' with domain: '.$domain);
         }
 
         // Try to find and submit age verification form
@@ -556,7 +556,7 @@ 
                 if (!empty($postData)) {
                     $submitUrl = $action;
                     if (!str_starts_with($submitUrl, 'http')) {
-                        $submitUrl = $this->getBaseUrl() . '/' . ltrim($submitUrl, '/');
+                        $submitUrl = $this->getBaseUrl().'/'.ltrim($submitUrl, '/');
                     }
 
                     // Submit the age verification
@@ -573,7 +573,7 @@ 
                             return $body;
                         }
                     } catch (\Exception $e) {
-                        Log::warning('Age verification submission failed for ' . $this->getName() . ': ' . $e->getMessage());
+                        Log::warning('Age verification submission failed for '.$this->getName().': '.$e->getMessage());
                     }
                 }
             }
@@ -586,7 +586,7 @@ 
             if (!empty($matches[1])) {
                 $enterUrl = $matches[1];
                 if (!str_starts_with($enterUrl, 'http')) {
-                    $enterUrl = $this->getBaseUrl() . '/' . ltrim($enterUrl, '/');
+                    $enterUrl = $this->getBaseUrl().'/'.ltrim($enterUrl, '/');
                 }
 
                 try {
@@ -599,7 +599,7 @@ 
                         return $body;
                     }
                 } catch (\Exception $e) {
-                    Log::warning('Age verification link follow failed for ' . $this->getName() . ': ' . $e->getMessage());
+                    Log::warning('Age verification link follow failed for '.$this->getName().': '.$e->getMessage());
                 }
             }
         }
@@ -616,11 +616,11 @@ 
                 return $body;
             }
         } catch (\Exception $e) {
-            Log::warning('Age verification retry failed for ' . $this->getName() . ': ' . $e->getMessage());
+            Log::warning('Age verification retry failed for '.$this->getName().': '.$e->getMessage());
         }
 
         // If we couldn't handle age verification, log and return false
-        Log::warning('Could not handle age verification for ' . $this->getName() . ': ' . $url);
+        Log::warning('Could not handle age verification for '.$this->getName().': '.$url);
         return false;
     }
 
@@ -810,7 +810,7 @@ 
      */
     protected function outputMatch(string $title): void
     {
-        if (! $this->echoOutput) {
+        if (!$this->echoOutput) {
             return;
         }
 
@@ -822,7 +822,7 @@ 
      */
     protected function outputNotFound(): void
     {
-        if (! $this->echoOutput) {
+        if (!$this->echoOutput) {
             return;
         }
 
@@ -867,7 +867,7 @@ 
         ];
 
         foreach ($metaTags as $property => $key) {
-            $meta = $this->getHtmlParser()->findOne('meta[property="' . $property . '"]');
+            $meta = $this->getHtmlParser()->findOne('meta[property="'.$property.'"]');
             if ($meta && isset($meta->content)) {
                 $og[$key] = trim($meta->content);
             }

app/Services/AdultProcessing/Pipes/HotmoviesPipe.php

Spacing +3 added lines, -3 removed lines

@@ -84,7 +84,7 @@ 
         // Initialize session with age verification
         $this->initializeSession();
 
-        $searchUrl = self::BASE_URL . self::SEARCH_URL . urlencode($movie) . self::EXTRA_SEARCH;
+        $searchUrl = self::BASE_URL.self::SEARCH_URL.urlencode($movie).self::EXTRA_SEARCH;
         $response = $this->fetchHtml($searchUrl, $this->cookie);
 
         if ($response === false) {
@@ -120,7 +120,7 @@ 
                         $highestSimilarity = $similarity;
                         $bestMatch = [
                             'title' => trim($title),
-                            'url' => str_starts_with($url, 'http') ? $url : self::BASE_URL . $url,
+                            'url' => str_starts_with($url, 'http') ? $url : self::BASE_URL.$url,
                         ];
                     }
                 }
@@ -353,7 +353,7 @@ 
             usleep(300000); // 300ms delay
 
         } catch (\Exception $e) {
-            \Illuminate\Support\Facades\Log::debug('HotMovies session initialization: ' . $e->getMessage());
+            \Illuminate\Support\Facades\Log::debug('HotMovies session initialization: '.$e->getMessage());
         }
     }
 }

app/Services/AdultProcessing/Pipes/PoppornPipe.php

Spacing +6 added lines, -6 removed lines

@@ -83,7 +83,7 @@ 
         // First, establish a session by visiting the AgeConfirmation endpoint to set cookies
         $this->acceptAgeVerification();
 
-        $searchUrl = self::BASE_URL . self::SEARCH_ENDPOINT . urlencode($movie);
+        $searchUrl = self::BASE_URL.self::SEARCH_ENDPOINT.urlencode($movie);
         $response = $this->fetchHtml($searchUrl, $this->cookie);
 
         if (empty($response)) {
@@ -117,7 +117,7 @@ 
                             $highestSimilarity = $similarity;
                             $bestMatch = [
                                 'title' => trim($title),
-                                'url' => str_starts_with($url, 'http') ? $url : self::BASE_URL . $url,
+                                'url' => str_starts_with($url, 'http') ? $url : self::BASE_URL.$url,
                             ];
                         }
                     }
@@ -480,7 +480,7 @@ 
 
             // First, make a request that disables redirects to see where we're being sent
             try {
-                $response = $client->get(self::BASE_URL . '/', [
+                $response = $client->get(self::BASE_URL.'/', [
                     'headers' => $this->getDefaultHeaders(),
                     'allow_redirects' => false,
                     'http_errors' => false,
@@ -496,7 +496,7 @@ 
                         // The redirect URL includes ?url2= parameter, we need to visit it
                         $ageConfirmUrl = $location;
                         if (!str_starts_with($ageConfirmUrl, 'http')) {
-                            $ageConfirmUrl = self::BASE_URL . $ageConfirmUrl;
+                            $ageConfirmUrl = self::BASE_URL.$ageConfirmUrl;
                         }
 
                         // Visit the age confirmation page
@@ -506,7 +506,7 @@ 
                             'http_errors' => false,
                         ]);
 
-                        \Illuminate\Support\Facades\Log::debug('PopPorn age confirmation visited: ' . $ageConfirmUrl);
+                        \Illuminate\Support\Facades\Log::debug('PopPorn age confirmation visited: '.$ageConfirmUrl);
                     }
                 }
             } catch (\Exception $e) {
@@ -518,7 +518,7 @@ 
 
         } catch (\Exception $e) {
             // Log but don't fail - we'll try the search anyway
-            \Illuminate\Support\Facades\Log::debug('PopPorn age verification setup: ' . $e->getMessage());
+            \Illuminate\Support\Facades\Log::debug('PopPorn age verification setup: '.$e->getMessage());
         }
     }
 }