bridtv-8.x-1.x-dev/src/Batch/BridBatchSync.php

<?php

namespace Drupal\bridtv\Batch;

/**
 * Holds helper methods for UI-based batch operations.
 */
abstract class BridBatchSync {

  /**
   * Initialize function.
   */
  public static function init() {
    $batch = [
      'title' => t('Synchronizing Brid.TV media...'),
      'operations' => [
        ['\Drupal\bridtv\Batch\BridBatchSync::start', []],
        ['\Drupal\bridtv\Batch\BridBatchSync::progress', []],
      ],
      'finished' => '\Drupal\bridtv\Batch\BridBatchSync::finished',
    ];
    batch_set($batch);
  }

  /**
   * Start the batch sync process.
   */
  public static function start() {
    $sync = static::getSyncService();
    $sync->prepareFullSync();
  }

  /**
   * Main batch function for processing.
   *
   * @param array $context
   *   The context.
   */
  public static function progress(&$context) {
    $sync = static::getSyncService();
    $limit = 1;
    if (!isset($context['sandbox']['total'])) {
      $context['sandbox']['total'] = $sync->getEntityResolver()
        ->getEntityQuery()
        ->count()
        ->execute();
      $videos_list = $sync->getConsumer()->getDecodedVideosList(1, 1);
      if ($context['sandbox']['total'] == 0 && !$videos_list) {
        return;
      }
      if (isset($videos_list['paging']['Video']['count'])) {
        $context['sandbox']['total'] += $videos_list['paging']['Video']['count'];
      }
      $context['sandbox']['synced'] = 0;
    }

    for ($i = 0; $i !== $limit; $i++) {
      if (!$sync->processNextItem()) {
        $context['finished'] = 1.0;
        // We know that the queue seems to be empty,
        // thus the progress can stop here.
        return;
      };
      $context['sandbox']['synced'] += $sync::ITEMS_PER_QUEUE_ITEM;
    }

    $context['finished'] = $context['sandbox']['synced'] / $context['sandbox']['total'];
    // The queue operation cannot foresee the exact number of steps to process.
    // It's never 100% sure whether it's already finished here.
    // Thus, make sure the progress is not stopping here.
    if ($context['finished'] >= 1.0) {
      $context['finished'] = 0.99;
    }
  }

  /**
   * Function called after batch job is finished.
   *
   * @param bool $success
   *   True if successful.
   * @param array $results
   *   The results.
   * @param array $operations
   *   The operations.
   */
  public static function finished($success, $results, $operations) {
    if ($success) {
      \Drupal::messenger()
        ->addMessage(t('All media items have been synchronized.'));
    }
    else {
      \Drupal::messenger()
        ->addMessage(t('An error occurred. Please contact the site administrator.'), 'error');
    }
  }

  /**
   * Get the sync service.
   *
   * @return \Drupal\bridtv\BridSync
   *   The sync service.
   */
  protected static function getSyncService() {
    return \Drupal::service('bridtv.sync');
  }

}