spiral / framework

src/Framework/Http/SapiDispatcher.php

Spacing +6 added lines, -6 removed lines

@@ -62,12 +62,12 @@ 
         $http = $this->container->get(Http::class);
         $emitter = $emitter ?? $this->container->get(EmitterInterface::class);
 
-        try {
+        try{
             $response = $http->handle($this->initRequest());
             $emitter->emit($response);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             $this->handleException($emitter, $e);
-        } finally {
+        }finally{
             $this->finalizer->finalize(false);
         }
     }
@@ -88,16 +88,16 @@ 
     {
         $handler = new HtmlHandler();
 
-        try {
+        try{
             /** @var SnapshotInterface $snapshot */
             $this->container->get(SnapshotterInterface::class)->register($e);
 
             // on demand
             $state = $this->container->get(StateInterface::class);
-            if ($state !== null) {
+            if ($state !== null){
                 $handler = $handler->withState($state);
             }
-        } catch (\Throwable | ContainerExceptionInterface $se) {
+        }catch (\Throwable | ContainerExceptionInterface $se){
             // nothing to report
         }
 

Braces +15 added lines, -6 removed lines

@@ -62,12 +62,17 @@ 
         $http = $this->container->get(Http::class);
         $emitter = $emitter ?? $this->container->get(EmitterInterface::class);
 
-        try {
+        try
+        {
             $response = $http->handle($this->initRequest());
             $emitter->emit($response);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             $this->handleException($emitter, $e);
-        } finally {
+        }
+        finally
+        {
             $this->finalizer->finalize(false);
         }
     }
@@ -88,16 +93,20 @@ 
     {
         $handler = new HtmlHandler();
 
-        try {
+        try
+        {
             /** @var SnapshotInterface $snapshot */
             $this->container->get(SnapshotterInterface::class)->register($e);
 
             // on demand
             $state = $this->container->get(StateInterface::class);
-            if ($state !== null) {
+            if ($state !== null)
+            {
                 $handler = $handler->withState($state);
             }
-        } catch (\Throwable | ContainerExceptionInterface $se) {
+        }
+        catch (\Throwable | ContainerExceptionInterface $se)
+        {
             // nothing to report
         }
 

src/Framework/Http/Diactoros/UploadedFileFactory.php

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
         string $clientFilename = null,
         string $clientMediaType = null
     ): UploadedFileInterface {
-        if ($size === null) {
+        if ($size === null){
             $size = $stream->getSize();
         }
 

Braces +2 added lines, -1 removed lines

@@ -26,7 +26,8 @@
         string $clientFilename = null,
         string $clientMediaType = null
     ): UploadedFileInterface {
-        if ($size === null) {
+        if ($size === null)
+        {
             $size = $stream->getSize();
         }
 

src/Framework/Http/Diactoros/ResponseFactory.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
         $response = new Response('php://memory', $code, []);
         $response = $response->withStatus($code, $reasonPhrase);
 
-        foreach ($this->config->getBaseHeaders() as $header => $value) {
+        foreach ($this->config->getBaseHeaders() as $header => $value){
             $response = $response->withAddedHeader($header, $value);
         }
 

Braces +2 added lines, -1 removed lines

@@ -37,7 +37,8 @@
         $response = new Response('php://memory', $code, []);
         $response = $response->withStatus($code, $reasonPhrase);
 
-        foreach ($this->config->getBaseHeaders() as $header => $value) {
+        foreach ($this->config->getBaseHeaders() as $header => $value)
+        {
             $response = $response->withAddedHeader($header, $value);
         }
 

src/Framework/Http/PaginationFactory.php

Spacing +2 added lines, -2 removed lines

@@ -46,7 +46,7 @@ 
      */
     public function createPaginator(string $parameter, int $limit = 25): PaginatorInterface
     {
-        if (!$this->container->has(ServerRequestInterface::class)) {
+        if (!$this->container->has(ServerRequestInterface::class)){
             throw new ScopeException('Unable to create paginator, no request scope found');
         }
         /**
@@ -56,7 +56,7 @@ 
 
         //Getting page number
         $page = 0;
-        if (!empty($query[$parameter]) && is_scalar($query[$parameter])) {
+        if (!empty($query[$parameter]) && is_scalar($query[$parameter])){
             $page = (int)$query[$parameter];
         }
 

Braces +4 added lines, -2 removed lines

@@ -46,7 +46,8 @@ 
      */
     public function createPaginator(string $parameter, int $limit = 25): PaginatorInterface
     {
-        if (!$this->container->has(ServerRequestInterface::class)) {
+        if (!$this->container->has(ServerRequestInterface::class))
+        {
             throw new ScopeException('Unable to create paginator, no request scope found');
         }
         /**
@@ -56,7 +57,8 @@ 
 
         //Getting page number
         $page = 0;
-        if (!empty($query[$parameter]) && is_scalar($query[$parameter])) {
+        if (!empty($query[$parameter]) && is_scalar($query[$parameter]))
+        {
             $page = (int)$query[$parameter];
         }
 

src/Framework/Http/RrDispatcher.php

Spacing +8 added lines, -8 removed lines

@@ -49,7 +49,7 @@ 
         FinalizerInterface $finalizer,
         ContainerInterface $container,
         FactoryInterface $factory
-    ) {
+    ){
         $this->env = $env;
         $this->finalizer = $finalizer;
         $this->container = $container;
@@ -75,12 +75,12 @@ 
 
         /** @var Http $http */
         $http = $this->container->get(Http::class);
-        while ($request = $client->acceptRequest()) {
-            try {
+        while ($request = $client->acceptRequest()){
+            try{
                 $client->respond($http->handle($request));
-            } catch (\Throwable $e) {
+            }catch (\Throwable $e){
                 $this->handleException($client, $e);
-            } finally {
+            }finally{
                 $this->finalizer->finalize(false);
             }
         }
@@ -94,17 +94,17 @@ 
     {
         $handler = new HtmlHandler();
 
-        try {
+        try{
             /** @var SnapshotInterface $snapshot */
             $snapshot = $this->container->get(SnapshotterInterface::class)->register($e);
             error_log($snapshot->getMessage());
 
             // on demand
             $state = $this->container->get(StateInterface::class);
-            if ($state !== null) {
+            if ($state !== null){
                 $handler = $handler->withState($state);
             }
-        } catch (\Throwable | ContainerExceptionInterface $se) {
+        }catch (\Throwable | ContainerExceptionInterface $se){
             error_log((string)$e);
         }
 

Braces +17 added lines, -7 removed lines

@@ -75,12 +75,18 @@ 
 
         /** @var Http $http */
         $http = $this->container->get(Http::class);
-        while ($request = $client->acceptRequest()) {
-            try {
+        while ($request = $client->acceptRequest())
+        {
+            try
+            {
                 $client->respond($http->handle($request));
-            } catch (\Throwable $e) {
+            }
+            catch (\Throwable $e)
+            {
                 $this->handleException($client, $e);
-            } finally {
+            }
+            finally
+            {
                 $this->finalizer->finalize(false);
             }
         }
@@ -94,17 +100,21 @@ 
     {
         $handler = new HtmlHandler();
 
-        try {
+        try
+        {
             /** @var SnapshotInterface $snapshot */
             $snapshot = $this->container->get(SnapshotterInterface::class)->register($e);
             error_log($snapshot->getMessage());
 
             // on demand
             $state = $this->container->get(StateInterface::class);
-            if ($state !== null) {
+            if ($state !== null)
+            {
                 $handler = $handler->withState($state);
             }
-        } catch (\Throwable | ContainerExceptionInterface $se) {
+        }
+        catch (\Throwable | ContainerExceptionInterface $se)
+        {
             error_log((string)$e);
         }
 

src/Framework/Http/Middleware/JsonPayloadMiddleware.php

Spacing +5 added lines, -5 removed lines

@@ -43,11 +43,11 @@ 
      */
     public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
     {
-        if ($this->isJsonPayload($request)) {
+        if ($this->isJsonPayload($request)){
             $body = (string)$request->getBody();
-            if ($body !== '') {
+            if ($body !== ''){
                 $request = $request->withParsedBody(json_decode($body, true));
-                if (json_last_error() !== 0) {
+                if (json_last_error() !== 0){
                     throw new ClientException(400, 'invalid json payload');
                 }
             }
@@ -64,8 +64,8 @@ 
     {
         $contentType = $request->getHeaderLine('Content-Type');
 
-        foreach ($this->config->getContentTypes() as $allowedType) {
-            if (stripos($contentType, $allowedType) === 0) {
+        foreach ($this->config->getContentTypes() as $allowedType){
+            if (stripos($contentType, $allowedType) === 0){
                 return true;
             }
         }

Braces +10 added lines, -5 removed lines

@@ -43,11 +43,14 @@ 
      */
     public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
     {
-        if ($this->isJsonPayload($request)) {
+        if ($this->isJsonPayload($request))
+        {
             $body = (string)$request->getBody();
-            if ($body !== '') {
+            if ($body !== '')
+            {
                 $request = $request->withParsedBody(json_decode($body, true));
-                if (json_last_error() !== 0) {
+                if (json_last_error() !== 0)
+                {
                     throw new ClientException(400, 'invalid json payload');
                 }
             }
@@ -64,8 +67,10 @@ 
     {
         $contentType = $request->getHeaderLine('Content-Type');
 
-        foreach ($this->config->getContentTypes() as $allowedType) {
-            if (stripos($contentType, $allowedType) === 0) {
+        foreach ($this->config->getContentTypes() as $allowedType)
+        {
+            if (stripos($contentType, $allowedType) === 0)
+            {
                 return true;
             }
         }

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