spiral / framework

src/Queue/src/DefaultSerializer.php

Spacing +4 added lines, -4 removed lines

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

Braces +10 added lines, -4 removed lines

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

src/Queue/src/Job/CallableJob.php

Spacing +2 added lines, -2 removed lines

@@ -20,11 +20,11 @@
 
     public function handle(string $name, string $id, array $payload): void
     {
-        if (!isset($payload['callback'])) {
+        if (!isset($payload['callback'])){
             throw new InvalidArgumentException('Payload `callback` key is required.');
         }
 
-        if (!$payload['callback'] instanceof Closure) {
+        if (!$payload['callback'] instanceof Closure){
             throw new InvalidArgumentException('Payload `callback` key value type should be a closure.');
         }
 

Braces +4 added lines, -2 removed lines

@@ -20,11 +20,13 @@
 
     public function handle(string $name, string $id, array $payload): void
     {
-        if (!isset($payload['callback'])) {
+        if (!isset($payload['callback']))
+        {
             throw new InvalidArgumentException('Payload `callback` key is required.');
         }
 
-        if (!$payload['callback'] instanceof Closure) {
+        if (!$payload['callback'] instanceof Closure)
+        {
             throw new InvalidArgumentException('Payload `callback` key value type should be a closure.');
         }
 

src/Queue/src/QueueManager.php

Spacing +3 added lines, -3 removed lines

@@ -28,7 +28,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);
         }
 
@@ -43,9 +43,9 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try{
             return $this->factory->make($config['driver'], $config);
-        } catch (ContainerException $e) {
+        }catch (ContainerException $e){
             throw new NotSupportedDriverException(
                 \sprintf(
                     'Driver `%s` is not supported. Connection `%s` cannot be created. Reason: `%s`',

Braces +7 added lines, -3 removed lines

@@ -28,7 +28,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);
         }
 
@@ -43,9 +44,12 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try
+        {
             return $this->factory->make($config['driver'], $config);
-        } catch (ContainerException $e) {
+        }
+        catch (ContainerException $e)
+        {
             throw new NotSupportedDriverException(
                 \sprintf(
                     'Driver `%s` is not supported. Connection `%s` cannot be created. Reason: `%s`',

src/Queue/src/JobHandler.php

Spacing +2 added lines, -2 removed lines

@@ -33,12 +33,12 @@
      */
     public function handle(string $name, string $id, array $payload): void
     {
-        try {
+        try{
             $this->invoker->invoke(
                 [$this, $this->getHandlerMethod()],
                 \array_merge(['payload' => $payload, 'id' => $id], $payload)
             );
-        } catch (Throwable $e) {
+        }catch (Throwable $e){
             $message = \sprintf('[%s] %s', \get_class($this), $e->getMessage());
             throw new JobException($message, (int)$e->getCode(), $e);
         }

Braces +5 added lines, -2 removed lines

@@ -33,12 +33,15 @@
      */
     public function handle(string $name, string $id, array $payload): void
     {
-        try {
+        try
+        {
             $this->invoker->invoke(
                 [$this, $this->getHandlerMethod()],
                 \array_merge(['payload' => $payload, 'id' => $id], $payload)
             );
-        } catch (Throwable $e) {
+        }
+        catch (Throwable $e)
+        {
             $message = \sprintf('[%s] %s', \get_class($this), $e->getMessage());
             throw new JobException($message, (int)$e->getCode(), $e);
         }

src/Queue/src/Driver/SyncDriver.php

Spacing +4 added lines, -4 removed lines

@@ -25,7 +25,7 @@ 
     public function __construct(
         HandlerRegistryInterface $registry,
         FailedJobHandlerInterface $failedJobHandler
-    ) {
+    ){
         $this->registry = $registry;
         $this->failedJobHandler = $failedJobHandler;
     }
@@ -33,15 +33,15 @@ 
     /** @inheritdoc */
     public function push(string $name, array $payload = [], OptionsInterface $options = null): string
     {
-        if ($options !== null && $options->getDelay()) {
+        if ($options !== null && $options->getDelay()){
             sleep($options->getDelay());
         }
 
         $id = (string)Uuid::uuid4();
 
-        try {
+        try{
             $this->registry->getHandler($name)->handle($name, $id, $payload);
-        } catch (Throwable $e) {
+        }catch (Throwable $e){
             $this->failedJobHandler->handle(
                 'sync',
                 'default',

Braces +7 added lines, -3 removed lines

@@ -33,15 +33,19 @@
     /** @inheritdoc */
     public function push(string $name, array $payload = [], OptionsInterface $options = null): string
     {
-        if ($options !== null && $options->getDelay()) {
+        if ($options !== null && $options->getDelay())
+        {
             sleep($options->getDelay());
         }
 
         $id = (string)Uuid::uuid4();
 
-        try {
+        try
+        {
             $this->registry->getHandler($name)->handle($name, $id, $payload);
-        } catch (Throwable $e) {
+        }
+        catch (Throwable $e)
+        {
             $this->failedJobHandler->handle(
                 'sync',
                 'default',

src/Queue/src/Core/QueueInjector.php

Spacing +7 added lines, -7 removed lines

@@ -27,21 +27,21 @@ 
 
     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 $e) {
+                }catch (InvalidArgumentException $e){
                     // Case when context doesn't match to configured connections
                     return $this->queueManager->getConnection();
                 }
             }
 
             $this->matchType($class, $context, $connection);
-        } catch (Throwable $e) {
+        }catch (Throwable $e){
             throw new ContainerException(sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e);
         }
 
@@ -56,7 +56,7 @@ 
     private function matchType(ReflectionClass $class, ?string $context, QueueInterface $connection): void
     {
         $className = $class->getName();
-        if ($className !== QueueInterface::class && !$connection instanceof $className) {
+        if ($className !== QueueInterface::class && !$connection instanceof $className){
             throw new RuntimeException(
                 \sprintf(
                     "The queue obtained by the context `%s` doesn't match the type `%s`.",

Braces +17 added lines, -7 removed lines

@@ -27,21 +27,30 @@ 
 
     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 $e) {
+                }
+                catch (InvalidArgumentException $e)
+                {
                     // Case when context doesn't match to configured connections
                     return $this->queueManager->getConnection();
                 }
             }
 
             $this->matchType($class, $context, $connection);
-        } catch (Throwable $e) {
+        }
+        catch (Throwable $e)
+        {
             throw new ContainerException(sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e);
         }
 
@@ -56,7 +65,8 @@ 
     private function matchType(ReflectionClass $class, ?string $context, QueueInterface $connection): void
     {
         $className = $class->getName();
-        if ($className !== QueueInterface::class && !$connection instanceof $className) {
+        if ($className !== QueueInterface::class && !$connection instanceof $className)
+        {
             throw new RuntimeException(
                 \sprintf(
                     "The queue obtained by the context `%s` doesn't match the type `%s`.",

src/Boot/src/Memory.php

Spacing +4 added lines, -4 removed lines

@@ -41,13 +41,13 @@ 
     {
         $filename = $this->getFilename($section);
 
-        if (!file_exists($filename)) {
+        if (!file_exists($filename)){
             return null;
         }
 
-        try {
+        try{
             return include($filename);
-        } catch (Throwable $e) {
+        }catch (Throwable $e){
             return null;
         }
     }
@@ -59,7 +59,7 @@ 
     {
         $this->files->write(
             $this->getFilename($section),
-            '<?php return ' . var_export($data, true) . ';',
+            '<?php return '.var_export($data, true).';',
             FilesInterface::RUNTIME,
             true
         );

Braces +7 added lines, -3 removed lines

@@ -41,13 +41,17 @@
     {
         $filename = $this->getFilename($section);
 
-        if (!file_exists($filename)) {
+        if (!file_exists($filename))
+        {
             return null;
         }
 
-        try {
+        try
+        {
             return include($filename);
-        } catch (Throwable $e) {
+        }
+        catch (Throwable $e)
+        {
             return null;
         }
     }

src/Boot/src/ExceptionHandler.php

Spacing +5 added lines, -5 removed lines

@@ -52,7 +52,7 @@ 
      */
     public static function handleShutdown(): void
     {
-        if (!empty($error = error_get_last())) {
+        if (!empty($error = error_get_last())){
             self::handleException(
                 new FatalException(
                     $error['message'],
@@ -77,7 +77,7 @@ 
      */
     public static function handleError($code, $message, $filename = '', $line = 0): void
     {
-        if (!(error_reporting() & $code)) {
+        if (!(error_reporting() & $code)){
             return;
         }
 
@@ -89,13 +89,13 @@ 
      */
     public static function handleException(Throwable $e): void
     {
-        if (self::$output === null) {
+        if (self::$output === null){
             self::$output = defined('STDERR') ? STDERR : fopen('php://stderr', 'w+');
         }
 
-        if (php_sapi_name() == 'cli') {
+        if (php_sapi_name() == 'cli'){
             $handler = new ConsoleHandler(self::$output);
-        } else {
+        }else{
             $handler = new HtmlHandler(HtmlHandler::INVERTED);
         }
 

Braces +11 added lines, -5 removed lines

@@ -52,7 +52,8 @@ 
      */
     public static function handleShutdown(): void
     {
-        if (!empty($error = error_get_last())) {
+        if (!empty($error = error_get_last()))
+        {
             self::handleException(
                 new FatalException(
                     $error['message'],
@@ -77,7 +78,8 @@ 
      */
     public static function handleError($code, $message, $filename = '', $line = 0): void
     {
-        if (!(error_reporting() & $code)) {
+        if (!(error_reporting() & $code))
+        {
             return;
         }
 
@@ -89,13 +91,17 @@ 
      */
     public static function handleException(Throwable $e): void
     {
-        if (self::$output === null) {
+        if (self::$output === null)
+        {
             self::$output = defined('STDERR') ? STDERR : fopen('php://stderr', 'w+');
         }
 
-        if (php_sapi_name() == 'cli') {
+        if (php_sapi_name() == 'cli')
+        {
             $handler = new ConsoleHandler(self::$output);
-        } else {
+        }
+        else
+        {
             $handler = new HtmlHandler(HtmlHandler::INVERTED);
         }
 

src/Boot/src/AbstractKernel.php

Spacing +10 added lines, -10 removed lines

@@ -114,7 +114,7 @@ 
         array $directories,
         bool $handleErrors = true
     ): self {
-        if ($handleErrors) {
+        if ($handleErrors){
             ExceptionHandler::register();
         }
 
@@ -137,7 +137,7 @@ 
         $environment ??= new Environment();
         $this->container->bindSingleton(EnvironmentInterface::class, $environment);
 
-        try {
+        try{
             // will protect any against env overwrite action
             $this->container->runScope(
                 [EnvironmentInterface::class => $environment],
@@ -146,7 +146,7 @@ 
                     $this->bootstrap();
                 }
             );
-        } catch (Throwable $e) {
+        }catch (Throwable $e){
             ExceptionHandler::handleException($e);
 
             return null;
@@ -166,7 +166,7 @@ 
      */
     public function starting(Closure ...$callbacks): void
     {
-        foreach ($callbacks as $callback) {
+        foreach ($callbacks as $callback){
             $this->startingCallbacks[] = $callback;
         }
     }
@@ -182,7 +182,7 @@ 
      */
     public function started(Closure ...$callbacks): void
     {
-        foreach ($callbacks as $callback) {
+        foreach ($callbacks as $callback){
             $this->startedCallbacks[] = $callback;
         }
     }
@@ -206,8 +206,8 @@ 
      */
     public function serve()
     {
-        foreach ($this->dispatchers as $dispatcher) {
-            if ($dispatcher->canServe()) {
+        foreach ($this->dispatchers as $dispatcher){
+            if ($dispatcher->canServe()){
                 return $this->container->runScope(
                     [DispatcherInterface::class => $dispatcher],
                     [$dispatcher, 'serve']
@@ -261,13 +261,13 @@ 
      */
     private function fireCallbacks(array &$callbacks): void
     {
-        if ($callbacks === []) {
+        if ($callbacks === []){
             return;
         }
 
-        do {
+        do{
             $this->container->invoke(\current($callbacks));
-        } while (\next($callbacks));
+        }while (\next($callbacks));
 
         $callbacks = [];
     }

Braces +19 added lines, -9 removed lines

@@ -114,7 +114,8 @@ 
         array $directories,
         bool $handleErrors = true
     ): self {
-        if ($handleErrors) {
+        if ($handleErrors)
+        {
             ExceptionHandler::register();
         }
 
@@ -137,7 +138,8 @@ 
         $environment ??= new Environment();
         $this->container->bindSingleton(EnvironmentInterface::class, $environment);
 
-        try {
+        try
+        {
             // will protect any against env overwrite action
             $this->container->runScope(
                 [EnvironmentInterface::class => $environment],
@@ -146,7 +148,9 @@ 
                     $this->bootstrap();
                 }
             );
-        } catch (Throwable $e) {
+        }
+        catch (Throwable $e)
+        {
             ExceptionHandler::handleException($e);
 
             return null;
@@ -166,7 +170,8 @@ 
      */
     public function starting(Closure ...$callbacks): void
     {
-        foreach ($callbacks as $callback) {
+        foreach ($callbacks as $callback)
+        {
             $this->startingCallbacks[] = $callback;
         }
     }
@@ -182,7 +187,8 @@ 
      */
     public function started(Closure ...$callbacks): void
     {
-        foreach ($callbacks as $callback) {
+        foreach ($callbacks as $callback)
+        {
             $this->startedCallbacks[] = $callback;
         }
     }
@@ -206,8 +212,10 @@ 
      */
     public function serve()
     {
-        foreach ($this->dispatchers as $dispatcher) {
-            if ($dispatcher->canServe()) {
+        foreach ($this->dispatchers as $dispatcher)
+        {
+            if ($dispatcher->canServe())
+            {
                 return $this->container->runScope(
                     [DispatcherInterface::class => $dispatcher],
                     [$dispatcher, 'serve']
@@ -261,11 +269,13 @@ 
      */
     private function fireCallbacks(array &$callbacks): void
     {
-        if ($callbacks === []) {
+        if ($callbacks === [])
+        {
             return;
         }
 
-        do {
+        do
+        {
             $this->container->invoke(\current($callbacks));
         } while (\next($callbacks));