forked from wallabag/wallabag
[#1590] Add JSON import from wallabag v2
This commit is contained in:
@ -11,12 +11,12 @@ use Wallabag\CoreBundle\Tools\Utils;
|
||||
|
||||
class WallabagV1Import implements ImportInterface
|
||||
{
|
||||
private $user;
|
||||
private $em;
|
||||
private $logger;
|
||||
private $skippedEntries = 0;
|
||||
private $importedEntries = 0;
|
||||
private $filepath;
|
||||
protected $user;
|
||||
protected $em;
|
||||
protected $logger;
|
||||
protected $skippedEntries = 0;
|
||||
protected $importedEntries = 0;
|
||||
protected $filepath;
|
||||
|
||||
public function __construct(EntityManager $em)
|
||||
{
|
||||
@ -72,13 +72,13 @@ class WallabagV1Import implements ImportInterface
|
||||
public function import()
|
||||
{
|
||||
if (!$this->user) {
|
||||
$this->logger->error('WallabagV1Import: user is not defined');
|
||||
$this->logger->error('WallabagImport: user is not defined');
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
if (!file_exists($this->filepath) || !is_readable($this->filepath)) {
|
||||
$this->logger->error('WallabagV1Import: unable to read file', array('filepath' => $this->filepath));
|
||||
$this->logger->error('WallabagImport: unable to read file', array('filepath' => $this->filepath));
|
||||
|
||||
return false;
|
||||
}
|
||||
@ -120,7 +120,7 @@ class WallabagV1Import implements ImportInterface
|
||||
/**
|
||||
* @param $entries
|
||||
*/
|
||||
private function parseEntries($entries)
|
||||
protected function parseEntries($entries)
|
||||
{
|
||||
$i = 1;
|
||||
|
||||
|
||||
75
src/Wallabag/ImportBundle/Import/WallabagV2Import.php
Normal file
75
src/Wallabag/ImportBundle/Import/WallabagV2Import.php
Normal file
@ -0,0 +1,75 @@
|
||||
<?php
|
||||
|
||||
namespace Wallabag\ImportBundle\Import;
|
||||
|
||||
use Wallabag\CoreBundle\Entity\Entry;
|
||||
|
||||
class WallabagV2Import extends WallabagV1Import implements ImportInterface
|
||||
{
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function getName()
|
||||
{
|
||||
return 'wallabag v2';
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function getUrl()
|
||||
{
|
||||
return 'import_wallabag_v2';
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritdoc}
|
||||
*/
|
||||
public function getDescription()
|
||||
{
|
||||
return 'This importer will import all your wallabag v2 articles. On the export sidebar, click on "JSON". You will have a "Unread articles.json" file.';
|
||||
}
|
||||
|
||||
/**
|
||||
* @param $entries
|
||||
*/
|
||||
protected function parseEntries($entries)
|
||||
{
|
||||
$i = 1;
|
||||
|
||||
foreach ($entries as $importedEntry) {
|
||||
$existingEntry = $this->em
|
||||
->getRepository('WallabagCoreBundle:Entry')
|
||||
->findByUrlAndUserId($importedEntry['url'], $this->user->getId());
|
||||
|
||||
if (false !== $existingEntry) {
|
||||
++$this->skippedEntries;
|
||||
continue;
|
||||
}
|
||||
|
||||
// @see ContentProxy->updateEntry
|
||||
$entry = new Entry($this->user);
|
||||
$entry->setUrl($importedEntry['url']);
|
||||
$entry->setTitle($importedEntry['title']);
|
||||
$entry->setArchived($importedEntry['is_archived']);
|
||||
$entry->setStarred($importedEntry['is_starred']);
|
||||
$entry->setContent($importedEntry['content']);
|
||||
$entry->setReadingTime($importedEntry['reading_time']);
|
||||
$entry->setDomainName($importedEntry['domain_name']);
|
||||
$entry->setMimetype($importedEntry['mimetype']);
|
||||
$entry->setLanguage($importedEntry['language']);
|
||||
$entry->setPreviewPicture($importedEntry['preview_picture']);
|
||||
|
||||
$this->em->persist($entry);
|
||||
++$this->importedEntries;
|
||||
|
||||
// flush every 20 entries
|
||||
if (($i % 20) === 0) {
|
||||
$this->em->flush();
|
||||
}
|
||||
++$i;
|
||||
}
|
||||
|
||||
$this->em->flush();
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user