Velikonja\LabbyBundle\Service\Syncer

Complexity

Total Complexity

5

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

95.65%

Importance

Changes	5
Bugs	1	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	sync()	0	7	1
A	syncFs()	0	6	1
A	syncDb()	0	10	2

<?php

namespace Velikonja\LabbyBundle\Service;

use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Velikonja\LabbyBundle\Database\SyncerDb;
use SyncFS\Syncer as SyncerFs;
use Velikonja\LabbyBundle\Event\SyncEvent;
use Velikonja\LabbyBundle\Events;

class Syncer
{
    /**
     * @var SyncerFs
     */
    private $syncerFs;

    /**
     * @var SyncerDb | null
     */
    private $syncerDb;

    /**
     * @var EventDispatcherInterface
     */
    private $eventDispatcher;

    /**
     * @param EventDispatcherInterface $eventDispatcher
     * @param SyncerFs                 $syncerFs
     * @param null|SyncerDb            $syncerDb
     */
    public function __construct(
        EventDispatcherInterface $eventDispatcher,
        SyncerFs $syncerFs,
        SyncerDb $syncerDb = null
    ) {
        $this->syncerFs        = $syncerFs;
        $this->syncerDb        = $syncerDb;
        $this->eventDispatcher = $eventDispatcher;
    }

    /**
     * @param OutputInterface $output
     */
    public function sync(OutputInterface $output)
    {
        $this->eventDispatcher->dispatch(Events::PRE_SYNC, new SyncEvent($output));
        $this->syncDb($output);
        $this->syncFs($output);
        $this->eventDispatcher->dispatch(Events::POST_SYNC, new SyncEvent($output));
    }

    /**
     * @param OutputInterface $output
     */
    public function syncFs(OutputInterface $output)
    {
        $this->eventDispatcher->dispatch(Events::PRE_SYNC_FS, new SyncEvent($output));
        $this->syncerFs->sync($output);
        $this->eventDispatcher->dispatch(Events::POST_SYNC_FS, new SyncEvent($output));
    }

    /**
     * @param OutputInterface $output
     *
     * @throws \Exception
     */
    public function syncDb(OutputInterface $output)
    {
        if (! $this->syncerDb) {
            throw new \RuntimeException('Syncer DB is not defined.');
        }

        $this->eventDispatcher->dispatch(Events::PRE_SYNC_DB, new SyncEvent($output));
        $this->syncerDb->sync($output);
        $this->eventDispatcher->dispatch(Events::POST_SYNC_DB, new SyncEvent($output));
    }
}