cs & fixes

diff --git a/app/config/config.yml b/app/config/config.yml
index 7ee0cfb833dc5612489d6776ec8d240d8f91d9a2..a4584a1ba435cd66cb12f42f904e938f14735cc5 100644 (file)
--- a/app/config/config.yml
+++ b/app/config/config.yml
@@ -246,6 +246,16 @@ old_sound_rabbit_mq:
             exchange_options:
                 name: 'wallabag.import.wallabag_v2'
                 type: topic
+        import_firefox:
+            connection: default
+            exchange_options:
+                name: 'wallabag.import.firefox'
+                type: topic
+        import_chrome:
+            connection: default
+            exchange_options:
+                name: 'wallabag.import.chrome'
+                type: topic
     consumers:
         import_pocket:
             connection: default
@@ -279,3 +289,19 @@ old_sound_rabbit_mq:
             queue_options:
                 name: 'wallabag.import.wallabag_v2'
             callback: wallabag_import.consumer.amqp.wallabag_v2
+        import_firefox:
+            connection: default
+            exchange_options:
+                name: 'wallabag.import.firefox'
+                type: topic
+            queue_options:
+                name: 'wallabag.import.firefox'
+            callback: wallabag_import.consumer.amqp.firefox
+        import_chrome:
+            connection: default
+            exchange_options:
+                name: 'wallabag.import.chrome'
+                type: topic
+            queue_options:
+                name: 'wallabag.import.chrome'
+            callback: wallabag_import.consumer.amqp.chrome

diff --git a/src/Wallabag/ImportBundle/Controller/ChromeController.php b/src/Wallabag/ImportBundle/Controller/ChromeController.php
index e4cc322a837e92d72325c47a281aec2138a2062d..454f3347478076a666db7510700adbca83aa9cf5 100644 (file)
--- a/src/Wallabag/ImportBundle/Controller/ChromeController.php
+++ b/src/Wallabag/ImportBundle/Controller/ChromeController.php
@@ -15,9 +15,9 @@ class ChromeController extends BrowserController
         $service = $this->get('wallabag_import.chrome.import');
 
         if ($this->get('craue_config')->get('import_with_rabbitmq')) {
-            $service->setProducer($this->get('old_sound_rabbit_mq.import_wallabag_v1_producer'));
+            $service->setProducer($this->get('old_sound_rabbit_mq.import_chrome_producer'));
         } elseif ($this->get('craue_config')->get('import_with_redis')) {
-            $service->setProducer($this->get('wallabag_import.producer.redis.wallabag_v1'));
+            $service->setProducer($this->get('wallabag_import.producer.redis.chrome'));
         }
 
         return $service;

diff --git a/src/Wallabag/ImportBundle/Controller/FirefoxController.php b/src/Wallabag/ImportBundle/Controller/FirefoxController.php
index e0dd8214715f1a90c9b171456e06dc1ef653c41f..c329b9c4a9f6a72681768359e8d6d7f69f07efa7 100644 (file)
--- a/src/Wallabag/ImportBundle/Controller/FirefoxController.php
+++ b/src/Wallabag/ImportBundle/Controller/FirefoxController.php
@@ -15,9 +15,9 @@ class FirefoxController extends BrowserController
         $service = $this->get('wallabag_import.firefox.import');
 
         if ($this->get('craue_config')->get('import_with_rabbitmq')) {
-            $service->setProducer($this->get('old_sound_rabbit_mq.import_wallabag_v1_producer'));
+            $service->setProducer($this->get('old_sound_rabbit_mq.import_firefox_producer'));
         } elseif ($this->get('craue_config')->get('import_with_redis')) {
-            $service->setProducer($this->get('wallabag_import.producer.redis.wallabag_v1'));
+            $service->setProducer($this->get('wallabag_import.producer.redis.firefox'));
         }
 
         return $service;

diff --git a/src/Wallabag/ImportBundle/Import/BrowserImport.php b/src/Wallabag/ImportBundle/Import/BrowserImport.php
index ef7d6d955ef541c826d94b531fcdface43728be5..3e1cb12b173bb578faad14e913eaf13449a687fc 100644 (file)
--- a/src/Wallabag/ImportBundle/Import/BrowserImport.php
+++ b/src/Wallabag/ImportBundle/Import/BrowserImport.php
@@ -2,9 +2,6 @@
 
 namespace Wallabag\ImportBundle\Import;
 
-use Psr\Log\LoggerInterface;
-use Psr\Log\NullLogger;
-use Doctrine\ORM\EntityManager;
 use Wallabag\CoreBundle\Entity\Entry;
 use Wallabag\UserBundle\Entity\User;
 use Wallabag\CoreBundle\Helper\ContentProxy;
@@ -121,7 +118,6 @@ abstract class BrowserImport extends AbstractImport
     protected function parseEntriesForProducer(array $entries)
     {
         foreach ($entries as $importedEntry) {
-
             if ((array) $importedEntry !== $importedEntry) {
                 continue;
             }
@@ -144,14 +140,15 @@ abstract class BrowserImport extends AbstractImport
      */
     public function parseEntry(array $importedEntry)
     {
-
         if ((!key_exists('guid', $importedEntry) || (!key_exists('id', $importedEntry))) && is_array(reset($importedEntry))) {
             $this->parseEntries($importedEntry);
+
             return;
         }
 
         if (key_exists('children', $importedEntry)) {
             $this->parseEntries($importedEntry['children']);
+
             return;
         }
 
@@ -191,7 +188,7 @@ abstract class BrowserImport extends AbstractImport
 
         if (!empty($data['created_at'])) {
             $dt = new \DateTime();
-            $entry->setCreatedAt($dt->setTimestamp($data['created_at']/1000));
+            $entry->setCreatedAt($dt->setTimestamp($data['created_at'] / 1000));
         }
 
         $this->em->persist($entry);

diff --git a/src/Wallabag/ImportBundle/Import/ChromeImport.php b/src/Wallabag/ImportBundle/Import/ChromeImport.php
index 7936ee2f427d862ab9df3f2f1d2994739814fa59..941d68d38690bc7799211c3ea391c6cf720b3190 100644 (file)
--- a/src/Wallabag/ImportBundle/Import/ChromeImport.php
+++ b/src/Wallabag/ImportBundle/Import/ChromeImport.php
@@ -2,13 +2,6 @@
 
 namespace Wallabag\ImportBundle\Import;
 
-use Psr\Log\LoggerInterface;
-use Psr\Log\NullLogger;
-use Doctrine\ORM\EntityManager;
-use Wallabag\CoreBundle\Entity\Entry;
-use Wallabag\UserBundle\Entity\User;
-use Wallabag\CoreBundle\Helper\ContentProxy;
-
 class ChromeImport extends BrowserImport
 {
     protected $filepath;
@@ -37,7 +30,7 @@ class ChromeImport extends BrowserImport
         return 'import.chrome.description';
     }
 
-    /**
+      /**
        * {@inheritdoc}
        */
       protected function prepareEntry($entry = [])
@@ -58,7 +51,6 @@ class ChromeImport extends BrowserImport
           return $data;
       }
 
-
     /**
      * {@inheritdoc}
      */

diff --git a/src/Wallabag/ImportBundle/Import/FirefoxImport.php b/src/Wallabag/ImportBundle/Import/FirefoxImport.php
index cbf10b87c0401a3b8b8a9d1a6b92c78713b6a3ab..351cbef12683545b47404fbad95c36a2ce19f6ad 100644 (file)
--- a/src/Wallabag/ImportBundle/Import/FirefoxImport.php
+++ b/src/Wallabag/ImportBundle/Import/FirefoxImport.php
@@ -2,13 +2,6 @@
 
 namespace Wallabag\ImportBundle\Import;
 
-use Psr\Log\LoggerInterface;
-use Psr\Log\NullLogger;
-use Doctrine\ORM\EntityManager;
-use Wallabag\CoreBundle\Entity\Entry;
-use Wallabag\UserBundle\Entity\User;
-use Wallabag\CoreBundle\Helper\ContentProxy;
-
 class FirefoxImport extends BrowserImport
 {
     protected $filepath;
@@ -42,7 +35,7 @@ class FirefoxImport extends BrowserImport
      */
     protected function prepareEntry($entry = [])
     {
-      $data = [
+        $data = [
           'title' => $entry['name'],
           'html' => '',
           'url' => $entry['url'],
@@ -51,13 +44,12 @@ class FirefoxImport extends BrowserImport
           'created_at' => $entry['date_added'],
       ];
 
-      if (array_key_exists('tags', $entry) && $entry['tags'] != '') {
-          $data['tags'] = $entry['tags'];
-      }
-
-      return $data;
-  }
+        if (array_key_exists('tags', $entry) && $entry['tags'] != '') {
+            $data['tags'] = $entry['tags'];
+        }
 
+        return $data;
+    }
 
     /**
      * {@inheritdoc}