first(commit): initial commit

Author: julien

README.md

@@ -0,0 +1,31 @@
+{
+  "name": "twc/bus-bundle",
+  "description": "Provide simple way to implement Message Bus concept in Symfony 4",
+  "keywords": [
+    "symfony",
+    "command bus",
+    "Domain events",
+    "cqrs",
+    "cqs",
+    "php",
+    "message bus"
+  ],
+  "homepage": "https://github.com/thewalkingcoder/TwcBusBundle",
+  "license": "MIT",
+  "authors": [
+    {
+      "name": "Julien T. (TheWalkingCoder)",
+      "email": "thewalkingcoder@gmail.com"
+    }
+  ],
+  "require": {
+    "php": "^7.1",
+    "symfony/dependency-injection": "^4.2",
+    "symfony/framework-bundle": "^4.2"
+  },
+  "autoload": {
+    "psr-4": {
+      "Twc\\BusBundle\\": "src/"
+    }
+  }
+}

composer.json

@@ -0,0 +1,11 @@
+<?php
+
+namespace Twc\BusBundle\Command;
+
+use Twc\BusBundle\Command\Interfaces\Command;
+use Twc\BusBundle\Command\Interfaces\CommandBusMiddleware;
+
+abstract class CommandBus implements CommandBusMiddleware
+{
+    abstract public function dispatch(Command $command): CommandResponse;
+}

src/Command/CommandBus.php

@@ -0,0 +1,39 @@
+<?php
+
+namespace Twc\BusBundle\Command;
+
+use Twc\BusBundle\Command\Interfaces\Command;
+use Twc\BusBundle\Command\Interfaces\CommandBusMiddleware;
+
+
+final class CommandBusDispatcher extends CommandBus implements CommandBusMiddleware
+{
+    private $handlers;
+
+    public function __construct(iterable $handlers)
+    {
+        $this->handlers = [];
+
+        foreach ($handlers as $handler) {
+            $this->handlers[$handler->listenTo()] = $handler;
+        }
+
+    }
+
+    public function dispatch(Command $command): CommandResponse
+    {
+        $commandClass = get_class($command);
+
+        if (false === array_key_exists($commandClass, $this->handlers)) {
+            throw new \LogicException("Handler for command $commandClass not found");
+        }
+        $handler = $this->handlers[$commandClass];
+        return $handler->handle($command);
+    }
+
+    public function appendMiddleware(CommandBusMiddleware $next): CommandBusMiddleware
+    {
+        return $this;
+    }
+
+}

src/Command/CommandBusDispatcher.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace Twc\BusBundle\Command;
+
+use Twc\BusBundle\Command\Interfaces\CommandBusMiddleware;
+
+class CommandBusFactory
+{
+
+    public static function build(iterable $handlers, iterable $middlewares): CommandBusMiddleware
+    {
+
+        $bus = new CommandBusDispatcher($handlers);
+        /** @var CommandBusMiddleware $middleware */
+        foreach ($middlewares as $middleware) {
+            $bus = $middleware->appendMiddleware($bus);
+        }
+
+        return $bus;
+    }
+}

src/Command/CommandBusFactory.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace Twc\BusBundle\Command;
+
+final class CommandResponse
+{
+    private $response;
+    private $status;
+    private $events;
+
+    public function __construct($response, int $status = 200, ?iterable $events = null)
+    {
+
+        $this->response = $response;
+        $this->status = $status;
+        $this->events = $events;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getResponse()
+    {
+        return $this->response;
+    }
+
+    /**
+     * @return int
+     */
+    public function getStatus(): int
+    {
+        return $this->status;
+    }
+
+    /**
+     * @return bool
+     */
+    public function hasEvents(): bool
+    {
+        return !empty($this->events);
+    }
+
+    /**
+     * @return iterable|null
+     */
+    public function getEvents(): ?iterable
+    {
+        return $this->events;
+    }
+
+
+}

src/Command/CommandResponse.php

@@ -0,0 +1,7 @@
+<?php
+
+namespace Twc\BusBundle\Command\Interfaces;
+
+interface Command
+{
+}

src/Command/Interfaces/Command.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace Twc\BusBundle\Command\Interfaces;
+
+
+use Twc\BusBundle\Command\CommandResponse;
+
+interface CommandBusMiddleware
+{
+
+    public function dispatch(Command $command): CommandResponse;
+
+    public function appendMiddleware(CommandBusMiddleware $next): self;
+}

src/Command/Interfaces/CommandBusMiddleware.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace Twc\BusBundle\Command\Interfaces;
+
+use Twc\BusBundle\Command\CommandResponse;
+
+interface CommandHandler
+{
+    public function handle(Command $command): CommandResponse;
+
+    public function listenTo(): string;
+}

src/Command/Interfaces/CommandHandler.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace Twc\BusBundle\DependencyInjection;
+
+use Symfony\Component\Config\FileLocator;
+use Symfony\Component\DependencyInjection\ContainerBuilder;
+use Symfony\Component\DependencyInjection\Extension\Extension;
+use Symfony\Component\DependencyInjection\Loader\YamlFileLoader;
+
+class TwcBusExtension extends Extension
+{
+    public function load(array $configs, ContainerBuilder $container)
+    {
+        $loader = new YamlFileLoader(
+            $container,
+            new FileLocator(__DIR__ . '/../Resources/config')
+        );
+        
+        $loader->load('services.yaml');
+    }
+
+}