filepath = $filepath; return $this; } public function import() { if (!$this->user) { $this->logger->error('DeliciousImport: user is not defined'); return false; } if (!file_exists($this->filepath) || !is_readable($this->filepath)) { $this->logger->error('DeliciousImport: unable to read file', ['filepath' => $this->filepath]); return false; } $data = json_decode(file_get_contents($this->filepath), true); if (empty($data)) { $this->logger->error('DeliciousImport: no entries in imported file'); return false; } if ($this->producer) { $this->parseEntriesForProducer($data); return true; } $this->parseEntries($data); return true; } public function validateEntry(array $importedEntry) { if (empty($importedEntry['url'])) { return false; } return true; } public function parseEntry(array $importedEntry) { $existingEntry = $this->em ->getRepository(Entry::class) ->findByUrlAndUserId($importedEntry['url'], $this->user->getId()); if (false !== $existingEntry) { ++$this->skippedEntries; return null; } $data = [ 'title' => $importedEntry['title'], 'url' => $importedEntry['url'], 'is_archived' => $this->markAsRead, 'is_starred' => false, 'created_at' => $importedEntry['created'], 'tags' => $importedEntry['tags'], ]; $entry = new Entry($this->user); $entry->setUrl($data['url']); $entry->setTitle($data['title']); // update entry with content (in case fetching failed, the given entry will be return) $this->fetchContent($entry, $data['url'], $data); if (!empty($data['tags'])) { $this->tagsAssigner->assignTagsToEntry( $entry, $data['tags'], $this->em->getUnitOfWork()->getScheduledEntityInsertions() ); } $entry->updateArchived($data['is_archived']); $entry->setStarred($data['is_starred']); $entry->setCreatedAt(\DateTime::createFromFormat('U', $data['created_at'])); $this->em->persist($entry); ++$this->importedEntries; return $entry; } protected function setEntryAsRead(array $importedEntry) { return $importedEntry; } }