SalesforcePushQueueProcessorRestTest.php in Salesforce Suite 8.4

Namespace

Drupal\Tests\salesforce_push\Unit

File

modules/salesforce_push/tests/src/Unit/SalesforcePushQueueProcessorRestTest.php

<?php

namespace Drupal\Tests\salesforce_push\Unit;

use Drupal\Core\Config\Entity\ConfigEntityStorageInterface;
use Drupal\Core\DependencyInjection\ContainerBuilder;
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\Entity\Sql\SqlEntityStorageInterface;
use Drupal\Core\Queue\SuspendQueueException;
use Drupal\salesforce\EntityNotFoundException;
use Drupal\salesforce\SalesforceAuthProviderPluginManager;
use Drupal\Tests\UnitTestCase;
use Drupal\salesforce\Rest\RestClientInterface;
use Drupal\salesforce_mapping\Entity\MappedObjectInterface;
use Drupal\salesforce_mapping\Entity\SalesforceMappingInterface;
use Drupal\salesforce_mapping\MappingConstants;
use Drupal\salesforce_push\Plugin\SalesforcePushQueueProcessor\Rest;
use Drupal\salesforce_push\PushQueueInterface;
use OAuth\Common\Token\TokenInterface;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Drupal\Core\Entity\EntityInterface;
use Drupal\Core\StringTranslation\TranslationInterface;

/**
 * Test SalesforcePushQueueProcessor plugin Rest.
 *
 * @coversDefaultClass \Drupal\salesforce_push\Plugin\SalesforcePushQueueProcessor\Rest
 *
 * @group salesforce_pull
 */
class SalesforcePushQueueProcessorRestTest extends UnitTestCase {

  /**
   * Required modules.
   *
   * @var array
   */
  public static $modules = [
    'salesforce_pull',
  ];

  /**
   * {@inheritdoc}
   */
  protected function setUp() {
    $this->entityType = 'default';
    $this->queue = $this
      ->getMockBuilder(PushQueueInterface::CLASS)
      ->getMock();
    $this->client = $this
      ->getMockBuilder(RestClientInterface::CLASS)
      ->getMock();
    $this->eventDispatcher = $this
      ->getMockBuilder(EventDispatcherInterface::CLASS)
      ->getMock();
    $this->eventDispatcher
      ->expects($this
      ->any())
      ->method('dispatch')
      ->willReturn(NULL);
    $this->entity_manager = $this
      ->getMockBuilder(EntityTypeManagerInterface::class)
      ->getMock();
    $this->string_translation = $this
      ->getMockBuilder(TranslationInterface::class)
      ->getMock();
    $this->mapping = $this
      ->getMockBuilder(SalesforceMappingInterface::CLASS)
      ->getMock();
    $this->mapping
      ->expects($this
      ->any())
      ->method('id')
      ->willReturn('foo_mapping');
    $this->mapping
      ->expects($this
      ->any())
      ->method('__get')
      ->with($this
      ->equalTo('drupal_entity_type'))
      ->willReturn($this->entityType);
    $this->mappingStorage = $this
      ->getMockBuilder(ConfigEntityStorageInterface::CLASS)
      ->getMock();
    $this->mappingStorage
      ->expects($this
      ->any())
      ->method('load')
      ->willReturn($this->mapping);
    $this->mappedObjectStorage = $this
      ->getMockBuilder(SqlEntityStorageInterface::CLASS)
      ->getMock();
    $prophecy = $this
      ->prophesize(EntityTypeManagerInterface::class);
    $prophecy
      ->getStorage('salesforce_mapping')
      ->willReturn($this->mappingStorage);
    $prophecy
      ->getStorage('salesforce_mapped_object')
      ->willReturn($this->mappedObjectStorage);
    $this->entityTypeManager = $prophecy
      ->reveal();
    $this->authToken = $this
      ->getMockBuilder(TokenInterface::CLASS)
      ->getMock();
    $this->authMan = $this
      ->getMockBuilder(SalesforceAuthProviderPluginManager::CLASS)
      ->disableOriginalConstructor()
      ->getMock();
    $this->authMan
      ->expects($this
      ->any())
      ->method('getToken')
      ->willReturn($this->authToken);
    $container = new ContainerBuilder();
    $container
      ->set('queue.salesforce_push', $this->queue);
    $container
      ->set('salesforce.client', $this->client);
    $container
      ->set('entity_type.manager', $this->entityTypeManager);
    $container
      ->set('event_dispatcher', $this->eventDispatcher);
    $container
      ->set('string_translation', $this->string_translation);
    $container
      ->set('entity_type.manager', $this->entity_manager);
    \Drupal::setContainer($container);
    $this->handler = new Rest([], '', [], $this->queue, $this->entityTypeManager, $this->eventDispatcher, $this->authMan);
  }

  /**
   * @covers ::process
   */
  public function testProcessMissingAuth() {
    $this->authMan = $this
      ->getMockBuilder(SalesforceAuthProviderPluginManager::CLASS)
      ->disableOriginalConstructor()
      ->getMock();
    $this->authMan
      ->expects($this
      ->any())
      ->method('getToken')
      ->willReturn(NULL);
    $this->handler = $this
      ->getMockBuilder(Rest::class)
      ->setMethods([
      'processItem',
    ])
      ->setConstructorArgs([
      [],
      '',
      [],
      $this->queue,
      $this->entityTypeManager,
      $this->eventDispatcher,
      $this->authMan,
    ])
      ->getMock();
    $this
      ->expectException(SuspendQueueException::class);
    $this->handler
      ->process([
      (object) [
        1,
      ],
    ]);
  }

  /**
   * @covers ::process
   */
  public function testProcessSuccess() {
    $this->handler = $this
      ->getMockBuilder(Rest::class)
      ->setMethods([
      'processItem',
    ])
      ->setConstructorArgs([
      [],
      '',
      [],
      $this->queue,
      $this->entityTypeManager,
      $this->eventDispatcher,
      $this->authMan,
    ])
      ->getMock();
    $this->handler
      ->expects($this
      ->once())
      ->method('processItem')
      ->willReturn(NULL);

    // Test delete item after successful processItem()
    $this->queue
      ->expects($this
      ->once())
      ->method('deleteItem')
      ->willReturn(NULL);
    $this->handler
      ->process([
      (object) [
        1,
      ],
    ]);
  }

  /**
   * @covers ::processItem
   */
  public function testProcessItemDeleteNoop() {
    $this->handler = $this
      ->getMockBuilder(Rest::class)
      ->setConstructorArgs([
      [],
      '',
      [],
      $this->queue,
      $this->entityTypeManager,
      $this->eventDispatcher,
      $this->authMan,
    ])
      ->setMethods([
      'getMappedObject',
    ])
      ->getMock();
    $mappedObject = $this
      ->getMockBuilder(MappedObjectInterface::class)
      ->getMock();
    $mappedObject
      ->expects($this
      ->once())
      ->method('isNew')
      ->willReturn(TRUE);
    $this->handler
      ->expects($this
      ->once())
      ->method('getMappedObject')
      ->willReturn($mappedObject);
    $this->handler
      ->processItem((object) [
      'op' => MappingConstants::SALESFORCE_MAPPING_SYNC_DRUPAL_DELETE,
      'mapped_object_id' => 'foo',
      'name' => 'bar',
    ]);
  }

  /**
   * @covers ::processItem
   */
  public function testProcessItemDelete() {

    // Test push delete for op == delete.
    $this->queueItem = (object) [
      'op' => MappingConstants::SALESFORCE_MAPPING_SYNC_DRUPAL_DELETE,
      'mapped_object_id' => 'foo',
      'name' => 'bar',
    ];
    $this->mappedObject = $this
      ->getMockBuilder(MappedObjectInterface::class)
      ->getMock();
    $this->mappedObject
      ->expects($this
      ->once())
      ->method('pushDelete')
      ->willReturn(NULL);
    $this->handler = $this
      ->getMockBuilder(Rest::class)
      ->setMethods([
      'getMappedObject',
    ])
      ->setConstructorArgs([
      [],
      '',
      [],
      $this->queue,
      $this->entityTypeManager,
      $this->eventDispatcher,
      $this->authMan,
    ])
      ->getMock();
    $this->handler
      ->expects($this
      ->once())
      ->method('getMappedObject')
      ->willReturn($this->mappedObject);

    // Test skip item on missing mapped object and op == delete
    // test push on op == insert / update
    // test throwing exception on drupal entity not found.
    $this->handler
      ->processItem($this->queueItem);
  }

  /**
   * @covers ::processItem
   */
  public function testProcessItemPush() {

    // Test push on op == insert / update.
    $this->mappedObject = $this
      ->getMockBuilder(MappedObjectInterface::class)
      ->getMock();
    $this->queueItem = (object) [
      'entity_id' => 'foo',
      'op' => NULL,
      'mapped_object_id' => NULL,
      'name' => NULL,
    ];
    $this->entity = $this
      ->getMockBuilder(EntityInterface::class)
      ->getMock();
    $this->entityStorage = $this
      ->getMockBuilder(SqlEntityStorageInterface::CLASS)
      ->getMock();
    $this->entityStorage
      ->expects($this
      ->once())
      ->method('load')
      ->willReturn($this->entity);
    $prophecy = $this
      ->prophesize(EntityTypeManagerInterface::class);
    $prophecy
      ->getStorage($this->entityType)
      ->willReturn($this->entityStorage);
    $prophecy
      ->getStorage('salesforce_mapping')
      ->willReturn($this->mappingStorage);
    $prophecy
      ->getStorage('salesforce_mapped_object')
      ->willReturn($this->mappedObjectStorage);
    $this->entityTypeManager = $prophecy
      ->reveal();
    $this->mappedObject
      ->expects($this
      ->once())
      ->method('setDrupalEntity')
      ->willReturn($this->mappedObject);
    $this->mappedObject
      ->expects($this
      ->once())
      ->method('push')
      ->willReturn(NULL);
    $this->handler = $this
      ->getMockBuilder(Rest::class)
      ->setMethods([
      'getMappedObject',
    ])
      ->setConstructorArgs([
      [],
      '',
      [],
      $this->queue,
      $this->entityTypeManager,
      $this->eventDispatcher,
      $this->authMan,
    ])
      ->getMock();
    $this->handler
      ->expects($this
      ->once())
      ->method('getMappedObject')
      ->willReturn($this->mappedObject);
    $this->handler
      ->processItem($this->queueItem);
  }

  /**
   * @covers ::processItem
   */
  public function testProcessItemEntityNotFound() {

    // Test throwing exception on drupal entity not found.
    $this->queueItem = (object) [
      'op' => '',
      'mapped_object_id' => 'foo',
      'name' => 'bar',
      'entity_id' => 'foo',
    ];
    $this->mappedObject = $this
      ->getMockBuilder(MappedObjectInterface::class)
      ->getMock();
    $this->mappedObject
      ->expects($this
      ->any())
      ->method('isNew')
      ->willReturn(TRUE);
    $this->entityStorage = $this
      ->getMockBuilder(SqlEntityStorageInterface::CLASS)
      ->getMock();
    $prophecy = $this
      ->prophesize(EntityTypeManagerInterface::class);
    $prophecy
      ->getStorage($this->entityType)
      ->willReturn($this->entityStorage);
    $prophecy
      ->getStorage('salesforce_mapping')
      ->willReturn($this->mappingStorage);
    $prophecy
      ->getStorage('salesforce_mapped_object')
      ->willReturn($this->mappedObjectStorage);
    $this->entityTypeManager = $prophecy
      ->reveal();
    $this->entityStorage
      ->expects($this
      ->once())
      ->method('load')
      ->willReturn(NULL);
    $this->handler = $this
      ->getMockBuilder(Rest::class)
      ->setMethods([
      'getMappedObject',
    ])
      ->setConstructorArgs([
      [],
      '',
      [],
      $this->queue,
      $this->entityTypeManager,
      $this->eventDispatcher,
      $this->authMan,
    ])
      ->getMock();
    $this->handler
      ->expects($this
      ->once())
      ->method('getMappedObject')
      ->willReturn($this->mappedObject);
    $this
      ->expectException(EntityNotFoundException::class);
    $this->handler
      ->processItem($this->queueItem);
  }

}

Classes

Name	Description
SalesforcePushQueueProcessorRestTest	Test SalesforcePushQueueProcessor plugin Rest.