spiral / framework

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

src/Boot/src/BootloadManager.php

Spacing +13 added lines, -13 removed lines

@@ -86,7 +86,7 @@ 
 
         $this->fireCallbacks($startingCallbacks);
 
-        foreach ($bootloaders as $data) {
+        foreach ($bootloaders as $data){
             $bootloader = $data['bootloader'];
             $options = $data['options'];
             $this->invokeBootloader($bootloader, 'start', $options);
@@ -100,7 +100,7 @@ 
      */
     protected function initBootloader(BootloaderInterface $bootloader): iterable
     {
-        if ($bootloader instanceof DependedInterface) {
+        if ($bootloader instanceof DependedInterface){
             yield from $this->initBootloaders($bootloader->defineDependencies());
         }
 
@@ -117,30 +117,30 @@ 
      */
     private function initBootloaders(array $classes): Generator
     {
-        foreach ($classes as $class => $options) {
+        foreach ($classes as $class => $options){
             // default bootload syntax as simple array
-            if (\is_string($options)) {
+            if (\is_string($options)){
                 $class = $options;
                 $options = [];
             }
 
             // Replace class aliases with source classes
-            try {
+            try{
                 $class = (new ReflectionClass($class))->getName();
-            } catch (ReflectionException $e) {
+            }catch (ReflectionException $e){
                 throw new ClassNotFoundException(
                     \sprintf('Bootloader class `%s` is not exist.', $class)
                 );
             }
 
-            if (\in_array($class, $this->classes, true)) {
+            if (\in_array($class, $this->classes, true)){
                 continue;
             }
 
             $this->classes[] = $class;
             $bootloader = $this->container->get($class);
 
-            if (!$bootloader instanceof BootloaderInterface) {
+            if (!$bootloader instanceof BootloaderInterface){
                 continue;
             }
 
@@ -156,11 +156,11 @@ 
      */
     private function initBindings(array $bindings, array $singletons): void
     {
-        foreach ($bindings as $aliases => $resolver) {
+        foreach ($bindings as $aliases => $resolver){
             $this->container->bind($aliases, $resolver);
         }
 
-        foreach ($singletons as $aliases => $resolver) {
+        foreach ($singletons as $aliases => $resolver){
             $this->container->bindSingleton($aliases, $resolver);
         }
     }
@@ -168,14 +168,14 @@ 
     private function invokeBootloader(BootloaderInterface $bootloader, string $method, array $options): void
     {
         $refl = new ReflectionClass($bootloader);
-        if (!$refl->hasMethod($method)) {
+        if (!$refl->hasMethod($method)){
             return;
         }
 
         $boot = new ReflectionMethod($bootloader, $method);
 
         $args = $this->container->resolveArguments($boot);
-        if (!isset($args['boot'])) {
+        if (!isset($args['boot'])){
             $args['boot'] = $options;
         }
 
@@ -187,7 +187,7 @@ 
      */
     private function fireCallbacks(array $callbacks): void
     {
-        foreach ($callbacks as $callback) {
+        foreach ($callbacks as $callback){
             $this->container->invoke($callback);
         }
     }

Braces +27 added lines, -13 removed lines

@@ -86,7 +86,8 @@ 
 
         $this->fireCallbacks($startingCallbacks);
 
-        foreach ($bootloaders as $data) {
+        foreach ($bootloaders as $data)
+        {
             $bootloader = $data['bootloader'];
             $options = $data['options'];
             $this->invokeBootloader($bootloader, 'start', $options);
@@ -100,7 +101,8 @@ 
      */
     protected function initBootloader(BootloaderInterface $bootloader): iterable
     {
-        if ($bootloader instanceof DependedInterface) {
+        if ($bootloader instanceof DependedInterface)
+        {
             yield from $this->initBootloaders($bootloader->defineDependencies());
         }
 
@@ -117,30 +119,37 @@ 
      */
     private function initBootloaders(array $classes): Generator
     {
-        foreach ($classes as $class => $options) {
+        foreach ($classes as $class => $options)
+        {
             // default bootload syntax as simple array
-            if (\is_string($options)) {
+            if (\is_string($options))
+            {
                 $class = $options;
                 $options = [];
             }
 
             // Replace class aliases with source classes
-            try {
+            try
+            {
                 $class = (new ReflectionClass($class))->getName();
-            } catch (ReflectionException $e) {
+            }
+            catch (ReflectionException $e)
+            {
                 throw new ClassNotFoundException(
                     \sprintf('Bootloader class `%s` is not exist.', $class)
                 );
             }
 
-            if (\in_array($class, $this->classes, true)) {
+            if (\in_array($class, $this->classes, true))
+            {
                 continue;
             }
 
             $this->classes[] = $class;
             $bootloader = $this->container->get($class);
 
-            if (!$bootloader instanceof BootloaderInterface) {
+            if (!$bootloader instanceof BootloaderInterface)
+            {
                 continue;
             }
 
@@ -156,11 +165,13 @@ 
      */
     private function initBindings(array $bindings, array $singletons): void
     {
-        foreach ($bindings as $aliases => $resolver) {
+        foreach ($bindings as $aliases => $resolver)
+        {
             $this->container->bind($aliases, $resolver);
         }
 
-        foreach ($singletons as $aliases => $resolver) {
+        foreach ($singletons as $aliases => $resolver)
+        {
             $this->container->bindSingleton($aliases, $resolver);
         }
     }
@@ -168,14 +179,16 @@ 
     private function invokeBootloader(BootloaderInterface $bootloader, string $method, array $options): void
     {
         $refl = new ReflectionClass($bootloader);
-        if (!$refl->hasMethod($method)) {
+        if (!$refl->hasMethod($method))
+        {
             return;
         }
 
         $boot = new ReflectionMethod($bootloader, $method);
 
         $args = $this->container->resolveArguments($boot);
-        if (!isset($args['boot'])) {
+        if (!isset($args['boot']))
+        {
             $args['boot'] = $options;
         }
 
@@ -187,7 +200,8 @@ 
      */
     private function fireCallbacks(array $callbacks): void
     {
-        foreach ($callbacks as $callback) {
+        foreach ($callbacks as $callback)
+        {
             $this->container->invoke($callback);
         }
     }

src/Mailer/src/Message.php

Spacing +2 added lines, -2 removed lines

@@ -154,11 +154,11 @@
      */
     public function setDelay($delay): self
     {
-        if ($delay instanceof DateInterval) {
+        if ($delay instanceof DateInterval){
             $delay = (new DateTimeImmutable('NOW'))->add($delay);
         }
 
-        if ($delay instanceof DateTimeInterface) {
+        if ($delay instanceof DateTimeInterface){
             $delay = max(0, $delay->getTimestamp() - time());
         }
 

Braces +4 added lines, -2 removed lines

@@ -154,11 +154,13 @@
      */
     public function setDelay($delay): self
     {
-        if ($delay instanceof DateInterval) {
+        if ($delay instanceof DateInterval)
+        {
             $delay = (new DateTimeImmutable('NOW'))->add($delay);
         }
 
-        if ($delay instanceof DateTimeInterface) {
+        if ($delay instanceof DateTimeInterface)
+        {
             $delay = max(0, $delay->getTimestamp() - time());
         }