App\Movies\EventListener\AddSimilarMoviesProcessor

Complexity

Total Complexity

13

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
B	process()	0	43	11
A	getSubscribedTopics()	0	4	1

<?php

namespace App\Movies\EventListener;

use App\Movies\Entity\Movie;
use App\Movies\Repository\MovieRepository;
use App\Movies\Service\TmdbSearchService;
use App\Users\Entity\User;
use Doctrine\ORM\EntityManager;
use Doctrine\ORM\EntityManagerInterface;
use Enqueue\Client\TopicSubscriberInterface;
use Interop\Queue\Context;
use Interop\Queue\Message as QMessage;
use Interop\Queue\Processor;

class AddSimilarMoviesProcessor implements Processor, TopicSubscriberInterface
{
    const ADD_SIMILAR_MOVIES = 'AddSimilarMovies';

    /** @var EntityManager */
    private $em;
    private $searchService;
    private $movieRepository;

    public function __construct(EntityManagerInterface $em, MovieRepository $movieRepository, TmdbSearchService $searchService)
    {
        $this->em = $em;

$em is of type object<Doctrine\ORM\EntityManagerInterface>, but the property $em was declared to be of type object<Doctrine\ORM\EntityManager>. Are you sure that you always receive this specific sub-class here, or does it make sense to add an instanceof check?

        $this->movieRepository = $movieRepository;
        $this->searchService = $searchService;
    }

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

        if ($this->em->isOpen() === false) {
            throw new \ErrorException('em is closed');
        }

        $originalMoviesIds = array_keys($moviesTable);
        $movies = $this->movieRepository->findAllByIds($originalMoviesIds);
        $supportAcc = $this->em->getReference(User::class, 1);

        //todo add tests
        foreach ($movies as $movie) {
            $similarMovies = $this->movieRepository->findAllIdsByTmdbIds($moviesTable[$movie->getId()]);
            foreach ($similarMovies as $similarMovie) {
                $similarMovieRef = $this->em->getReference(Movie::class, $similarMovie['id']);
                $movie->addSimilarMovie($similarMovieRef);
                if (is_numeric($similarMovie['tmdb.voteAverage']) && $similarMovie['tmdb.voteAverage'] >= 7) {
                    if ($similarMovie['releaseDate'] !== null) {
                        $releaseDate = new \DateTimeImmutable($similarMovie['releaseDate']);
                        // some kind of discrimination of old movies
                        if ($releaseDate->format('Y') <= 1980 && $similarMovie['tmdb.voteAverage'] <= 8) {
                            continue;
                        }
                        if ($releaseDate->format('Y') <= 1990 && $similarMovie['tmdb.voteAverage'] <= 7) {
                            continue;
                        }
                    }

                    $movie->addRecommendation($supportAcc, $similarMovieRef);
                }
            }

            $this->em->persist($movie);
        }

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

        return self::ACK;
    }

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