thibaud-lclr/ltbxd-actorle
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

feat: import actor awards during film batch import

Browse Source
This commit is contained in:
thibaud-leclere
2026-04-01 14:27:54 +02:00
parent 8aa33ccefc
commit 0fd0b85b8f
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/MessageHandler/ImportFilmsBatchMessageHandler.php
View File

@@ -10,6 +10,7 @@ use App\Gateway\LtbxdGateway;
use App\Message\ImportFilmsBatchMessage; use App\Message\ImportFilmsBatchMessage;
use App\Repository\ImportRepository; use App\Repository\ImportRepository;
use App\Service\ActorSyncer; use App\Service\ActorSyncer;
use App\Service\AwardImporter;
use App\Service\FilmImporter; use App\Service\FilmImporter;
use Doctrine\ORM\EntityManagerInterface; use Doctrine\ORM\EntityManagerInterface;
use League\Flysystem\FilesystemOperator; use League\Flysystem\FilesystemOperator;
@@ -25,6 +26,7 @@ readonly class ImportFilmsBatchMessageHandler
private LtbxdGateway $ltbxdGateway, private LtbxdGateway $ltbxdGateway,
private FilmImporter $filmImporter, private FilmImporter $filmImporter,
private ActorSyncer $actorSyncer, private ActorSyncer $actorSyncer,
private AwardImporter $awardImporter,
private ImportRepository $importRepository, private ImportRepository $importRepository,
private LoggerInterface $logger, private LoggerInterface $logger,
) {} ) {}
@@ -62,6 +64,11 @@ readonly class ImportFilmsBatchMessageHandler
$this->actorSyncer->syncActorsForMovie($movie); $this->actorSyncer->syncActorsForMovie($movie);
// Import awards for actors of this movie
foreach ($movie->getActors() as $role) {
$this->awardImporter->importForActor($role->getActor());
}
$user = $this->em->getReference(\App\Entity\User::class, $userId); $user = $this->em->getReference(\App\Entity\User::class, $userId);
$existingLink = $this->em->getRepository(UserMovie::class)->findOneBy([ $existingLink = $this->em->getRepository(UserMovie::class)->findOneBy([
'user' => $user, 'user' => $user,