spiral / framework

src/Queue/src/QueueManager.php

Spacing +6 added lines, -6 removed lines

@@ -24,7 +24,7 @@ 
         private readonly ContainerInterface $container,
         private readonly FactoryInterface $factory,
         private readonly ?EventDispatcherInterface $dispatcher = null
-    ) {
+    ){
     }
 
     public function getConnection(?string $name = null): QueueInterface
@@ -33,7 +33,7 @@ 
         // Replaces alias with real pipeline name
         $name = $this->config->getAliases()[$name] ?? $name;
 
-        if (!isset($this->pipelines[$name])) {
+        if (!isset($this->pipelines[$name])){
             $this->pipelines[$name] = $this->resolveConnection($name);
         }
 
@@ -48,7 +48,7 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try{
             $driver = $this->factory->make($config['driver'], $config);
 
             $core = new InterceptableCore(
@@ -56,8 +56,8 @@ 
                 $this->dispatcher
             );
 
-            foreach ($this->config->getPushInterceptors() as $interceptor) {
-                if (\is_string($interceptor) || $interceptor instanceof Autowire) {
+            foreach ($this->config->getPushInterceptors() as $interceptor){
+                if (\is_string($interceptor) || $interceptor instanceof Autowire){
                     $interceptor = $this->container->get($interceptor);
                 }
 
@@ -66,7 +66,7 @@ 
             }
 
             return new Queue($core);
-        } catch (ContainerException $e) {
+        }catch (ContainerException $e){
             throw new Exception\NotSupportedDriverException(
                 \sprintf(
                     'Driver `%s` is not supported. Connection `%s` cannot be created. Reason: `%s`',

Braces +11 added lines, -5 removed lines

@@ -33,7 +33,8 @@ 
         // Replaces alias with real pipeline name
         $name = $this->config->getAliases()[$name] ?? $name;
 
-        if (!isset($this->pipelines[$name])) {
+        if (!isset($this->pipelines[$name]))
+        {
             $this->pipelines[$name] = $this->resolveConnection($name);
         }
 
@@ -48,7 +49,8 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try
+        {
             $driver = $this->factory->make($config['driver'], $config);
 
             $core = new InterceptableCore(
@@ -56,8 +58,10 @@ 
                 $this->dispatcher
             );
 
-            foreach ($this->config->getPushInterceptors() as $interceptor) {
-                if (\is_string($interceptor) || $interceptor instanceof Autowire) {
+            foreach ($this->config->getPushInterceptors() as $interceptor)
+            {
+                if (\is_string($interceptor) || $interceptor instanceof Autowire)
+                {
                     $interceptor = $this->container->get($interceptor);
                 }
 
@@ -66,7 +70,9 @@ 
             }
 
             return new Queue($core);
-        } catch (ContainerException $e) {
+        }
+        catch (ContainerException $e)
+        {
             throw new Exception\NotSupportedDriverException(
                 \sprintf(
                     'Driver `%s` is not supported. Connection `%s` cannot be created. Reason: `%s`',

src/Queue/src/Bootloader/QueueBootloader.php

Braces +11 added lines, -5 removed lines

@@ -66,11 +66,13 @@ 
             $registry = $container->get(QueueRegistry::class);
             $config = $container->get(QueueConfig::class);
 
-            foreach ($config->getRegistryHandlers() as $jobType => $handler) {
+            foreach ($config->getRegistryHandlers() as $jobType => $handler)
+            {
                 $registry->setHandler($jobType, $handler);
             }
 
-            foreach ($config->getRegistrySerializers() as $jobType => $serializer) {
+            foreach ($config->getRegistrySerializers() as $jobType => $serializer)
+            {
                 $registry->setSerializer($jobType, $serializer);
             }
         });
@@ -128,10 +130,14 @@ 
     ): Handler {
         $core = new InterceptableCore($core, $dispatcher);
 
-        foreach ($config->getConsumeInterceptors() as $interceptor) {
-            if (\is_string($interceptor)) {
+        foreach ($config->getConsumeInterceptors() as $interceptor)
+        {
+            if (\is_string($interceptor))
+            {
                 $interceptor = $container->get($interceptor);
-            } elseif ($interceptor instanceof Autowire) {
+            }
+            elseif ($interceptor instanceof Autowire)
+            {
                 $interceptor = $interceptor->resolve($factory);
             }
 

Spacing +9 added lines, -9 removed lines

@@ -47,7 +47,7 @@ 
 
     public function __construct(
         private readonly ConfiguratorInterface $config,
-    ) {
+    ){
     }
 
     public function init(
@@ -65,11 +65,11 @@ 
             $registry = $container->get(QueueRegistry::class);
             $config = $container->get(QueueConfig::class);
 
-            foreach ($config->getRegistryHandlers() as $jobType => $handler) {
+            foreach ($config->getRegistryHandlers() as $jobType => $handler){
                 $registry->setHandler($jobType, $handler);
             }
 
-            foreach ($config->getRegistrySerializers() as $jobType => $serializer) {
+            foreach ($config->getRegistrySerializers() as $jobType => $serializer){
                 $registry->setSerializer($jobType, $serializer);
             }
         });
@@ -78,7 +78,7 @@ 
     /**
      * @param class-string<CoreInterceptorInterface>|CoreInterceptorInterface|Autowire $interceptor
      */
-    public function addConsumeInterceptor(string|CoreInterceptorInterface|Autowire $interceptor): void
+    public function addConsumeInterceptor(string | CoreInterceptorInterface | Autowire $interceptor): void
     {
         $this->config->modify(
             QueueConfig::CONFIG,
@@ -89,7 +89,7 @@ 
     /**
      * @param class-string<CoreInterceptorInterface>|CoreInterceptorInterface|Autowire $interceptor
      */
-    public function addPushInterceptor(string|CoreInterceptorInterface|Autowire $interceptor): void
+    public function addPushInterceptor(string | CoreInterceptorInterface | Autowire $interceptor): void
     {
         $this->config->modify(
             QueueConfig::CONFIG,
@@ -114,7 +114,7 @@ 
         ContainerInterface $container,
         FactoryInterface $factory,
         ContainerRegistry $registry,
-    ) {
+    ){
         return new QueueRegistry($container, $factory, $registry);
     }
 
@@ -128,10 +128,10 @@ 
     ): Handler {
         $core = new InterceptableCore($core, $dispatcher);
 
-        foreach ($config->getConsumeInterceptors() as $interceptor) {
-            if (\is_string($interceptor)) {
+        foreach ($config->getConsumeInterceptors() as $interceptor){
+            if (\is_string($interceptor)){
                 $interceptor = $container->get($interceptor);
-            } elseif ($interceptor instanceof Autowire) {
+            } elseif ($interceptor instanceof Autowire){
                 $interceptor = $interceptor->resolve($factory);
             }
 

src/Queue/src/Core/QueueInjector.php

Spacing +7 added lines, -7 removed lines

@@ -18,24 +18,24 @@
 {
     public function __construct(
         private readonly QueueConnectionProviderInterface $queueManager
-    ) {
+    ){
     }
 
     public function createInjection(ReflectionClass $class, string $context = null): QueueInterface
     {
-        try {
-            if ($context === null) {
+        try{
+            if ($context === null){
                 $connection = $this->queueManager->getConnection();
-            } else {
+            }else{
                 // Get Queue by context
-                try {
+                try{
                     $connection = $this->queueManager->getConnection($context);
-                } catch (InvalidArgumentException) {
+                }catch (InvalidArgumentException){
                     // Case when context doesn't match to configured connections
                     return $this->queueManager->getConnection();
                 }
             }
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             throw new ContainerException(\sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e);
         }
 

Braces +15 added lines, -6 removed lines

@@ -23,19 +23,28 @@
 
     public function createInjection(ReflectionClass $class, string $context = null): QueueInterface
     {
-        try {
-            if ($context === null) {
+        try
+        {
+            if ($context === null)
+            {
                 $connection = $this->queueManager->getConnection();
-            } else {
+            }
+            else
+            {
                 // Get Queue by context
-                try {
+                try
+                {
                     $connection = $this->queueManager->getConnection($context);
-                } catch (InvalidArgumentException) {
+                }
+                catch (InvalidArgumentException)
+                {
                     // Case when context doesn't match to configured connections
                     return $this->queueManager->getConnection();
                 }
             }
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             throw new ContainerException(\sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e);
         }
 

src/Queue/tests/Core/QueueInjectorTest.php

Spacing +1 added lines, -1 removed lines

@@ -87,7 +87,7 @@
         $factory->shouldReceive('make')->andReturnUsing(function (string $name): QueueInterface {
             $result = ['sync' => $this->defaultQueue, 'test' => $this->testQueue][$name] ?? null;
 
-            if ($result === null) {
+            if ($result === null){
                 throw new NotFoundException();
             }
             return $result;

Braces +2 added lines, -1 removed lines

@@ -87,7 +87,8 @@
         $factory->shouldReceive('make')->andReturnUsing(function (string $name): QueueInterface {
             $result = ['sync' => $this->defaultQueue, 'test' => $this->testQueue][$name] ?? null;
 
-            if ($result === null) {
+            if ($result === null)
+            {
                 throw new NotFoundException();
             }
             return $result;

src/Framework/Bootloader/Auth/HttpAuthBootloader.php

Spacing +6 added lines, -6 removed lines

@@ -42,7 +42,7 @@ 
 
     public function __construct(
         private readonly ConfiguratorInterface $config
-    ) {
+    ){
     }
 
     public function init(AbstractKernel $kernel, EnvironmentInterface $env): void
@@ -57,7 +57,7 @@ 
             ]
         );
 
-        $kernel->booting(function () {
+        $kernel->booting(function (){
             $this->addTransport('cookie', $this->createDefaultCookieTransport());
             $this->addTransport('header', new HeaderTransport('X-Auth-Token'));
             $this->addTokenStorage('session', SessionTokenStorage::class);
@@ -70,7 +70,7 @@ 
      * @param non-empty-string $name
      * @param Autowire|HttpTransportInterface|class-string<HttpTransportInterface> $transport
      */
-    public function addTransport(string $name, Autowire|HttpTransportInterface|string $transport): void
+    public function addTransport(string $name, Autowire | HttpTransportInterface | string $transport): void
     {
         $this->config->modify(AuthConfig::CONFIG, new Append('transports', $name, $transport));
     }
@@ -81,7 +81,7 @@ 
      * @param non-empty-string $name
      * @param Autowire|TokenStorageInterface|class-string<TokenStorageInterface> $storage
      */
-    public function addTokenStorage(string $name, Autowire|TokenStorageInterface|string $storage): void
+    public function addTokenStorage(string $name, Autowire | TokenStorageInterface | string $storage): void
     {
         $this->config->modify(AuthConfig::CONFIG, new Append('storages', $name, $storage));
     }
@@ -104,8 +104,8 @@ 
         $registry = new TransportRegistry();
         $registry->setDefaultTransport($config->getDefaultTransport());
 
-        foreach ($config->getTransports() as $name => $transport) {
-            if ($transport instanceof Autowire) {
+        foreach ($config->getTransports() as $name => $transport){
+            if ($transport instanceof Autowire){
                 $transport = $transport->resolve($factory);
             }
 

Braces +6 added lines, -3 removed lines

@@ -57,7 +57,8 @@ 
             ]
         );
 
-        $kernel->booting(function () {
+        $kernel->booting(function ()
+        {
             $this->addTransport('cookie', $this->createDefaultCookieTransport());
             $this->addTransport('header', new HeaderTransport('X-Auth-Token'));
             $this->addTokenStorage('session', SessionTokenStorage::class);
@@ -104,8 +105,10 @@ 
         $registry = new TransportRegistry();
         $registry->setDefaultTransport($config->getDefaultTransport());
 
-        foreach ($config->getTransports() as $name => $transport) {
-            if ($transport instanceof Autowire) {
+        foreach ($config->getTransports() as $name => $transport)
+        {
+            if ($transport instanceof Autowire)
+            {
                 $transport = $transport->resolve($factory);
             }
 

src/Framework/Auth/Config/AuthConfig.php

Spacing +2 added lines, -2 removed lines

@@ -39,9 +39,9 @@
      * @return TokenStorageInterface|class-string<TokenStorageInterface>|Autowire
      * @throws InvalidArgumentException
      */
-    public function getStorage(string $name): TokenStorageInterface|string|Autowire
+    public function getStorage(string $name): TokenStorageInterface | string | Autowire
     {
-        if (!isset($this->config['storages'][$name])) {
+        if (!isset($this->config['storages'][$name])){
             throw new InvalidArgumentException(
                 \sprintf('Token storage `%s` is not defined.', $name)
             );

Braces +2 added lines, -1 removed lines

@@ -41,7 +41,8 @@
      */
     public function getStorage(string $name): TokenStorageInterface|string|Autowire
     {
-        if (!isset($this->config['storages'][$name])) {
+        if (!isset($this->config['storages'][$name]))
+        {
             throw new InvalidArgumentException(
                 \sprintf('Token storage `%s` is not defined.', $name)
             );

src/AuthHttp/src/Middleware/AuthTransportWithStorageMiddleware.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
         TransportRegistry $transportRegistry,
         ?EventDispatcherInterface $eventDispatcher = null,
         ?string $storage = null
-    ) {
+    ){
         $this->authMiddleware = new AuthTransportMiddleware(
             $transportName,
             $scope,

src/Auth/src/TokenStorageProvider.php

Spacing +4 added lines, -4 removed lines

@@ -16,14 +16,14 @@ 
     public function __construct(
         private readonly AuthConfig $config,
         private readonly FactoryInterface $factory
-    ) {
+    ){
     }
 
     public function getStorage(?string $name = null): TokenStorageInterface
     {
         $name ??= $this->config->getDefaultStorage();
 
-        if (isset($this->storages[$name])) {
+        if (isset($this->storages[$name])){
             return $this->storages[$name];
         }
 
@@ -34,11 +34,11 @@ 
     {
         $storage = $this->config->getStorage($name);
 
-        if ($storage instanceof TokenStorageInterface) {
+        if ($storage instanceof TokenStorageInterface){
             return $storage;
         }
 
-        if ($storage instanceof Autowire) {
+        if ($storage instanceof Autowire){
             return $storage->resolve($this->factory);
         }
 

Braces +6 added lines, -3 removed lines

@@ -23,7 +23,8 @@ 
     {
         $name ??= $this->config->getDefaultStorage();
 
-        if (isset($this->storages[$name])) {
+        if (isset($this->storages[$name]))
+        {
             return $this->storages[$name];
         }
 
@@ -34,11 +35,13 @@ 
     {
         $storage = $this->config->getStorage($name);
 
-        if ($storage instanceof TokenStorageInterface) {
+        if ($storage instanceof TokenStorageInterface)
+        {
             return $storage;
         }
 
-        if ($storage instanceof Autowire) {
+        if ($storage instanceof Autowire)
+        {
             return $storage->resolve($this->factory);
         }
 

src/AuthHttp/tests/Middleware/Firewall/OverwriteFirewallTest.php

Spacing +1 added lines, -1 removed lines

@@ -34,6 +34,6 @@
             new ServerRequest('GET', new Uri('/admin'), ['X-Auth-Token' => $token], 'php://input')
         );
 
-        $this->assertSame($token === 'ok' ? '/admin' : '/login', (string) $response->getBody());
+        $this->assertSame($token === 'ok' ? '/admin' : '/login', (string)$response->getBody());
     }
 }