App\Movies\Service\SearchService

Complexity

Total Complexity

18

Size/Duplication

Total Lines	134
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

44%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
B	findByQuery()	0	35	7
B	findByQueryWithUserRecommendedMovie()	0	35	7
A	findByTmdbId()	0	12	3

<?php

declare(strict_types=1);

namespace App\Movies\Service;

use App\Movies\Entity\Movie;
use App\Movies\Exception\TmdbMovieNotFoundException;
use App\Movies\Exception\TmdbRequestLimitException;
use App\Movies\Pagination\MovieCollection;
use App\Movies\Repository\MovieRepository;
use App\Pagination\PaginatedCollection;
use App\Pagination\PaginatedCollectionInterface;

// todo all pages option
class SearchService
{
    private $repository;
    private $tmdb;
    private $sync;
    private $normalizer;

    public function __construct(MovieRepository $repository, TmdbSearchService $tmdb, TmdbSyncService $sync, TmdbNormalizerService $normalizer)
    {
        $this->repository = $repository;
        $this->tmdb = $tmdb;
        $this->sync = $sync;
        $this->normalizer = $normalizer;
    }

    /**
     * @param string   $query
     * @param string   $locale
     * @param int      $offset
     * @param int|null $limit
     *
     * @throws TmdbMovieNotFoundException
     * @throws TmdbRequestLimitException
     * @throws \ErrorException
     * @throws \Psr\SimpleCache\InvalidArgumentException
     *
     * @return PaginatedCollectionInterface
     */
    public function findByQuery(string $query, string $locale, int $offset = 0, ?int $limit = null): PaginatedCollectionInterface
    {
        $moviesQuery = $this->repository->findByTitleQuery($query);
        $movies = new PaginatedCollection($moviesQuery, $offset, $limit);
        if ($movies->getTotal() > 0) {
            return $movies;
        }

        $movies = $this->tmdb->findMoviesByQuery($query, $locale);
        $totalResults = (int) $movies['total_results'];

        if ($totalResults === 0) {
            return new MovieCollection([], 0, $offset);
        }

        $moviesObjects = $this->normalizer->normalizeMoviesToObjects($movies['results'], $locale);
        $this->sync->syncMovies($movies['results']);

        // If we have a lot of movies then save it all
        if (isset($movies['total_pages']) && $movies['total_pages'] > 1) {
            // $i = 2 because $movies currently already has movies from page 1
            for ($i = 2; $i <= $movies['total_pages']; ++$i) {
                try {
                    $moviesOnPage = $this->tmdb->findMoviesByQuery($query, $locale, [
                        'page' => $i,
                    ]);
                } catch (TmdbRequestLimitException $requestLimitException) {
                    continue;
                }
                $this->sync->syncMovies($moviesOnPage['results']);
            }
        }

        return new MovieCollection($moviesObjects, $totalResults, $offset);
    }

    /**
     * @param string   $query
     * @param string   $locale
     * @param int      $offset
     * @param int|null $limit
     *
     * @throws TmdbMovieNotFoundException
     * @throws TmdbRequestLimitException
     * @throws \ErrorException
     * @throws \Psr\SimpleCache\InvalidArgumentException
     *
     * @return PaginatedCollectionInterface
     */
    public function findByQueryWithUserRecommendedMovie(string $query, int $originalMovieId, int $userId, string $locale, int $offset = 0, ?int $limit = null): PaginatedCollectionInterface
    {
        $moviesQuery = $this->repository->findByTitleWithUserRecommendedMovieQuery($query, $userId, $originalMovieId);
        $movies = new PaginatedCollection($moviesQuery, $offset, $limit);
        if ($movies->getTotal() > 0) {
            return $movies;
        }

        $movies = $this->tmdb->findMoviesByQuery($query, $locale);
        $totalResults = (int) $movies['total_results'];

        if ($totalResults === 0) {
            return new MovieCollection([], 0, $offset);
        }

        $moviesObjects = $this->normalizer->normalizeMoviesToObjects($movies['results'], $locale);
        $this->sync->syncMovies($movies['results']);

        // If we have a lot of movies then save it all
        if (isset($movies['total_pages']) && $movies['total_pages'] > 1) {
            // $i = 2 because $movies currently already has movies from page 1
            for ($i = 2; $i <= $movies['total_pages']; ++$i) {
                try {
                    $moviesOnPage = $this->tmdb->findMoviesByQuery($query, $locale, [
                        'page' => $i,
                    ]);
                } catch (TmdbRequestLimitException $requestLimitException) {
                    continue;
                }
                $this->sync->syncMovies($moviesOnPage['results']);
            }
        }

        return new MovieCollection($moviesObjects, $totalResults, $offset);
    }

    /**
     * @param int    $tmdb_id
     * @param string $locale
     *
     * @throws \Exception
     *
     * @return Movie|null
     */
    public function findByTmdbId(int $tmdb_id, string $locale): ?Movie
    {
        try {
            $movie = $this->tmdb->findMovieById($tmdb_id, $locale);
        } catch (TmdbMovieNotFoundException $exception) {
            return null;
        }

        $movies = $this->normalizer->normalizeMoviesToObjects([$movie], $locale);

        return $movies->current() ?: null;
    }
}