spiral / framework

src/Http/SapiDispatcher.php

Spacing +5 added lines, -5 removed lines

@@ -59,12 +59,12 @@ 
         $http = $this->container->get(HttpCore::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);
         }
     }
@@ -85,10 +85,10 @@ 
     {
         $handler = new HtmlHandler(HtmlHandler::INVERTED);
 
-        try {
+        try{
             /** @var SnapshotInterface $snapshot */
             $this->container->get(SnapshotterInterface::class)->register($e);
-        } catch (\Throwable|ContainerExceptionInterface $se) {
+        }catch (\Throwable | ContainerExceptionInterface $se){
             // nothing to report
         }
 

Braces +13 added lines, -5 removed lines

@@ -59,12 +59,17 @@ 
         $http = $this->container->get(HttpCore::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);
         }
     }
@@ -85,10 +90,13 @@ 
     {
         $handler = new HtmlHandler(HtmlHandler::INVERTED);
 
-        try {
+        try
+        {
             /** @var SnapshotInterface $snapshot */
             $this->container->get(SnapshotterInterface::class)->register($e);
-        } catch (\Throwable|ContainerExceptionInterface $se) {
+        }
+        catch (\Throwable|ContainerExceptionInterface $se)
+        {
             // nothing to report
         }
 

src/GRPC/ServiceLocator.php

Spacing +4 added lines, -4 removed lines

@@ -38,15 +38,15 @@
     public function getServices(): array
     {
         $result = [];
-        foreach ($this->classes->getClasses(ServiceInterface::class) as $service) {
-            if (!$service->isInstantiable()) {
+        foreach ($this->classes->getClasses(ServiceInterface::class) as $service){
+            if (!$service->isInstantiable()){
                 continue;
             }
 
             $instance = $this->container->get($service->getName());
 
-            foreach ($service->getInterfaces() as $interface) {
-                if ($interface->isSubclassOf(ServiceInterface::class)) {
+            foreach ($service->getInterfaces() as $interface){
+                if ($interface->isSubclassOf(ServiceInterface::class)){
                     $result[$interface->getName()] = $instance;
                 }
             }

Braces +8 added lines, -4 removed lines

@@ -38,15 +38,19 @@
     public function getServices(): array
     {
         $result = [];
-        foreach ($this->classes->getClasses(ServiceInterface::class) as $service) {
-            if (!$service->isInstantiable()) {
+        foreach ($this->classes->getClasses(ServiceInterface::class) as $service)
+        {
+            if (!$service->isInstantiable())
+            {
                 continue;
             }
 
             $instance = $this->container->get($service->getName());
 
-            foreach ($service->getInterfaces() as $interface) {
-                if ($interface->isSubclassOf(ServiceInterface::class)) {
+            foreach ($service->getInterfaces() as $interface)
+            {
+                if ($interface->isSubclassOf(ServiceInterface::class))
+                {
                     $result[$interface->getName()] = $instance;
                 }
             }

src/GRPC/GRPCDispatcher.php

Spacing +6 added lines, -6 removed lines

@@ -37,7 +37,7 @@ 
         EnvironmentInterface $env,
         FinalizerInterface $finalizer,
         ContainerInterface $container
-    ) {
+    ){
         $this->env = $env;
         $this->finalizer = $finalizer;
         $this->container = $container;
@@ -65,12 +65,12 @@ 
         $worker = $this->container->get(Worker::class);
         $locator = $this->container->get(LocatorInterface::class);
 
-        foreach ($locator->getServices() as $interface => $service) {
+        foreach ($locator->getServices() as $interface => $service){
             $server->registerService($interface, $service);
         }
 
-        $server->serve($worker, function (\Throwable $e = null) {
-            if ($e !== null) {
+        $server->serve($worker, function (\Throwable $e = null){
+            if ($e !== null){
                 $this->handleException($e);
             }
 
@@ -83,9 +83,9 @@ 
      */
     protected function handleException(\Throwable $e)
     {
-        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 +11 added lines, -5 removed lines

@@ -65,12 +65,15 @@ 
         $worker = $this->container->get(Worker::class);
         $locator = $this->container->get(LocatorInterface::class);
 
-        foreach ($locator->getServices() as $interface => $service) {
+        foreach ($locator->getServices() as $interface => $service)
+        {
             $server->registerService($interface, $service);
         }
 
-        $server->serve($worker, function (\Throwable $e = null) {
-            if ($e !== null) {
+        $server->serve($worker, function (\Throwable $e = null)
+        {
+            if ($e !== null)
+            {
                 $this->handleException($e);
             }
 
@@ -83,9 +86,12 @@ 
      */
     protected function handleException(\Throwable $e)
     {
-        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/Console/Sequence/RuntimeDirectory.php

Spacing +6 added lines, -6 removed lines

@@ -43,19 +43,19 @@ 
 
         $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;
-        } else {
+        }else{
             $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(
                     "<fg=red>[errored]</fg=red> `%s`: <fg=red>%s</fg=red>",
@@ -66,7 +66,7 @@ 
                 // @codeCoverageIgnoreEnd
             }
 
-            if ($output->isVerbose()) {
+            if ($output->isVerbose()){
                 $output->writeln(sprintf(
                     "<fg=green>[updated]</fg=green> `%s`",
                     $this->files->relativePath($filename, $runtimeDirectory)

Braces +14 added lines, -6 removed lines

@@ -43,19 +43,26 @@ 
 
         $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;
-        } else {
+        }
+        else
+        {
             $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(
                     "<fg=red>[errored]</fg=red> `%s`: <fg=red>%s</fg=red>",
@@ -66,7 +73,8 @@ 
                 // @codeCoverageIgnoreEnd
             }
 
-            if ($output->isVerbose()) {
+            if ($output->isVerbose())
+            {
                 $output->writeln(sprintf(
                     "<fg=green>[updated]</fg=green> `%s`",
                     $this->files->relativePath($filename, $runtimeDirectory)

src/Http/Middleware/ErrorHandlerMiddleware.php

Spacing +8 added lines, -8 removed lines

@@ -44,7 +44,7 @@ 
         bool $suppressErrors,
         RendererInterface $renderer,
         SnapshotterInterface $snapshots = null
-    ) {
+    ){
         $this->suppressErrors = $suppressErrors;
         $this->renderer = $renderer;
         $this->snapshotter = $snapshots;
@@ -57,20 +57,20 @@ 
      */
     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) {
-            if (!$this->suppressErrors) {
+        }catch (\Throwable $e){
+            if (!$this->suppressErrors){
                 throw $e;
             }
 
-            if ($this->snapshotter !== null) {
+            if ($this->snapshotter !== null){
                 $this->snapshotter->register($e);
             }
 

Braces +17 added lines, -7 removed lines

@@ -57,20 +57,30 @@
      */
     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) {
-            if (!$this->suppressErrors) {
+        }
+        catch (\Throwable $e)
+        {
+            if (!$this->suppressErrors)
+            {
                 throw $e;
             }
 
-            if ($this->snapshotter !== null) {
+            if ($this->snapshotter !== null)
+            {
                 $this->snapshotter->register($e);
             }
 

src/Http/RrDispacher.php

Spacing +7 added lines, -7 removed lines

@@ -46,7 +46,7 @@ 
         FinalizerInterface $finalizer,
         ContainerInterface $container,
         FactoryInterface $factory
-    ) {
+    ){
         $this->env = $env;
         $this->finalizer = $finalizer;
         $this->container = $container;
@@ -70,12 +70,12 @@ 
 
         /** @var HttpCore $http */
         $http = $this->container->get(HttpCore::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);
             }
         }
@@ -89,11 +89,11 @@ 
     {
         $handler = new HtmlHandler(HtmlHandler::INVERTED);
 
-        try {
+        try{
             /** @var SnapshotInterface $snapshot */
             $snapshot = $this->container->get(SnapshotterInterface::class)->register($e);
             error_log($snapshot->getMessage());
-        } catch (\Throwable|ContainerExceptionInterface $se) {
+        }catch (\Throwable | ContainerExceptionInterface $se){
             error_log((string)$e);
         }
 

Braces +15 added lines, -6 removed lines

@@ -70,12 +70,18 @@ 
 
         /** @var HttpCore $http */
         $http = $this->container->get(HttpCore::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);
             }
         }
@@ -89,11 +95,14 @@ 
     {
         $handler = new HtmlHandler(HtmlHandler::INVERTED);
 
-        try {
+        try
+        {
             /** @var SnapshotInterface $snapshot */
             $snapshot = $this->container->get(SnapshotterInterface::class)->register($e);
             error_log($snapshot->getMessage());
-        } catch (\Throwable|ContainerExceptionInterface $se) {
+        }
+        catch (\Throwable|ContainerExceptionInterface $se)
+        {
             error_log((string)$e);
         }
 

src/Bootloader/ServerBootloader.php

Spacing +4 added lines, -4 removed lines

@@ -36,21 +36,21 @@
     {
         $conn = $env->get('RR_RPC', static::RPC_DEFAULT);
 
-        if (!preg_match('#^([a-z]+)://([^:]+):?(\d+)?$#i', $conn, $parts)) {
+        if (!preg_match('#^([a-z]+)://([^:]+):?(\d+)?$#i', $conn, $parts)){
             throw new BootException(
                 "Unable to configure RPC connection, invalid DSN given `{$conn}`."
             );
         }
 
-        if (!in_array($parts[1], ['tcp', 'unix'])) {
+        if (!in_array($parts[1], ['tcp', 'unix'])){
             throw new BootException(
                 "Unable to configure RPC connection, invalid DSN given `{$conn}`."
             );
         }
 
-        if ($parts[1] == 'unix') {
+        if ($parts[1] == 'unix'){
             $relay = new SocketRelay($parts[2], null, SocketRelay::SOCK_UNIX);
-        } else {
+        }else{
             $relay = new SocketRelay($parts[2], (int)$parts[3], SocketRelay::SOCK_TCP);
         }
 

Braces +9 added lines, -4 removed lines

@@ -36,21 +36,26 @@
     {
         $conn = $env->get('RR_RPC', static::RPC_DEFAULT);
 
-        if (!preg_match('#^([a-z]+)://([^:]+):?(\d+)?$#i', $conn, $parts)) {
+        if (!preg_match('#^([a-z]+)://([^:]+):?(\d+)?$#i', $conn, $parts))
+        {
             throw new BootException(
                 "Unable to configure RPC connection, invalid DSN given `{$conn}`."
             );
         }
 
-        if (!in_array($parts[1], ['tcp', 'unix'])) {
+        if (!in_array($parts[1], ['tcp', 'unix']))
+        {
             throw new BootException(
                 "Unable to configure RPC connection, invalid DSN given `{$conn}`."
             );
         }
 
-        if ($parts[1] == 'unix') {
+        if ($parts[1] == 'unix')
+        {
             $relay = new SocketRelay($parts[2], null, SocketRelay::SOCK_UNIX);
-        } else {
+        }
+        else
+        {
             $relay = new SocketRelay($parts[2], (int)$parts[3], SocketRelay::SOCK_TCP);
         }
 

src/Cycle/SelectInjector.php

Spacing +2 added lines, -2 removed lines

@@ -35,11 +35,11 @@
      */
     public function createInjection(\ReflectionClass $class, string $context = null)
     {
-        if (!$this->orm->getSchema()->defines($context)) {
+        if (!$this->orm->getSchema()->defines($context)){
             $context = Inflector::singularize($context);
         }
 
-        if (!$this->orm->getSchema()->defines($context)) {
+        if (!$this->orm->getSchema()->defines($context)){
             throw new ORMException("Cycle schema is not initiated or role missing, run `cycle`");
         }
 

Braces +4 added lines, -2 removed lines

@@ -35,11 +35,13 @@
      */
     public function createInjection(\ReflectionClass $class, string $context = null)
     {
-        if (!$this->orm->getSchema()->defines($context)) {
+        if (!$this->orm->getSchema()->defines($context))
+        {
             $context = Inflector::singularize($context);
         }
 
-        if (!$this->orm->getSchema()->defines($context)) {
+        if (!$this->orm->getSchema()->defines($context))
+        {
             throw new ORMException("Cycle schema is not initiated or role missing, run `cycle`");
         }
 

src/Command/CleanCommand.php

Spacing +6 added lines, -6 removed lines

@@ -26,20 +26,20 @@ 
     public function perform(FilesInterface $files, DirectoriesInterface $directories)
     {
         $cacheDirectory = $directories->get('cache');
-        if (!$files->exists($cacheDirectory)) {
+        if (!$files->exists($cacheDirectory)){
             $this->writeln("Cache directory is missing, no cache to be cleaned.");
 
             return;
         }
 
-        if ($this->isVerbose()) {
+        if ($this->isVerbose()){
             $this->writeln("<info>Cleaning application cache:</info>");
         }
 
-        foreach ($files->getFiles($cacheDirectory) as $filename) {
-            try {
+        foreach ($files->getFiles($cacheDirectory) as $filename){
+            try{
                 $files->delete($filename);
-            } catch (\Throwable $e) {
+            }catch (\Throwable $e){
                 // @codeCoverageIgnoreStart
                 $this->sprintf("<fg=red>[errored]</fg=red> `%s`: <fg=red>%s</fg=red>\n",
                     $files->relativePath($filename, $cacheDirectory),
@@ -50,7 +50,7 @@ 
                 // @codeCoverageIgnoreEnd
             }
 
-            if ($this->isVerbose()) {
+            if ($this->isVerbose()){
                 $this->sprintf(
                     "<fg=green>[deleted]</fg=green> `%s`\n",
                     $files->relativePath($filename, $cacheDirectory)

Braces +13 added lines, -6 removed lines

@@ -26,20 +26,26 @@ 
     public function perform(FilesInterface $files, DirectoriesInterface $directories)
     {
         $cacheDirectory = $directories->get('cache');
-        if (!$files->exists($cacheDirectory)) {
+        if (!$files->exists($cacheDirectory))
+        {
             $this->writeln("Cache directory is missing, no cache to be cleaned.");
 
             return;
         }
 
-        if ($this->isVerbose()) {
+        if ($this->isVerbose())
+        {
             $this->writeln("<info>Cleaning application cache:</info>");
         }
 
-        foreach ($files->getFiles($cacheDirectory) as $filename) {
-            try {
+        foreach ($files->getFiles($cacheDirectory) as $filename)
+        {
+            try
+            {
                 $files->delete($filename);
-            } catch (\Throwable $e) {
+            }
+            catch (\Throwable $e)
+            {
                 // @codeCoverageIgnoreStart
                 $this->sprintf("<fg=red>[errored]</fg=red> `%s`: <fg=red>%s</fg=red>\n",
                     $files->relativePath($filename, $cacheDirectory),
@@ -50,7 +56,8 @@ 
                 // @codeCoverageIgnoreEnd
             }
 
-            if ($this->isVerbose()) {
+            if ($this->isVerbose())
+            {
                 $this->sprintf(
                     "<fg=green>[deleted]</fg=green> `%s`\n",
                     $files->relativePath($filename, $cacheDirectory)