PreSend.php

<?php

namespace Enqueue\Client;

final class PreSend
{
    private $message;

    private $originalMessage;

    private $commandOrTopic;

    private $producer;

    private $driver;

    public function __construct(
        string $commandOrTopic,
        Message $message,
        ProducerInterface $producer,
        DriverInterface $driver,
    ) {
        $this->message = $message;
        $this->commandOrTopic = $commandOrTopic;
        $this->producer = $producer;
        $this->driver = $driver;

        $this->originalMessage = clone $message;
    }

    public function getCommand(): string
    {
        return $this->commandOrTopic;
    }

    public function getTopic(): string
    {
        return $this->commandOrTopic;
    }

    public function changeCommand(string $newCommand): void
    {
        $this->commandOrTopic = $newCommand;
    }

    public function changeTopic(string $newTopic): void
    {
        $this->commandOrTopic = $newTopic;
    }

    public function changeBody($body, ?string $contentType = null): void
    {
        $this->message->setBody($body);

        if (null !== $contentType) {
            $this->message->setContentType($contentType);
        }
    }

    public function getMessage(): Message
    {
        return $this->message;
    }

    public function getOriginalMessage(): Message
    {
        return $this->originalMessage;
    }

    public function getProducer(): ProducerInterface
    {
        return $this->producer;
    }

    public function getDriver(): DriverInterface
    {
        return $this->driver;
    }
}