AnimeDb\Bundle\AppBundle\Event\Listener\Package

Complexity

Total Complexity

16

Size/Duplication

Total Lines	156
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	10

Test Coverage

Coverage

97.78%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	1
A	onUpdated()	0	6	2
A	onInstalled()	0	6	2
B	addPackage()	0	25	4
A	onRemoved()	0	11	3
A	onInstalledConfigureShmop()	0	8	2
A	onRemovedShmop()	0	6	2

<?php
/**
 * AnimeDb package.
 *
 * @author    Peter Gribanov <info@peter-gribanov.ru>
 * @copyright Copyright (c) 2011, Peter Gribanov
 * @license   http://opensource.org/licenses/GPL-3.0 GPL v3
 */
namespace AnimeDb\Bundle\AppBundle\Event\Listener;

use AnimeDb\Bundle\ApiClientBundle\Service\Client;
use AnimeDb\Bundle\AppBundle\Service\Downloader;
use AnimeDb\Bundle\AnimeDbBundle\Event\Package\Installed as InstalledEvent;
use AnimeDb\Bundle\AnimeDbBundle\Event\Package\Removed as RemovedEvent;
use AnimeDb\Bundle\AnimeDbBundle\Event\Package\Updated as UpdatedEvent;
use AnimeDb\Bundle\AppBundle\Entity\Plugin;
use Composer\Package\Package as ComposerPackage;
use AnimeDb\Bundle\AnimeDbBundle\Manipulator\Parameters;
use Doctrine\ORM\EntityManagerInterface;
use Doctrine\ORM\EntityRepository;

class Package
{
    /**
     * @var string
     */
    const PLUGIN_TYPE = 'anime-db-plugin';

    /**
     * @var string
     */
    const PACKAGE_SHMOP = 'anime-db/shmop';

    /**
     * @var EntityManagerInterface
     */
    protected $em;

    /**
     * @var EntityRepository
     */
    protected $rep;

    /**
     * API client.
     *
     * @var Client
     */
    protected $client;

    /**
     * @var Parameters
     */
    protected $parameters;

    /**
     * @var Downloader
     */
    protected $downloader;

    /**
     * @param EntityManagerInterface $em
     * @param Client $client
     * @param Downloader $downloader
     * @param Parameters $parameters
     */
    public function __construct(
        EntityManagerInterface $em,
        Client $client,
        Downloader $downloader,
        Parameters $parameters
    ) {
        $this->client = $client;
        $this->downloader = $downloader;
        $this->em = $em;
        $this->parameters = $parameters;
        $this->rep = $em->getRepository('AnimeDbAppBundle:Plugin');
    }

    /**
     * Update plugin data.
     *
     * @param UpdatedEvent $event
     */
    public function onUpdated(UpdatedEvent $event)
    {
        if ($event->getPackage()->getType() == self::PLUGIN_TYPE) {
            $this->addPackage($event->getPackage());
        }
    }

    /**
     * Registr plugin.
     *
     * @param InstalledEvent $event
     */
    public function onInstalled(InstalledEvent $event)
    {
        if ($event->getPackage()->getType() == self::PLUGIN_TYPE) {
            $this->addPackage($event->getPackage());
        }
    }

    /**
     * Add plugin from package.
     *
     * @param ComposerPackage $package
     */
    protected function addPackage(ComposerPackage $package)
    {
        $plugin = $this->rep->find($package->getName());

        // create new plugin if not exists
        if (!$plugin) {
            $plugin = new Plugin();
            $plugin->setName($package->getName());
        }

        list($vendor, $package) = explode('/', $plugin->getName());

        try {
            $data = $this->client->getPlugin($vendor, $package);
            $plugin->setTitle($data['title'])->setDescription($data['description']);
            if ($data['logo']) {
                $this->downloader->entity($data['logo'], $plugin, true);
            }
        } catch (\Exception $e) {
            // is not a critical error
        }

        $this->em->persist($plugin);
        $this->em->flush();
    }

    /**
     * Unregistr plugin.
     *
     * @param RemovedEvent $event
     */
    public function onRemoved(RemovedEvent $event)
    {
        if ($event->getPackage()->getType() == self::PLUGIN_TYPE) {
            $plugin = $this->rep->find($event->getPackage()->getName());

            if ($plugin) {
                $this->em->remove($plugin);
                $this->em->flush();
            }
        }
    }

    /**
     * Configure shmop.
     *
     * @param InstalledEvent $event
     */
    public function onInstalledConfigureShmop(InstalledEvent $event)
    {
        // use Shmop as driver for Cache Time Keeper
        if ($event->getPackage()->getName() == self::PACKAGE_SHMOP) {
            $this->parameters->set('cache_time_keeper.driver', 'cache_time_keeper.driver.multi');
            $this->parameters->set('cache_time_keeper.driver.multi.fast', 'cache_time_keeper.driver.shmop');
        }
    }

    /**
     * Restore config on removed shmop.
     *
     * @param RemovedEvent $event
     */
    public function onRemovedShmop(RemovedEvent $event)
    {
        if ($event->getPackage()->getName() == self::PACKAGE_SHMOP) {
            $this->parameters->set('cache_time_keeper.driver', 'cache_time_keeper.driver.file');
        }
    }
}