protected function ImportPartialCommand::execute in Tome 8

Overrides ImportCommand::execute

File

modules/tome_sync/src/Commands/ImportPartialCommand.php, line 59

Class

ImportPartialCommand

Contains the tome:import-partial command.

Namespace

Drupal\tome_sync\Commands

Code

protected function execute(InputInterface $input, OutputInterface $output) {
  if (!$this->contentHasher
    ->hashesExist()) {
    $this
      ->io()
      ->error('No content hashes exist to perform a partial import. Please run a full Tome install and export (i.e. "drush tome:install && drush tome:export"), which will ensure hashes exist in the database and filesystem.');
    return 1;
  }
  $options = $input
    ->getOptions();
  $change_list = $this->contentHasher
    ->getChangelist();
  if (empty($change_list['modified']) && empty($change_list['deleted']) && empty($change_list['added'])) {
    $this
      ->io()
      ->success('No content has been changed or deleted. There may be config and file changes to import.');
  }
  if (!empty($change_list['modified'])) {
    $this
      ->io()
      ->section('Modified');
    $this
      ->io()
      ->listing($change_list['modified']);
  }
  if (!empty($change_list['added'])) {
    $this
      ->io()
      ->section('Added');
    $this
      ->io()
      ->listing($change_list['added']);
  }
  if (!empty($change_list['deleted'])) {
    $this
      ->io()
      ->section('Deleted');
    $this
      ->io()
      ->listing($change_list['deleted']);
  }
  if (!$options['yes'] && !$this
    ->io()
    ->confirm('Your local site\'s config, content, and files will be deleted or updated.', FALSE)) {
    return 0;
  }
  if (!$this
    ->checkImportingState($options)) {
    return 0;
  }
  $this->state
    ->set(ImporterInterface::STATE_KEY_IMPORTING, TRUE);
  $delete_content = [];
  foreach ($change_list['deleted'] as $content_name) {
    list($entity_type_id, $uuid, $langcode) = TomeSyncHelper::getPartsFromContentName($content_name);
    $results = $this->entityTypeManager
      ->getStorage($entity_type_id)
      ->getQuery()
      ->condition('uuid', $uuid)
      ->execute();
    if (count($results) === 1) {
      $id = reset($results);
      $name = $entity_type_id . ':' . $id;
      if ($langcode) {
        $name .= ':' . $langcode;
      }
      $delete_content[] = $name;
    }
  }
  if (!$this
    ->deleteContent($delete_content, $options['entity-count'], $options['process-count'])) {
    return 1;
  }
  $this
    ->prepareConfigForImport();
  if (!$this
    ->runCommand($this->executable . " config:import --partial -y", NULL, NULL)) {
    return 1;
  }
  $chunked_names = $this->importer
    ->getChunkedNames();
  foreach ($chunked_names as $i => $chunk) {
    foreach ($chunk as $j => $name) {
      if (!in_array($name, $change_list['modified'], TRUE) && !in_array($name, $change_list['added'], TRUE)) {
        unset($chunked_names[$i][$j]);
      }
    }
    $chunked_names[$i] = array_values($chunked_names[$i]);
  }
  if (!$this
    ->importChunks($chunked_names, $options['entity-count'], $options['process-count'])) {
    return 1;
  }
  $this->importer
    ->importFiles();
  if (!$this
    ->runCommand($this->executable . " tome:import-complete")) {
    return 1;
  }
  $this->state
    ->set(ImporterInterface::STATE_KEY_IMPORTING, FALSE);
  $this
    ->io()
    ->success('Imported config, content, and files.');
}