Download the PHP package lmc/cqrs-bundle without Composer

LMC CQRS Bundle

Symfony bundle for CQRS libraries and extensions. It registers services, data collectors etc. by a configuration.

Table of contents

• Installation
• Configuration
  • Routes
  • Tags
• Services
  • Handlers
• Extensions
  • HTTP
  • Solr
• List of all predefined services

Installation

Configuration

Profiler extended configuration

TIPs:

• it is advised to set profiler: '%kernel.debug%' so it profiles (and registers all services for profiling) only when it is really used
• you can define profiler and debug in your dev/lmc_cqrs.yaml to only allow it in dev Symfony environment

Note: if you don't enable any of the extension, there will only be a CallbackQueryHandler and CallbackSendCommandHandler, so you probably need to register your own.

Routes

You must register the routes for a CQRS bundle if you enable a profiler.

Tags:

Tags are automatically registered, if your class implements an Interface and is registered in Symfony container as a service

• lmc_cqrs.query_handler (QueryHandlerInterface)
• lmc_cqrs.send_command_handler (SendCommandHandlerInterface)
• lmc_cqrs.profiler_formatter (ProfilerFormatterInterface)
• lmc_cqrs.response_decoder (ResponseDecoderInterface)

With priority

Note: Default priority is 50 and none of the predefined handlers, profilers, etc. has priority higher than 90 (see complete list below)

Services

Bundle registers all necessary services according to configuration (for example, if you set http: true it will automatically register all http handlers, etc.)

Most of the services are registered both by an alias and a class name, so it will be available for autowiring. All interfaces are automatically configured to have a tag (see Tags section above).

Handlers

There are 2 main services, which are essential to the library. Both of them have its interface to represent it, and it is advised to use it via the interface.

1. Query Fetcher Interface

• implementation Lmc\Cqrs\Handler\QueryFetcher
• alias: @lmc_cqrs.query_fetcher
• it will find a handler for your query, handles it, decodes a response and caches the result (if cache is enabled)
• provides features:
  • caching
    • requires:
      • cache_provider (set in the configuration) - service implements Psr\Cache\CacheItemPoolInterface
      • Query to implement Lmc\Cqrs\Types\Feature\CacheableInterface
    • it allows to cache a decoded result and load it again from cache
  • profiling
    • requires:
      • enabled profiler (in the configuration)
      • Query to implement Lmc\Cqrs\Types\Feature\ProfileableInterface
    • it profiles a query, its execution time, response, applied handler and decoders and shows the info in the Symfony profiler

Fetching a query

You can do whatever you want with a response, we will persist a result into db, for an example or log an error.

2. Command Sender Interface

• implementation Lmc\Cqrs\Handler\CommandSender
• alias: @lmc_cqrs.command_sender
• it will find a handler for your command, handles it, decodes a response
• provides features:
  • profiling
    • requires:
      • enabled profiler (in the configuration)
      • Command to implement Lmc\Cqrs\Types\Feature\ProfileableInterface
    • it profiles a command, its execution time, response, applied handler and decoders and shows the info in the Symfony profiler

Sending a command

You can do whatever you want with a response, we will persist a result into db, for an example or log an error.

Note: There is no logging feature in the CQRS library, if you need one, you have to implement it by yourself.

Profiler Bag

There is a profiler bag service, which is a collection of all profiler information in the current request. The information inside are used by a CqrsDataCollector, which shows them in the Symfony profiler.

It requires profiler: true in the configuration.

You can access the profiler bag either by:

• @lmc_cqrs.profiler_bag (alias)
• Lmc\Cqrs\Handler\ProfilerBag (autowiring)
• or access a CqrsDataCollector programmatically (see here)

Extensions

We offer a basic extensions for a common Commands & Queries

• PSR-7)
• Solarium)

Http

Http extension repository

Installation

NOTE: You will also need an implementation for PSR-7, PSR-17 and PSR-18 for HTTP extensions to work.

Configuration

Enabling a Http extension will allow a QueryFetcher and CommandSender to handle a PSR-7 Requests/Response and decode it.

Solr

SOLR extension repository

Installation

Configuration

Enabling a Solr extension will allow a QueryFetcher and CommandSender to handle a Solarium Requests/Result and decode it.

Solarium Query Builder

It allows you to build a Solarium request only by defining an Entity with all features you want to provide. See Solr extension readme for more information.

Note: You can specify a tag for your custom applicator by lmc_cqrs.solr.query_builder_applicator

List of all predefined services and their priorities

Note: To see a list of all services really registered in your application use bin/console debug:cqrs (it requires debug: true in your configuration)

Top most handlers for Commands & Queries

Query Handlers

Send Command Handlers

Response decoders

Profiler formatters

Other services