pluginManager = $manager; foreach ($manager->getAvailableImportPlugins() as $id => $definition) { $this->availablePlugins[$id] = $manager->createInstance($id); } } /** * {@inheritdoc} */ public static function create(ContainerInterface $container) { return new static( $container->get('plugin.manager.search_api_synonym.import') ); } /** * {@inheritdoc} */ public function getFormId() { return 'search_api_synonym_import'; } /** * {@inheritdoc} */ public function buildForm(array $form, FormStateInterface $form_state) { // File. $form['file_upload'] = [ '#type' => 'file', '#title' => $this->t('File'), '#description' => $this->t('Select the import file.'), '#required' => FALSE, ]; // Update $form['update_existing'] = [ '#type' => 'radios', '#title' => $this->t('Update existing'), '#description' => $this->t('What should happen with existing synonyms?'), '#options' => [ 'merge' => $this->t('Merge'), 'overwrite' => $this->t('Overwrite') ], '#default_value' => 'merge', '#required' => TRUE, ]; // Synonym type. $form['synonym_type'] = [ '#type' => 'radios', '#title' => $this->t('Type '), '#description' => $this->t('Which synonym type should the imported data be saved as?'), '#options' => [ 'synonym' => $this->t('Synonym'), 'spelling_error' => $this->t('Spelling error'), 'mixed' => $this->t('Mixed - Controlled by information in the source file') ], '#default_value' => 'synonym', '#required' => TRUE, ]; $message = $this->t('Notice: the source file must contain information per synonym about the synonym type. All synonyms without type information will be skipped during import!'); $message = Markup::create('

' . $message . '

'); $form['synonym_type_notice'] = [ '#type' => 'item', '#markup' => $message, '#states' => [ 'visible' => [ ':radio[name="synonym_type"]' => ['value' => 'mixed'], ], ], ]; // Activate. $form['status'] = [ '#type' => 'checkbox', '#title' => $this->t('Activate synonyms'), '#description' => $this->t('Mark import synonyms as active. Only active synonyms will be exported to the configured search backend.'), '#default_value' => TRUE, '#required' => TRUE, ]; // Language code. $form['langcode'] = [ '#type' => 'language_select', '#title' => $this->t('Language'), '#description' => $this->t('Which language should the imported data be saved as?'), '#default_value' => \Drupal::languageManager()->getCurrentLanguage()->getId(), ]; // Import plugin configuration. $form['plugin'] = [ '#type' => 'radios', '#title' => $this->t('Import format'), '#description' => $this->t('Choose the import format to use.'), '#options' => [], '#default_value' => key($this->availablePlugins), '#required' => TRUE, ]; $form['plugin_settings'] = [ '#tree' => TRUE, ]; foreach ($this->availablePlugins as $id => $instance) { $definition = $instance->getPluginDefinition(); $form['plugin']['#options'][$id] = $definition['label']; $form['plugin_settings'][$id] = [ '#type' => 'details', '#title' => $this->t('@plugin plugin', ['@plugin' => $definition['label']]), '#open' => TRUE, '#tree' => TRUE, '#states' => [ 'visible' => [ ':radio[name="plugin"]' => ['value' => $id], ], ], ]; $form['plugin_settings'][$id] += $instance->buildConfigurationForm([], $form_state); } // Actions. $form['actions']['submit'] = [ '#type' => 'submit', '#value' => $this->t('Import file'), '#button_type' => 'primary', ]; return $form; } /** * {@inheritdoc} */ public function validateForm(array &$form, FormStateInterface $form_state) { parent::validateForm($form, $form_state); $values = $form_state->getValues(); // Get plugin instance for active plugin. $instance_active = $this->getPluginInstance($values['plugin']); // Validate the uploaded file. $extensions = $instance_active->allowedExtensions(); $validators = ['file_validate_extensions' => $extensions]; $file = file_save_upload('file_upload', $validators, FALSE, 0, FILE_EXISTS_RENAME); if (isset($file)) { if ($file) { $form_state->setValue('file_upload', $file); } else { $form_state->setErrorByName('file_upload', $this->t('The import file could not be uploaded.')); } } // Call the form validation handler for each of the plugins. foreach ($this->availablePlugins as $instance) { $instance->validateConfigurationForm($form, $form_state); } } /** * {@inheritdoc} */ public function submitForm(array &$form, FormStateInterface $form_state) { try { // All values from the form. $values = $form_state->getValues(); // Instance of active import plugin. $plugin_id = $values['plugin']; $instance = $this->getPluginInstance($plugin_id); // Parse file. $data = $instance->parseFile($values['file_upload'], (array) $values['plugin_settings'][$plugin_id]); // Import data. $importer = new Importer(); $results = $importer->execute($data, $values); if (!empty($results['errors'])) { $count = count($results['errors']); $message = \Drupal::translation()->formatPlural($count, '@count synonym failed import.', '@count synonyms failed import.', ['@count' => $count] ); drupal_set_message($message); } } catch (ImportException $e) { $this->logger('search_api_synonym')->error($this->t('Failed to import file due to "%error".', ['%error' => $e->getMessage()])); drupal_set_message($this->t('Failed to import file due to "%error".', ['%error' => $e->getMessage()])); } } /** * Returns an import plugin instance for a given plugin id. * * @param string $plugin_id * The plugin_id for the plugin instance. * * @return \Drupal\search_api_synonym\Import\ImportPluginInterface * An import plugin instance. */ public function getPluginInstance($plugin_id) { return $this->pluginManager->createInstance($plugin_id, []); } }