feeds_processor_term.test 11.70 KiB
<?php
/**
* @file
* Tests for plugins/FeedsTermProcessor.inc
*/
/**
* Test aggregating a feed as data records.
*/
class FeedsCSVtoTermsTest extends FeedsWebTestCase {
public static function getInfo() {
return array(
'name' => 'Processor: Taxonomy',
'description' => 'Tests a standalone import configuration that uses file fetcher and CSV parser to import taxonomy terms from a CSV file.',
'group' => 'Feeds',
);
}
/**
* Set up test.
*/
public function setUp() {
parent::setUp();
// Create an importer.
$this->createImporterConfiguration('Term import', 'term_import');
// Set and configure plugins and mappings.
$this->setPlugin('term_import', 'FeedsFileFetcher');
$this->setPlugin('term_import', 'FeedsCSVParser');
$this->setPlugin('term_import', 'FeedsTermProcessor');
// Create vocabulary.
$edit = array(
'name' => 'Addams vocabulary',
'machine_name' => 'addams',
);
$this->drupalPost('admin/structure/taxonomy/add', $edit, t('Save'));
$this->setSettings('term_import', 'FeedsTermProcessor', array('bundle' => 'addams'));
// Use standalone form.
$this->setSettings('term_import', NULL, array('content_type' => ''));
}
/**
* Test term creation, refreshing/deleting feeds and feed items.
*/
public function test() {
$mappings = array(
0 => array(
'source' => 'name',
'target' => 'name',
'unique' => 1,
),
);
$this->addMappings('term_import', $mappings);
// Import and assert.
$this->importFile('term_import', $this->absolutePath() . '/tests/feeds/users.csv');
$this->assertText('Created 5 terms');
$this->drupalGet('admin/structure/taxonomy/addams');
$this->assertText('Morticia');
$this->assertText('Fester');
$this->assertText('Gomez');
$this->assertText('Pugsley');
// Import again. $this->importFile('term_import', $this->absolutePath() . '/tests/feeds/users.csv');
$this->assertText('There are no new terms.');
// Force update.
$this->setSettings('term_import', 'FeedsTermProcessor', array(
'skip_hash_check' => TRUE,
'update_existing' => 2,
));
$this->importFile('term_import', $this->absolutePath() . '/tests/feeds/users.csv');
$this->assertText('Updated 5 terms.');
// Add a term manually, delete all terms, this term should still stand.
$edit = array(
'name' => 'Cousin Itt',
);
$this->drupalPost('admin/structure/taxonomy/addams/add', $edit, t('Save'));
$this->drupalPost('import/term_import/delete-items', array(), t('Delete'));
$this->drupalGet('admin/structure/taxonomy/addams');
$this->assertText('Cousin Itt');
$this->assertNoText('Morticia');
$this->assertNoText('Fester');
$this->assertNoText('Gomez');
$this->assertNoText('Pugsley');
}
/**
* Test that saving an invalid vocabulary throws an exception.
*/
public function testInvalidVocabulary() {
$mappings = array(
0 => array(
'source' => 'name',
'target' => 'name',
'unique' => 1,
),
);
$this->addMappings('term_import', $mappings);
// Force configuration to be invalid.
$config = unserialize(db_query("SELECT config FROM {feeds_importer} WHERE id = :id", array(':id' => 'term_import'))->fetchField());
$config['processor']['config']['bundle'] = 'does_not_exist';
db_update('feeds_importer')
->fields(array('config' => serialize($config)))
->condition('id', 'term_import')
->execute();
// Import and assert.
$this->importFile('term_import', $this->absolutePath() . '/tests/feeds/users.csv');
$this->assertText(t('No vocabulary defined for Taxonomy Term processor.'));
}
/**
* Tests that terms mapped to their parent by GUID are from the same vocabulary.
*/
public function testParentTargetByGUID() {
// Create an other vocabulary.
$vocabulary1 = 'addams';
$vocabulary2 = strtolower($this->randomName());
$edit = array(
'name' => $this->randomString(),
'machine_name' => $vocabulary2,
);
$this->drupalPost('admin/structure/taxonomy/add', $edit, t('Save'));
// Add mappings for the first importer.
$this->addMappings('term_import',
array(
0 => array(
'source' => 'guid', 'target' => 'guid',
'unique' => TRUE,
),
1 => array(
'source' => 'name',
'target' => 'name',
),
2 => array(
'source' => 'parentguid',
'target' => 'parentguid',
),
)
);
// Create a second importer.
$this->createImporterConfiguration('Term import 2', 'term_import2');
$this->setSettings('term_import2', NULL, array('content_type' => ''));
// Set and configure plugins and mappings.
$this->setPlugin('term_import2', 'FeedsFileFetcher');
$this->setPlugin('term_import2', 'FeedsCSVParser');
$this->setPlugin('term_import2', 'FeedsTermProcessor');
$this->setSettings('term_import2', 'FeedsTermProcessor', array('bundle' => $vocabulary2));
// Add mappings for the second importer.
$this->addMappings('term_import2',
array(
0 => array(
'source' => 'guid',
'target' => 'guid',
'unique' => TRUE,
),
1 => array(
'source' => 'name',
'target' => 'name',
),
2 => array(
'source' => 'parentguid',
'target' => 'parentguid',
),
)
);
$values = array(
1 => 'Europe',
2 => 'Belgium',
);
// Import file using the first importer.
$this->importFile('term_import', $this->absolutePath() . '/tests/feeds/terms.csv');
$this->assertText('Created 2 terms.');
// Assert that two terms were created in the first vocabulary.
$terms = entity_load('taxonomy_term', array_keys($values));
foreach ($terms as $tid => $term) {
$this->assertEqual($values[$tid], $term->name);
$this->assertEqual($vocabulary1, $term->vocabulary_machine_name);
}
// Assert that the second term's parent is the first term.
$parents = taxonomy_get_parents($terms[2]->tid);
$message = format_string('The term @term is correctly linked to its parent.', array('@term' => $terms[2]->name));
if (!empty($parents)) {
$parent = current($parents);
$this->assertEqual(1, $parent->tid, $message);
}
else {
$this->fail($message);
}
$values = array( 3 => 'Europe',
4 => 'Belgium',
);
// Now import the file using the second importer.
$this->importFile('term_import2', $this->absolutePath() . '/tests/feeds/terms.csv');
$this->assertText('Created 2 terms.');
// Assert that two terms were created in the second vocabulary.
$terms = entity_load('taxonomy_term', array_keys($values));
foreach ($terms as $tid => $term) {
$this->assertEqual($values[$tid], $term->name);
$this->assertEqual($vocabulary2, $term->vocabulary_machine_name);
}
// Assert that the second term's parent is the first term.
$parents = taxonomy_get_parents($terms[4]->tid);
$message = format_string('The term @term is correctly linked to its parent.', array('@term' => $terms[4]->name));
if (!empty($parents)) {
$parent = current($parents);
$this->assertEqual(3, $parent->tid, $message);
}
else {
$this->fail($message);
}
}
/**
* Tests that terms mapped to their parent by GUID are from the same vocabulary.
*/
public function testParentTargetByName() {
// Create an other vocabulary.
$vocabulary1 = 'addams';
$vocabulary2 = strtolower($this->randomName());
$edit = array(
'name' => $this->randomString(),
'machine_name' => $vocabulary2,
);
$this->drupalPost('admin/structure/taxonomy/add', $edit, t('Save'));
// Add mappings for the first importer.
$this->addMappings('term_import',
array(
0 => array(
'source' => 'guid',
'target' => 'guid',
'unique' => TRUE,
),
1 => array(
'source' => 'name',
'target' => 'name',
),
2 => array(
'source' => 'parent',
'target' => 'parent',
),
)
);
// Create a second importer.
$this->createImporterConfiguration('Term import 2', 'term_import2');
$this->setSettings('term_import2', NULL, array('content_type' => ''));
// Set and configure plugins and mappings.
$this->setPlugin('term_import2', 'FeedsFileFetcher');
$this->setPlugin('term_import2', 'FeedsCSVParser');
$this->setPlugin('term_import2', 'FeedsTermProcessor');
$this->setSettings('term_import2', 'FeedsTermProcessor', array('bundle' => $vocabulary2));
// Add mappings for the second importer.
$this->addMappings('term_import2', array(
0 => array(
'source' => 'guid',
'target' => 'guid',
'unique' => TRUE,
),
1 => array(
'source' => 'name',
'target' => 'name',
),
2 => array(
'source' => 'parent',
'target' => 'parent',
),
)
);
$values = array(
1 => 'Europe',
2 => 'Belgium',
);
// Import file using the first importer.
$this->importFile('term_import', $this->absolutePath() . '/tests/feeds/terms.csv');
$this->assertText('Created 2 terms.');
// Assert that two terms were created in the first vocabulary.
$terms = entity_load('taxonomy_term', array_keys($values));
foreach ($terms as $tid => $term) {
$this->assertEqual($values[$tid], $term->name);
$this->assertEqual($vocabulary1, $term->vocabulary_machine_name);
}
// Assert that the second term's parent is the first term.
$parents = taxonomy_get_parents($terms[2]->tid);
$message = format_string('The term @term is correctly linked to its parent.', array('@term' => $terms[2]->name));
if (!empty($parents)) {
$parent = current($parents);
$this->assertEqual(1, $parent->tid, $message);
}
else {
$this->fail($message);
}
$values = array(
3 => 'Europe',
4 => 'Belgium',
);
// Now import the file using the second importer.
$this->importFile('term_import2', $this->absolutePath() . '/tests/feeds/terms.csv');
$this->assertText('Created 2 terms.');
// Assert that two terms were created in the second vocabulary.
$terms = entity_load('taxonomy_term', array_keys($values));
foreach ($terms as $tid => $term) {
$this->assertEqual($values[$tid], $term->name);
$this->assertEqual($vocabulary2, $term->vocabulary_machine_name);
}
// Assert that the second term's parent is the first term.
$parents = taxonomy_get_parents($terms[4]->tid);
$message = format_string('The term @term is correctly linked to its parent.', array('@term' => $terms[4]->name));
if (!empty($parents)) {
$parent = current($parents);
$this->assertEqual(3, $parent->tid, $message);
}
else {
$this->fail($message);
}
}
/**
* Test replacing terms on subsequent imports.
*/
public function testReplaceTerms() {
$mappings = array(
0 => array(
'source' => 'name',
'target' => 'name',
'unique' => 1,
),
);
$this->addMappings('term_import', $mappings);
// Configure the processor to "Replace existing terms".
$this->setSettings('term_import', 'FeedsTermProcessor', array(
'skip_hash_check' => TRUE,
'update_existing' => 1,
));
// Import first time.
$this->importFile('term_import', $this->absolutePath() . '/tests/feeds/users.csv');
$this->assertText('Created 5 terms');
// Import again to replace terms.
$this->importFile('term_import', $this->absolutePath() . '/tests/feeds/users.csv');
$this->assertText('Updated 5 terms.');
}
}