refactor: extract ActorSyncer service from SyncActorsCommand

2026-03-29 10:18:00 +02:00
parent bbbfb895af
commit dedc41e237
2 changed files with 89 additions and 65 deletions
--- a/src/Service/ActorSyncer.php
+++ b/src/Service/ActorSyncer.php
@@ -0,0 +1,52 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Service;
+
+use App\Entity\Actor;
+use App\Entity\Movie;
+use App\Entity\MovieRole;
+use App\Exception\GatewayException;
+use App\Gateway\TMDBGateway;
+use Doctrine\ORM\EntityManagerInterface;
+
+readonly class ActorSyncer
+{
+    public function __construct(
+        private TMDBGateway $tmdbGateway,
+        private EntityManagerInterface $em,
+    ) {}
+
+    /**
+     * Fetch credits from TMDB for the given movie and create missing Actor/MovieRole entries.
+     *
+     * @throws GatewayException
+     */
+    public function syncActorsForMovie(Movie $movie): void
+    {
+        $creditsContext = $this->tmdbGateway->getMovieCredits($movie->getTmdbId());
+
+        foreach ($creditsContext->cast as $actorModel) {
+            $actor = $this->em->getRepository(Actor::class)->findOneBy(['tmdbId' => $actorModel->id]);
+            if (!$actor instanceof Actor) {
+                $actor = new Actor()
+                    ->setPopularity($actorModel->popularity)
+                    ->setName($actorModel->name)
+                    ->setTmdbId($actorModel->id);
+
+                $this->em->persist($actor);
+            }
+
+            $existingRole = $this->em->getRepository(MovieRole::class)->count(['actor' => $actor, 'movie' => $movie]);
+            if (0 === $existingRole) {
+                $role = new MovieRole()
+                    ->setMovie($movie)
+                    ->setActor($actor)
+                    ->setCharacter($actorModel->character);
+
+                $this->em->persist($role);
+            }
+        }
+    }
+}