Add import all option to series import

Author: sparkison

app/Filament/Resources/SeriesResource.php

@@ -468,6 +468,17 @@ public static function getFormSteps(): array
                 ]),
             Forms\Components\Wizard\Step::make('Series to Import')
                 ->schema([
+                    Forms\Components\Toggle::make('import_all')
+                        ->label('Import All Series')
+                        ->live()
+                        ->helperText('If enabled, all series in the selected category will be imported.')
+                        ->default(false)
+                        ->columnSpanFull()
+                        ->afterStateUpdated(function (Get $get, $set) {
+                            if ($get('import_all')) {
+                                $set('series', []);
+                            }
+                        }),
                     Forms\Components\CheckboxList::make('series')
                         ->label('Series to Import')
                         ->required()
@@ -486,8 +497,7 @@ public static function getFormSteps(): array
                             $xtreamPass = $xtreamConfig['password'] ?? '';
                             $cacheKey = 'xtream_category_series' . md5($xtremeUrl . $xtreamUser . $xtreamPass . $category);
                             $cachedCategories = Cache::remember($cacheKey, 60 * 1, function () use ($xtremeUrl, $xtreamUser, $xtreamPass, $category) {
-                                $service = new XtreamService();
-                                $xtream = $service->init(xtream_config: [
+                                $xtream = XtreamService::make(xtream_config: [
                                     'url' => $xtremeUrl,
                                     'username' => $xtreamUser,
                                     'password' => $xtreamPass,
@@ -512,8 +522,8 @@ public static function getFormSteps(): array
                                 ? 'Which series would you like to import.'
                                 : 'You must select a playlist and category first.'
                         )
-                        ->disabled(fn(Get $get): bool => ! $get('playlist') || ! $get('category'))
-                        ->hidden(fn(Get $get): bool => ! $get('playlist') || ! $get('category')),
+                        ->disabled(fn(Get $get): bool => ! $get('playlist') || ! $get('category') || $get('import_all'))
+                        ->hidden(fn(Get $get): bool => ! $get('playlist') || ! $get('category') || $get('import_all')),
                 ])
         ];
     }

app/Filament/Resources/SeriesResource/Pages/ListSeries.php

@@ -28,7 +28,8 @@ protected function getHeaderActions(): array
                             playlist: $data['playlist'],
                             catId: $data['category'],
                             catName: $data['category_name'],
-                            series: $data['series'],
+                            series: $data['series'] ?? [],
+                            importAll: $data['import_all'] ?? false,
                         ));
                 })->after(function () {
                     Notification::make()

app/Jobs/SyncXtreamSeries.php

@@ -20,6 +20,7 @@ public function __construct(
         public int $catId,
         public string $catName,
         public array $series,
+        public bool $importAll = false,
     ) {}
 
     /**
@@ -58,6 +59,12 @@ public function handle(XtreamService $xtream): void
                 ]);
         }
 
+        if ($this->importAll) {
+            // If importAll is true, we need to import all series from the category
+            $this->series = collect($xtream->getSeries($this->catId))
+                ->pluck('series_id')
+                ->toArray();
+        }
         foreach ($this->series as $seriesId) {
             // Check if the series exists for the playlist
             $playlistSeries = $playlist->series()

app/Services/XtreamService.php

@@ -15,6 +15,31 @@ class XtreamService
     protected Playlist|null $playlist;
     protected array|null $xtream_config;
 
+    /**
+     * Factory method to create an instance of XtreamService.
+     *
+     * @param Playlist|null $playlist
+     * @param array|null $xtream_config
+     * @param int $retryLimit Number of retries for HTTP requests
+     * @return XtreamService
+     */
+    public static function make(
+        Playlist|null $playlist = null,
+        array|null $xtream_config = null,
+        $retryLimit = 5
+    ): self {
+        $instance = new self();
+        return $instance->init($playlist, $xtream_config, $retryLimit);
+    }
+
+    /**
+     * Initialize the XtreamService with a Playlist or Xtream config.
+     *
+     * @param Playlist|null $playlist
+     * @param array|null $xtream_config
+     * @param int $retryLimit Number of retries for HTTP requests
+     * @return bool|self Returns false if initialization fails, otherwise returns the instance.
+     */
     public function init(
         Playlist|null $playlist = null,
         array|null $xtream_config = null,