for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
namespace EventSauce\EventSourcing\TestUtilities;
use EventSauce\EventSourcing\Message;
use EventSauce\EventSourcing\MessageConsumer;
use EventSauce\EventSourcing\Serialization\ConstructingMessageSerializer;
use EventSauce\EventSourcing\Serialization\MessageSerializer;
use PHPUnit\Framework\TestCase;
use stdClass;
use function iterator_to_array;
class MessageConsumerThatSerializesMessages implements MessageConsumer
{
/**
* @var MessageSerializer
*/
private $serializer;
public function __construct(MessageSerializer $serializer = null)
$this->serializer = $serializer ?: new ConstructingMessageSerializer();
}
public function handle(Message $message): void
$payload = $this->serializer->serializeMessage($message);
$deserializedMessage = iterator_to_array($this->serializer->unserializePayload($payload))[0]
?? new Message(new stdClass());
TestCase::assertEquals($message->event(), $deserializedMessage->event());
EventSaucePHP /
EventSauce
