CQRS with Api Platform

README.md

Thanks to the above configuration you can now send a InputTodo that'll be handled by the InputTodoHandler.

DataTransformer.php

<?php

namespace App\DataTransformer;

use ApiPlatform\Core\DataTransformer\DataTransformerInterface;
use App\Entity\InputTodo;
use App\Entity\Todo;

final class DataTransformer implements DataTransformerInterface {
    public function transform($object, string $to, array $context = [])
    {
        return $object;
    }

    public function supportsTransformation($object, string $to, array $context = []): bool
    {
        if (\is_object($object)) {
            return false;
        }

        return Todo::class === $to && InputTodo::class === ($context['input']['class'] ?? null);
    }
}

InputTodoHandler.php

<?php

namespace App\Messenger;

use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
use App\Entity\InputTodo;

final class InputTodoHandler implements MessageHandlerInterface {
    public function __invoke(InputTodo $inputTodo) {

    }
}

Todo.php

<?php

namespace App\Entity;

use ApiPlatform\Core\Annotation\ApiResource;
use Doctrine\ORM\Mapping as ORM;

/**
 * @ApiResource(
 *   collectionOperations={
 *   "get",
 *   "post"={
 *     "messenger"=true,
 *     "output"=false,
 *     "status"=202,
 *     "input"=InputTodo::class
 *   }
 * })
 * @ORM\Entity()
 */
class Todo
{
    /**
     * @ORM\Id()
     * @ORM\GeneratedValue()
     * @ORM\Column(type="integer")
     */
    private $id;

    /**
     * @ORM\Column(type="string", length=255)
     */
    private $description;

    public function getId(): ?int
    {
        return $this->id;
    }

    public function getDescription(): ?string
    {
        return $this->description;
    }

    public function setDescription(string $description): self
    {
        $this->description = $description;

        return $this;
    }
}

TodoInput.php

<?php

namespace App\Entity;

class InputTodo {
    public $description;
}