Pim\Bundle\CustomEntityBundle\Action\QuickExportAction

Complexity

Total Complexity

8

Size/Duplication

Total Lines	115
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	18	1
B	doExecute()	0	25	2
A	getUser()	0	9	3
A	setDefaultOptions()	0	11	1
A	getType()	0	4	1

<?php

namespace Pim\Bundle\CustomEntityBundle\Action;

use Akeneo\Bundle\BatchBundle\Launcher\JobLauncherInterface;
use Pim\Bundle\CustomEntityBundle\Event\ActionEventManager;
use Pim\Bundle\CustomEntityBundle\Manager\Registry as ManagerRegistry;
use Pim\Bundle\DataGridBundle\Extension\MassAction\MassActionDispatcher;
use Pim\Bundle\ImportExportBundle\Entity\Repository\JobInstanceRepository;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\OptionsResolver\OptionsResolver;
use Symfony\Component\Routing\RouterInterface;
use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
use Symfony\Component\Security\Core\Exception\TokenNotFoundException;
use Symfony\Component\Security\Core\User\UserInterface;
use Symfony\Component\Translation\TranslatorInterface;

/**
 * @author    Antoine Guigan <antoine@akeneo.com>
 * @copyright 2014 Akeneo SAS (http://www.akeneo.com)
 * @license   http://opensource.org/licenses/osl-3.0.php  Open Software License (OSL 3.0)
 */
class QuickExportAction extends AbstractAction
{
    /** @var MassActionDispatcher */
    protected $massActionDispatcher;

    /** @var JobInstanceRepository */
    protected $jobInstanceRepo;

    /** @var JobLauncherInterface */
    protected $jobLauncher;

    /** @var TokenStorageInterface */
    protected $tokenStorage;

    /**
     * @param ActionFactory         $actionFactory
     * @param ActionEventManager    $eventManager
     * @param ManagerRegistry       $managerRegistry
     * @param RouterInterface       $router
     * @param TranslatorInterface   $translator
     * @param MassActionDispatcher  $massActionDispatcher
     * @param JobInstanceRepository $jobInstanceRepo
     * @param JobLauncherInterface  $jobLauncher
     * @param TokenStorageInterface $tokenStorage
     */
    public function __construct(
        ActionFactory $actionFactory,
        ActionEventManager $eventManager,
        ManagerRegistry $managerRegistry,
        RouterInterface $router,
        TranslatorInterface $translator,
        MassActionDispatcher $massActionDispatcher,
        JobInstanceRepository $jobInstanceRepo,
        JobLauncherInterface $jobLauncher,
        TokenStorageInterface $tokenStorage
    ) {
        parent::__construct($actionFactory, $eventManager, $managerRegistry, $router, $translator);

        $this->massActionDispatcher = $massActionDispatcher;
        $this->jobInstanceRepo      = $jobInstanceRepo;
        $this->jobLauncher          = $jobLauncher;
        $this->tokenStorage         = $tokenStorage;
    }

    /**
     * {@inheritdoc}
     */
    public function doExecute(Request $request)
    {
        $jobInstance = $this->jobInstanceRepo->findOneBy(['code' => $this->getOption('job_profile')]);
        if (null === $jobInstance) {
            throw new \LogicException(
                sprintf(
                    'The job instance "%s" does not exist. Please contact your administrator',
                    $this->getOption('job_profile')
                )
            );
        }

        $rawConfiguration = addslashes(
            json_encode(
                [
                    'reference_data' => $this->configuration->getEntityClass(),
                    'ids'            => $this->massActionDispatcher->dispatch($request),
                ]
            )
        );

        $this->jobLauncher->launch($jobInstance, $this->getUser(), $rawConfiguration);

        return new Response();
    }

    /**
     * Get the authenticated user from the Security Context
     *
     * @return UserInterface
     *
     * @throws TokenNotFoundException
     *
     * @see Symfony\Component\Security\Core\Authentication\Token\TokenInterface::getUser()
     */
    protected function getUser()
    {
        $token = $this->tokenStorage->getToken();
        if (null === $token || !is_object($user = $token->getUser())) {
            throw new TokenNotFoundException('You are no longer authenticated. Please log in and try again');
        }

        return $user;
    }

    /**
     * {@inheritdoc}
     */
    protected function setDefaultOptions(OptionsResolver $resolver)
    {
        $resolver->setDefined(['limit']);
        $resolver->setDefaults(
            [
                'route'               => 'pim_customentity_quickexport',
                'job_profile'         => 'csv_reference_data_quick_export',
                'serializer_context'  => [],
            ]
        );
    }

    /**
     * {@inheritdoc}
     */
    public function getType()
    {
        return 'quick_export';
    }
}