Fix BackgroundSyncCommand

src/Console/Commands/BackgroundSyncCommand.php

@@ -2,134 +2,51 @@
 
 namespace Atom\Core\Console\Commands;
 
-use Atom\Core\Models\Badge;
+use Atom\Core\Models\RoomAds;
 use Illuminate\Console\Command;
-use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Storage;
 
 use function Laravel\Prompts\progress;
 
-class BadgeSyncCommand extends Command
+class BackgroundSyncCommand extends Command
 {
     /**
      * The name and signature of the console command.
      *
      * @var string
      */
-    protected $signature = 'atom:sync-badges';
+    protected $signature = 'atom:sync-backgrounds';
 
     /**
      * The console command description.
      *
      * @var string
      */
-    protected $description = 'The command for syncing the badges.';
+    protected $description = 'The command for syncing the room ads.';
 
     /**
      * Execute the console command.
      */
     public function handle()
     {
-        $filePath = config('nitro.external_texts_file');
+        $backgrounds = Storage::disk('room_backgrounds')
+            ->files();
 
-        // Validate file path in configuration
-        if (! $filePath) {
-            $this->error('The configuration for the external texts file is missing.');
-
-            return 1;
-        }
-
-        // Attempt to read the file directly from the full path
-        if (! file_exists($filePath)) {
-            $this->error(sprintf('The external texts file does not exist at %s.', $filePath));
-
-            return 1;
-        }
-
-        $file = file_get_contents($filePath); // Use file_get_contents for direct file reading
-
-        // Handle missing or empty file
-        if (empty($file)) {
-            $this->error(sprintf('The external texts file is empty or missing at %s.', $filePath));
-
-            return 1;
-        }
-
-        // Decode JSON and handle errors
-        $decoded = json_decode($file, true);
-
-        if (json_last_error() !== JSON_ERROR_NONE) {
-            $this->error(sprintf('Error decoding JSON: %s', json_last_error_msg()));
-
-            return 1;
-        }
-
-        // Filter badges
-        $badges = collect($decoded)
-            ->filter(fn ($value, $key) => str_starts_with($key, 'badge_name_') || str_starts_with($key, 'badge_desc_'));
-
-        // Handle empty badge data
-        if ($badges->isEmpty()) {
-            $this->info('No badges to sync.');
-
-            return 0;
-        }
-
-        // Process badges with progress bar
         progress(
             label: 'Syncing badges',
-            steps: $badges->keys()->toArray(),
-            callback: function ($key) use ($badges) {
-                try {
-                    $this->sync($key, $badges[$key]);
-                } catch (\Exception $e) {
-                    $this->error(sprintf('Failed to sync %s: %s', $key, $e->getMessage()));
-                }
-            }
+            steps: $backgrounds,
+            callback: fn (string $file) => $this->sync($file),
         );
-
-        $this->info('Badge synchronization completed.');
-
-        return 0;
     }
 
     /**
-     * Sync the local badge data.
+     * Sync the local background data.
      */
-    public function sync(string $key, string $value): bool
+    public function sync(string $file): bool
     {
-        $code = trim(str_replace(['badge_name_', 'badge_desc_'], '', $key));
-        $column = str_starts_with($key, 'badge_name_') ? 'name' : 'description';
-
-        if (empty($code) || empty($value)) {
-            $this->error(sprintf('Invalid data for badge key "%s". Skipping...', $key));
-
-            return false;
-        }
-
-        try {
-            $filePath = sprintf('%s.gif', $code);
-
-            if (! file_exists($filePath)) {
-                $this->warn(sprintf('Badge file "%s" does not exist. Skipping badge "%s".', $filePath, $code));
-
-                return false;
-            }
-
-            $badge = Badge::withoutEvents(fn () => Badge::updateOrCreate(
-                ['code' => $code, 'file' => $filePath],
-                [$column => $value]
-            ));
-
-            if ($this->option('verbose')) {
-                $this->info(sprintf('Successfully synced badge "%s".', $code));
-            }
-
-            return (bool) $badge;
-        } catch (\Exception $e) {
-            $this->error(sprintf('Error syncing badge "%s": %s', $code, $e->getMessage()));
-            Log::error(sprintf('Error syncing badge "%s": %s', $code, $e->getMessage()));
-
-            return false;
-        }
+        return (bool) RoomAds::withoutEvents(fn () => RoomAds::updateOrCreate(
+            ['file' => $file],
+            ['file' => $file],
+        ));
     }
 }