<?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.');
  }

}