Added subscriber test

FastyBird · Aug 29, 2020 · 13bf79b · 13bf79b
1 parent 219e8b0
commit 13bf79b
Showing 1 changed file with 249 additions and 0 deletions.
diff --git a/tests/cases/Unit/Subscribers/EntitiesSubscriberTest.phpt b/tests/cases/Unit/Subscribers/EntitiesSubscriberTest.phpt
@@ -0,0 +1,249 @@
+<?php declare(strict_types = 1);
+
+namespace Tests\Cases;
+
+use Doctrine\ORM;
+use FastyBird\NodeExchange\Publishers as NodeExchangePublishers;
+use FastyBird\TriggersNode\Entities;
+use FastyBird\TriggersNode\Subscribers;
+use FastyBird\TriggersNode\Types;
+use Mockery;
+use Ninjify\Nunjuck\TestCase\BaseMockeryTestCase;
+use stdClass;
+use Tester\Assert;
+
+require_once __DIR__ . '/../../../bootstrap.php';
+
+/**
+ * @testCase
+ */
+final class EntitiesSubscriberTest extends BaseMockeryTestCase
+{
+
+	public function testSubscriberEvents(): void
+	{
+		$publisher = Mockery::mock(NodeExchangePublishers\IRabbitMqPublisher::class);
+		$entityManager = Mockery::mock(ORM\EntityManagerInterface::class);
+
+		$subscriber = new Subscribers\EntitiesSubscriber(
+			$publisher,
+			$entityManager
+		);
+
+		Assert::same(['onFlush', 'postPersist', 'postUpdate'], $subscriber->getSubscribedEvents());
+	}
+
+	public function testPublishCreatedEntity(): void
+	{
+		$publisher = Mockery::mock(NodeExchangePublishers\IRabbitMqPublisher::class);
+		$publisher
+			->shouldReceive('publish')
+			->withArgs(function (string $key, array $data): bool {
+				unset($data['id']);
+
+				Assert::same('fb.bus.node.entity.created.trigger', $key);
+				Assert::equal([
+					'name'       => 'Trigger name',
+					'comment'    => null,
+					'is_enabled' => true,
+					'owner'      => null,
+					'device'     => 'device-name',
+					'channel'    => 'channel-name',
+					'property'   => 'property-name',
+					'operand'    => '10',
+					'operator'   => 'eq',
+				], $data);
+
+				return true;
+			})
+			->times(1);
+
+		$entityManager = $this->getEntityManager();
+
+		$subscriber = new Subscribers\EntitiesSubscriber(
+			$publisher,
+			$entityManager
+		);
+
+		$entity = new Entities\Triggers\ChannelPropertyTrigger(
+			'device-name',
+			'channel-name',
+			'property-name',
+			Types\ConditionOperatorType::get(Types\ConditionOperatorType::STATE_VALUE_EQUAL),
+			'10',
+			'Trigger name'
+		);
+
+		$eventArgs = Mockery::mock(ORM\Event\LifecycleEventArgs::class);
+		$eventArgs
+			->shouldReceive('getObject')
+			->withNoArgs()
+			->andReturn($entity)
+			->times(1);
+
+		$subscriber->postPersist($eventArgs);
+	}
+
+	public function testPublishUpdatedEntity(): void
+	{
+		$publisher = Mockery::mock(NodeExchangePublishers\IRabbitMqPublisher::class);
+		$publisher
+			->shouldReceive('publish')
+			->withArgs(function (string $key, array $data): bool {
+				unset($data['id']);
+
+				Assert::same('fb.bus.node.entity.updated.trigger', $key);
+				Assert::equal([
+					'name'       => 'Trigger name',
+					'comment'    => null,
+					'is_enabled' => true,
+					'owner'      => null,
+					'device'     => 'device-name',
+					'channel'    => 'channel-name',
+					'property'   => 'property-name',
+					'operand'    => '10',
+					'operator'   => 'eq',
+				], $data);
+
+				return true;
+			})
+			->times(1);
+
+		$entityManager = $this->getEntityManager(true);
+
+		$subscriber = new Subscribers\EntitiesSubscriber(
+			$publisher,
+			$entityManager
+		);
+
+		$entity = new Entities\Triggers\ChannelPropertyTrigger(
+			'device-name',
+			'channel-name',
+			'property-name',
+			Types\ConditionOperatorType::get(Types\ConditionOperatorType::STATE_VALUE_EQUAL),
+			'10',
+			'Trigger name'
+		);
+
+		$eventArgs = Mockery::mock(ORM\Event\LifecycleEventArgs::class);
+		$eventArgs
+			->shouldReceive('getObject')
+			->andReturn($entity)
+			->times(1);
+
+		$subscriber->postUpdate($eventArgs);
+	}
+
+	public function testPublishDeletedEntity(): void
+	{
+		$publisher = Mockery::mock(NodeExchangePublishers\IRabbitMqPublisher::class);
+		$publisher
+			->shouldReceive('publish')
+			->withArgs(function (string $key, array $data): bool {
+				unset($data['id']);
+
+				Assert::same('fb.bus.node.entity.deleted.trigger', $key);
+				Assert::equal([
+					'name'       => 'Trigger name',
+					'comment'    => null,
+					'is_enabled' => true,
+					'owner'      => null,
+					'device'     => 'device-name',
+					'channel'    => 'channel-name',
+					'property'   => 'property-name',
+					'operand'    => '10',
+					'operator'   => 'eq',
+				], $data);
+
+				return true;
+			})
+			->times(1);
+
+		$entity = new Entities\Triggers\ChannelPropertyTrigger(
+			'device-name',
+			'channel-name',
+			'property-name',
+			Types\ConditionOperatorType::get(Types\ConditionOperatorType::STATE_VALUE_EQUAL),
+			'10',
+			'Trigger name'
+		);
+
+		$uow = Mockery::mock(ORM\UnitOfWork::class);
+		$uow
+			->shouldReceive('getScheduledEntityDeletions')
+			->withNoArgs()
+			->andReturn([$entity])
+			->times(1)
+			->getMock()
+			->shouldReceive('getEntityIdentifier')
+			->andReturn([
+				123,
+			])
+			->times(1);
+
+		$entityManager = $this->getEntityManager();
+		$entityManager
+			->shouldReceive('getUnitOfWork')
+			->withNoArgs()
+			->andReturn($uow)
+			->times(1);
+
+		$subscriber = new Subscribers\EntitiesSubscriber(
+			$publisher,
+			$entityManager
+		);
+
+		$subscriber->onFlush();
+	}
+
+	/**
+	 * @param bool $withUow
+	 *
+	 * @return ORM\EntityManagerInterface
+	 */
+	private function getEntityManager(bool $withUow = false): ORM\EntityManagerInterface
+	{
+		$metadata = new stdClass();
+		$metadata->fieldMappings = [
+			[
+				'fieldName' => 'name',
+			],
+			[
+				'fieldName' => 'comment',
+			],
+			[
+				'fieldName' => 'enabled',
+			],
+		];
+
+		$entityManager = Mockery::mock(ORM\EntityManagerInterface::class);
+		$entityManager
+			->shouldReceive('getClassMetadata')
+			->withArgs([Entities\Triggers\Trigger::class])
+			->andReturn($metadata);
+
+		if ($withUow) {
+			$uow = Mockery::mock(ORM\UnitOfWork::class);
+			$uow
+				->shouldReceive('getEntityChangeSet')
+				->andReturn(['name'])
+				->times(1)
+				->getMock()
+				->shouldReceive('isScheduledForDelete')
+				->andReturn(false)
+				->getMock();
+
+			$entityManager
+				->shouldReceive('getUnitOfWork')
+				->withNoArgs()
+				->andReturn($uow)
+				->times(1);
+		}
+
+		return $entityManager;
+	}
+
+}
+
+$test_case = new EntitiesSubscriberTest();
+$test_case->run();