CQRS

CQRS abstraction for your application

Installation

composer req nuvolapl/cqrs

Usage

class AccountController
{
    /**
     * @var SystemInterface
     */
    private $system;

    public function __construct(SystemInterface $system)
    {
        $this->system = $system;
    }

    public function post(array $payload): void
    {
        $command = new CreateAccountCommand(
            $payload['name'],
            $payload['confirmed'],
            new \DateTimeImmutable()
        );

        $this->system->command($command);
    }

    public function get(int $id): Account
    {
        return $this->system->query(
            new GetAccountByIdQuery($id)
        );
    }

    /**
     * {@inheritdoc}
     *
     * @return Account[]
     */
    public function getCollection(array $query): array
    {
        $collection = $this->system->query(
            new GetAccountCollectionQuery(
                $query['limit'],
                $query['offset']
            )
        );

        return \iterator_to_array($collection);
    }
}

Example

• Basic - manual route configuration
• Magic - auto route configuration