ICanBoogie / MessageBus

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/Symfony/HandlerProviderPass.php

Spacing +2 added lines, -2 removed lines

@@ -69,7 +69,7 @@ 
      */
     public function process(ContainerBuilder $container): void
     {
-        [ $mapping, $refMap ] = $this->collectHandlers($container);
+        [$mapping, $refMap] = $this->collectHandlers($container);
 
         $container
             ->register($this->serviceId, $this->providerClass)
@@ -118,6 +118,6 @@ 
             $refMap[$id] = new TypedReference($id, $class);
         }
 
-        return [ $mapping, $refMap ];
+        return [$mapping, $refMap];
     }
 }

Indentation +66 added lines, -66 removed lines

@@ -27,70 +27,70 @@
  */
 class HandlerProviderPass implements CompilerPassInterface
 {
-    public const DEFAULT_SERVICE_ID = HandlerProvider::class;
-    public const DEFAULT_HANDLER_TAG = 'message_dispatcher.handler';
-    public const DEFAULT_MESSAGE_PROPERTY = 'message';
-    public const DEFAULT_PROVIDER_CLASS = ContainerHandlerProvider::class;
-
-    public function __construct(
-        private string $serviceId = self::DEFAULT_SERVICE_ID,
-        private string $handlerTag = self::DEFAULT_HANDLER_TAG,
-        private string $messageProperty = self::DEFAULT_MESSAGE_PROPERTY,
-        private string $providerClass = self::DEFAULT_PROVIDER_CLASS
-    ) {
-    }
-
-    /**
-     * @inheritdoc
-     */
-    public function process(ContainerBuilder $container): void
-    {
-        [ $mapping, $refMap ] = $this->collectHandlers($container);
-
-        $container
-            ->register($this->serviceId, $this->providerClass)
-            ->setArguments([
-                ServiceLocatorTagPass::register($container, $refMap),
-                $mapping
-            ]);
-    }
-
-    /**
-     * @return array{0: array<string, string>, 1: array<string, TypedReference>}
-     */
-    private function collectHandlers(ContainerBuilder $container): array
-    {
-        $handlers = $container->findTaggedServiceIds($this->handlerTag, true);
-        $messageProperty = $this->messageProperty;
-        $mapping = [];
-        $refMap = [];
-
-        foreach ($handlers as $id => $tags) {
-            assert(is_string($id));
-
-            $command = $tags[0][$messageProperty]
-                ?? throw new InvalidArgumentException(
-                    "The `$messageProperty` property is required for service `$id`."
-                );
-
-            assert(is_string($command));
-
-            if (isset($mapping[$command])) {
-                throw new LogicException(
-                    "The command `$command` already has an handler: `{$mapping[$command]}`."
-                );
-            }
-
-            $class = $container->getDefinition($id)->getClass();
-
-            if (!$class) {
-                throw new LogicException("Unable to get class of service `$id`.");
-            }
-
-            $mapping[$command] = $id;
-            $refMap[$id] = new TypedReference($id, $class);
-        }
-
-        return [ $mapping, $refMap ];
-    }
+	public const DEFAULT_SERVICE_ID = HandlerProvider::class;
+	public const DEFAULT_HANDLER_TAG = 'message_dispatcher.handler';
+	public const DEFAULT_MESSAGE_PROPERTY = 'message';
+	public const DEFAULT_PROVIDER_CLASS = ContainerHandlerProvider::class;
+
+	public function __construct(
+		private string $serviceId = self::DEFAULT_SERVICE_ID,
+		private string $handlerTag = self::DEFAULT_HANDLER_TAG,
+		private string $messageProperty = self::DEFAULT_MESSAGE_PROPERTY,
+		private string $providerClass = self::DEFAULT_PROVIDER_CLASS
+	) {
+	}
+
+	/**
+	 * @inheritdoc
+	 */
+	public function process(ContainerBuilder $container): void
+	{
+		[ $mapping, $refMap ] = $this->collectHandlers($container);
+
+		$container
+			->register($this->serviceId, $this->providerClass)
+			->setArguments([
+				ServiceLocatorTagPass::register($container, $refMap),
+				$mapping
+			]);
+	}
+
+	/**
+	 * @return array{0: array<string, string>, 1: array<string, TypedReference>}
+	 */
+	private function collectHandlers(ContainerBuilder $container): array
+	{
+		$handlers = $container->findTaggedServiceIds($this->handlerTag, true);
+		$messageProperty = $this->messageProperty;
+		$mapping = [];
+		$refMap = [];
+
+		foreach ($handlers as $id => $tags) {
+			assert(is_string($id));
+
+			$command = $tags[0][$messageProperty]
+				?? throw new InvalidArgumentException(
+					"The `$messageProperty` property is required for service `$id`."
+				);
+
+			assert(is_string($command));
+
+			if (isset($mapping[$command])) {
+				throw new LogicException(
+					"The command `$command` already has an handler: `{$mapping[$command]}`."
+				);
+			}
+
+			$class = $container->getDefinition($id)->getClass();
+
+			if (!$class) {
+				throw new LogicException("Unable to get class of service `$id`.");
+			}
+
+			$mapping[$command] = $id;
+			$refMap[$id] = new TypedReference($id, $class);
+		}
+
+		return [ $mapping, $refMap ];
+	}
 }

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/AssertingDispatcher.php

Indentation +25 added lines, -25 removed lines

@@ -16,32 +16,32 @@
  */
 class AssertingDispatcher implements Dispatcher
 {
-    /**
-     * @var callable
-     */
-    private $assertion;
+	/**
+	 * @var callable
+	 */
+	private $assertion;
 
-    /**
-     * @param callable $assertion
-     *     A callable that should throw an exception if the message shouldn't be dispatched.
-     */
-    public function __construct(
-        private Dispatcher $dispatcher,
-        callable $assertion
-    ) {
-        $this->dispatcher = $dispatcher;
-        $this->assertion = $assertion;
-    }
+	/**
+	 * @param callable $assertion
+	 *     A callable that should throw an exception if the message shouldn't be dispatched.
+	 */
+	public function __construct(
+		private 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/RestrictedDispatcherWithVoter.php

Indentation +13 added lines, -13 removed lines

@@ -16,19 +16,19 @@
  */
 final class RestrictedDispatcherWithVoter implements RestrictedDispatcher
 {
-    public function __construct(
-        private Dispatcher $innerDispatcher,
-        private Voter $voter,
-    ) {
-    }
+	public function __construct(
+		private Dispatcher $innerDispatcher,
+		private Voter $voter,
+	) {
+	}
 
-    /**
-     * @throws PermissionNotGranted
-     */
-    public function dispatch(object $message, Context $context): mixed
-    {
-        $this->voter->isGranted($message, $context) or throw new PermissionNotGranted($message, $context);
+	/**
+	 * @throws PermissionNotGranted
+	 */
+	public function dispatch(object $message, Context $context): mixed
+	{
+		$this->voter->isGranted($message, $context) or throw new PermissionNotGranted($message, $context);
 
-        return $this->innerDispatcher->dispatch($message);
-    }
+		return $this->innerDispatcher->dispatch($message);
+	}
 }

lib/NotInContext.php

Indentation +9 added lines, -9 removed lines

@@ -19,13 +19,13 @@
  */
 class NotInContext extends LogicException implements Exception
 {
-    /**
-     * @param class-string $class
-     */
-    public function __construct(
-        public string $class,
-        ?Throwable $previous = null
-    ) {
-        parent::__construct("Unable to find object matching: $class", 0, $previous);
-    }
+	/**
+	 * @param class-string $class
+	 */
+	public function __construct(
+		public string $class,
+		?Throwable $previous = null
+	) {
+		parent::__construct("Unable to find object matching: $class", 0, $previous);
+	}
 }

lib/RestrictedDispatcher.php

Indentation +4 added lines, -4 removed lines

@@ -13,8 +13,8 @@
 
 interface RestrictedDispatcher
 {
-    /**
-     * @throws PermissionNotGranted
-     */
-    public function dispatch(object $message, Context $context): mixed;
+	/**
+	 * @throws PermissionNotGranted
+	 */
+	public function dispatch(object $message, Context $context): mixed;
 }

lib/PermissionNotGranted.php

Indentation +10 added lines, -10 removed lines

@@ -15,14 +15,14 @@
 
 class PermissionNotGranted extends \Exception implements Exception
 {
-    /**
-     * @param Context $context
-     */
-    public function __construct(
-        public object $dispatched_message,
-        public Context $context,
-        ?Throwable $previous = null
-    ) {
-        parent::__construct("Permission not granted for message: " . $dispatched_message::class, 0, $previous);
-    }
+	/**
+	 * @param Context $context
+	 */
+	public function __construct(
+		public object $dispatched_message,
+		public Context $context,
+		?Throwable $previous = null
+	) {
+		parent::__construct("Permission not granted for message: " . $dispatched_message::class, 0, $previous);
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -23,6 +23,6 @@
         public Context $context,
         ?Throwable $previous = null
     ) {
-        parent::__construct("Permission not granted for message: " . $dispatched_message::class, 0, $previous);
+        parent::__construct("Permission not granted for message: ".$dispatched_message::class, 0, $previous);
     }
 }