VideoGamesRecords\IgdbBundle\Command\ImportGenresCommand

Complexity

Total Complexity

10

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	execute()	0	75	9

<?php

declare(strict_types=1);

namespace VideoGamesRecords\IgdbBundle\Command;

use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\Console\Attribute\AsCommand;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
use VideoGamesRecords\IgdbBundle\Entity\Genre;
use VideoGamesRecords\IgdbBundle\Client\IgdbClient;

#[AsCommand(
    name: 'igdb:import:genres',
    description: 'Import all genres from IGDB API into database'
)]
class ImportGenresCommand extends Command
{
    public function __construct(
        private IgdbClient $igdbClient,
        private EntityManagerInterface $entityManager
    ) {
        parent::__construct();
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $io = new SymfonyStyle($input, $output);

        $io->title('Importing genres from IGDB API');

        try {
            $genres = $this->igdbClient->getAllGenres();
            $io->progressStart(count($genres));

            $insertedCount = 0;
            $updatedCount = 0;
            $skippedCount = 0;

            foreach ($genres as $genreData) {
                $existingGenre = $this->entityManager->getRepository(Genre::class)->find($genreData['id']);

                if ($existingGenre) {
                    // Comparer les updated_at pour savoir si une mise à jour est nécessaire
                    $needsUpdate = true;
                    if (isset($genreData['updated_at'])) {
                        $igdbUpdatedAt = new \DateTimeImmutable('@' . $genreData['updated_at']);
                        $needsUpdate = $existingGenre->getUpdatedAt() < $igdbUpdatedAt;
                    }

                    if ($needsUpdate) {
                        $existingGenre->setName($genreData['name']);
                        $existingGenre->setSlug($genreData['slug']);
                        $existingGenre->setUrl($genreData['url'] ?? null);

                        if (isset($genreData['updated_at'])) {
                            $existingGenre->setUpdatedAt(new \DateTimeImmutable('@' . $genreData['updated_at']));
                        } else {
                            $existingGenre->setUpdatedAt(new \DateTimeImmutable());
                        }
                        $updatedCount++;
                    } else {
                        $skippedCount++;
                    }
                } else {
                    $genre = new Genre();
                    $genre->setId($genreData['id']);
                    $genre->setName($genreData['name']);
                    $genre->setSlug($genreData['slug']);
                    $genre->setUrl($genreData['url'] ?? null);

                    if (isset($genreData['created_at'])) {
                        $genre->setCreatedAt(new \DateTimeImmutable('@' . $genreData['created_at']));
                    }
                    if (isset($genreData['updated_at'])) {
                        $genre->setUpdatedAt(new \DateTimeImmutable('@' . $genreData['updated_at']));
                    }

                    $this->entityManager->persist($genre);
                    $insertedCount++;
                }

                $io->progressAdvance();
            }

            $this->entityManager->flush();
            $io->progressFinish();

            $io->success([
                "Genres imported successfully!",
                "Inserted: $insertedCount genres",
                "Updated: $updatedCount genres",
                "Skipped: $skippedCount genres (no changes)",
                "Total processed: " . ($insertedCount + $updatedCount + $skippedCount) . " genres"
            ]);

            return Command::SUCCESS;
        } catch (\Exception $e) {
            $io->error('Failed to import genres: ' . $e->getMessage());
            return Command::FAILURE;
        }
    }
}