ICanBoogie / MessageBus

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

Indentation +56 added lines, -56 removed lines

@@ -28,69 +28,69 @@
  */
 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_PERMISSION_TO_VOTER = '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_VOTERS = '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_PERMISSION_TO_VOTER = '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_VOTERS = 'message_bus.permission_to_voter';
+	public const DEFAULT_TAG_FOR_VOTER = 'message_bus.voter';
 
-    /**
-     * @param string $parameterForMessageToHandler
-     * @param string $tagForHandler
-     * @param string $attributeForMessage
-     * @param string $parameterForPermissionToVoter
-     * @param string $tagForPermission
-     * @param string $attributeForPermission
-     * @param string $parameterForVoter
-     * @param string $tagForVoter
-     */
-    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 $parameterForPermissionToVoter = self::DEFAULT_PARAMETER_FOR_PERMISSION_TO_VOTER,
-        private string $tagForPermission = self::DEFAULT_TAG_FOR_PERMISSION,
-        private string $attributeForPermission = self::DEFAULT_ATTRIBUTE_FOR_PERMISSION,
-        private string $parameterForVoter = self::DEFAULT_PARAMETER_FOR_VOTERS,
-        private string $tagForVoter = self::DEFAULT_TAG_FOR_VOTER,
-    ) {
-    }
+	/**
+	 * @param string $parameterForMessageToHandler
+	 * @param string $tagForHandler
+	 * @param string $attributeForMessage
+	 * @param string $parameterForPermissionToVoter
+	 * @param string $tagForPermission
+	 * @param string $attributeForPermission
+	 * @param string $parameterForVoter
+	 * @param string $tagForVoter
+	 */
+	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 $parameterForPermissionToVoter = self::DEFAULT_PARAMETER_FOR_PERMISSION_TO_VOTER,
+		private string $tagForPermission = self::DEFAULT_TAG_FOR_PERMISSION,
+		private string $attributeForPermission = self::DEFAULT_ATTRIBUTE_FOR_PERMISSION,
+		private string $parameterForVoter = self::DEFAULT_PARAMETER_FOR_VOTERS,
+		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);
+	}
 
-    public function processHandlersAndPermissions(ContainerBuilder $container): void
-    {
-        $messageToHandler = [];
-        $permissionsByMessage = [];
+	public function processHandlersAndPermissions(ContainerBuilder $container): void
+	{
+		$messageToHandler = [];
+		$permissionsByMessage = [];
 
-        foreach ($container->findTaggedServiceIds($this->tagForHandler) as $id => $hTags) {
-            $message = $hTags[0][$this->attributeForMessage];
-            $messageToHandler[$message] = $id;
+		foreach ($container->findTaggedServiceIds($this->tagForHandler) as $id => $hTags) {
+			$message = $hTags[0][$this->attributeForMessage];
+			$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->parameterForPermissionToVoter, $permissionsByMessage);
-    }
+		$container->setParameter($this->parameterForMessageToHandler, $messageToHandler);
+		$container->setParameter($this->parameterForPermissionToVoter, $permissionsByMessage);
+	}
 
-    public function processVoters(ContainerBuilder $container): void
-    {
-        $permissionToVoter = [];
+	public 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->parameterForVoter, $permissionToVoter);
-    }
+		$container->setParameter($this->parameterForVoter, $permissionToVoter);
+	}
 }

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

lib/Context.php

Indentation +41 added lines, -41 removed lines

@@ -18,50 +18,50 @@
  */
 final class Context
 {
-    /**
-     * @var object[]
-     */
-    private array $objects = [];
+	/**
+	 * @var object[]
+	 */
+	private array $objects = [];
 
-    /**
-     * @param iterable<object> $objects
-     */
-    public function __construct(iterable $objects = [])
-    {
-        foreach ($objects as $object) {
-            $this->add($object);
-        }
-    }
+	/**
+	 * @param iterable<object> $objects
+	 */
+	public function __construct(iterable $objects = [])
+	{
+		foreach ($objects as $object) {
+			$this->add($object);
+		}
+	}
 
-    /**
-     * Adds an object to the context.
-     */
-    public function add(object $object): self
-    {
-        array_unshift($this->objects, $object);
+	/**
+	 * Adds an object to the context.
+	 */
+	public function add(object $object): self
+	{
+		array_unshift($this->objects, $object);
 
-        return $this;
-    }
+		return $this;
+	}
 
-    /**
-     * Returns the object matching the specified class.
-     *
-     * @template T of object
-     *
-     * @param class-string<T> $class
-     *
-     * @return T
-     *
-     * @throws NotInContext
-     */
-    public function get(string $class): object
-    {
-        foreach ($this->objects as $object) {
-            if ($object instanceof $class) {
-                return $object;
-            }
-        }
+	/**
+	 * Returns the object matching the specified class.
+	 *
+	 * @template T of object
+	 *
+	 * @param class-string<T> $class
+	 *
+	 * @return T
+	 *
+	 * @throws NotInContext
+	 */
+	public function get(string $class): object
+	{
+		foreach ($this->objects as $object) {
+			if ($object instanceof $class) {
+				return $object;
+			}
+		}
 
-        throw new NotInContext($class);
-    }
+		throw new NotInContext($class);
+	}
 }

lib/PSR/VoterProviderWithContainer.php

Indentation +19 added lines, -19 removed lines

@@ -22,25 +22,25 @@
  */
 final class VoterProviderWithContainer implements VoterProvider
 {
-    /**
-     * @param array<string, string> $permissionToService
-     *     Where _key_ is a permission and _value_ a service.
-     */
-    public function __construct(
-        private ContainerInterface $container,
-        private array $permissionToService,
-    ) {
-    }
+	/**
+	 * @param array<string, string> $permissionToService
+	 *     Where _key_ is a permission and _value_ a service.
+	 */
+	public function __construct(
+		private ContainerInterface $container,
+		private array $permissionToService,
+	) {
+	}
 
-    public function getVoterForPermission(string $permission): ?Voter
-    {
-        $id = $this->permissionToService[$permission]
-            ?? throw new VoterNotFound($permission);
+	public function getVoterForPermission(string $permission): ?Voter
+	{
+		$id = $this->permissionToService[$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);
+		}
+	}
 }

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