You are here

public function SkipOnValue::process in Migrate Plus 8.4

Same name and namespace in other branches
  1. 8.5 src/Plugin/migrate/process/SkipOnValue.php \Drupal\migrate_plus\Plugin\migrate\process\SkipOnValue::process()
  2. 8.2 src/Plugin/migrate/process/SkipOnValue.php \Drupal\migrate_plus\Plugin\migrate\process\SkipOnValue::process()
  3. 8.3 src/Plugin/migrate/process/SkipOnValue.php \Drupal\migrate_plus\Plugin\migrate\process\SkipOnValue::process()

File

src/Plugin/migrate/process/SkipOnValue.php, line 91

Class

SkipOnValue
If the source evaluates to a configured value, skip processing or whole row.

Namespace

Drupal\migrate_plus\Plugin\migrate\process

Code

public function process($value, MigrateExecutableInterface $migrate_executable, Row $row, $destination_property) {
  if (empty($this->configuration['value']) && !array_key_exists('value', $this->configuration)) {
    throw new MigrateException('Skip on value plugin is missing value configuration.');
  }
  if (is_array($this->configuration['value'])) {
    $value_in_array = FALSE;
    $not_equals = isset($this->configuration['not_equals']);
    foreach ($this->configuration['value'] as $skipValue) {
      $value_in_array |= $this
        ->compareValue($value, $skipValue);
    }
    if ($not_equals && !$value_in_array || !$not_equals && $value_in_array) {
      throw new MigrateSkipProcessException();
    }
  }
  elseif ($this
    ->compareValue($value, $this->configuration['value'], !isset($this->configuration['not_equals']))) {
    throw new MigrateSkipProcessException();
  }
  return $value;
}