namespace Wallabag\CoreBundle\Command;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
+use Symfony\Component\Config\Definition\Exception\Exception;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
protected function configure()
{
$this
- ->setName('import:json')
+ ->setName('wallabag:import')
->setDescription('Import entries from JSON file')
->addArgument(
'userId',
protected function import(InputInterface $input, OutputInterface $output)
{
- $userId = $input->getArgument('userId');
-
// Getting php array of data from CSV
$data = $this->get($input, $output);
$batchSize = 20;
$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->start();
- $user = $em->getRepository('WallabagCoreBundle:User')
- ->findOneById($userId);
-
foreach ($data as $object) {
$array = (array) $object;
$entry = $em->getRepository('WallabagCoreBundle:Entry')
protected function get(InputInterface $input, OutputInterface $output)
{
- $fileName = 'web/uploads/import/import.json';
- $data = $this->convert($fileName);
+ $filename = __DIR__.'/../../../../web/uploads/import/'.$input->getArgument('userId').'.json';
+ $data = $this->convert($filename);
return $data;
}
--- /dev/null
+<?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('/');
+ }
+}
<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 {% 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"><a class="waves-effect" class="icon icon-power" href="{{ path('fos_user_security_logout') }}" title="{% trans %}logout{% endtrans %}">{% trans %}logout{% endtrans %}</a></li>
</ul>