$criteria =
new SearchCriteria($backlog['entity'
]);
$repository =
$registry->
getRepository($criteria);
if (!
$repository instanceof EsAwareRepository
) { continue;
} $output->
writeln(sprintf('Sync %s with id %s',
$backlog['entity'
],
$backlog['entity_id'
]));
if ($backlog['entity'
] === Article::
class) { $this->
indexArticle($backlog['entity_id'
]);
} else { $index =
$this->
getIndexName($repository->
getDomainName());
$indexer->
indexEntities($index,
$repository,
[$backlog['entity_id'
]]);
} } $ids =
array_column($backlogs, 'id'
);
$backlogService->
cleanup($ids);
return 0;
}