CQRS PHP

Command Query Responsibility Segregation PHP
Description
Command Query Responsibility Segregation (CQRS) is principle that help distinguish actions that change the state of the system from the actions that are responsible for queries it. 
To The Code!
Registering Command Handlers
Command Handlers are responsible for changing the state. 
It's a place where we will put our business logic. 

Let's first create PlaceOrder Command that will place an order in our system.
class PlaceOrder
{
    private string $orderId;
    private string $productName;
​
    public function __construct(string $orderId, string $productName)
    {
        $this->orderId = $orderId;
        $this->productName = $productName;
    }
​
    public function getOrderId(): string
    {
        return $this->orderId;
    }
​
    public function getProductName(): string
    {
        return $this->productName;
    }
}
And Command Handler.One Command can target only one handler. 
use Ecotone\Modelling\Attribute\CommandHandler;
​
class OrderService
{
    private array $orders;
​
    #[CommandHandler]
    public function placeOrder(PlaceOrder $command) : void
    {
        $this->orders[$command->getOrderId()] = $command->getProductName();
    }
}
Registering Query Handlers
Query Handlers are responsible for querying the state of the system.
Let's define GetOrder Query that will find our placed order.
class GetOrder
{
    private string $orderId;
​
    public function __construct(string $orderId)
    {
        $this->orderId = $orderId;
    }
​
    public function getOrderId(): string
    {
        return $this->orderId;
    }
}
And Query Handler. One query can target only one handler.
use Ecotone\Modelling\Attribute\CommandHandler;
use Ecotone\Modelling\Attribute\QueryHandler;
​
class OrderService
{
    private array $orders;
​
    #[CommandHandler]
    public function placeOrder(PlaceOrder $command) : void
    {
        $this->orders[$command->getOrderId()] = $command->getProductName();
    }
​
    #[QueryHandler]
    public function getOrder(GetOrder $query) : string
    {
         if (!array_key_exists($query->getOrderId(), $this->orders)) {
             throw new \InvalidArgumentException("Order was not found " . $query->getOrderId());
         }
​
         return $this->orders[$query->getOrderId()];
    }
}
Running The Example
$commandBus->send(new PlaceOrder(1, "Milk"));
​
echo $queryBus->send(new GetOrder(1));
Implementation Using Lite
​https://github.com/ecotoneframework/quickstart-examples/tree/master/src/CQRS​
Quick Start - DDD CQRS PHP
Event Handling PHP
Last updated 1 month ago