public function PullEntity::post in CMS Content Sync 2.1.x

Same name and namespace in other branches

1. 8 src/Plugin/rest/resource/PullEntity.php \Drupal\cms_content_sync\Plugin\rest\resource\PullEntity::post()
2. 2.0.x src/Plugin/rest/resource/PullEntity.php \Drupal\cms_content_sync\Plugin\rest\resource\PullEntity::post()

Responds to entity POST requests.

Return value

\Symfony\Component\HttpFoundation\Response -

Throws

\Exception

File

src/Plugin/rest/resource/PullEntity.php, line 339

Class

PullEntity

Provides entity interfaces for Content Sync, allowing the manual pull dashboard to query preview entities and to pull them to the site.

Namespace

Drupal\cms_content_sync\Plugin\rest\resource

Code

public function post(string $pool_id, string $entity_type_name, string $bundle_name, string $shared_entity_id) {
  $pool = Pool::getAll()[$pool_id];
  if (!$pool) {
    return new ResourceResponse([
      'message' => "Unknown pool ID {$pool_id}.",
    ], self::CODE_NOT_FOUND);
  }
  $preview_item = null;
  foreach (Flow::getAll() as $flow) {
    foreach ($flow
      ->getController()
      ->getEntityTypeConfig() as $entity_type_name => $bundles) {
      foreach ($bundles as $bundle_name => $definition) {
        if (!$flow
          ->getController()
          ->canPullEntity($entity_type_name, $bundle_name, PullIntent::PULL_MANUALLY)) {
          continue;
        }
        if ($entity_type_name != $entity_type_name) {
          continue;
        }
        if ($bundle_name != $bundle_name) {
          continue;
        }
        if (Pool::POOL_USAGE_ALLOW != $definition['import_pools'][$pool->id]) {
          continue;
        }
        try {
          $preview_item = $pool
            ->getClient()
            ->getSyndicationService()
            ->pullSingle($flow->id, $entity_type_name, $bundle_name, $shared_entity_id)
            ->fromPool($pool->id)
            ->manually(true)
            ->execute()
            ->getPullDashboardSearchResultItem();
          break 2;
        } catch (SyncCoreException $e) {
          return new ResourceResponse([
            'message' => 'Failed to pull entity: ' . $e
              ->getMessage(),
          ], self::CODE_UNEXPECTED_ERROR);
        }
      }
    }
  }
  if (!$preview_item) {
    return new ResourceResponse([
      'message' => "Missing flow for pool {$pool_id}.",
    ], self::CODE_NOT_FOUND);
  }
  $data = array_merge($preview_item
    ->toArray(), $this
    ->getPreviewItemData($preview_item
    ->getType(), $preview_item
    ->getBundle(), $preview_item
    ->getId()));

  // Entity was ignored by the Sync Core for some reason or the update was rejected by Drupal.
  if (empty($data['last_import'])) {
    return new ResourceResponse([
      'message' => 'Failed to pull entity. Pull was triggered but there\'s no new status entity.',
    ], self::CODE_UNEXPECTED_ERROR);
  }
  return new ResourceResponse($data);
}