<?php

declare(strict_types=1);

namespace Drupal\migrate_tools\Form;

use Drupal\Component\Datetime\TimeInterface;
use Drupal\Core\Form\FormBase;
use Drupal\Core\Form\FormStateInterface;
use Drupal\Core\KeyValueStore\KeyValueFactoryInterface;
use Drupal\Core\StringTranslation\TranslationInterface;
use Drupal\migrate\MigrateMessage;
use Drupal\migrate\Plugin\MigrationInterface;
use Drupal\migrate\Plugin\MigrationPluginManagerInterface;
use Drupal\migrate_tools\MigrateBatchExecutable;
use Drupal\migrate_tools\MigrateTools;
use Symfony\Component\DependencyInjection\ContainerInterface;

/**
 * This form is specifically for configuring process pipelines.
 *
 * @phpstan-consistent-constructor
 */
class MigrationExecuteForm extends FormBase {

  public function __construct(
    protected MigrationPluginManagerInterface $migrationPluginManager,
    protected $routeMatch,
    protected KeyValueFactoryInterface $keyValue,
    protected TimeInterface $time,
    protected TranslationInterface $translation,
  ) {}

  /**
   * {@inheritdoc}
   */
  public static function create(ContainerInterface $container): static {
    return new static(
      $container->get('plugin.manager.migration'),
      $container->get('current_route_match'),
      $container->get('keyvalue'),
      $container->get('datetime.time'),
      $container->get('string_translation'),
    );
  }

  /**
   * {@inheritdoc}
   */
  public function getFormId(): string {
    return 'migration_execute_form';
  }

  /**
   * {@inheritdoc}
   */
  public function buildForm(array $form, FormStateInterface $form_state): array {
    $form = $form ?: [];

    /** @var \Drupal\migrate_plus\Entity\MigrationInterface $migration */
    $migration = $this->getRouteMatch()->getParameter('migration');
    $form['#title'] = $this->t('Execute migration %label', ['%label' => $migration->label()]);

    $form = $this->buildFormOperations($form, $form_state);
    $form = $this->buildFormOptions($form, $form_state);

    $form['submit'] = [
      '#type' => 'submit',
      '#value' => $this->t('Execute'),
    ];

    return $form;
  }

  /**
   * Build the operation form field.
   *
   * @param array $form
   *   The execution form.
   * @param \Drupal\Core\Form\FormStateInterface $form_state
   *   The form state.
   *
   * @return array
   *   The execution form updated with the operations.
   */
  protected function buildFormOperations(array $form, FormStateInterface $form_state): array {
    // Build the migration execution form.
    $options = [
      'import' => $this->t('Import'),
      'rollback' => $this->t('Rollback'),
      'stop' => $this->t('Stop'),
      'reset' => $this->t('Reset'),
    ];

    $form['operation'] = [
      '#type' => 'radios',
      '#title' => $this->t('Operation'),
      '#description' => $this->t('Choose an operation to run.'),
      '#options' => $options,
      '#default_value' => 'import',
      '#required' => TRUE,
      'import' => [
        '#description' => $this->t('Imports all previously unprocessed records from the source, plus any records marked for update, into destination Drupal objects.'),
      ],
      'rollback' => [
        '#description' => $this->t('Deletes all Drupal objects created by the import.'),
      ],
      'stop' => [
        '#description' => $this->t('Cleanly interrupts any import or rollback processes that may currently be running.'),
      ],
      'reset' => [
        '#description' => $this->t('Sometimes a process may fail to stop cleanly, and be left stuck in an Importing or Rolling Back status. Choose Reset to clear the status and permit other operations to proceed.'),
      ],
    ];

    return $form;
  }

  /**
   * Build the execution options form field.
   *
   * @param array $form
   *   The execution form.
   * @param \Drupal\Core\Form\FormStateInterface $form_state
   *   The form state.
   *
   * @return array
   *   The execution form updated with the execution options.
   */
  protected function buildFormOptions(array $form, FormStateInterface $form_state): array {
    $form['options'] = [
      '#type' => 'details',
      '#title' => $this->t('Additional execution options'),
      '#open' => FALSE,
    ];

    $form['options']['update'] = [
      '#type' => 'checkbox',
      '#title' => $this->t('Update'),
      '#description' => $this->t('Check this box to update all previously-imported content in addition to importing new content. Leave unchecked to only import new content'),
    ];

    $form['options']['force'] = [
      '#type' => 'checkbox',
      '#title' => $this->t('Ignore dependencies'),
      '#description' => $this->t('Check this box to ignore dependencies when running imports - all tasks will run whether or not their dependent tasks have completed.'),
    ];

    $form['options']['limit'] = [
      '#type' => 'number',
      '#title' => $this->t('Limit to:'),
      '#size' => 10,
      '#description' => $this->t('Set a limit of how many items to process for each migration task.'),
      '#min' => 1,
    ];

    $form['options']['idlist'] = [
      '#type' => 'textfield',
      '#title' => $this->t('ID List'),
      '#maxlength' => 255,
      '#size' => 60,
      '#pattern' => '^[0-9]+(' . MigrateTools::DEFAULT_ID_LIST_DELIMITER . '[0-9]+)?(,?[0-9]+(' . MigrateTools::DEFAULT_ID_LIST_DELIMITER . '[0-9]+)?)*$',
      '#description' => $this->t('Comma-separated list of IDs to process.'),
      '#states' => [
        'enabled' => [
          ':input[name="operation"]' => [
            ['value' => 'import'],
            'or',
            ['value' => 'rollback'],
          ],
        ],
      ],
    ];

    $form['options']['batch_size'] = [
      '#type' => 'number',
      '#title' => $this->t('Batch size:'),
      '#size' => 10,
      '#description' => $this->t('Set the number of items to process in each batch within a migration task.'),
    ];

    return $form;
  }

  /**
   * {@inheritdoc}
   */
  public function submitForm(array &$form, FormStateInterface $form_state): void {
    $migration = $this->getRouteMatch()->getParameter('migration');
    if ($migration) {
      $migration_id = $migration->id();
      /** @var \Drupal\migrate\Plugin\MigrationInterface $migration_plugin */
      $migration_plugin = $this->migrationPluginManager->createInstance($migration_id);
      $migrateMessage = new MigrateMessage();

      switch ($form_state->getValue('operation')) {
        case 'import':
          $executable = new MigrateBatchExecutable(
            $migration_plugin,
            $migrateMessage,
            $this->keyValue,
            $this->time,
            $this->translation,
            $this->migrationPluginManager,
            $this->buildOptions($form_state),
          );
          $executable->batchImport();
          break;

        case 'rollback':
          $executable = new MigrateBatchExecutable(
            $migration_plugin,
            $migrateMessage,
            $this->keyValue,
            $this->time,
            $this->translation,
            $this->migrationPluginManager,
            $this->buildOptions($form_state),
          );
          $status = $executable->rollback();
          if ($status === MigrationInterface::RESULT_COMPLETED) {
            $this->messenger()->addStatus($this->t('Rollback completed', ['@id' => $migration_id]));
          }
          else {
            $this->messenger()->addError($this->t('Rollback of @name migration failed.', ['@name' => $migration_id]));
          }
          break;

        case 'stop':
          $migration_plugin->interruptMigration(MigrationInterface::RESULT_STOPPED);
          $status = $migration_plugin->getStatus();
          switch ($status) {
            case MigrationInterface::STATUS_IDLE:
              $this->messenger()->addStatus($this->t('Migration @id is idle', ['@id' => $migration_id]));
              break;

            case MigrationInterface::STATUS_DISABLED:
              $this->messenger()->addWarning($this->t('Migration @id is disabled', ['@id' => $migration_id]));
              break;

            case MigrationInterface::STATUS_STOPPING:
              $this->messenger()->addWarning($this->t('Migration @id is already stopping', ['@id' => $migration_id]));
              break;

            default:
              $migration->interruptMigration(MigrationInterface::RESULT_STOPPED);
              $this->messenger()->addStatus($this->t('Migration @id requested to stop', ['@id' => $migration_id]));
              break;
          }
          break;

        case 'reset':
          $status = $migration_plugin->getStatus();
          if ($status === MigrationInterface::STATUS_IDLE) {
            $this->messenger()->addWarning($this->t('Migration @id is already Idle', ['@id' => $migration_id]));
          }
          else {
            $this->messenger()->addStatus($this->t('Migration @id reset to Idle', ['@id' => $migration_id]));
          }
          $migration_plugin->setStatus(MigrationInterface::STATUS_IDLE);
          break;
      }
    }
  }

  /**
   * Build migrate execute options from the submitted form values.
   *
   * @param \Drupal\Core\Form\FormStateInterface $form_state
   *   The form state.
   *
   * @return array
   *   Options array for the migrate execution.
   */
  protected function buildOptions(FormStateInterface $form_state) {
    $options = [
      'limit' => $form_state->getValue('limit') ?: 0,
      'update' => $form_state->getValue('update') ?: 0,
      'force' => $form_state->getValue('force') ?: 0,
      'batch-size' => $form_state->getValue('batch_size') ?: 0,
    ];

    if ($idlist = $form_state->getValue('idlist')) {
      $options['idlist'] = $idlist;
    }

    return $options;
  }

}