ICanBoogie / MessageBus

lib/HandlerProviderWithHandlers.php

Indentation +12 added lines, -12 removed lines

@@ -16,17 +16,17 @@
  */
 final class HandlerProviderWithHandlers implements HandlerProvider
 {
-    /**
-     * @param array<class-string, callable> $handlers
-     *     Where _key_ is a message class and _value_ a handler for that message class.
-     */
-    public function __construct(
-        private array $handlers
-    ) {
-    }
+	/**
+	 * @param array<class-string, callable> $handlers
+	 *     Where _key_ is a message class and _value_ a handler for that message class.
+	 */
+	public function __construct(
+		private array $handlers
+	) {
+	}
 
-    public function getHandlerForMessage(object $message): ?callable
-    {
-        return $this->handlers[$message::class] ?? null;
-    }
+	public function getHandlerForMessage(object $message): ?callable
+	{
+		return $this->handlers[$message::class] ?? null;
+	}
 }

lib/Symfony/MessageBusPass.php

Indentation +73 added lines, -73 removed lines

@@ -30,77 +30,77 @@
  */
 final class MessageBusPass implements CompilerPassInterface
 {
-    public const DEFAULT_PARAMETER_FOR_MESSAGE_TO_HANDLER = 'message_bus.message_to_handler';
-    public const DEFAULT_TAG_FOR_HANDLER = 'message_bus.handler';
-    public const DEFAULT_ATTRIBUTE_FOR_MESSAGE = 'message';
-    public const DEFAULT_PARAMETER_FOR_PERMISSIONS_BY_MESSAGE = 'message_bus.permissions_by_message';
-    public const DEFAULT_TAG_FOR_PERMISSION = 'message_bus.permission';
-    public const DEFAULT_ATTRIBUTE_FOR_PERMISSION = 'permission';
-    public const DEFAULT_PARAMETER_FOR_PERMISSION_TO_VOTER = 'message_bus.permission_to_voter';
-    public const DEFAULT_TAG_FOR_VOTER = 'message_bus.voter';
-
-    public function __construct(
-        private string $parameterForMessageToHandler = self::DEFAULT_PARAMETER_FOR_MESSAGE_TO_HANDLER,
-        private string $tagForHandler = self::DEFAULT_TAG_FOR_HANDLER,
-        private string $attributeForMessage = self::DEFAULT_ATTRIBUTE_FOR_MESSAGE,
-        private string $parameterForPermissionsByMessage = self::DEFAULT_PARAMETER_FOR_PERMISSIONS_BY_MESSAGE,
-        private string $tagForPermission = self::DEFAULT_TAG_FOR_PERMISSION,
-        private string $attributeForPermission = self::DEFAULT_ATTRIBUTE_FOR_PERMISSION,
-        private string $parameterForPermissionToVoter = self::DEFAULT_PARAMETER_FOR_PERMISSION_TO_VOTER,
-        private string $tagForVoter = self::DEFAULT_TAG_FOR_VOTER,
-    ) {
-    }
-
-    public function process(ContainerBuilder $container): void
-    {
-        $this->processHandlersAndPermissions($container);
-        $this->processVoters($container);
-    }
-
-    /**
-     * Builds a map of message class to handler service identifier,
-     * and another of permissions by message class.
-     */
-    private function processHandlersAndPermissions(ContainerBuilder $container): void
-    {
-        $messageToHandler = [];
-        $permissionsByMessage = [];
-
-        foreach ($container->findTaggedServiceIds($this->tagForHandler) as $id => $hTags) {
-            $message = $hTags[0][$this->attributeForMessage]
-                ?? throw new InvalidArgumentException(
-                    "Missing attribute '$this->attributeForMessage' for service '$id'"
-                );
-
-            $duplicate = $messageToHandler[$message] ?? null;
-
-            if ($duplicate) {
-                throw new LogicException("Unable to register handler '$id'"
-                    . ", the handler '$duplicate' is already registered for message class '$message'");
-            }
-
-            $messageToHandler[$message] = $id;
-
-            foreach ($container->findDefinition($id)->getTag($this->tagForPermission) as $pTags) {
-                $permissionsByMessage[$message][] = $pTags[$this->attributeForPermission];
-            }
-        }
-
-        $container->setParameter($this->parameterForMessageToHandler, $messageToHandler);
-        $container->setParameter($this->parameterForPermissionsByMessage, $permissionsByMessage);
-    }
-
-    /**
-     * Builds a map of permission to voter service identifier.
-     */
-    private function processVoters(ContainerBuilder $container): void
-    {
-        $permissionToVoter = [];
-
-        foreach ($container->findTaggedServiceIds($this->tagForVoter) as $id => $tags) {
-            $permissionToVoter[$tags[0][$this->attributeForPermission]] = $id;
-        }
-
-        $container->setParameter($this->parameterForPermissionToVoter, $permissionToVoter);
-    }
+	public const DEFAULT_PARAMETER_FOR_MESSAGE_TO_HANDLER = 'message_bus.message_to_handler';
+	public const DEFAULT_TAG_FOR_HANDLER = 'message_bus.handler';
+	public const DEFAULT_ATTRIBUTE_FOR_MESSAGE = 'message';
+	public const DEFAULT_PARAMETER_FOR_PERMISSIONS_BY_MESSAGE = 'message_bus.permissions_by_message';
+	public const DEFAULT_TAG_FOR_PERMISSION = 'message_bus.permission';
+	public const DEFAULT_ATTRIBUTE_FOR_PERMISSION = 'permission';
+	public const DEFAULT_PARAMETER_FOR_PERMISSION_TO_VOTER = 'message_bus.permission_to_voter';
+	public const DEFAULT_TAG_FOR_VOTER = 'message_bus.voter';
+
+	public function __construct(
+		private string $parameterForMessageToHandler = self::DEFAULT_PARAMETER_FOR_MESSAGE_TO_HANDLER,
+		private string $tagForHandler = self::DEFAULT_TAG_FOR_HANDLER,
+		private string $attributeForMessage = self::DEFAULT_ATTRIBUTE_FOR_MESSAGE,
+		private string $parameterForPermissionsByMessage = self::DEFAULT_PARAMETER_FOR_PERMISSIONS_BY_MESSAGE,
+		private string $tagForPermission = self::DEFAULT_TAG_FOR_PERMISSION,
+		private string $attributeForPermission = self::DEFAULT_ATTRIBUTE_FOR_PERMISSION,
+		private string $parameterForPermissionToVoter = self::DEFAULT_PARAMETER_FOR_PERMISSION_TO_VOTER,
+		private string $tagForVoter = self::DEFAULT_TAG_FOR_VOTER,
+	) {
+	}
+
+	public function process(ContainerBuilder $container): void
+	{
+		$this->processHandlersAndPermissions($container);
+		$this->processVoters($container);
+	}
+
+	/**
+	 * Builds a map of message class to handler service identifier,
+	 * and another of permissions by message class.
+	 */
+	private function processHandlersAndPermissions(ContainerBuilder $container): void
+	{
+		$messageToHandler = [];
+		$permissionsByMessage = [];
+
+		foreach ($container->findTaggedServiceIds($this->tagForHandler) as $id => $hTags) {
+			$message = $hTags[0][$this->attributeForMessage]
+				?? throw new InvalidArgumentException(
+					"Missing attribute '$this->attributeForMessage' for service '$id'"
+				);
+
+			$duplicate = $messageToHandler[$message] ?? null;
+
+			if ($duplicate) {
+				throw new LogicException("Unable to register handler '$id'"
+					. ", the handler '$duplicate' is already registered for message class '$message'");
+			}
+
+			$messageToHandler[$message] = $id;
+
+			foreach ($container->findDefinition($id)->getTag($this->tagForPermission) as $pTags) {
+				$permissionsByMessage[$message][] = $pTags[$this->attributeForPermission];
+			}
+		}
+
+		$container->setParameter($this->parameterForMessageToHandler, $messageToHandler);
+		$container->setParameter($this->parameterForPermissionsByMessage, $permissionsByMessage);
+	}
+
+	/**
+	 * Builds a map of permission to voter service identifier.
+	 */
+	private function processVoters(ContainerBuilder $container): void
+	{
+		$permissionToVoter = [];
+
+		foreach ($container->findTaggedServiceIds($this->tagForVoter) as $id => $tags) {
+			$permissionToVoter[$tags[0][$this->attributeForPermission]] = $id;
+		}
+
+		$container->setParameter($this->parameterForPermissionToVoter, $permissionToVoter);
+	}
 }

lib/Symfony/MessageBusPassWithAttributes.php

Indentation +72 added lines, -72 removed lines

@@ -30,76 +30,76 @@
  */
 final class MessageBusPassWithAttributes implements CompilerPassInterface
 {
-    public function __construct(
-        private string $tagForHandler = MessageBusPass::DEFAULT_TAG_FOR_HANDLER,
-        private string $attributeForMessage = MessageBusPass::DEFAULT_ATTRIBUTE_FOR_MESSAGE,
-        private string $tagForPermission = MessageBusPass::DEFAULT_TAG_FOR_PERMISSION,
-        private string $attributeForPermission = MessageBusPass::DEFAULT_ATTRIBUTE_FOR_PERMISSION,
-        private string $tagForVoter = MessageBusPass::DEFAULT_TAG_FOR_VOTER,
-    ) {
-    }
-
-    /**
-     * @throws ReflectionException
-     */
-    public function process(ContainerBuilder $container): void
-    {
-        /** @var array<class-string, Definition> $definitions */
-        $definitions = [];
-
-        /**
-         * @var array<class-string, string[]> $permissions
-         *     Where _key_ is a command and _value_ its associated permissions.
-         */
-        $permissions = [];
-
-        foreach (Attributes::findTargetClasses(Attribute\Permission::class) as $targetClass) {
-            $permissions[$targetClass->name][] = $targetClass->attribute->permission;
-        }
-
-        foreach (Attributes::findTargetClasses(Attribute\Handler::class) as $targetClass) {
-            $handler = $targetClass->name;
-            $message = self::resolveMessage($handler);
-
-            $definition = new Definition($handler);
-            $definition->addTag($this->tagForHandler, [ $this->attributeForMessage => $message ]);
-
-            foreach ($permissions[$message] ?? [] as $permission) {
-                $definition->addTag($this->tagForPermission, [ $this->attributeForPermission => $permission ]);
-            }
-
-            $definitions[$handler] = $definition;
-        }
-
-        foreach (Attributes::findTargetClasses(Attribute\Vote::class) as $targetClass) {
-            $voter = $targetClass->name;
-            $permission = $targetClass->attribute->permission;
-
-            $definition = new Definition($voter);
-            $definition->addTag($this->tagForVoter, [ $this->attributeForPermission => $permission ]);
-
-            $definitions[$voter] = $definition;
-        }
-
-        $container->addDefinitions($definitions);
-    }
-
-    /**
-     * @param class-string $handler
-     *
-     * @return class-string
-     *
-     * @throws ReflectionException
-     */
-    private static function resolveMessage(string $handler): string
-    {
-        $type = (new ReflectionMethod($handler, '__invoke'))
-            ->getParameters()[0]
-            ->getType() ?? throw new LogicException("Expected a type for the first argument");
-
-        assert($type instanceof ReflectionNamedType);
-
-        // @phpstan-ignore-next-line
-        return $type->getName();
-    }
+	public function __construct(
+		private string $tagForHandler = MessageBusPass::DEFAULT_TAG_FOR_HANDLER,
+		private string $attributeForMessage = MessageBusPass::DEFAULT_ATTRIBUTE_FOR_MESSAGE,
+		private string $tagForPermission = MessageBusPass::DEFAULT_TAG_FOR_PERMISSION,
+		private string $attributeForPermission = MessageBusPass::DEFAULT_ATTRIBUTE_FOR_PERMISSION,
+		private string $tagForVoter = MessageBusPass::DEFAULT_TAG_FOR_VOTER,
+	) {
+	}
+
+	/**
+	 * @throws ReflectionException
+	 */
+	public function process(ContainerBuilder $container): void
+	{
+		/** @var array<class-string, Definition> $definitions */
+		$definitions = [];
+
+		/**
+		 * @var array<class-string, string[]> $permissions
+		 *     Where _key_ is a command and _value_ its associated permissions.
+		 */
+		$permissions = [];
+
+		foreach (Attributes::findTargetClasses(Attribute\Permission::class) as $targetClass) {
+			$permissions[$targetClass->name][] = $targetClass->attribute->permission;
+		}
+
+		foreach (Attributes::findTargetClasses(Attribute\Handler::class) as $targetClass) {
+			$handler = $targetClass->name;
+			$message = self::resolveMessage($handler);
+
+			$definition = new Definition($handler);
+			$definition->addTag($this->tagForHandler, [ $this->attributeForMessage => $message ]);
+
+			foreach ($permissions[$message] ?? [] as $permission) {
+				$definition->addTag($this->tagForPermission, [ $this->attributeForPermission => $permission ]);
+			}
+
+			$definitions[$handler] = $definition;
+		}
+
+		foreach (Attributes::findTargetClasses(Attribute\Vote::class) as $targetClass) {
+			$voter = $targetClass->name;
+			$permission = $targetClass->attribute->permission;
+
+			$definition = new Definition($voter);
+			$definition->addTag($this->tagForVoter, [ $this->attributeForPermission => $permission ]);
+
+			$definitions[$voter] = $definition;
+		}
+
+		$container->addDefinitions($definitions);
+	}
+
+	/**
+	 * @param class-string $handler
+	 *
+	 * @return class-string
+	 *
+	 * @throws ReflectionException
+	 */
+	private static function resolveMessage(string $handler): string
+	{
+		$type = (new ReflectionMethod($handler, '__invoke'))
+			->getParameters()[0]
+			->getType() ?? throw new LogicException("Expected a type for the first argument");
+
+		assert($type instanceof ReflectionNamedType);
+
+		// @phpstan-ignore-next-line
+		return $type->getName();
+	}
 }

Spacing +3 added lines, -3 removed lines

@@ -62,10 +62,10 @@ 
             $message = self::resolveMessage($handler);
 
             $definition = new Definition($handler);
-            $definition->addTag($this->tagForHandler, [ $this->attributeForMessage => $message ]);
+            $definition->addTag($this->tagForHandler, [$this->attributeForMessage => $message]);
 
             foreach ($permissions[$message] ?? [] as $permission) {
-                $definition->addTag($this->tagForPermission, [ $this->attributeForPermission => $permission ]);
+                $definition->addTag($this->tagForPermission, [$this->attributeForPermission => $permission]);
             }
 
             $definitions[$handler] = $definition;
@@ -76,7 +76,7 @@ 
             $permission = $targetClass->attribute->permission;
 
             $definition = new Definition($voter);
-            $definition->addTag($this->tagForVoter, [ $this->attributeForPermission => $permission ]);
+            $definition->addTag($this->tagForVoter, [$this->attributeForPermission => $permission]);
 
             $definitions[$voter] = $definition;
         }

lib/DispatcherWithHandlerProvider.php

Indentation +11 added lines, -11 removed lines

@@ -16,17 +16,17 @@
  */
 final class DispatcherWithHandlerProvider implements Dispatcher
 {
-    public function __construct(
-        private HandlerProvider $handlerProvider
-    ) {
-    }
+	public function __construct(
+		private HandlerProvider $handlerProvider
+	) {
+	}
 
-    public function dispatch(object $message)
-    {
-        $class = $message::class;
-        $handler = $this->handlerProvider->getHandlerForMessage($message)
-            ?? throw new HandlerNotFound("No handler for messages of type `$class`");
+	public function dispatch(object $message)
+	{
+		$class = $message::class;
+		$handler = $this->handlerProvider->getHandlerForMessage($message)
+			?? throw new HandlerNotFound("No handler for messages of type `$class`");
 
-        return $handler($message);
-    }
+		return $handler($message);
+	}
 }

lib/HandlerNotFound.php

Indentation +4 added lines, -4 removed lines

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

lib/PSR/HandlerProviderWithContainer.php

Indentation +19 added lines, -19 removed lines

@@ -16,26 +16,26 @@
 
 final class HandlerProviderWithContainer implements HandlerProvider
 {
-    /**
-     * @param array<class-string, string> $messageToHandler
-     *     Where _key_ is a message class and _value_ the service identifier of its handler.
-     */
-    public function __construct(
-        private ContainerInterface $container,
-        private array $messageToHandler
-    ) {
-        $this->container = $container;
-        $this->messageToHandler = $messageToHandler;
-    }
+	/**
+	 * @param array<class-string, string> $messageToHandler
+	 *     Where _key_ is a message class and _value_ the service identifier of its handler.
+	 */
+	public function __construct(
+		private ContainerInterface $container,
+		private array $messageToHandler
+	) {
+		$this->container = $container;
+		$this->messageToHandler = $messageToHandler;
+	}
 
-    public function getHandlerForMessage(object $message): ?callable
-    {
-        $id = $this->messageToHandler[$message::class] ?? null;
+	public function getHandlerForMessage(object $message): ?callable
+	{
+		$id = $this->messageToHandler[$message::class] ?? null;
 
-        if (!$id) {
-            return null;
-        }
+		if (!$id) {
+			return null;
+		}
 
-        return $this->container->get($id); // @phpstan-ignore-line
-    }
+		return $this->container->get($id); // @phpstan-ignore-line
+	}
 }

lib/Attribute/Vote.php

Indentation +4 added lines, -4 removed lines

@@ -12,8 +12,8 @@
 #[Attribute(Attribute::TARGET_CLASS)]
 final class Vote
 {
-    public function __construct(
-        public string $permission,
-    ) {
-    }
+	public function __construct(
+		public string $permission,
+	) {
+	}
 }

lib/Attribute/Permission.php

Indentation +4 added lines, -4 removed lines

@@ -23,8 +23,8 @@
 #[Attribute(Attribute::TARGET_CLASS | Attribute::IS_REPEATABLE)]
 final class Permission
 {
-    public function __construct(
-        public string $permission
-    ) {
-    }
+	public function __construct(
+		public string $permission
+	) {
+	}
 }

lib/HandlerProviderWithChain.php

Indentation +17 added lines, -17 removed lines

@@ -16,24 +16,24 @@
  */
 final class HandlerProviderWithChain implements HandlerProvider
 {
-    /**
-     * @param iterable<HandlerProvider> $providers
-     */
-    public function __construct(
-        private iterable $providers
-    ) {
-    }
+	/**
+	 * @param iterable<HandlerProvider> $providers
+	 */
+	public function __construct(
+		private iterable $providers
+	) {
+	}
 
-    public function getHandlerForMessage(object $message): ?callable
-    {
-        foreach ($this->providers as $provider) {
-            $handler = $provider->getHandlerForMessage($message);
+	public function getHandlerForMessage(object $message): ?callable
+	{
+		foreach ($this->providers as $provider) {
+			$handler = $provider->getHandlerForMessage($message);
 
-            if ($handler) {
-                return $handler;
-            }
-        }
+			if ($handler) {
+				return $handler;
+			}
+		}
 
-        return null;
-    }
+		return null;
+	}
 }