spiral / framework

src/Framework/Http/Middleware/ErrorHandlerMiddleware.php

Spacing +13 added lines, -13 removed lines

@@ -57,7 +57,7 @@ 
         RendererInterface $renderer,
         ResponseFactoryInterface $responseFactory,
         ContainerInterface $container
-    ) {
+    ){
         $this->suppressErrors = $suppressErrors;
         $this->renderer = $renderer;
         $this->responseFactory = $responseFactory;
@@ -71,22 +71,22 @@ 
      */
     public function process(Request $request, Handler $handler): Response
     {
-        try {
+        try{
             return $handler->handle($request);
-        } catch (ClientException | RouterException $e) {
-            if ($e instanceof ClientException) {
+        }catch (ClientException | RouterException $e){
+            if ($e instanceof ClientException){
                 $code = $e->getCode();
-            } else {
+            }else{
                 $code = 404;
             }
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             $snapshotter = $this->getOptional(SnapshotterInterface::class);
-            if ($snapshotter !== null) {
+            if ($snapshotter !== null){
                 /** @var SnapshotterInterface $snapshotter */
                 $snapshotter->register($e);
             }
 
-            if (!$this->suppressErrors) {
+            if (!$this->suppressErrors){
                 return $this->renderError($request, $e);
             }
 
@@ -109,7 +109,7 @@ 
     {
         $response = $this->responseFactory->createResponse(500);
 
-        if ($request->getHeaderLine('Accept') == 'application/json') {
+        if ($request->getHeaderLine('Accept') == 'application/json'){
             $response = $response->withHeader('Content-Type', 'application/json');
             $handler = new JsonHandler();
             $response->getBody()->write(
@@ -121,10 +121,10 @@ 
                     )
                 )
             );
-        } else {
+        }else{
             $handler = new HtmlHandler();
             $state = $this->getOptional(StateInterface::class);
-            if ($state !== null) {
+            if ($state !== null){
                 $handler = $handler->withState($state);
             }
 
@@ -160,9 +160,9 @@ 
      */
     private function getOptional(string $class)
     {
-        try {
+        try{
             return $this->container->get($class);
-        } catch (\Throwable | ContainerExceptionInterface $se) {
+        }catch (\Throwable | ContainerExceptionInterface $se){
             return null;
         }
     }

Braces +29 added lines, -12 removed lines

@@ -71,22 +71,32 @@ 
      */
     public function process(Request $request, Handler $handler): Response
     {
-        try {
+        try
+        {
             return $handler->handle($request);
-        } catch (ClientException | RouterException $e) {
-            if ($e instanceof ClientException) {
+        }
+        catch (ClientException | RouterException $e)
+        {
+            if ($e instanceof ClientException)
+            {
                 $code = $e->getCode();
-            } else {
+            }
+            else
+            {
                 $code = 404;
             }
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             $snapshotter = $this->getOptional(SnapshotterInterface::class);
-            if ($snapshotter !== null) {
+            if ($snapshotter !== null)
+            {
                 /** @var SnapshotterInterface $snapshotter */
                 $snapshotter->register($e);
             }
 
-            if (!$this->suppressErrors) {
+            if (!$this->suppressErrors)
+            {
                 return $this->renderError($request, $e);
             }
 
@@ -109,7 +119,8 @@ 
     {
         $response = $this->responseFactory->createResponse(500);
 
-        if ($request->getHeaderLine('Accept') == 'application/json') {
+        if ($request->getHeaderLine('Accept') == 'application/json')
+        {
             $response = $response->withHeader('Content-Type', 'application/json');
             $handler = new JsonHandler();
             $response->getBody()->write(
@@ -121,10 +132,13 @@ 
                     )
                 )
             );
-        } else {
+        }
+        else
+        {
             $handler = new HtmlHandler();
             $state = $this->getOptional(StateInterface::class);
-            if ($state !== null) {
+            if ($state !== null)
+            {
                 $handler = $handler->withState($state);
             }
 
@@ -160,9 +174,12 @@ 
      */
     private function getOptional(string $class)
     {
-        try {
+        try
+        {
             return $this->container->get($class);
-        } catch (\Throwable | ContainerExceptionInterface $se) {
+        }
+        catch (\Throwable | ContainerExceptionInterface $se)
+        {
             return null;
         }
     }

src/Framework/Jobs/JobDispatcher.php

Spacing +4 added lines, -4 removed lines

@@ -39,7 +39,7 @@ 
         EnvironmentInterface $env,
         FinalizerInterface $finalizer,
         ContainerInterface $container
-    ) {
+    ){
         $this->env = $env;
         $this->finalizer = $finalizer;
         $this->container = $container;
@@ -70,7 +70,7 @@ 
         $consumer->serve(
             $worker,
             function (\Throwable $e = null): void {
-                if ($e !== null) {
+                if ($e !== null){
                     $this->handleException($e);
                 }
 
@@ -84,9 +84,9 @@ 
      */
     protected function handleException(\Throwable $e): void
     {
-        try {
+        try{
             $this->container->get(SnapshotterInterface::class)->register($e);
-        } catch (\Throwable | ContainerExceptionInterface $se) {
+        }catch (\Throwable | ContainerExceptionInterface $se){
             // no need to notify when unable to register an exception
         }
     }

Braces +7 added lines, -3 removed lines

@@ -70,7 +70,8 @@ 
         $consumer->serve(
             $worker,
             function (\Throwable $e = null): void {
-                if ($e !== null) {
+                if ($e !== null)
+                {
                     $this->handleException($e);
                 }
 
@@ -84,9 +85,12 @@ 
      */
     protected function handleException(\Throwable $e): void
     {
-        try {
+        try
+        {
             $this->container->get(SnapshotterInterface::class)->register($e);
-        } catch (\Throwable | ContainerExceptionInterface $se) {
+        }
+        catch (\Throwable | ContainerExceptionInterface $se)
+        {
             // no need to notify when unable to register an exception
         }
     }

src/Framework/Jobs/JobQueue.php

Spacing +2 added lines, -2 removed lines

@@ -42,12 +42,12 @@
      */
     public function push(string $jobType, array $payload = [], Options $options = null): string
     {
-        if ($options === null) {
+        if ($options === null){
             $options = new Options();
         }
 
         $pipeline = $this->registry->getPipeline($jobType);
-        if ($pipeline !== null && $options->getPipeline() === null) {
+        if ($pipeline !== null && $options->getPipeline() === null){
             $options = $options->withPipeline($pipeline);
         }
 

Braces +4 added lines, -2 removed lines

@@ -42,12 +42,14 @@
      */
     public function push(string $jobType, array $payload = [], Options $options = null): string
     {
-        if ($options === null) {
+        if ($options === null)
+        {
             $options = new Options();
         }
 
         $pipeline = $this->registry->getPipeline($jobType);
-        if ($pipeline !== null && $options->getPipeline() === null) {
+        if ($pipeline !== null && $options->getPipeline() === null)
+        {
             $options = $options->withPipeline($pipeline);
         }
 

src/Framework/Jobs/JobRegistry.php

Spacing +7 added lines, -7 removed lines

@@ -45,7 +45,7 @@ 
         ContainerInterface $container,
         HandlerRegistryInterface $handlers,
         SerializerRegistryInterface $serializers
-    ) {
+    ){
         $this->container = $container;
         $this->fallbackHandlers = $handlers;
         $this->fallbackSerializers = $serializers;
@@ -66,8 +66,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];
             }
 
@@ -92,20 +92,20 @@ 
      */
     public function getSerializer(string $jobType): SerializerInterface
     {
-        if (isset($this->serializers[$jobType])) {
-            if ($this->serializers[$jobType] instanceof SerializerInterface) {
+        if (isset($this->serializers[$jobType])){
+            if ($this->serializers[$jobType] instanceof SerializerInterface){
                 return $this->serializers[$jobType];
             }
 
             return $this->container->get($this->serializers[$jobType]);
         }
 
-        if (!isset($this->handlers[$jobType])) {
+        if (!isset($this->handlers[$jobType])){
             return $this->fallbackSerializers->getSerializer($jobType);
         }
 
         $handler = $this->getHandler($jobType);
-        if ($handler instanceof SerializerInterface) {
+        if ($handler instanceof SerializerInterface){
             return $handler;
         }
 

Braces +12 added lines, -6 removed lines

@@ -66,8 +66,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];
             }
 
@@ -92,20 +94,24 @@ 
      */
     public function getSerializer(string $jobType): SerializerInterface
     {
-        if (isset($this->serializers[$jobType])) {
-            if ($this->serializers[$jobType] instanceof SerializerInterface) {
+        if (isset($this->serializers[$jobType]))
+        {
+            if ($this->serializers[$jobType] instanceof SerializerInterface)
+            {
                 return $this->serializers[$jobType];
             }
 
             return $this->container->get($this->serializers[$jobType]);
         }
 
-        if (!isset($this->handlers[$jobType])) {
+        if (!isset($this->handlers[$jobType]))
+        {
             return $this->fallbackSerializers->getSerializer($jobType);
         }
 
         $handler = $this->getHandler($jobType);
-        if ($handler instanceof SerializerInterface) {
+        if ($handler instanceof SerializerInterface)
+        {
             return $handler;
         }
 

src/Framework/Console/ConsoleDispatcher.php

Spacing +8 added lines, -8 removed lines

@@ -48,7 +48,7 @@ 
         EnvironmentInterface $env,
         FinalizerInterface $finalizer,
         ContainerInterface $container
-    ) {
+    ){
         $this->env = $env;
         $this->finalizer = $finalizer;
         $this->container = $container;
@@ -79,13 +79,13 @@ 
         /** @var Console $console */
         $console = $this->container->get(Console::class);
 
-        try {
+        try{
             return $console->start($input ?? new ArgvInput(), $output);
-        } catch (Throwable $e) {
+        }catch (Throwable $e){
             $this->handleException($e, $output);
 
             return 255;
-        } finally {
+        }finally{
             $listener->disable();
             $this->finalizer->finalize(false);
         }
@@ -97,9 +97,9 @@ 
      */
     protected function handleException(Throwable $e, OutputInterface $output): void
     {
-        try {
+        try{
             $this->container->get(SnapshotterInterface::class)->register($e);
-        } catch (Throwable | ContainerExceptionInterface $se) {
+        }catch (Throwable | ContainerExceptionInterface $se){
             // no need to notify when unable to register an exception
         }
 
@@ -114,11 +114,11 @@ 
      */
     private function mapVerbosity(OutputInterface $output): int
     {
-        if ($output->isDebug()) {
+        if ($output->isDebug()){
             return ConsoleHandler::VERBOSITY_DEBUG;
         }
 
-        if ($output->isVeryVerbose()) {
+        if ($output->isVeryVerbose()){
             return ConsoleHandler::VERBOSITY_VERBOSE;
         }
 

Braces +17 added lines, -7 removed lines

@@ -79,13 +79,18 @@ 
         /** @var Console $console */
         $console = $this->container->get(Console::class);
 
-        try {
+        try
+        {
             return $console->start($input ?? new ArgvInput(), $output);
-        } catch (Throwable $e) {
+        }
+        catch (Throwable $e)
+        {
             $this->handleException($e, $output);
 
             return 255;
-        } finally {
+        }
+        finally
+        {
             $listener->disable();
             $this->finalizer->finalize(false);
         }
@@ -97,9 +102,12 @@ 
      */
     protected function handleException(Throwable $e, OutputInterface $output): void
     {
-        try {
+        try
+        {
             $this->container->get(SnapshotterInterface::class)->register($e);
-        } catch (Throwable | ContainerExceptionInterface $se) {
+        }
+        catch (Throwable | ContainerExceptionInterface $se)
+        {
             // no need to notify when unable to register an exception
         }
 
@@ -114,11 +122,13 @@ 
      */
     private function mapVerbosity(OutputInterface $output): int
     {
-        if ($output->isDebug()) {
+        if ($output->isDebug())
+        {
             return ConsoleHandler::VERBOSITY_DEBUG;
         }
 
-        if ($output->isVeryVerbose()) {
+        if ($output->isVeryVerbose())
+        {
             return ConsoleHandler::VERBOSITY_VERBOSE;
         }
 

src/Framework/Console/CommandLocator.php

Spacing +2 added lines, -2 removed lines

@@ -37,8 +37,8 @@
     public function locateCommands(): array
     {
         $commands = [];
-        foreach ($this->classes->getClasses(SymfonyCommand::class) as $class) {
-            if ($class->isAbstract()) {
+        foreach ($this->classes->getClasses(SymfonyCommand::class) as $class){
+            if ($class->isAbstract()){
                 continue;
             }
 

Braces +4 added lines, -2 removed lines

@@ -37,8 +37,10 @@
     public function locateCommands(): array
     {
         $commands = [];
-        foreach ($this->classes->getClasses(SymfonyCommand::class) as $class) {
-            if ($class->isAbstract()) {
+        foreach ($this->classes->getClasses(SymfonyCommand::class) as $class)
+        {
+            if ($class->isAbstract())
+            {
                 continue;
             }
 

src/Framework/Console/Logger/DebugListener.php

Spacing +9 added lines, -9 removed lines

@@ -51,11 +51,11 @@ 
      */
     public function __invoke(LogEvent $event): void
     {
-        if (empty($this->output)) {
+        if (empty($this->output)){
             return;
         }
 
-        if ($this->output->getVerbosity() < OutputInterface::VERBOSITY_VERY_VERBOSE) {
+        if ($this->output->getVerbosity() < OutputInterface::VERBOSITY_VERY_VERBOSE){
             return;
         }
 
@@ -93,7 +93,7 @@ 
      */
     public function enable(): self
     {
-        if (!empty($this->listenerRegistry)) {
+        if (!empty($this->listenerRegistry)){
             $this->listenerRegistry->addListener($this);
         }
 
@@ -107,7 +107,7 @@ 
      */
     public function disable(): self
     {
-        if (!empty($this->listenerRegistry)) {
+        if (!empty($this->listenerRegistry)){
             $this->listenerRegistry->removeListener($this);
         }
 
@@ -130,13 +130,13 @@ 
      */
     private function getChannel(string $channel): string
     {
-        if (!class_exists($channel, false)) {
+        if (!class_exists($channel, false)){
             return "[{$channel}]";
         }
 
-        try {
+        try{
             $reflection = new \ReflectionClass($channel);
-        } catch (\ReflectionException $e) {
+        }catch (\ReflectionException $e){
             return $channel;
         }
 
@@ -150,10 +150,10 @@ 
      */
     private function getMessage(bool $decorated, string $message): string
     {
-        if (!$decorated) {
+        if (!$decorated){
             return $message;
         }
 
-        return Color::GRAY . $message . Color::RESET;
+        return Color::GRAY.$message.Color::RESET;
     }
 }

Braces +17 added lines, -8 removed lines

@@ -51,11 +51,13 @@ 
      */
     public function __invoke(LogEvent $event): void
     {
-        if (empty($this->output)) {
+        if (empty($this->output))
+        {
             return;
         }
 
-        if ($this->output->getVerbosity() < OutputInterface::VERBOSITY_VERY_VERBOSE) {
+        if ($this->output->getVerbosity() < OutputInterface::VERBOSITY_VERY_VERBOSE)
+        {
             return;
         }
 
@@ -93,7 +95,8 @@ 
      */
     public function enable(): self
     {
-        if (!empty($this->listenerRegistry)) {
+        if (!empty($this->listenerRegistry))
+        {
             $this->listenerRegistry->addListener($this);
         }
 
@@ -107,7 +110,8 @@ 
      */
     public function disable(): self
     {
-        if (!empty($this->listenerRegistry)) {
+        if (!empty($this->listenerRegistry))
+        {
             $this->listenerRegistry->removeListener($this);
         }
 
@@ -130,13 +134,17 @@ 
      */
     private function getChannel(string $channel): string
     {
-        if (!class_exists($channel, false)) {
+        if (!class_exists($channel, false))
+        {
             return "[{$channel}]";
         }
 
-        try {
+        try
+        {
             $reflection = new \ReflectionClass($channel);
-        } catch (\ReflectionException $e) {
+        }
+        catch (\ReflectionException $e)
+        {
             return $channel;
         }
 
@@ -150,7 +158,8 @@ 
      */
     private function getMessage(bool $decorated, string $message): string
     {
-        if (!$decorated) {
+        if (!$decorated)
+        {
             return $message;
         }
 

src/Framework/Console/Sequence/RuntimeDirectory.php

Spacing +5 added lines, -5 removed lines

@@ -45,7 +45,7 @@ 
 
         $runtimeDirectory = $this->dirs->get('runtime');
 
-        if (!$this->files->exists($runtimeDirectory)) {
+        if (!$this->files->exists($runtimeDirectory)){
             $this->files->ensureDirectory($runtimeDirectory);
             $output->writeln('<comment>created</comment>');
             return;
@@ -53,11 +53,11 @@ 
         $output->writeln('<info>exists</info>');
 
 
-        foreach ($this->files->getFiles($runtimeDirectory) as $filename) {
-            try {
+        foreach ($this->files->getFiles($runtimeDirectory) as $filename){
+            try{
                 $this->files->setPermissions($filename, FilesInterface::RUNTIME);
                 $this->files->setPermissions(dirname($filename), FilesInterface::RUNTIME);
-            } catch (\Throwable $e) {
+            }catch (\Throwable $e){
                 // @codeCoverageIgnoreStart
                 $output->writeln(
                     sprintf(
@@ -70,7 +70,7 @@ 
                 // @codeCoverageIgnoreEnd
             }
 
-            if ($output->isVerbose()) {
+            if ($output->isVerbose()){
                 $output->writeln(
                     sprintf(
                         '<fg=green>[updated]</fg=green> `%s`',

Braces +11 added lines, -5 removed lines

@@ -45,7 +45,8 @@ 
 
         $runtimeDirectory = $this->dirs->get('runtime');
 
-        if (!$this->files->exists($runtimeDirectory)) {
+        if (!$this->files->exists($runtimeDirectory))
+        {
             $this->files->ensureDirectory($runtimeDirectory);
             $output->writeln('<comment>created</comment>');
             return;
@@ -53,11 +54,15 @@ 
         $output->writeln('<info>exists</info>');
 
 
-        foreach ($this->files->getFiles($runtimeDirectory) as $filename) {
-            try {
+        foreach ($this->files->getFiles($runtimeDirectory) as $filename)
+        {
+            try
+            {
                 $this->files->setPermissions($filename, FilesInterface::RUNTIME);
                 $this->files->setPermissions(dirname($filename), FilesInterface::RUNTIME);
-            } catch (\Throwable $e) {
+            }
+            catch (\Throwable $e)
+            {
                 // @codeCoverageIgnoreStart
                 $output->writeln(
                     sprintf(
@@ -70,7 +75,8 @@ 
                 // @codeCoverageIgnoreEnd
             }
 
-            if ($output->isVerbose()) {
+            if ($output->isVerbose())
+            {
                 $output->writeln(
                     sprintf(
                         '<fg=green>[updated]</fg=green> `%s`',

src/Framework/Session/SessionScope.php

Spacing +2 added lines, -2 removed lines

@@ -124,9 +124,9 @@
      */
     public function getActiveSession(): SessionInterface
     {
-        try {
+        try{
             return $this->container->get(SessionInterface::class);
-        } catch (NotFoundExceptionInterface $e) {
+        }catch (NotFoundExceptionInterface $e){
             throw new ScopeException(
                 'Unable to receive active session, invalid request scope',
                 $e->getCode(),

Braces +5 added lines, -2 removed lines

@@ -124,9 +124,12 @@
      */
     public function getActiveSession(): SessionInterface
     {
-        try {
+        try
+        {
             return $this->container->get(SessionInterface::class);
-        } catch (NotFoundExceptionInterface $e) {
+        }
+        catch (NotFoundExceptionInterface $e)
+        {
             throw new ScopeException(
                 'Unable to receive active session, invalid request scope',
                 $e->getCode(),