EventSauce\EventSourcing\DefaultHeadersDecorator::decorate()

Complexity

Conditions	2
Paths	2

Size

Total Lines	16
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	2

Importance

Changes

0

<?php
    public function decorate(Message $message): Message
    {
        $event = $message->event();
        $id = $message->header(Header::AGGREGATE_ROOT_ID);
        $headers = [
            Header::EVENT_TYPE        => $this->inflector->instanceToType($event),
            Header::TIME_OF_RECORDING => $event->timeOfRecording()->toString(),
        ];

        if ($id instanceof AggregateRootId) {
            $headers[Header::AGGREGATE_ROOT_ID] = $id->toString();
            $headers[Header::AGGREGATE_ROOT_ID_TYPE] = $this->inflector->instanceToType($id);
        }

        return $message->withHeaders($headers);
    }
}