]> git.immae.eu Git - github/wallabag/wallabag.git/blob - src/Wallabag/ImportBundle/Controller/ReadabilityController.php
Enable Redis async import
[github/wallabag/wallabag.git] / src / Wallabag / ImportBundle / Controller / ReadabilityController.php
1 <?php
2
3 namespace Wallabag\ImportBundle\Controller;
4
5 use Symfony\Bundle\FrameworkBundle\Controller\Controller;
6 use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
7 use Symfony\Component\HttpFoundation\Request;
8 use Wallabag\ImportBundle\Form\Type\UploadImportType;
9
10 class ReadabilityController extends Controller
11 {
12 /**
13 * @Route("/readability", name="import_readability")
14 */
15 public function indexAction(Request $request)
16 {
17 $form = $this->createForm(UploadImportType::class);
18 $form->handleRequest($request);
19
20 $readability = $this->get('wallabag_import.readability.import');
21 $readability->setUser($this->getUser());
22
23 if ($this->get('craue_config')->get('import_with_rabbitmq')) {
24 $readability->setProducer($this->get('old_sound_rabbit_mq.import_readability_producer'));
25 } elseif ($this->get('craue_config')->get('import_with_redis')) {
26 $readability->setProducer($this->get('wallabag_import.producer.redis.readability'));
27 }
28
29 if ($form->isValid()) {
30 $file = $form->get('file')->getData();
31 $markAsRead = $form->get('mark_as_read')->getData();
32 $name = 'readability_'.$this->getUser()->getId().'.json';
33
34 if (in_array($file->getClientMimeType(), $this->getParameter('wallabag_import.allow_mimetypes')) && $file->move($this->getParameter('wallabag_import.resource_dir'), $name)) {
35 $res = $readability
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 = $readability->getSummary();
44 $message = $this->get('translator')->trans('flashes.import.notice.summary', [
45 '%imported%' => $summary['imported'],
46 '%skipped%' => $summary['skipped'],
47 ]);
48
49 unlink($this->getParameter('wallabag_import.resource_dir').'/'.$name);
50 }
51
52 $this->get('session')->getFlashBag()->add(
53 'notice',
54 $message
55 );
56
57 return $this->redirect($this->generateUrl('homepage'));
58 } else {
59 $this->get('session')->getFlashBag()->add(
60 'notice',
61 'flashes.import.notice.failed_on_file'
62 );
63 }
64 }
65
66 return $this->render('WallabagImportBundle:Readability:index.html.twig', [
67 'form' => $form->createView(),
68 'import' => $readability,
69 ]);
70 }
71 }