ICanBoogie / MessageBus

lib/SimpleHandlerProvider.php

Indentation +20 added lines, -20 removed lines

@@ -16,28 +16,28 @@
  */
 final class SimpleHandlerProvider implements HandlerProvider
 {
-    /**
-     * @var array<string, callable>
-     */
-    private $handlers;
+	/**
+	 * @var array<string, callable>
+	 */
+	private $handlers;
 
-    /**
-     * @param array<string, callable> $handlers
-     */
-    public function __construct(array $handlers)
-    {
-        $this->handlers = $handlers;
-    }
+	/**
+	 * @param array<string, callable> $handlers
+	 */
+	public function __construct(array $handlers)
+	{
+		$this->handlers = $handlers;
+	}
 
-    public function getHandlerForMessage(object $message): callable
-    {
-        $class = get_class($message);
-        $handler = $this->handlers[$class] ?? null;
+	public function getHandlerForMessage(object $message): callable
+	{
+		$class = get_class($message);
+		$handler = $this->handlers[$class] ?? null;
 
-        if (!$handler) {
-            throw new NotFound("No handler for messages of type `$class`.");
-        }
+		if (!$handler) {
+			throw new NotFound("No handler for messages of type `$class`.");
+		}
 
-        return $handler;
-    }
+		return $handler;
+	}
 }

lib/HandlerProvider.php

Indentation +11 added lines, -11 removed lines

@@ -16,15 +16,15 @@
  */
 interface HandlerProvider
 {
-    /**
-     * @param object $message
-     *   A message for which to return the relevant handler.
-     *
-     * @return callable
-     *   A callable that MUST be type-compatible with $message.
-     *
-     * @throws NotFound
-     *   The handler for the message cannot the found.
-     */
-    public function getHandlerForMessage(object $message): callable;
+	/**
+	 * @param object $message
+	 *   A message for which to return the relevant handler.
+	 *
+	 * @return callable
+	 *   A callable that MUST be type-compatible with $message.
+	 *
+	 * @throws NotFound
+	 *   The handler for the message cannot the found.
+	 */
+	public function getHandlerForMessage(object $message): callable;
 }

lib/PSR/QueryDispatcher.php

Indentation +4 added lines, -4 removed lines

@@ -15,8 +15,8 @@
 
 class QueryDispatcher extends SimpleDispatcher
 {
-    public function __construct(QueryHandlerProvider $handlerProvider)
-    {
-        parent::__construct($handlerProvider);
-    }
+	public function __construct(QueryHandlerProvider $handlerProvider)
+	{
+		parent::__construct($handlerProvider);
+	}
 }

lib/PSR/ContainerHandlerProvider.php

Indentation +36 added lines, -36 removed lines

@@ -20,40 +20,40 @@
 
 class ContainerHandlerProvider implements HandlerProvider
 {
-    /**
-     * @var ContainerInterface
-     */
-    private $container;
-
-    /**
-     * @var array<string, string>
-     */
-    private $handlers;
-
-    /**
-     * @param array<string, string> $mapping
-     *   An array of key/value pairs where _key_ is a message class and _value_ the service
-     *   identifier of its handler.
-     */
-    public function __construct(ContainerInterface $container, array $mapping)
-    {
-        $this->handlers = $mapping;
-        $this->container = $container;
-    }
-
-    public function getHandlerForMessage(object $message): callable
-    {
-        $class = get_class($message);
-        $id = $this->handlers[$class] ?? null;
-
-        if (!$id) {
-            throw new NotFound("No handler for messages of type `$class`.");
-        }
-
-        try {
-            return $this->container->get($id);
-        } catch (NotFoundExceptionInterface $e) {
-            throw new NotFound("No handler for messages of type `$class`.", $e);
-        }
-    }
+	/**
+	 * @var ContainerInterface
+	 */
+	private $container;
+
+	/**
+	 * @var array<string, string>
+	 */
+	private $handlers;
+
+	/**
+	 * @param array<string, string> $mapping
+	 *   An array of key/value pairs where _key_ is a message class and _value_ the service
+	 *   identifier of its handler.
+	 */
+	public function __construct(ContainerInterface $container, array $mapping)
+	{
+		$this->handlers = $mapping;
+		$this->container = $container;
+	}
+
+	public function getHandlerForMessage(object $message): callable
+	{
+		$class = get_class($message);
+		$id = $this->handlers[$class] ?? null;
+
+		if (!$id) {
+			throw new NotFound("No handler for messages of type `$class`.");
+		}
+
+		try {
+			return $this->container->get($id);
+		} catch (NotFoundExceptionInterface $e) {
+			throw new NotFound("No handler for messages of type `$class`.", $e);
+		}
+	}
 }

lib/PSR/CommandDispatcher.php

Indentation +4 added lines, -4 removed lines

@@ -15,8 +15,8 @@
 
 class CommandDispatcher extends SimpleDispatcher
 {
-    public function __construct(CommandHandlerProvider $handlerProvider)
-    {
-        parent::__construct($handlerProvider);
-    }
+	public function __construct(CommandHandlerProvider $handlerProvider)
+	{
+		parent::__construct($handlerProvider);
+	}
 }

lib/AssertingDispatcher.php

Indentation +28 added lines, -28 removed lines

@@ -16,36 +16,36 @@
  */
 class AssertingDispatcher implements Dispatcher
 {
-    /**
-     * @var Dispatcher
-     */
-    private $dispatcher;
+	/**
+	 * @var Dispatcher
+	 */
+	private $dispatcher;
 
-    /**
-     * @var callable
-     */
-    private $assertion;
+	/**
+	 * @var callable
+	 */
+	private $assertion;
 
-    /**
-     * @param Dispatcher $dispatcher
-     * @param callable $assertion A callable that should throw an exception if the message shouldn't
-     * be dispatched.
-     */
-    public function __construct(Dispatcher $dispatcher, callable $assertion)
-    {
-        $this->dispatcher = $dispatcher;
-        $this->assertion = $assertion;
-    }
+	/**
+	 * @param Dispatcher $dispatcher
+	 * @param callable $assertion A callable that should throw an exception if the message shouldn't
+	 * be dispatched.
+	 */
+	public function __construct(Dispatcher $dispatcher, callable $assertion)
+	{
+		$this->dispatcher = $dispatcher;
+		$this->assertion = $assertion;
+	}
 
-    /**
-     * @param object $message
-     *
-     * @return mixed
-     */
-    public function dispatch(object $message)
-    {
-        ($this->assertion)($message);
+	/**
+	 * @param object $message
+	 *
+	 * @return mixed
+	 */
+	public function dispatch(object $message)
+	{
+		($this->assertion)($message);
 
-        return $this->dispatcher->dispatch($message);
-    }
+		return $this->dispatcher->dispatch($message);
+	}
 }

lib/SimpleDispatcher.php

Indentation +12 added lines, -12 removed lines

@@ -16,18 +16,18 @@
  */
 class SimpleDispatcher implements Dispatcher
 {
-    /**
-     * @var HandlerProvider
-     */
-    private $handler_provider;
+	/**
+	 * @var HandlerProvider
+	 */
+	private $handler_provider;
 
-    public function __construct(HandlerProvider $handlerProvider)
-    {
-        $this->handler_provider = $handlerProvider;
-    }
+	public function __construct(HandlerProvider $handlerProvider)
+	{
+		$this->handler_provider = $handlerProvider;
+	}
 
-    public function dispatch(object $message)
-    {
-        return $this->handler_provider->getHandlerForMessage($message)($message);
-    }
+	public function dispatch(object $message)
+	{
+		return $this->handler_provider->getHandlerForMessage($message)($message);
+	}
 }

lib/NotFound.php

Indentation +4 added lines, -4 removed lines

@@ -19,8 +19,8 @@
  */
 final class NotFound extends LogicException implements Exception
 {
-    public function __construct(string $message, Throwable $previous = null)
-    {
-        parent::__construct($message, 0, $previous);
-    }
+	public function __construct(string $message, Throwable $previous = null)
+	{
+		parent::__construct($message, 0, $previous);
+	}
 }

lib/Dispatcher.php

Indentation +11 added lines, -11 removed lines

@@ -16,15 +16,15 @@
  */
 interface Dispatcher
 {
-    /**
-     * @param object $message
-     *   The message to dispatch.
-     *
-     * @return mixed
-     *   Result type depends on the handler.
-     *
-     * @throws NotFound
-     *   The handler for the message cannot the found.
-     */
-    public function dispatch(object $message);
+	/**
+	 * @param object $message
+	 *   The message to dispatch.
+	 *
+	 * @return mixed
+	 *   Result type depends on the handler.
+	 *
+	 * @throws NotFound
+	 *   The handler for the message cannot the found.
+	 */
+	public function dispatch(object $message);
 }