public function ChangesNormalizer::normalize in Replication 8.2
Same name and namespace in other branches
- 8 src/Normalizer/ChangesNormalizer.php \Drupal\replication\Normalizer\ChangesNormalizer::normalize()
File
- src/
Normalizer/ ChangesNormalizer.php, line 14
Class
Namespace
Drupal\replication\NormalizerCode
public function normalize($changes, $format = NULL, array $context = []) {
/** @var \Drupal\replication\Changes\ChangesInterface $changes */
if (isset($context['query']['filter'])) {
$changes
->filter($context['query']['filter']);
}
if (isset($context['query']['parameters'])) {
$changes
->parameters($context['query']['parameters']);
}
if (isset($context['query']['limit'])) {
$changes
->setLimit($context['query']['limit']);
}
$since = isset($context['query']['since']) && is_numeric($context['query']['since']) ? $context['query']['since'] : 0;
$changes
->setSince($since);
$results = $changes
->getNormal();
$last_result = end($results);
$last_seq = isset($last_result['seq']) ? $last_result['seq'] : 0;
return [
'last_seq' => $last_seq,
'results' => $results,
];
}