spiral / framework

src/Queue/src/Config/QueueConfig.php

Spacing +11 added lines, -11 removed lines

@@ -32,11 +32,11 @@ 
      */
     public function getDefaultDriver(): string
     {
-        if (!isset($this->config['default']) || empty($this->config['default'])) {
+        if (!isset($this->config['default']) || empty($this->config['default'])){
             throw new InvalidArgumentException('Default queue connection is not defined.');
         }
 
-        if (!\is_string($this->config['default'])) {
+        if (!\is_string($this->config['default'])){
             throw new InvalidArgumentException('Default queue connection config value must be a string');
         }
 
@@ -58,14 +58,14 @@ 
     {
         $connections = $this->config['connections'] ?? [];
 
-        if ($driver === null) {
+        if ($driver === null){
             return $connections;
         }
 
         $driverAliases = $this->getDriverAliases();
 
-        if (isset($driverAliases[$driver])) {
-            if (!\is_string($this->config['driverAliases'][$driver])) {
+        if (isset($driverAliases[$driver])){
+            if (!\is_string($this->config['driverAliases'][$driver])){
                 throw new InvalidArgumentException(
                     sprintf('Driver alias for `%s` value must be a string', $driver)
                 );
@@ -75,7 +75,7 @@ 
         }
 
         return array_filter($connections, static function (array $connection) use ($driverAliases, $driver): bool {
-            if (empty($connection['driver'])) {
+            if (empty($connection['driver'])){
                 return false;
             }
 
@@ -93,28 +93,28 @@ 
     {
         $connections = $this->getConnections();
 
-        if (!isset($connections[$name])) {
+        if (!isset($connections[$name])){
             throw new InvalidArgumentException(sprintf('Queue connection with given name `%s` is not defined.', $name));
         }
 
-        if (!isset($connections[$name]['driver'])) {
+        if (!isset($connections[$name]['driver'])){
             throw new InvalidArgumentException(sprintf('Driver for queue connection `%s` is not defined.', $name));
         }
 
         $connection = $connections[$name];
         $driver = $connection['driver'];
 
-        if (!\is_string($driver)) {
+        if (!\is_string($driver)){
             throw new InvalidArgumentException(
                 sprintf('Driver for queue connection `%s` value must be a string', $name)
             );
         }
 
-        if (isset($this->config['driverAliases'][$driver])) {
+        if (isset($this->config['driverAliases'][$driver])){
             $connection['driver'] = $this->config['driverAliases'][$driver];
         }
 
-        if (!\is_string($connection['driver'])) {
+        if (!\is_string($connection['driver'])){
             throw new InvalidArgumentException(
                 sprintf('Driver alias for queue connection `%s` value must be a string', $name)
             );

Braces +22 added lines, -11 removed lines

@@ -32,11 +32,13 @@ 
      */
     public function getDefaultDriver(): string
     {
-        if (!isset($this->config['default']) || empty($this->config['default'])) {
+        if (!isset($this->config['default']) || empty($this->config['default']))
+        {
             throw new InvalidArgumentException('Default queue connection is not defined.');
         }
 
-        if (!\is_string($this->config['default'])) {
+        if (!\is_string($this->config['default']))
+        {
             throw new InvalidArgumentException('Default queue connection config value must be a string');
         }
 
@@ -58,14 +60,17 @@ 
     {
         $connections = $this->config['connections'] ?? [];
 
-        if ($driver === null) {
+        if ($driver === null)
+        {
             return $connections;
         }
 
         $driverAliases = $this->getDriverAliases();
 
-        if (isset($driverAliases[$driver])) {
-            if (!\is_string($this->config['driverAliases'][$driver])) {
+        if (isset($driverAliases[$driver]))
+        {
+            if (!\is_string($this->config['driverAliases'][$driver]))
+            {
                 throw new InvalidArgumentException(
                     sprintf('Driver alias for `%s` value must be a string', $driver)
                 );
@@ -75,7 +80,8 @@ 
         }
 
         return array_filter($connections, static function (array $connection) use ($driverAliases, $driver): bool {
-            if (empty($connection['driver'])) {
+            if (empty($connection['driver']))
+            {
                 return false;
             }
 
@@ -93,28 +99,33 @@ 
     {
         $connections = $this->getConnections();
 
-        if (!isset($connections[$name])) {
+        if (!isset($connections[$name]))
+        {
             throw new InvalidArgumentException(sprintf('Queue connection with given name `%s` is not defined.', $name));
         }
 
-        if (!isset($connections[$name]['driver'])) {
+        if (!isset($connections[$name]['driver']))
+        {
             throw new InvalidArgumentException(sprintf('Driver for queue connection `%s` is not defined.', $name));
         }
 
         $connection = $connections[$name];
         $driver = $connection['driver'];
 
-        if (!\is_string($driver)) {
+        if (!\is_string($driver))
+        {
             throw new InvalidArgumentException(
                 sprintf('Driver for queue connection `%s` value must be a string', $name)
             );
         }
 
-        if (isset($this->config['driverAliases'][$driver])) {
+        if (isset($this->config['driverAliases'][$driver]))
+        {
             $connection['driver'] = $this->config['driverAliases'][$driver];
         }
 
-        if (!\is_string($connection['driver'])) {
+        if (!\is_string($connection['driver']))
+        {
             throw new InvalidArgumentException(
                 sprintf('Driver alias for queue connection `%s` value must be a string', $name)
             );

src/Queue/src/Bootloader/QueueBootloader.php

Spacing +2 added lines, -2 removed lines

@@ -57,7 +57,7 @@ 
             $registry = $container->get(HandlerRegistryInterface::class);
             $config = $container->get(QueueConfig::class);
 
-            foreach ($config->getRegistryHandlers() as $jobType => $handler) {
+            foreach ($config->getRegistryHandlers() as $jobType => $handler){
                 $registry->setHandler($jobType, $handler);
             }
         });
@@ -83,7 +83,7 @@ 
 
     private function registerJobsSerializer(Container $container): void
     {
-        $container->bindSingleton(SerializerInterface::class, static function () {
+        $container->bindSingleton(SerializerInterface::class, static function (){
             return new DefaultSerializer();
         });
     }

Braces +4 added lines, -2 removed lines

@@ -57,7 +57,8 @@ 
             $registry = $container->get(HandlerRegistryInterface::class);
             $config = $container->get(QueueConfig::class);
 
-            foreach ($config->getRegistryHandlers() as $jobType => $handler) {
+            foreach ($config->getRegistryHandlers() as $jobType => $handler)
+            {
                 $registry->setHandler($jobType, $handler);
             }
         });
@@ -83,7 +84,8 @@ 
 
     private function registerJobsSerializer(Container $container): void
     {
-        $container->bindSingleton(SerializerInterface::class, static function () {
+        $container->bindSingleton(SerializerInterface::class, static function ()
+        {
             return new DefaultSerializer();
         });
     }

src/Queue/src/DefaultSerializer.php

Spacing +4 added lines, -4 removed lines

@@ -16,9 +16,9 @@ 
      */
     public function serialize(array $payload): string
     {
-        try {
+        try{
             return \Opis\Closure\serialize($payload);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             throw new SerializationException($e->getMessage(), (int)$e->getCode(), $e);
         }
     }
@@ -28,9 +28,9 @@ 
      */
     public function deserialize(string $payload): array
     {
-        try {
+        try{
             return (array)\Opis\Closure\unserialize($payload);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             throw new SerializationException($e->getMessage(), (int)$e->getCode(), $e);
         }
     }

Braces +10 added lines, -4 removed lines

@@ -16,9 +16,12 @@ 
      */
     public function serialize(array $payload): string
     {
-        try {
+        try
+        {
             return \Opis\Closure\serialize($payload);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             throw new SerializationException($e->getMessage(), (int)$e->getCode(), $e);
         }
     }
@@ -28,9 +31,12 @@ 
      */
     public function deserialize(string $payload): array
     {
-        try {
+        try
+        {
             return (array)\Opis\Closure\unserialize($payload);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             throw new SerializationException($e->getMessage(), (int)$e->getCode(), $e);
         }
     }

src/Queue/src/QueueRegistry.php

Spacing +3 added lines, -3 removed lines

@@ -18,7 +18,7 @@ 
     public function __construct(
         ContainerInterface $container,
         HandlerRegistryInterface $handlers
-    ) {
+    ){
         $this->container = $container;
         $this->fallbackHandlers = $handlers;
     }
@@ -37,8 +37,8 @@ 
      */
     public function getHandler(string $jobType): HandlerInterface
     {
-        if (isset($this->handlers[$jobType])) {
-            if ($this->handlers[$jobType] instanceof HandlerInterface) {
+        if (isset($this->handlers[$jobType])){
+            if ($this->handlers[$jobType] instanceof HandlerInterface){
                 return $this->handlers[$jobType];
             }
 

Braces +4 added lines, -2 removed lines

@@ -37,8 +37,10 @@
      */
     public function getHandler(string $jobType): HandlerInterface
     {
-        if (isset($this->handlers[$jobType])) {
-            if ($this->handlers[$jobType] instanceof HandlerInterface) {
+        if (isset($this->handlers[$jobType]))
+        {
+            if ($this->handlers[$jobType] instanceof HandlerInterface)
+            {
                 return $this->handlers[$jobType];
             }
 

src/Queue/tests/Driver/SyncDriverTest.php

Spacing +1 added lines, -1 removed lines

@@ -67,7 +67,7 @@
             $handler = m::mock(HandlerInterface::class)
         );
 
-        $callback = function () {
+        $callback = function (){
             return 'bar';
         };
 

Braces +2 added lines, -1 removed lines

@@ -67,7 +67,8 @@
             $handler = m::mock(HandlerInterface::class)
         );
 
-        $callback = function () {
+        $callback = function ()
+        {
             return 'bar';
         };
 

src/Queue/tests/DefaultSerializerTest.php

Braces +2 added lines, -1 removed lines

@@ -31,7 +31,8 @@
             'string' => 'foo',
             'array' => ['foo'],
             'object' => $object,
-            'closure' => function () use ($object) {
+            'closure' => function () use ($object)
+            {
                 return $object;
             },
         ]);

src/Queue/tests/Job/ObjectJobTest.php

Braces +4 added lines, -2 removed lines

@@ -41,7 +41,8 @@ 
 
     public function testHandleWithHandleMethod(): void
     {
-        $object = new class($this) {
+        $object = new class($this)
+        {
             private $testCase;
 
             public function __construct($testCase)
@@ -64,7 +65,8 @@ 
 
     public function testHandleWithInvokeMethod(): void
     {
-        $object = new class($this) {
+        $object = new class($this)
+        {
             private $testCase;
 
             public function __construct($testCase)

src/Boot/src/Directories.php

Spacing +3 added lines, -3 removed lines

@@ -23,7 +23,7 @@ 
 
     public function __construct(array $directories)
     {
-        foreach ($directories as $name => $directory) {
+        foreach ($directories as $name => $directory){
             $this->set($name, $directory);
         }
     }
@@ -42,7 +42,7 @@ 
     public function set(string $name, string $path): DirectoriesInterface
     {
         $path = str_replace(['\\', '//'], '/', $path);
-        $this->directories[$name] = rtrim($path, '/') . '/';
+        $this->directories[$name] = rtrim($path, '/').'/';
 
         return $this;
     }
@@ -52,7 +52,7 @@ 
      */
     public function get(string $name): string
     {
-        if (!$this->has($name)) {
+        if (!$this->has($name)){
             throw new DirectoryException("Undefined directory '{$name}'");
         }
 

Braces +4 added lines, -2 removed lines

@@ -23,7 +23,8 @@ 
 
     public function __construct(array $directories)
     {
-        foreach ($directories as $name => $directory) {
+        foreach ($directories as $name => $directory)
+        {
             $this->set($name, $directory);
         }
     }
@@ -52,7 +53,8 @@ 
      */
     public function get(string $name): string
     {
-        if (!$this->has($name)) {
+        if (!$this->has($name))
+        {
             throw new DirectoryException("Undefined directory '{$name}'");
         }
 

src/Boot/tests/Fixtures/ConfigBootloader.php

Braces +14 added lines, -7 removed lines

@@ -18,22 +18,27 @@ 
 
     public function boot(Container $container, AbstractKernel $kernel): void
     {
-        $kernel->starting(static function (AbstractKernel $kernel) use ($container) {
+        $kernel->starting(static function (AbstractKernel $kernel) use ($container)
+        {
             $container->bind('hij', 'foo');
 
-            $kernel->starting(static function () use ($container) {
+            $kernel->starting(static function () use ($container)
+            {
                 $container->bind('ijk', 'foo');
             });
         });
 
-        $kernel->started(function (AbstractKernel $kernel) use ($container) {
+        $kernel->started(function (AbstractKernel $kernel) use ($container)
+        {
             $container->bind('jkl', 'foo');
 
-            $kernel->starting(function () use ($container) {
+            $kernel->starting(function () use ($container)
+            {
                 $container->bind('klm', 'foo');
             });
 
-            $kernel->started(function () use ($container) {
+            $kernel->started(function () use ($container)
+            {
                 $container->bind('lmn', 'foo');
             });
         });
@@ -44,11 +49,13 @@ 
     public function start(ConfigurationBootloader $configuration, AbstractKernel $kernel, Container $container): void
     {
         // won't be executed
-        $kernel->starting(function (AbstractKernel $kernel) use ($container) {
+        $kernel->starting(function (AbstractKernel $kernel) use ($container)
+        {
             $container->bind('ghi', 'foo');
         });
 
-        $kernel->started(function (AbstractKernel $kernel) use ($container) {
+        $kernel->started(function (AbstractKernel $kernel) use ($container)
+        {
             $container->bind('mno', 'foo');
         });