Completed
Push — master ( 196fcb...26caf8 )
by Valentyn
03:58 queued 01:37
created

TmdbSyncService::__construct()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 5

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 4
CRAP Score 1

Importance

Changes 0
Metric Value
dl 0
loc 5
ccs 4
cts 4
cp 1
rs 10
c 0
b 0
f 0
cc 1
nc 1
nop 2
crap 1
1
<?php
2
3
declare(strict_types=1);
4
5
namespace App\Movies\Service;
6
7
use App\Movies\Entity\Movie;
8
use App\Movies\EventListener\MovieSyncProcessor;
9
use App\Movies\Repository\MovieRepository;
10
use Enqueue\Client\Message;
11
use Enqueue\Client\ProducerInterface;
12
13
class TmdbSyncService
14
{
15
    private $repository;
16
    private $producer;
17
18 9
    public function __construct(MovieRepository $repository, ProducerInterface $producer)
19
    {
20 9
        $this->repository = $repository;
21 9
        $this->producer = $producer;
22 9
    }
23
24
    /**
25
     * @param array|Movie[] $movies
26
     * @param bool $loadSimilar
27
     */
28 1
    public function syncMovies(array $movies, bool $loadSimilar = true): void
29
    {
30 1
        if ($this->isSupport(reset($movies)) === false) {
31
            throw new \InvalidArgumentException('Unsupported array of movies provided');
32
        }
33
34 1
        if (!count($movies)) {
35
            return;
36
        }
37
38 1
        $message = new Message(serialize($movies), [
39 1
            'load_similar' => $loadSimilar,
40
        ]);
41
42 1
        $this->producer->sendEvent(MovieSyncProcessor::ADD_MOVIES_TMDB, $message);
43 1
    }
44
45 1
    private function isSupport($movie)
46
    {
47 1
        return $movie instanceof Movie;
48
    }
49
}
50