Message.php

<?php
declare(strict_types=1);

namespace PcComponentes\Ddd\Util\Message;

use PcComponentes\Ddd\Domain\Model\ValueObject\Uuid;

abstract class Message implements \JsonSerializable
{
    private Uuid $messageId;
    private array $payload;

    protected function __construct(Uuid $messageId, array $payload)
    {
        $this->assertPrimitivePayload($payload);
        $this->messageId = $messageId;
        $this->payload = $payload;
    }

    abstract public static function messageName(): string;

    abstract public static function messageVersion(): string;

    abstract public static function messageType(): string;

    abstract public function accept(MessageVisitor $visitor): void;

    public function messageId(): Uuid
    {
        return $this->messageId;
    }

    public function messagePayload(): array
    {
        return $this->payload;
    }

    public function jsonSerialize(): array
    {
        return [
            'message_id' => $this->messageId(),
            'name' => static::messageName(),
            'version' => static::messageVersion(),
            'type' => static::messageType(),
            'payload' => $this->messagePayload(),
        ];
    }

    private function assertPrimitivePayload(array &$payload, string $index = 'payload'): void
    {
        \array_walk(
            $payload,
            function ($item, $currentIndex) use ($index) {
                $newIndex = "{$index}.{$currentIndex}";

                if (true === \is_object($item)) {
                    throw new \InvalidArgumentException(
                        \sprintf(
                            'Attribute %s is an object. Payload parameters only can be primitive.',
                            $newIndex,
                        ),
                    );
                }

                if (true !== \is_array($item)) {
                    return;
                }

                $this->assertPrimitivePayload($item, $newIndex);
            },
        );
    }
}