EventSauce\EventSourcing\Integration\Upcasting\UpcastingEventsTest::upcasting_works()

Complexity

Conditions	1
Paths	1

Size

Total Lines	43
Code Lines	30

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function upcasting_works()
    {
        $clock = new TestClock();
        $pointInTime = $clock->pointInTime();

        $payload = [
            'type' => EventType::fromClassName(UpcastedEventStub::class)->toEventName(),
            'version' => 0,
            'aggregateRootId' => $uuid = AggregateRootId::create()->toString(),
            'timeOfRecording' => $pointInTime->toString(),
            'metadata' => [],
            'data' => [],
        ];

        $upcaster = new DelegatingUpcaster(new UpcasterStub());
        $serializer = new UpcastingMessageSerializer(new ConstructingMessageSerializer(), $upcaster);

        $message = iterator_to_array($serializer->unserializePayload($payload))[0];
        $expected = new Message(new UpcastedEventStub(
            new AggregateRootId($uuid),
            $pointInTime,
            'upcasted'
        ));

        $this->assertEquals($expected, $message);

        $serializeMessage = $serializer->serializeMessage($message);
        $expectedPayload = $payload = [
            'type' => EventType::fromClassName(UpcastedEventStub::class)->toEventName(),
            'version' => 1,
            'aggregateRootId' => $uuid,
            'timeOfRecording' => $pointInTime->toString(),
            'metadata' => [],
            'data' => [
                'property' => 'upcasted',
            ],
        ];

        $this->assertEquals($expectedPayload, $serializeMessage);
        $messageFromSerializedPayload = iterator_to_array($serializer->unserializePayload($expectedPayload))[0];

        $this->assertEquals($expected, $messageFromSerializedPayload);
    }
}