Dsantang\DomainEventsDoctrine\Outbox\OutboxMappedSuperclass

Complexity

Total Complexity

1

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	withOutboxEntry()	0	14	1

<?php

declare(strict_types=1);

namespace Dsantang\DomainEventsDoctrine\Outbox;

use DateTimeImmutable;
use Doctrine\ORM\Mapping as ORM;
use Doctrine\ORM\Mapping\MappedSuperclass;
use Ramsey\Uuid\UuidInterface;

/**
 * @MappedSuperclass
 */
abstract class OutboxMappedSuperclass
{
    /**
     * @ORM\Id()
     * @ORM\Column(type="uuid", unique=true)
     *
     * @var UuidInterface
     */
    protected $id;

    /**
     * @ORM\Column(type="string")
     *
     * @var string
     */
    protected $messageKey;

    /**
     * @ORM\Column(type="string")
     *
     * @var string
     */
    protected $messageRoute;

    /**
     * @ORM\Column(type="string")
     *
     * @var string
     */
    protected $messageType;

    /**
     * @ORM\Column(type="uuid")
     *
     * @var UuidInterface
     */
    protected $aggregateId;

    /**
     * @ORM\Column(type="string")
     *
     * @var string
     */
    protected $aggregateType;

    /**
     * @ORM\Column(type="string")
     *
     * @var string
     */
    protected $payloadType;

    /**
     * @ORM\Column(type="json")
     *
     * @var string
     */
    protected $payload;

    /**
     * @ORM\Column(type="integer")
     *
     * @var int
     */
    protected $schemaVersion;

    /**
     * @ORM\Column(type="utc_datetime_immutable")
     *
     * @var DateTimeImmutable
     */
    protected $createdAt;

    public function withOutboxEntry(OutboxEntry $outboxEntry) : OutboxMappedSuperclass
    {
        $outbox = clone $this;

        $outbox->messageKey    = $outboxEntry->getMessageKey();
        $outbox->messageRoute  = $outboxEntry->getMessageRoute();
        $outbox->messageType   = $outboxEntry->getMessageType();
        $outbox->aggregateId   = $outboxEntry->getAggregateId();
        $outbox->aggregateType = $outboxEntry->getAggregateType();
        $outbox->payloadType   = $outboxEntry->getPayloadType();
        $outbox->payload       = $outboxEntry->getPayload();
        $outbox->schemaVersion = $outboxEntry->getSchemaVersion();

        return $outbox;
    }
}