PullQueueTest.php in Salesforce Suite 5.0.x

Namespace

Drupal\Tests\salesforce_pull\Functional

File

modules/salesforce_pull/tests/src/Functional/PullQueueTest.php

<?php

namespace Drupal\Tests\salesforce_pull\Functional;

use Drupal\salesforce\SFID;
use Drupal\salesforce\Tests\TestRestClient;
use Drupal\salesforce_mapping\Entity\SalesforceMapping;
use Drupal\Tests\BrowserTestBase;

/**
 * Test PushQueue.
 *
 * @group salesforce_push
 */
class PullQueueTest extends BrowserTestBase {

  /**
   * Default theme required for D9.
   *
   * @var string
   */
  protected $defaultTheme = 'stark';

  /**
   * Required modules.
   *
   * @var array
   */
  protected static $modules = [
    'typed_data',
    'dynamic_entity_reference',
    'salesforce_mapping',
    'salesforce_mapping_test',
    'salesforce_pull',
  ];

  /**
   * Test that saving mapped nodes enqueues them for push to Salesforce.
   */
  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());
      }
    }
  }

}

Classes

Name	Description
PullQueueTest	Test PushQueue.