ICanBoogie / MessageBus

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/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/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);
 }

lib/Symfony/QueryHandlerProviderPass.php

Indentation +12 added lines, -12 removed lines

@@ -26,17 +26,17 @@
  */
 final class QueryHandlerProviderPass extends HandlerProviderPass
 {
-    public const DEFAULT_SERVICE_ID = QueryHandlerProvider::class;
-    public const DEFAULT_HANDLER_TAG = 'query_dispatcher.handler';
-    public const DEFAULT_MESSAGE_PROPERTY = 'query';
-    public const DEFAULT_PROVIDER_CLASS = QueryHandlerProvider::class;
+	public const DEFAULT_SERVICE_ID = QueryHandlerProvider::class;
+	public const DEFAULT_HANDLER_TAG = 'query_dispatcher.handler';
+	public const DEFAULT_MESSAGE_PROPERTY = 'query';
+	public const DEFAULT_PROVIDER_CLASS = QueryHandlerProvider::class;
 
-    public function __construct(
-        string $serviceId = self::DEFAULT_SERVICE_ID,
-        string $handlerTag = self::DEFAULT_HANDLER_TAG,
-        string $messageProperty = self::DEFAULT_MESSAGE_PROPERTY,
-        string $providerClass = self::DEFAULT_PROVIDER_CLASS
-    ) {
-        parent::__construct($serviceId, $handlerTag, $messageProperty, $providerClass);
-    }
+	public function __construct(
+		string $serviceId = self::DEFAULT_SERVICE_ID,
+		string $handlerTag = self::DEFAULT_HANDLER_TAG,
+		string $messageProperty = self::DEFAULT_MESSAGE_PROPERTY,
+		string $providerClass = self::DEFAULT_PROVIDER_CLASS
+	) {
+		parent::__construct($serviceId, $handlerTag, $messageProperty, $providerClass);
+	}
 }

lib/Symfony/CommandHandlerProviderPass.php

Indentation +12 added lines, -12 removed lines

@@ -26,17 +26,17 @@
  */
 final class CommandHandlerProviderPass extends HandlerProviderPass
 {
-    public const DEFAULT_SERVICE_ID = CommandHandlerProvider::class;
-    public const DEFAULT_HANDLER_TAG = 'command_dispatcher.handler';
-    public const DEFAULT_MESSAGE_PROPERTY = 'command';
-    public const DEFAULT_PROVIDER_CLASS = CommandHandlerProvider::class;
+	public const DEFAULT_SERVICE_ID = CommandHandlerProvider::class;
+	public const DEFAULT_HANDLER_TAG = 'command_dispatcher.handler';
+	public const DEFAULT_MESSAGE_PROPERTY = 'command';
+	public const DEFAULT_PROVIDER_CLASS = CommandHandlerProvider::class;
 
-    public function __construct(
-        string $serviceId = self::DEFAULT_SERVICE_ID,
-        string $handlerTag = self::DEFAULT_HANDLER_TAG,
-        string $messageProperty = self::DEFAULT_MESSAGE_PROPERTY,
-        string $providerClass = self::DEFAULT_PROVIDER_CLASS
-    ) {
-        parent::__construct($serviceId, $handlerTag, $messageProperty, $providerClass);
-    }
+	public function __construct(
+		string $serviceId = self::DEFAULT_SERVICE_ID,
+		string $handlerTag = self::DEFAULT_HANDLER_TAG,
+		string $messageProperty = self::DEFAULT_MESSAGE_PROPERTY,
+		string $providerClass = self::DEFAULT_PROVIDER_CLASS
+	) {
+		parent::__construct($serviceId, $handlerTag, $messageProperty, $providerClass);
+	}
 }

lib/SimpleDispatcher.php

Indentation +8 added lines, -8 removed lines

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

lib/SimpleHandlerProvider.php

Indentation +13 added lines, -13 removed lines

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