View source
<?php
namespace Drupal\social_demo;
use Drupal\user\UserStorageInterface;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Drush\Log\LogLevel;
abstract class DemoComment extends DemoContent {
protected $userStorage;
public function __construct(array $configuration, $plugin_id, $plugin_definition, DemoContentParserInterface $parser, UserStorageInterface $user_storage) {
parent::__construct($configuration, $plugin_id, $plugin_definition);
$this->parser = $parser;
$this->userStorage = $user_storage;
}
public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition) {
return new static($configuration, $plugin_id, $plugin_definition, $container
->get('social_demo.yaml_parser'), $container
->get('entity.manager')
->getStorage('user'));
}
public function createContent() {
$data = $this
->fetchData();
foreach ($data as $uuid => $item) {
if ($uuid !== $item['uuid']) {
drush_log(dt("Comment with uuid: {$uuid} has a different uuid in content."), LogLevel::ERROR);
continue;
}
$comments = $this->entityStorage
->loadByProperties([
'uuid' => $uuid,
]);
if ($comments) {
drush_log(dt("Comment with uuid: {$uuid} already exists."), LogLevel::WARNING);
continue;
}
$accounts = $this->userStorage
->loadByProperties([
'uuid' => $item['uid'],
]);
if (!$accounts) {
drush_log(dt("Account with uuid: {$item['uid']} doesn't exists."), LogLevel::ERROR);
continue;
}
$account = current($accounts);
$item['uid'] = $account
->id();
$item['pid'] = NULL;
if (!empty($item['parent'])) {
$comments = $this->entityStorage
->loadByProperties([
'uuid' => $item['parent'],
]);
if ($comments) {
$comment = current($comments);
$item['pid'] = $comment
->id();
}
}
$entity = $this
->loadByUuid($item['entity_type'], $item['entity_id']);
if (!$entity) {
drush_log(dt("Entity {$item['entity_type']} with uuid: {$item['entity_id']} doesn't exists."), LogLevel::ERROR);
continue;
}
if (!empty($item['created'])) {
$item['created'] = $this
->createDate($item['created']);
if ($item['created'] < $entity
->get('created')->value) {
$item['created'] = \Drupal::time()
->getRequestTime();
}
}
else {
$item['created'] = \Drupal::time()
->getRequestTime();
}
$item['entity_id'] = $entity
->id();
$entry = $this
->getEntry($item);
$entity = $this->entityStorage
->create($entry);
$entity
->save();
if ($entity
->id()) {
$this->content[$entity
->id()] = $entity;
}
}
return $this->content;
}
protected function createDate($date_string) {
if ($date_string === 'now') {
return time();
}
$timestamp = explode('|', $date_string);
$date = strtotime($timestamp[0]);
$date = date('Y-m-d', $date) . 'T' . $timestamp[1] . ':00';
return strtotime($date);
}
protected function getEntry(array $item) {
$entry = [
'uuid' => $item['uuid'],
'field_comment_body' => [
[
'value' => $this
->checkMentionOrLinkByUuid($item['body']),
'format' => 'basic_html',
],
],
'langcode' => $item['langcode'],
'uid' => $item['uid'],
'entity_id' => $item['entity_id'],
'pid' => $item['pid'],
'created' => $item['created'],
'changed' => $item['created'],
'field_name' => $item['field_name'],
'comment_type' => $item['type'],
'entity_type' => $item['entity_type'],
'status' => 1,
];
return $entry;
}
}