<?php

namespace Enqueue\Stomp\Tests;

use Enqueue\Stomp\ExtensionType;

use Enqueue\Stomp\StompDestination;

use Enqueue\Test\ClassExtensionTrait;

use Interop\Queue\Queue;

use Interop\Queue\Topic;

class StompDestinationTest extends \PHPUnit\Framework\TestCase

{

use ClassExtensionTrait;

public function testShouldImplementsTopicAndQueueInterfaces()

{

$this->assertClassImplements(Topic::class, StompDestination::class);

$this->assertClassImplements(Queue::class, StompDestination::class);

}

public function testShouldReturnDestinationStringWithRoutingKey()

{

$destination = new StompDestination(ExtensionType::RABBITMQ);

$destination->setType(StompDestination::TYPE_AMQ_QUEUE);

$destination->setStompName('name');

$destination->setRoutingKey('routing-key');

$this->assertSame(StompDestination::TYPE_AMQ_QUEUE, $destination->getType());

$this->assertSame('name', $destination->getStompName());

$this->assertSame('routing-key', $destination->getRoutingKey());

$this->assertSame('/amq/queue/name/routing-key', $destination->getQueueName());

}

public function testShouldReturnDestinationStringWithoutRoutingKey()

{

$destination = new StompDestination(ExtensionType::RABBITMQ);

$destination->setType(StompDestination::TYPE_TOPIC);

$destination->setStompName('name');

$this->assertSame(StompDestination::TYPE_TOPIC, $destination->getType());

$this->assertSame('name', $destination->getStompName());

$this->assertNull($destination->getRoutingKey());

$this->assertSame('/topic/name', $destination->getQueueName());

}

public function testShouldThrowLogicExceptionIfNameIsNotSet()

{

$this->expectException(\LogicException::class);

$this->expectExceptionMessage('Destination name is not set');

$destination = new StompDestination(ExtensionType::RABBITMQ);

$destination->setType(StompDestination::TYPE_QUEUE);

$destination->setStompName('');

$destination->getQueueName();

}

public function testSetTypeShouldThrowLogicExceptionIfTypeIsInvalid()

{

$this->expectException(\LogicException::class);

$this->expectExceptionMessage('Invalid destination type: "invalid-type"');

$destination = new StompDestination(ExtensionType::RABBITMQ);

$destination->setType('invalid-type');

}

}