kreta / Kreta

use PhpSpec\ObjectBehavior;

use Prophecy\Argument;

class UserSignedUpSubscriberSpec extends ObjectBehavior

{

    function let(CommandBus $commandBus)

    {

        $this->beConstructedWith($commandBus);

    }

    function it_is_initializable()

    {

        $this->shouldHaveType(UserSignedUpSubscriber::class);

        $this->shouldHaveType(AsyncEventSubscriber::class);

    }

    function it_can_be_handle(AsyncDomainEvent $event, CommandBus $commandBus)

    {

        $event->values()->shouldBeCalled()->willReturn([

            'userId' => 'user-id',

        ]);

        $commandBus->handle(Argument::type(SignUpUserCommand::class))->shouldBeCalled();

        $this->handle($event);

    }

    function it_cannot_be_handle_when_values_does_not_contain_user_id(AsyncDomainEvent $event)

    {

        $event->values()->shouldBeCalled()->willReturn([]);

        $this->shouldThrow(AsyncDomainEventValueDoesNotExistException::class)->duringHandle($event);

    }

}

use PhpSpec\ObjectBehavior;

use Prophecy\Argument;

class UserRegisteredSubscriberSpec extends ObjectBehavior

{

    function let(CommandBus $commandBus)

    {

        $this->beConstructedWith($commandBus);

    }

    function it_is_initializable()

    {

        $this->shouldHaveType(UserRegisteredSubscriber::class);

        $this->shouldHaveType(AsyncEventSubscriber::class);

    }

    function it_can_be_handle(AsyncDomainEvent $event, CommandBus $commandBus)

    {

        $event->values()->shouldBeCalled()->willReturn([

            'userId' => 'user-id',

        ]);

        $commandBus->handle(Argument::type(AddUserCommand::class))->shouldBeCalled();

        $this->handle($event);

    }

    function it_cannot_be_handle_when_values_does_not_contain_user_id(AsyncDomainEvent $event)

    {

        $event->values()->shouldBeCalled()->willReturn([]);

        $this->shouldThrow(AsyncDomainEventValueDoesNotExistException::class)->duringHandle($event);

    }

}