public function FeedsBatchBatch::run in Feeds 8.3

Runs the batch.

Return value

$this An instance of this class.

Overrides FeedsBatchInterface::run

File

src/FeedsBatchBatch.php, line 27

Class

FeedsBatchBatch

A batch task for the batch API.

Namespace

Drupal\feeds

Code

public function run() {
  $batch = [
    'title' => '',
    'operations' => [],
  ];
  foreach ($this->operations as $operation) {
    $batch['operations'][] = [
      [
        $this->executable,
        'processItem',
      ],
      [
        $this->feed,
        $operation['stage'],
        $operation['params'],
      ],
    ];
  }
  switch ($this->stage) {
    case FeedsExecutableInterface::FETCH:
      $batch['title'] = $this
        ->t('Fetching: %title', [
        '%title' => $this->feed
          ->label(),
      ]);
      $batch['error_message'] = $this
        ->t('An error occurred while fetching %title.', [
        '%title' => $this->feed
          ->label(),
      ]);
      break;
    case FeedsExecutableInterface::PARSE:
      $batch['title'] = $this
        ->t('Parsing: %title', [
        '%title' => $this->feed
          ->label(),
      ]);
      $batch['error_message'] = $this
        ->t('An error occurred while parsing %title.', [
        '%title' => $this->feed
          ->label(),
      ]);
      break;
    case FeedsExecutableInterface::PROCESS:
      $batch['title'] = $this
        ->t('Processing: %title', [
        '%title' => $this->feed
          ->label(),
      ]);
      $batch['error_message'] = $this
        ->t('An error occurred while processing %title.', [
        '%title' => $this->feed
          ->label(),
      ]);
      break;
    case FeedsExecutableInterface::CLEAN:
      $batch['title'] = $this
        ->t('Cleaning: %title', [
        '%title' => $this->feed
          ->label(),
      ]);
      $batch['error_message'] = $this
        ->t('An error occurred while cleaning %title.', [
        '%title' => $this->feed
          ->label(),
      ]);
      break;
  }
  $batch += [
    'init_message' => $batch['title'],
    'progress_message' => $batch['title'],
  ];
  $this
    ->batchSet($batch);
  return $this;
}