public function FeedsSchedulerTestCase::testScheduling in Feeds 7

Same name and namespace in other branches
6 tests/feeds_scheduler.test \FeedsSchedulerTestCase::testScheduling()
7.2 tests/feeds_scheduler.test \FeedsSchedulerTestCase::testScheduling()
Test scheduling on cron.
File

tests/feeds_scheduler.test, line 68: Feeds tests.
Class

FeedsSchedulerTestCase: Test cron scheduling.
Code

public function testScheduling() {

  // Create 10 feed nodes. Turn off import on create before doing that.
  $edit = array(
    'import_on_create' => FALSE,
  );
  $this
    ->drupalPost('admin/structure/feeds/edit/syndication/settings', $edit, 'Save');
  $this
    ->assertText('Do not import on create');
  $nids = $this
    ->createFeedNodes();

  // This implicitly tests the import_on_create node setting being 0.
  $this
    ->assertTrue($nids[0] == 1 && $nids[1] == 2, 'Node ids sequential.');

  // Check whether feed got properly added to scheduler.
  foreach ($nids as $nid) {
    $this
      ->assertEqual(1, db_query("SELECT COUNT(*) FROM {job_schedule} WHERE type = 'syndication' AND id = :nid AND callback = 'feeds_source_import' AND last <> 0 AND scheduled = 0 AND period = 1800 AND periodic = 1", array(
      ':nid' => $nid,
    ))
      ->fetchField());
  }

  // Take time for comparisons.
  $time = time();
  sleep(1);

  // Log out and run cron, no changes.
  $this
    ->drupalLogout();
  $this
    ->runCron();
  $count = db_query("SELECT COUNT(*) FROM {job_schedule} WHERE last > :time", array(
    ':time' => $time,
  ))
    ->fetchField();
  $this
    ->assertEqual($count, 0, '0 feeds refreshed on cron.');

  // Set next time to 0 to simulate updates.
  // There should be 2 x job_schedule_num (= 10) feeds updated now.
  db_query("UPDATE {job_schedule} SET next = 0");
  $this
    ->runCron();
  $this
    ->runCron();
  $schedule = array();
  $count = db_query("SELECT COUNT(*) FROM {job_schedule} WHERE last > :time", array(
    ':time' => $time,
  ))
    ->fetchField();
  $this
    ->assertEqual($count, 10, '10 feeds refreshed on cron.');
  $result = db_query("SELECT * FROM {job_schedule}", $time);

  // There should be 100 article nodes in the database.
  $count = db_query("SELECT COUNT(*) FROM {node} WHERE type = 'article'")
    ->fetchField();
  $this
    ->assertEqual($count, 100, 'There are 100 article nodes aggregated.');

  // Hit twice cron again.
  $this
    ->runCron();
  $this
    ->runCron();

  // There should be feeds_schedule_num X 2 (= 20) feeds updated now.
  $schedule = array();
  $rows = db_query("SELECT id, last, scheduled FROM {job_schedule} WHERE last > :time", array(
    ':time' => $time,
  ));
  foreach ($rows as $row) {
    $schedule[$row->id] = $row;
  }
  $this
    ->assertEqual(count($schedule), 20, '20 feeds refreshed on cron.');

  // There should be 200 article nodes in the database.
  $count = db_query("SELECT COUNT(*) FROM {node} WHERE type = 'article' AND status = 1")
    ->fetchField();
  $this
    ->assertEqual($count, 200, 'There are 200 article nodes aggregated.');

  // There shouldn't be any items with scheduled = 1 now, if so, this would
  // mean they are stuck.
  $count = db_query("SELECT COUNT(*) FROM {job_schedule} WHERE scheduled = 1")
    ->fetchField();
  $this
    ->assertEqual($count, 0, 'All items are unscheduled (schedule flag = 0).');

  // Hit cron again twice.
  $this
    ->runCron();
  $this
    ->runCron();

  // The import_period setting of the feed configuration is 1800, there
  // shouldn't be any change to the database now.
  $equal = TRUE;
  $rows = db_query("SELECT id, last, scheduled FROM {job_schedule} WHERE last > :time", array(
    ':time' => $time,
  ));
  foreach ($rows as $row) {
    $equal = $equal && $row->last == $schedule[$row->id]->last;
  }
  $this
    ->assertTrue($equal, 'Schedule did not change.');

  // Log back in and set refreshing to as often as possible.
  $this
    ->loginAdmin();
  $edit = array(
    'import_period' => 0,
  );
  $this
    ->drupalPost('admin/structure/feeds/edit/syndication/settings', $edit, 'Save');
  $this
    ->assertText('Refresh: as often as possible');
  $this
    ->drupalLogout();

  // Hit cron once, this should cause Feeds to reschedule all entries.
  $this
    ->runCron();
  $equal = FALSE;
  $rows = db_query("SELECT id, last, scheduled FROM {job_schedule} WHERE last > :time", array(
    ':time' => $time,
  ));
  foreach ($rows as $row) {
    $equal = $equal && $row->last == $schedule[$row->id]->last;
    $schedule[$row->id] = $row;
  }
  $this
    ->assertFalse($equal, 'Every feed schedule time changed.');

  // Hit cron again, 4 times now, every item should change again.
  for ($i = 0; $i < 4; $i++) {
    $this
      ->runCron();
  }
  $equal = FALSE;
  $rows = db_query("SELECT id, last, scheduled FROM {job_schedule} WHERE last > :time", array(
    ':time' => $time,
  ));
  foreach ($rows as $row) {
    $equal = $equal && $row->last == $schedule[$row->id]->last;
  }
  $this
    ->assertFalse($equal, 'Every feed schedule time changed.');

  // There should be 200 article nodes in the database.
  $count = db_query("SELECT COUNT(*) FROM {node} WHERE type = 'article' AND status = 1")
    ->fetchField();
  $this
    ->assertEqual($count, 200, 'The total of 200 article nodes has not changed.');

  // Set expire settings, check rescheduling.
  $max_last = db_query("SELECT MAX(last) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_source_import' AND period = 0")
    ->fetchField();
  $min_last = db_query("SELECT MIN(last) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_source_import' AND period = 0")
    ->fetchField();
  $this
    ->assertEqual(0, db_query("SELECT COUNT(*) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_importer_expire' AND last <> 0 AND scheduled = 0")
    ->fetchField());
  $this
    ->loginAdmin();
  $this
    ->setSettings('syndication', 'FeedsNodeProcessor', array(
    'expire' => 86400,
  ));
  $this
    ->drupalLogout();
  sleep(1);
  $this
    ->runCron();

  // There should be a feeds_importer_expire callback now, and all last fields should be reset.
  $this
    ->assertEqual(1, db_query("SELECT COUNT(*) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_importer_expire' AND last <> 0 AND scheduled = 0 AND period = 3600")
    ->fetchField());
  $new_max_last = db_query("SELECT MAX(last) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_source_import' AND period = 0")
    ->fetchField();
  $new_min_last = db_query("SELECT MIN(last) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_source_import' AND period = 0")
    ->fetchField();
  $this
    ->assertNotEqual($new_max_last, $max_last);
  $this
    ->assertNotEqual($new_min_last, $min_last);
  $this
    ->assertEqual($new_max_last, $new_min_last);
  $max_last = $new_max_last;
  $min_last = $new_min_last;

  // Set import settings, check rescheduling.
  $this
    ->loginAdmin();
  $this
    ->setSettings('syndication', '', array(
    'import_period' => 3600,
  ));
  $this
    ->drupalLogout();
  sleep(1);
  $this
    ->runCron();
  $new_max_last = db_query("SELECT MAX(last) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_source_import' AND period = 3600")
    ->fetchField();
  $new_min_last = db_query("SELECT MIN(last) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_source_import' AND period = 3600")
    ->fetchField();
  $this
    ->assertNotEqual($new_max_last, $max_last);
  $this
    ->assertNotEqual($new_min_last, $min_last);
  $this
    ->assertEqual($new_max_last, $new_min_last);
  $this
    ->assertEqual(0, db_query("SELECT COUNT(*) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_source_import' AND period <> 3600")
    ->fetchField());
  $this
    ->assertEqual(1, db_query("SELECT COUNT(*) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_importer_expire' AND period = 3600 AND last = :last", array(
    ':last' => $new_min_last,
  ))
    ->fetchField());

  // Delete source, delete importer, check schedule.
  $this
    ->loginAdmin();
  $nid = array_shift($nids);
  $this
    ->drupalPost("node/{$nid}/delete", array(), t('Delete'));
  $this
    ->assertEqual(0, db_query("SELECT COUNT(*) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_source_import' AND id = :nid", array(
    ':nid' => $nid,
  ))
    ->fetchField());
  $this
    ->assertEqual(count($nids), db_query("SELECT COUNT(*) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_source_import'")
    ->fetchField());
  $this
    ->assertEqual(1, db_query("SELECT COUNT(*) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_importer_expire' AND id = 0")
    ->fetchField());
  $this
    ->drupalPost('admin/structure/feeds/delete/syndication', array(), t('Delete'));
  $this
    ->assertEqual(0, db_query("SELECT COUNT(*) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_importer_expire' AND id = 0")
    ->fetchField());
  $this
    ->assertEqual(count($nids), db_query("SELECT COUNT(*) FROM {job_schedule} WHERE type = 'syndication' AND callback = 'feeds_source_import'")
    ->fetchField());
}
You are here

public function FeedsSchedulerTestCase::testScheduling in Feeds 7

File

Class

Code

API Navigation
