You are here

Home » API reference » Feeds 8.3 » LazySubscriberTest.php

class LazySubscriberTest in Feeds 8.3

@coversDefaultClass \Drupal\feeds\EventSubscriber\LazySubscriber @group feeds

Hierarchy

Expanded class hierarchy of LazySubscriberTest

File

tests/src/Unit/EventSubscriber/LazySubscriberTest.php, line 22

Namespace

Drupal\Tests\feeds\Unit\EventSubscriber
View source 
class LazySubscriberTest extends FeedsUnitTestCase {

  /**
   * The event dispatcher.
   *
   * @var \Symfony\Component\EventDispatcher\EventDispatcher
   */
  protected $dispatcher;

  /**
   * A second event dispatcher.
   *
   * @var \Symfony\Component\EventDispatcher\EventDispatcherInterface
   */
  protected $explodingDispatcher;

  /**
   * The feed entity.
   *
   * @var \Drupal\feeds\FeedInterface
   */
  protected $feed;

  /**
   * The state object.
   *
   * @var \Drupal\feeds\StateInterface
   */
  protected $state;

  /**
   * The feed type entity.
   *
   * @var \Drupal\feeds\FeedTypeInterface
   */
  protected $feedType;

  /**
   * The Feeds fetcher plugin.
   *
   * @var \Drupal\feeds\Plugin\Type\Fetcher\FetcherInterface
   */
  protected $fetcher;

  /**
   * The Feeds parser plugin.
   *
   * @var \Drupal\feeds\Plugin\Type\Parser\ParserInterface
   */
  protected $parser;

  /**
   * The Feeds processor plugin.
   *
   * @var \Drupal\feeds\Plugin\Type\Processor\ProcessorInterface
   */
  protected $processor;

  /**
   * {@inheritdoc}
   */
  public function setUp() {
    parent::setUp();
    $this->dispatcher = new EventDispatcher();

    // Dispatcher used to verify things only get called once.
    $this->explodingDispatcher = $this
      ->createMock('Symfony\\Component\\EventDispatcher\\EventDispatcherInterface');
    $this->explodingDispatcher
      ->expects($this
      ->any())
      ->method('addListener')
      ->will($this
      ->throwException(new \Exception()));
    $this->state = $this
      ->createMock('Drupal\\feeds\\StateInterface');
    $this->feed = $this
      ->createMock('Drupal\\feeds\\FeedInterface');
    $this->feed
      ->expects($this
      ->any())
      ->method('getState')
      ->will($this
      ->returnValue($this->state));
    $this->feedType = $this
      ->createMock('Drupal\\feeds\\FeedTypeInterface');
    $this->feedType
      ->expects($this
      ->any())
      ->method('getMappedSources')
      ->will($this
      ->returnValue([]));
    $this->fetcher = $this
      ->createMock('Drupal\\feeds\\Plugin\\Type\\Fetcher\\FetcherInterface');
    $this->parser = $this
      ->createMock('Drupal\\feeds\\Plugin\\Type\\Parser\\ParserInterface');
    $this->processor = $this
      ->createMock('Drupal\\feeds\\Plugin\\Type\\Processor\\ProcessorInterface');
    $this->feed
      ->expects($this
      ->any())
      ->method('getType')
      ->will($this
      ->returnValue($this->feedType));
  }

  /**
   * @covers ::getSubscribedEvents
   */
  public function testGetSubscribedEvents() {
    $events = LazySubscriber::getSubscribedEvents();
    $this
      ->assertSame(3, count($events));
  }

  /**
   * @covers ::onInitImport
   */
  public function testOnInitImport() {
    $fetcher_result = $this
      ->createMock('Drupal\\feeds\\Result\\FetcherResultInterface');
    $parser_result = new ParserResult();
    $parser_result
      ->addItem(new DynamicItem());
    $this->fetcher
      ->expects($this
      ->once())
      ->method('fetch')
      ->with($this->feed, $this->state)
      ->will($this
      ->returnValue($fetcher_result));
    $this->parser
      ->expects($this
      ->once())
      ->method('parse')
      ->with($this->feed, $fetcher_result, $this->state)
      ->will($this
      ->returnValue($parser_result));
    $this->processor
      ->expects($this
      ->once())
      ->method('process');
    $this->feedType
      ->expects($this
      ->once())
      ->method('getFetcher')
      ->will($this
      ->returnValue($this->fetcher));
    $this->feedType
      ->expects($this
      ->once())
      ->method('getParser')
      ->will($this
      ->returnValue($this->parser));
    $this->feedType
      ->expects($this
      ->once())
      ->method('getProcessor')
      ->will($this
      ->returnValue($this->processor));
    $subscriber = new LazySubscriber();

    // Fetch.
    $subscriber
      ->onInitImport(new InitEvent($this->feed, 'fetch'), FeedsEvents::INIT_IMPORT, $this->dispatcher);
    $fetch_event = $this->dispatcher
      ->dispatch(FeedsEvents::FETCH, new FetchEvent($this->feed));
    $this
      ->assertSame($fetcher_result, $fetch_event
      ->getFetcherResult());

    // Parse.
    $subscriber
      ->onInitImport(new InitEvent($this->feed, 'parse'), FeedsEvents::INIT_IMPORT, $this->dispatcher);
    $parse_event = $this->dispatcher
      ->dispatch(FeedsEvents::PARSE, new ParseEvent($this->feed, $fetcher_result));
    $this
      ->assertSame($parser_result, $parse_event
      ->getParserResult());

    // Process.
    $subscriber
      ->onInitImport(new InitEvent($this->feed, 'process'), FeedsEvents::INIT_IMPORT, $this->dispatcher);
    foreach ($parse_event
      ->getParserResult() as $item) {
      $this->dispatcher
        ->dispatch(FeedsEvents::PROCESS, new ProcessEvent($this->feed, $item));
    }

    // Call again.
    $subscriber
      ->onInitImport(new InitEvent($this->feed, 'fetch'), FeedsEvents::INIT_IMPORT, $this->explodingDispatcher);
  }

  /**
   * @covers ::onInitClear
   */
  public function testOnInitClear() {
    $clearable = $this
      ->createMock('Drupal\\feeds\\Plugin\\Type\\ClearableInterface');
    $clearable
      ->expects($this
      ->exactly(2))
      ->method('clear')
      ->with($this->feed);
    $this->feedType
      ->expects($this
      ->once())
      ->method('getPlugins')
      ->will($this
      ->returnValue([
      $clearable,
      $this->dispatcher,
      $clearable,
    ]));
    $subscriber = new LazySubscriber();
    $subscriber
      ->onInitClear(new InitEvent($this->feed), FeedsEvents::INIT_CLEAR, $this->dispatcher);
    $this->dispatcher
      ->dispatch(FeedsEvents::CLEAR, new ClearEvent($this->feed));

    // Call again.
    $subscriber
      ->onInitClear(new InitEvent($this->feed), FeedsEvents::INIT_CLEAR, $this->explodingDispatcher);
  }

  /**
   * @covers ::onInitExpire
   */
  public function testOnInitExpire() {
    $this->feedType
      ->expects($this
      ->once())
      ->method('getProcessor')
      ->will($this
      ->returnValue($this->processor));
    $this->processor
      ->expects($this
      ->once())
      ->method('expireItem')
      ->with($this->feed);
    $subscriber = new LazySubscriber();
    $subscriber
      ->onInitExpire(new InitEvent($this->feed), FeedsEvents::INIT_IMPORT, $this->dispatcher);
    $this->dispatcher
      ->dispatch(FeedsEvents::EXPIRE, new ExpireEvent($this->feed, 1234));

    // Call again.
    $subscriber
      ->onInitExpire(new InitEvent($this->feed), FeedsEvents::INIT_IMPORT, $this->explodingDispatcher);
  }

}

Members

Namesort descending Modifiers Type Description Overrides
FeedsMockingTrait::getMockAccount protected function Mocks an account object.
FeedsMockingTrait::getMockedAccountSwitcher protected function Returns a mocked AccountSwitcher object.
FeedsMockingTrait::getMockFeed protected function Returns a mocked feed entity.
FeedsMockingTrait::getMockFeedType protected function Returns a mocked feed type entity.
FeedsMockingTrait::getMockFieldDefinition protected function Mocks a field definition. 1
FeedsMockingTrait::getMockFileSystem protected function Mocks the file system.
FeedsReflectionTrait::callProtectedMethod protected function Calls a protected method on the given object.
FeedsReflectionTrait::getMethod protected function Gets a ReflectionMethod for a class method.
FeedsReflectionTrait::getProtectedClosure protected function Returns a dynamically created closure for the object's method.
FeedsReflectionTrait::setProtectedProperty protected function Sets a protected property.
FeedsUnitTestCase::absolutePath protected function Returns the absolute directory path of the Feeds module.
FeedsUnitTestCase::defineConstants protected function Defines stub constants.
FeedsUnitTestCase::getMockStreamWrapperManager protected function Returns a mock stream wrapper manager.
FeedsUnitTestCase::resourcesPath protected function Returns the absolute directory path of the resources folder.
LazySubscriberTest::$dispatcher protected property The event dispatcher.
LazySubscriberTest::$explodingDispatcher protected property A second event dispatcher.
LazySubscriberTest::$feed protected property The feed entity.
LazySubscriberTest::$feedType protected property The feed type entity.
LazySubscriberTest::$fetcher protected property The Feeds fetcher plugin.
LazySubscriberTest::$parser protected property The Feeds parser plugin.
LazySubscriberTest::$processor protected property The Feeds processor plugin.
LazySubscriberTest::$state protected property The state object.
LazySubscriberTest::setUp public function Overrides FeedsUnitTestCase::setUp
LazySubscriberTest::testGetSubscribedEvents public function @covers ::getSubscribedEvents
LazySubscriberTest::testOnInitClear public function @covers ::onInitClear
LazySubscriberTest::testOnInitExpire public function @covers ::onInitExpire
LazySubscriberTest::testOnInitImport public function @covers ::onInitImport
PhpunitCompatibilityTrait::getMock Deprecated public function Returns a mock object for the specified class using the available method.
PhpunitCompatibilityTrait::setExpectedException Deprecated public function Compatibility layer for PHPUnit 6 to support PHPUnit 4 code.
UnitTestCase::$randomGenerator protected property The random generator.
UnitTestCase::$root protected property The app root. 1
UnitTestCase::assertArrayEquals protected function Asserts if two arrays are equal by sorting them first.
UnitTestCase::getBlockMockWithMachineName Deprecated protected function Mocks a block with a block plugin. 1
UnitTestCase::getClassResolverStub protected function Returns a stub class resolver.
UnitTestCase::getConfigFactoryStub public function Returns a stub config factory that behaves according to the passed array.
UnitTestCase::getConfigStorageStub public function Returns a stub config storage that returns the supplied configuration.
UnitTestCase::getContainerWithCacheTagsInvalidator protected function Sets up a container with a cache tags invalidator.
UnitTestCase::getRandomGenerator protected function Gets the random generator for the utility methods.
UnitTestCase::getStringTranslationStub public function Returns a stub translation manager that just returns the passed string.
UnitTestCase::randomMachineName public function Generates a unique random string containing letters and numbers.