Implements hook_cron().
Queues news feeds for updates once their refresh interval has elapsed.
function aggregator_cron() {
$result = db_query('SELECT fid FROM {aggregator_feed} WHERE queued = 0 AND checked + refresh < :time AND refresh <> :never', array(
':time' => REQUEST_TIME,
':never' => AGGREGATOR_CLEAR_NEVER,
));
$queue = Drupal::queue('aggregator_feeds');
foreach ($result
->fetchCol() as $fid) {
$feed = aggregator_feed_load($fid);
if ($queue
->createItem($feed)) {
// Add timestamp to avoid queueing item more than once.
$feed->queued->value = REQUEST_TIME;
$feed
->save();
}
}
// Remove queued timestamp after 6 hours assuming the update has failed.
db_update('aggregator_feed')
->fields(array(
'queued' => 0,
))
->condition('queued', REQUEST_TIME - 3600 * 6, '<')
->execute();
}