ICanBoogie / MessageBus

lib/PSR/QueryDispatcher.php

Indentation +4 added lines, -4 removed lines

@@ -18,8 +18,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

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

lib/Voter.php

Indentation +4 added lines, -4 removed lines

@@ -16,8 +16,8 @@
  */
 interface Voter
 {
-    /**
-     * Returns `true` when permission is granted, ending the voting process positively.
-     */
-    public function isGranted(object $message, Context $context): bool;
+	/**
+	 * Returns `true` when permission is granted, ending the voting process positively.
+	 */
+	public function isGranted(object $message, Context $context): bool;
 }

lib/VoterWithPermissions.php

Indentation +22 added lines, -22 removed lines

@@ -16,30 +16,30 @@
  */
 final class VoterWithPermissions implements Voter
 {
-    /**
-     * @param array<class-string, string[]> $permissionsByMessage
-     *     Where _key_ is a command class and _value_ the permissions for that message.
-     */
-    public function __construct(
-        private VoterProvider $voters,
-        private array $permissionsByMessage,
-    ) {
-    }
+	/**
+	 * @param array<class-string, string[]> $permissionsByMessage
+	 *     Where _key_ is a command class and _value_ the permissions for that message.
+	 */
+	public function __construct(
+		private VoterProvider $voters,
+		private array $permissionsByMessage,
+	) {
+	}
 
-    public function isGranted(object $message, Context $context): bool
-    {
-        $permissions = $this->permissionsByMessage[$message::class] ?? null;
+	public function isGranted(object $message, Context $context): bool
+	{
+		$permissions = $this->permissionsByMessage[$message::class] ?? null;
 
-        if (!$permissions) {
-            return true;
-        }
+		if (!$permissions) {
+			return true;
+		}
 
-        foreach ($permissions as $permission) {
-            if ($this->voters->getVoterForPermission($permission)?->isGranted($message, $context)) {
-                return true;
-            }
-        }
+		foreach ($permissions as $permission) {
+			if ($this->voters->getVoterForPermission($permission)?->isGranted($message, $context)) {
+				return true;
+			}
+		}
 
-        return false;
-    }
+		return false;
+	}
 }

lib/HandlerProviderWithHandlers.php

Indentation +14 added lines, -14 removed lines

@@ -16,20 +16,20 @@
  */
 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
-    {
-        $class = $message::class;
+	public function getHandlerForMessage(object $message): callable
+	{
+		$class = $message::class;
 
-        return $this->handlers[$class]
-            ?? throw new HandlerNotFound("No handler for messages of type `$class`.");
-    }
+		return $this->handlers[$class]
+			?? throw new HandlerNotFound("No handler for messages of type `$class`.");
+	}
 }

lib/Symfony/MessageBusPass.php

Indentation +56 added lines, -56 removed lines

@@ -29,70 +29,70 @@
  */
 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 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 __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);
-    }
+	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 = [];
+	/**
+	 * 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`"
-                );
+		foreach ($container->findTaggedServiceIds($this->tagForHandler) as $id => $hTags) {
+			$message = $hTags[0][$this->attributeForMessage]
+				?? throw new InvalidArgumentException(
+					"Missing attribute `$this->attributeForMessage` for service `$id`"
+				);
 
-            $messageToHandler[$message] = $id;
+			$messageToHandler[$message] = $id;
 
-            foreach ($container->findDefinition($id)->getTag($this->tagForPermission) as $pTags) {
-                $permissionsByMessage[$message][] = $pTags[$this->attributeForPermission];
-            }
-        }
+			foreach ($container->findDefinition($id)->getTag($this->tagForPermission) as $pTags) {
+				$permissionsByMessage[$message][] = $pTags[$this->attributeForPermission];
+			}
+		}
 
-        $container->setParameter($this->parameterForMessageToHandler, $messageToHandler);
-        $container->setParameter($this->parameterForPermissionsByMessage, $permissionsByMessage);
-    }
+		$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 = [];
+	/**
+	 * 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;
-        }
+		foreach ($container->findTaggedServiceIds($this->tagForVoter) as $id => $tags) {
+			$permissionToVoter[$tags[0][$this->attributeForPermission]] = $id;
+		}
 
-        $container->setParameter($this->parameterForPermissionToVoter, $permissionToVoter);
-    }
+		$container->setParameter($this->parameterForPermissionToVoter, $permissionToVoter);
+	}
 }

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 HandlerNotFound
-     *   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 HandlerNotFound
+	 *   The handler for the message cannot the found.
+	 */
+	public function dispatch(object $message);
 }

lib/DispatcherWithHandlerProvider.php

Indentation +8 added lines, -8 removed lines

@@ -16,13 +16,13 @@
  */
 final class DispatcherWithHandlerProvider 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/PSR/VoterProviderWithContainer.php

Indentation +19 added lines, -19 removed lines

@@ -22,25 +22,25 @@
  */
 final class VoterProviderWithContainer implements VoterProvider
 {
-    /**
-     * @param array<string, string> $permissionToVoter
-     *     Where _key_ is a permission and _value_ a voter service identifier.
-     */
-    public function __construct(
-        private ContainerInterface $container,
-        private array $permissionToVoter,
-    ) {
-    }
+	/**
+	 * @param array<string, string> $permissionToVoter
+	 *     Where _key_ is a permission and _value_ a voter service identifier.
+	 */
+	public function __construct(
+		private ContainerInterface $container,
+		private array $permissionToVoter,
+	) {
+	}
 
-    public function getVoterForPermission(string $permission): ?Voter
-    {
-        $id = $this->permissionToVoter[$permission]
-            ?? throw new VoterNotFound($permission);
+	public function getVoterForPermission(string $permission): ?Voter
+	{
+		$id = $this->permissionToVoter[$permission]
+			?? throw new VoterNotFound($permission);
 
-        try {
-            return $this->container->get($id); // @phpstan-ignore-line
-        } catch (Throwable $e) {
-            throw new VoterNotFound($permission, $e);
-        }
-    }
+		try {
+			return $this->container->get($id); // @phpstan-ignore-line
+		} catch (Throwable $e) {
+			throw new VoterNotFound($permission, $e);
+		}
+	}
 }