src/Wallabag/ImportBundle/Controller/InstapaperController.php

   1 <?php
   2
   3 namespace Wallabag\ImportBundle\Controller;
   4
   5 use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
   6 use Symfony\Bundle\FrameworkBundle\Controller\Controller;
   7 use Symfony\Component\HttpFoundation\Request;
   8 use Wallabag\ImportBundle\Form\Type\UploadImportType;
   9
  10 class InstapaperController extends Controller
  11 {
  12     /**
  13      * @Route("/instapaper", name="import_instapaper")
  14      */
  15     public function indexAction(Request $request)
  16     {
  17         $form = $this->createForm(UploadImportType::class);
  18         $form->handleRequest($request);
  19
  20         $instapaper = $this->get('wallabag_import.instapaper.import');
  21         $instapaper->setUser($this->getUser());
  22
  23         if ($this->get('craue_config')->get('import_with_rabbitmq')) {
  24             $instapaper->setProducer($this->get('old_sound_rabbit_mq.import_instapaper_producer'));
  25         } elseif ($this->get('craue_config')->get('import_with_redis')) {
  26             $instapaper->setProducer($this->get('wallabag_import.producer.redis.instapaper'));
  27         }
  28
  29         if ($form->isSubmitted() && $form->isValid()) {
  30             $file = $form->get('file')->getData();
  31             $markAsRead = $form->get('mark_as_read')->getData();
  32             $name = 'instapaper_' . $this->getUser()->getId() . '.csv';
  33
  34             if (null !== $file && in_array($file->getClientMimeType(), $this->getParameter('wallabag_import.allow_mimetypes'), true) && $file->move($this->getParameter('wallabag_import.resource_dir'), $name)) {
  35                 $res = $instapaper
  36                     ->setFilepath($this->getParameter('wallabag_import.resource_dir') . '/' . $name)
  37                     ->setMarkAsRead($markAsRead)
  38                     ->import();
  39
  40                 $message = 'flashes.import.notice.failed';
  41
  42                 if (true === $res) {
  43                     $summary = $instapaper->getSummary();
  44                     $message = $this->get('translator')->trans('flashes.import.notice.summary', [
  45                         '%imported%' => $summary['imported'],
  46                         '%skipped%' => $summary['skipped'],
  47                     ]);
  48
  49                     if (0 < $summary['queued']) {
  50                         $message = $this->get('translator')->trans('flashes.import.notice.summary_with_queue', [
  51                             '%queued%' => $summary['queued'],
  52                         ]);
  53                     }
  54
  55                     unlink($this->getParameter('wallabag_import.resource_dir') . '/' . $name);
  56                 }
  57
  58                 $this->get('session')->getFlashBag()->add(
  59                     'notice',
  60                     $message
  61                 );
  62
  63                 return $this->redirect($this->generateUrl('homepage'));
  64             }
  65
  66             $this->get('session')->getFlashBag()->add(
  67                 'notice',
  68                 'flashes.import.notice.failed_on_file'
  69             );
  70         }
  71
  72         return $this->render('WallabagImportBundle:Instapaper:index.html.twig', [
  73             'form' => $form->createView(),
  74             'import' => $instapaper,
  75         ]);
  76     }
  77 }