cms_content_sync-3.0.x-dev/src/SyncCorePoolExport.php

<?php

namespace Drupal\cms_content_sync;

use Drupal\cms_content_sync\Controller\ContentSyncSettings;
use Drupal\cms_content_sync\Entity\Pool;
use EdgeBox\SyncCore\Exception\NotFoundException;

/**
 *
 */
class SyncCorePoolExport extends SyncCoreExport {
  /**
   * @var \Drupal\cms_content_sync\Entity\Pool
   */
  protected $pool;

  /**
   * SyncCorePoolExport constructor.
   *
   * @param \Drupal\cms_content_sync\Entity\Pool $pool
   *   The pool this exporter is used for.
   */
  public function __construct(Pool $pool) {
    parent::__construct($pool->getClient());

    $this->pool = $pool;
  }

  /**
   *
   */
  public static function all($machine_names = NULL) {
    foreach (Pool::getAll() as $pool) {
      if (!$machine_names || in_array($pool->id(), $machine_names)) {
        $exporter = new SyncCorePoolExport($pool);
        $batch = $exporter->prepareBatch(TRUE);
        $batch->executeAll();
      }
    }
  }

  /**
   * {@inheritdoc}
   */
  public function prepareBatch($subsequent = FALSE, $force = FALSE) {
    $base_url = ContentSyncSettings::getInstance()->getSiteBaseUrl();
    if (empty($base_url)) {
      throw new \Exception('Please provide a base_url via settings or drush command.');
    }

    $batch = $this
      ->client
      ->batch();

    // Skip creation of base entities if they are already created.
    if (!$subsequent) {
      // Register site independently of batch operations.
      $this
        ->client
        ->registerSite($force);

      // Enable previews used in the pull dashboard independently of batch operations.
      // @todo Only do this if any Flow is actually pulling manually.
      $this
        ->client
        ->getConfigurationService()
        ->enableEntityPreviews(_cms_content_sync_is_cloud_version());
    }

    $this
      ->client
      ->getConfigurationService()
      ->usePool($this->pool->id, $this->pool->label())
      ->addToBatch($batch);

    $this
      ->client
      ->getConfigurationService()
      ->usePool($this->pool->id, $this->pool->label())
      ->addToBatch($batch);

    return $batch;
  }

}