public function PullQueueTest::testEnqueue in Salesforce Suite 5.0.x

Same name and namespace in other branches

1. 8.4 modules/salesforce_pull/tests/src/Functional/PullQueueTest.php \Drupal\Tests\salesforce_pull\Functional\PullQueueTest::testEnqueue()

Test that saving mapped nodes enqueues them for push to Salesforce.

File

modules/salesforce_pull/tests/src/Functional/PullQueueTest.php, line 40

Class

PullQueueTest

Test PushQueue.

Namespace

Drupal\Tests\salesforce_pull\Functional

Code

public function testEnqueue() {

  // Trigger salesforce_pull_cron to ensure an item in the pull queue, thanks
  // to our mocked response from TestRestClient service.
  \Drupal::service('salesforce_pull.queue_handler')
    ->getUpdatedRecords();
  $items = TestRestClient::getContactQueryResults();

  // Pulled from Cron.php in core.
  $queue_name = 'cron_salesforce_pull';

  /** @var \Drupal\Core\Queue\QueueFactory $queueFactory */
  $queueFactory = \Drupal::service('queue');
  $queue = $queueFactory
    ->get($queue_name);
  $this
    ->assertEquals($items['totalSize'], $queue
    ->numberOfItems());

  /** @var \Drupal\Core\Queue\QueueWorkerManagerInterface $queueManager */
  $queueManager = \Drupal::service('plugin.manager.queue_worker');
  $queueFactory
    ->get('cron_salesforce_pull')
    ->createQueue();
  $queue_worker = $queueManager
    ->createInstance($queue_name);

  // Process the queue.
  $mapping = SalesforceMapping::load('test_mapping');

  /** @var \Drupal\salesforce_mapping\MappedObjectStorage $mappedObjectStorage */
  $mappedObjectStorage = \Drupal::entityTypeManager()
    ->getStorage('salesforce_mapped_object');
  for ($i = 0; $i < $items['totalSize']; $i++) {
    $item = $queue
      ->claimItem();

    /** @var \Drupal\salesforce_pull\PullQueueItem $data */
    $data = $item->data;
    $queue_worker
      ->processItem($item->data);
    $queue
      ->deleteItem($item);
    $this
      ->assertEquals($items['totalSize'] - ($i + 1), $queue
      ->numberOfItems());
    $sfid = $data
      ->getSobject()
      ->id();

    /** @var \Drupal\salesforce_mapping\Entity\MappedObject $mappedObject */
    $mappedObject = $mappedObjectStorage
      ->loadBySfidAndMapping($sfid, $mapping);

    /** @var \Drupal\node\Entity\Node $createdEntity */
    $createdEntity = $mappedObject
      ->getMappedEntity();
    $this
      ->assertEquals('SALESFORCE TEST', $createdEntity
      ->getTitle());
    $this
      ->assertEquals($data
      ->getSobject()
      ->field('Email'), $createdEntity->field_salesforce_test_email->value);
    $this
      ->assertEquals(date('Y-m-d', strtotime($data
      ->getSobject()
      ->field('Birthdate'))), date('Y-m-d', strtotime($createdEntity->field_salesforce_test_date->value)));
    $this
      ->assertEquals((bool) $data
      ->getSobject()
      ->field('d5__Do_Not_Mail__c'), (bool) $createdEntity->field_salesforce_test_bool->value);
    $this
      ->assertEquals($data
      ->getSobject()
      ->field('Description'), $createdEntity->field_salesforce_test_link->uri);
  }
  drupal_flush_all_caches();

  // If we have any entity reference, we can't be sure it'll be pulled
  // before the record to which it points. So, we pull the entire queue a 2nd
  // time in order to check that references get assigned properly.
  \Drupal::service('salesforce_pull.queue_handler')
    ->getUpdatedRecords();

  // Make sure our queue was re-populated.
  $this
    ->assertEquals($items['totalSize'], $queue
    ->numberOfItems());
  for ($i = 0; $i < $items['totalSize']; $i++) {
    $item = $queue
      ->claimItem();

    /** @var \Drupal\salesforce_pull\PullQueueItem $data */
    $data = $item->data;
    $queue_worker
      ->processItem($data);
    $queue
      ->deleteItem($item);
    $this
      ->assertEquals($items['totalSize'] - ($i + 1), $queue
      ->numberOfItems());
    $sfid = $data
      ->getSobject()
      ->id();

    /** @var \Drupal\salesforce_mapping\Entity\MappedObject $mappedObject */
    $mappedObject = $mappedObjectStorage
      ->loadBySfidAndMapping($sfid, $mapping);

    /** @var \Drupal\node\Entity\Node $createdEntity */
    $createdEntity = $mappedObject
      ->getMappedEntity();
    if (!empty($data
      ->getSobject()
      ->field('ReportsToId'))) {
      $referencedSfid = new SFID($data
        ->getSobject()
        ->field('ReportsToId'));
      $referencedMappedObject = $mappedObjectStorage
        ->loadBySfidAndMapping($referencedSfid, $mapping);
      $referencedEntity = $referencedMappedObject
        ->getMappedEntity();
      $this
        ->assertEquals($referencedEntity
        ->uuid(), $createdEntity->field_salesforce_test_reference->entity
        ->uuid());
    }
  }
}