create controller to launch import command

This commit is contained in:
Nicolas Lœuillet 2015-09-30 15:10:46 +02:00 committed by Jeremy Benoist
parent a1bb1b3c2a
commit 8c3c77c1bd
3 changed files with 52 additions and 8 deletions

View File

@ -3,6 +3,7 @@
namespace Wallabag\CoreBundle\Command; namespace Wallabag\CoreBundle\Command;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand; use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Config\Definition\Exception\Exception;
use Symfony\Component\Console\Input\InputArgument; use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface; use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface; use Symfony\Component\Console\Output\OutputInterface;
@ -15,7 +16,7 @@ class ImportCommand extends ContainerAwareCommand
protected function configure() protected function configure()
{ {
$this $this
->setName('import:json') ->setName('wallabag:import')
->setDescription('Import entries from JSON file') ->setDescription('Import entries from JSON file')
->addArgument( ->addArgument(
'userId', 'userId',
@ -38,8 +39,6 @@ class ImportCommand extends ContainerAwareCommand
protected function import(InputInterface $input, OutputInterface $output) protected function import(InputInterface $input, OutputInterface $output)
{ {
$userId = $input->getArgument('userId');
// Getting php array of data from CSV // Getting php array of data from CSV
$data = $this->get($input, $output); $data = $this->get($input, $output);
@ -52,12 +51,16 @@ class ImportCommand extends ContainerAwareCommand
$batchSize = 20; $batchSize = 20;
$i = 1; $i = 1;
$user = $em->getRepository('WallabagCoreBundle:User')
->findOneById($input->getArgument('userId'));
if (!is_object($user)) {
throw new Exception('User not found');
}
$progress = new ProgressBar($output, $size); $progress = new ProgressBar($output, $size);
$progress->start(); $progress->start();
$user = $em->getRepository('WallabagCoreBundle:User')
->findOneById($userId);
foreach ($data as $object) { foreach ($data as $object) {
$array = (array) $object; $array = (array) $object;
$entry = $em->getRepository('WallabagCoreBundle:Entry') $entry = $em->getRepository('WallabagCoreBundle:Entry')
@ -112,8 +115,8 @@ class ImportCommand extends ContainerAwareCommand
protected function get(InputInterface $input, OutputInterface $output) protected function get(InputInterface $input, OutputInterface $output)
{ {
$fileName = 'web/uploads/import/import.json'; $filename = __DIR__.'/../../../../web/uploads/import/'.$input->getArgument('userId').'.json';
$data = $this->convert($fileName); $data = $this->convert($filename);
return $data; return $data;
} }

View File

@ -0,0 +1,40 @@
<?php
namespace Wallabag\CoreBundle\Controller;
use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
use Symfony\Bundle\FrameworkBundle\Controller\Controller;
use Symfony\Component\Console\Input\ArrayInput;
use Symfony\Component\Console\Output\NullOutput;
use Symfony\Component\HttpFoundation\Request;
use Wallabag\CoreBundle\Command\ImportCommand;
class ImportController extends Controller
{
/**
* @param Request $request
*
* @Route("/import", name="import")
*/
public function importAction(Request $request)
{
$command = new ImportCommand();
$command->setContainer($this->container);
$input = new ArrayInput(array('userId' => $this->getUser()->getId()));
$return = $command->run($input, new NullOutput());
if ($return == 0) {
$this->get('session')->getFlashBag()->add(
'notice',
'Import successful'
);
} else {
$this->get('session')->getFlashBag()->add(
'warning',
'Import failed'
);
}
return $this->redirect('/');
}
}

View File

@ -45,6 +45,7 @@
<li class="bold border-bottom {% if currentRoute == 'all' %}active{% endif %}"><a class="waves-effect" href="{{ path('all') }}">{% trans %}all{% endtrans %}</a></li> <li class="bold border-bottom {% if currentRoute == 'all' %}active{% endif %}"><a class="waves-effect" href="{{ path('all') }}">{% trans %}all{% endtrans %}</a></li>
<li class="bold border-bottom {% if currentRoute == 'tags' %}active{% endif %}"><a class="waves-effect" href="{{ path('tag') }}">{% trans %}tags{% endtrans %}</a></li> <li class="bold border-bottom {% if currentRoute == 'tags' %}active{% endif %}"><a class="waves-effect" href="{{ path('tag') }}">{% trans %}tags{% endtrans %}</a></li>
<li class="bold {% if currentRoute == 'config' %}active{% endif %}"><a class="waves-effect" href="{{ path('config') }}">{% trans %}config{% endtrans %}</a></li> <li class="bold {% if currentRoute == 'config' %}active{% endif %}"><a class="waves-effect" href="{{ path('config') }}">{% trans %}config{% endtrans %}</a></li>
<li class="bold {% if currentRoute == 'import' %}active{% endif %}"><a class="waves-effect" href="{{ path('import') }}">{% trans %}import{% endtrans %}</a></li>
<li class="bold {% if currentRoute == 'howto' %}active{% endif %}"><a class="waves-effect" href="{{ path('howto') }}">{% trans %}howto{% endtrans %}</a></li> <li class="bold {% if currentRoute == 'howto' %}active{% endif %}"><a class="waves-effect" href="{{ path('howto') }}">{% trans %}howto{% endtrans %}</a></li>
<li class="bold"><a class="waves-effect" class="icon icon-power" href="{{ path('fos_user_security_logout') }}" title="{% trans %}logout{% endtrans %}">{% trans %}logout{% endtrans %}</a></li> <li class="bold"><a class="waves-effect" class="icon icon-power" href="{{ path('fos_user_security_logout') }}" title="{% trans %}logout{% endtrans %}">{% trans %}logout{% endtrans %}</a></li>
</ul> </ul>