// Create feed and test basic updating on cron.
$this->createSampleNodes();
$feed = $this->createFeed();
+ $count_query = \Drupal::entityQuery('aggregator_item')->condition('fid', $feed->id())->count();
+
$this->cronRun();
- $this->assertEqual(5, db_query('SELECT COUNT(*) FROM {aggregator_item} WHERE fid = :fid', [':fid' => $feed->id()])->fetchField());
+ $this->assertEqual(5, $count_query->execute());
$this->deleteFeedItems($feed);
- $this->assertEqual(0, db_query('SELECT COUNT(*) FROM {aggregator_item} WHERE fid = :fid', [':fid' => $feed->id()])->fetchField());
+ $this->assertEqual(0, $count_query->execute());
$this->cronRun();
- $this->assertEqual(5, db_query('SELECT COUNT(*) FROM {aggregator_item} WHERE fid = :fid', [':fid' => $feed->id()])->fetchField());
+ $this->assertEqual(5, $count_query->execute());
// Test feed locking when queued for update.
$this->deleteFeedItems($feed);
- db_update('aggregator_feed')
- ->condition('fid', $feed->id())
- ->fields([
- 'queued' => REQUEST_TIME,
- ])
- ->execute();
+ $feed->setQueuedTime(REQUEST_TIME)->save();
$this->cronRun();
- $this->assertEqual(0, db_query('SELECT COUNT(*) FROM {aggregator_item} WHERE fid = :fid', [':fid' => $feed->id()])->fetchField());
- db_update('aggregator_feed')
- ->condition('fid', $feed->id())
- ->fields([
- 'queued' => 0,
- ])
- ->execute();
+ $this->assertEqual(0, $count_query->execute());
+ $feed->setQueuedTime(0)->save();
$this->cronRun();
- $this->assertEqual(5, db_query('SELECT COUNT(*) FROM {aggregator_item} WHERE fid = :fid', [':fid' => $feed->id()])->fetchField());
+ $this->assertEqual(5, $count_query->execute());
}
}