App\Movies\EventListener\MoviePostersProcessor

Complexity

Total Complexity

6

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	process()	0	33	4
A	getSubscribedTopics()	0	4	1

<?php

namespace App\Movies\EventListener;

use App\Movies\Repository\MovieRepository;
use App\Movies\Utils\Poster;
use Doctrine\ORM\EntityManagerInterface;
use Enqueue\Client\ProducerInterface;
use Enqueue\Client\TopicSubscriberInterface;
use Interop\Queue\Context;
use Interop\Queue\Message as QMessage;
use Interop\Queue\Processor;

class MoviePostersProcessor implements Processor, TopicSubscriberInterface
{
    public const LOAD_POSTERS = 'LoadMoviesPosters';

    private $em;
    private $movieRepository;
    private $producer;

    public function __construct(EntityManagerInterface $em, MovieRepository $movieRepository, ProducerInterface $producer)
    {
        $this->em = $em;
        $this->movieRepository = $movieRepository;
        $this->producer = $producer;
    }

    public function process(QMessage $message, Context $session)
    {
        $movieId = $message->getBody();
        $movieId = json_decode($movieId, true);

        $movie = $this->movieRepository->find($movieId);

        if ($movie === null) {
            return self::REJECT;
        }

        $posterUrl = $movie->getOriginalPosterUrl();
        // $posterName = str_replace('https://image.tmdb.org/t/p/original', '', $posterUrl);
        if ($posterUrl === 'https://image.tmdb.org/t/p/original') {
            return self::REJECT;
        }

        $posterPath = Poster::savePoster($movie->getId(), $movie->getOriginalPosterUrl());
        if ($posterPath === null) {
            return self::REJECT;
        }

        $this->producer->sendEvent(PosterResizerProcessor::RESIZE_POSTERS, json_encode($movieId));
        $movie->setOriginalPosterUrl(Poster::getUrl($movie->getId()));

        $this->em->flush();
        $this->em->clear();

        $message = $session = $movieId = $movie = null;
        unset($message, $session, $movieId, $movie);

        return self::ACK;
    }

    public static function getSubscribedTopics()
    {
        return [self::LOAD_POSTERS];
    }
}