ojhaujjwal

DDD, CQRS and Event Sourcing in PHP

• ProophEventSourcing - Provides basic functionality for event-sourced aggregates
• ProophServiceBus - PHP Enterprise Service Bus Implementation supporting CQRS and DDD
• Broadway - Infrastructure and testing helpers for creating CQRS and event sourced applications
• EventSauce - Pragmatic event sourcing for PHP
• ProophEventMachine - The world's only CQRS / ES framework that lets you pick your Flavour ]* predaddy - Common DDD classes including an annotation driven message bus and tools for CQRS and Event Sourcing
• mmasiukevich/service-bus - CQRS\Event Sourcing\Message based framework

ojhaujjwal

Add the following xdebug.ini in your docker container:

zend_extension=/usr/lib/php/20170718/xdebug.so
xdebug.remote_enable=1
xdebug.remote_handler=dbgp
xdebug.remote_port=9000
xdebug.remote_autostart=1
xdebug.remote_connect_back=off
xdebug.idekey=debugit
xdebug.remote_host=docker.for.mac.localhost

ojhaujjwal

# Install docker-sync
sudo gem install docker-sync

# if you want to use the unison strategy instead of rsync strategy
brew install unison eugenmayer/dockersync/unox

docker-sync-stack start

ojhaujjwal

version: "2"
services:
  app-rsync:
    volumes:
      - appcode-rsync-sync:/var/www:nocopy # will be mounted on /var/www

# that the important thing
volumes:
  appcode-rsync-sync:
external: true

ojhaujjwal

<?php
$eventDispatcher = new EventDispatcher();

$eventDispatcher->addListener(
    Bernard\BernardEvents::INVOKE,
    function(Bernard\Event\EnvelopeEvent $envelopeEvent) {
        echo PHP_EOL . 'Processing: ' . $envelopeEvent->getEnvelope()->getClass();
    }
);

ojhaujjwal

<?php
namespace App\Message;

use Bernard\Message;

abstract class AbstractMessage implements Message
{  
  public function getName()
  {
    return get_class($this);

ojhaujjwal

<?php
namespace App\Handler;

use App\Message\SendForgotPasswordEmail;

class SendForgotPasswordEmailHandler
{
  private $mailer;
  
  public function __construct(Mailer $mailer)

ojhaujjwal

<?php
use Bernard\Router\ClassNameRouter;
use Bernard\Consumer;
use Bernard\Queue\RoundRobinQueue;
use Bernard\Message;

/** @var Psr\Container\ContainerInterface */
$conatiner = ...
  
$router = new ClassNameRouter();

ojhaujjwal

<?php
$handlers = [
  'SendForgotPasswordEmail' => App\Handler\SendForgotPasswordEmailHandler::class,
  'SendImportantEmail' => App\Handler\SendImportantEmailHandler::class,
];

ojhaujjwal

<?php
use App\Message\SendForgotPassword;
use App\Message\SendImportantEmail;

$router = new SimpleRouter();

$router->add('SendForgotPasswordEmail', function(SendForgotPassword $message) {
  // $mailer = ....
  // $mailer->sendMail($message->getUser()->getEmail(), 'subject', 'contents');  
});