3 namespace Wallabag\ImportBundle\Import
;
5 use Psr\Log\LoggerInterface
;
6 use Psr\Log\NullLogger
;
7 use Doctrine\ORM\EntityManager
;
8 use Wallabag\CoreBundle\Entity\Entry
;
9 use Wallabag\UserBundle\Entity\User
;
10 use Wallabag\CoreBundle\Tools\Utils
;
11 use Wallabag\CoreBundle\Helper\ContentProxy
;
13 class WallabagV1Import
implements ImportInterface
18 protected $contentProxy;
19 protected $skippedEntries = 0;
20 protected $importedEntries = 0;
22 protected $markAsRead;
24 public function __construct(EntityManager
$em, ContentProxy
$contentProxy)
27 $this->logger
= new NullLogger();
28 $this->contentProxy
= $contentProxy;
31 public function setLogger(LoggerInterface
$logger)
33 $this->logger
= $logger;
37 * We define the user in a custom call because on the import command there is no logged in user.
38 * So we can't retrieve user from the `security.token_storage` service.
42 public function setUser(User
$user)
52 public function getName()
60 public function getUrl()
62 return 'import_wallabag_v1';
68 public function getDescription()
70 return 'import.wallabag_v1.description';
76 public function import()
79 $this->logger
->error('WallabagImport: user is not defined');
84 if (!file_exists($this->filepath
) || !is_readable($this->filepath
)) {
85 $this->logger
->error('WallabagImport: unable to read file', array('filepath' => $this->filepath
));
90 $data = json_decode(file_get_contents($this->filepath
), true);
96 $this->parseEntries($data);
104 public function getSummary()
107 'skipped' => $this->skippedEntries
,
108 'imported' => $this->importedEntries
,
113 * Set file path to the json file.
115 * @param string $filepath
117 public function setFilepath($filepath)
119 $this->filepath
= $filepath;
125 * Set whether articles must be all marked as read.
127 * @param bool $markAsRead
129 public function setMarkAsRead($markAsRead)
131 $this->markAsRead
= $markAsRead;
139 protected function parseEntries($entries)
143 //Untitled in all languages from v1. This should never have been translated
144 $untitled = array('Untitled', 'Sans titre', 'podle nadpisu', 'Sin título', 'با عنوان', 'per titolo', 'Sem título', 'Без названия', 'po naslovu', 'Без назви', 'No title found', '');
146 foreach ($entries as $importedEntry) {
147 $existingEntry = $this->em
148 ->getRepository('WallabagCoreBundle:Entry')
149 ->findByUrlAndUserId($importedEntry['url'], $this->user
->getId());
151 if (false !== $existingEntry) {
152 ++
$this->skippedEntries
;
156 // @see ContentProxy->updateEntry
157 $entry = new Entry($this->user
);
158 $entry->setUrl($importedEntry['url']);
160 if (in_array($importedEntry['title'], $untitled)) {
161 $entry = $this->contentProxy
->updateEntry($entry, $importedEntry['url']);
163 $entry->setContent($importedEntry['content']);
164 $entry->setTitle($importedEntry['title']);
165 $entry->setReadingTime(Utils
::getReadingTime($importedEntry['content']));
166 $entry->setDomainName(parse_url($importedEntry['url'], PHP_URL_HOST
));
169 if (array_key_exists('tags', $importedEntry) && $importedEntry['tags'] != '') {
170 $this->contentProxy
->assignTagsToEntry(
172 $importedEntry['tags']
176 $entry->setArchived($importedEntry['is_read'] || $this->markAsRead
);
177 $entry->setStarred($importedEntry['is_fav']);
179 $this->em
->persist($entry);
180 ++
$this->importedEntries
;
182 // flush every 20 entries
183 if (($i %
20) === 0) {