ChainTranslator.php

<?php

declare(strict_types=1);

namespace Patchlevel\EventSourcing\Message\Translator;

use Patchlevel\EventSourcing\Message\Message;

final class ChainTranslator implements Translator
{
    /** @param iterable<Translator> $translators */
    public function __construct(
        private readonly iterable $translators,
    ) {
    }

    /** @return list<Message> */
    public function __invoke(Message $message): array
    {
        $messages = [$message];

        foreach ($this->translators as $middleware) {
            $messages = $this->process($middleware, $messages);
        }

        return $messages;
    }

    /**
     * @param list<Message> $messages
     *
     * @return list<Message>
     */
    private function process(Translator $translator, array $messages): array
    {
        $result = [];

        foreach ($messages as $message) {
            $result = [...$result, ...$translator($message)];
        }

        return $result;
    }
}