spiral / framework

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/CommandBootloader.php

Spacing +9 added lines, -9 removed lines

@@ -51,31 +51,31 @@ 
             '<fg=magenta>[runtime]</fg=magenta> <fg=cyan>verify `runtime` directory access</fg=cyan>'
         );
 
-        if ($container->has(DatabaseProviderInterface::class)) {
+        if ($container->has(DatabaseProviderInterface::class)){
             $this->configureDatabase($console);
         }
 
-        if ($container->has(ORMInterface::class)) {
+        if ($container->has(ORMInterface::class)){
             $this->configureCycle($console, $container);
         }
 
-        if ($container->has(TranslatorInterface::class)) {
+        if ($container->has(TranslatorInterface::class)){
             $this->configureTranslator($console);
         }
 
-        if ($container->has(ViewsInterface::class)) {
+        if ($container->has(ViewsInterface::class)){
             $this->configureViews($console);
         }
 
-        if ($container->has(Migrator::class)) {
+        if ($container->has(Migrator::class)){
             $this->configureMigrations($console);
         }
 
-        if ($container->has(InvokerInterface::class)) {
+        if ($container->has(InvokerInterface::class)){
             $this->configureGRPC($console);
         }
 
-        if ($container->has(EncryptionInterface::class)) {
+        if ($container->has(EncryptionInterface::class)){
             $this->configureEncrypter($console);
         }
     }
@@ -114,7 +114,7 @@ 
 
         $console->addCommand(Cycle\SyncCommand::class);
 
-        if ($container->has(Migrator::class)) {
+        if ($container->has(Migrator::class)){
             $console->addCommand(Cycle\MigrateCommand::class);
         }
     }
@@ -129,7 +129,7 @@ 
         $console->addCommand(Translator\ResetCommand::class);
 
         $console->addConfigureSequence(
-            function (FilesInterface $files, TranslatorConfig $config, OutputInterface $output) {
+            function (FilesInterface $files, TranslatorConfig $config, OutputInterface $output){
                 $files->ensureDirectory($config->getLocaleDirectory($config->getDefaultLocale()));
                 $output->writeln("<info>The default locale directory has been ensured.</info>");
             },

Braces +18 added lines, -9 removed lines

@@ -51,31 +51,38 @@ 
             '<fg=magenta>[runtime]</fg=magenta> <fg=cyan>verify `runtime` directory access</fg=cyan>'
         );
 
-        if ($container->has(DatabaseProviderInterface::class)) {
+        if ($container->has(DatabaseProviderInterface::class))
+        {
             $this->configureDatabase($console);
         }
 
-        if ($container->has(ORMInterface::class)) {
+        if ($container->has(ORMInterface::class))
+        {
             $this->configureCycle($console, $container);
         }
 
-        if ($container->has(TranslatorInterface::class)) {
+        if ($container->has(TranslatorInterface::class))
+        {
             $this->configureTranslator($console);
         }
 
-        if ($container->has(ViewsInterface::class)) {
+        if ($container->has(ViewsInterface::class))
+        {
             $this->configureViews($console);
         }
 
-        if ($container->has(Migrator::class)) {
+        if ($container->has(Migrator::class))
+        {
             $this->configureMigrations($console);
         }
 
-        if ($container->has(InvokerInterface::class)) {
+        if ($container->has(InvokerInterface::class))
+        {
             $this->configureGRPC($console);
         }
 
-        if ($container->has(EncryptionInterface::class)) {
+        if ($container->has(EncryptionInterface::class))
+        {
             $this->configureEncrypter($console);
         }
     }
@@ -114,7 +121,8 @@ 
 
         $console->addCommand(Cycle\SyncCommand::class);
 
-        if ($container->has(Migrator::class)) {
+        if ($container->has(Migrator::class))
+        {
             $console->addCommand(Cycle\MigrateCommand::class);
         }
     }
@@ -129,7 +137,8 @@ 
         $console->addCommand(Translator\ResetCommand::class);
 
         $console->addConfigureSequence(
-            function (FilesInterface $files, TranslatorConfig $config, OutputInterface $output) {
+            function (FilesInterface $files, TranslatorConfig $config, OutputInterface $output)
+            {
                 $files->ensureDirectory($config->getLocaleDirectory($config->getDefaultLocale()));
                 $output->writeln("<info>The default locale directory has been ensured.</info>");
             },

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)

src/Command/GRPC/ListCommand.php

Spacing +2 added lines, -2 removed lines

@@ -24,7 +24,7 @@ 
     {
         $services = $locator->getServices();
 
-        if ($services === []) {
+        if ($services === []){
             $this->writeln("<comment>No GRPC services were found.</comment>");
             return;
         }
@@ -35,7 +35,7 @@ 
             'File:',
         ]);
 
-        foreach ($services as $interface => $instance) {
+        foreach ($services as $interface => $instance){
             $grid->addRow([
                 $interface::NAME,
                 get_class($instance),

Braces +4 added lines, -2 removed lines

@@ -24,7 +24,8 @@ 
     {
         $services = $locator->getServices();
 
-        if ($services === []) {
+        if ($services === [])
+        {
             $this->writeln("<comment>No GRPC services were found.</comment>");
             return;
         }
@@ -35,7 +36,8 @@ 
             'File:',
         ]);
 
-        foreach ($services as $interface => $instance) {
+        foreach ($services as $interface => $instance)
+        {
             $grid->addRow([
                 $interface::NAME,
                 get_class($instance),

src/Command/GRPC/GenerateCommand.php

Spacing +7 added lines, -7 removed lines

@@ -39,7 +39,7 @@ 
     public function perform(KernelInterface $kernel, FilesInterface $files, DirectoriesInterface $dirs)
     {
         $protoFile = $this->argument('proto');
-        if (!file_exists($protoFile)) {
+        if (!file_exists($protoFile)){
             $this->sprintf("<error>File `%s` not found.</error>", $protoFile);
             return;
         }
@@ -52,19 +52,19 @@ 
 
         $this->sprintf("<info>Compiling <fg=cyan>`%s`</fg=cyan>:</info>\n", $protoFile);
 
-        try {
+        try{
             $result = $compiler->compile($protoFile);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             $this->sprintf("<error>Error:</error> <fg=red>%s</fg=red>\n", $e->getMessage());
             return;
         }
 
-        if ($result === []) {
+        if ($result === []){
             $this->sprintf("<info>No files were generated.</info>\n", $protoFile);
             return;
         }
 
-        foreach ($result as $file) {
+        foreach ($result as $file){
             $this->sprintf(
                 "<fg=green>•</fg=green> %s%s%s\n",
                 Color::LIGHT_WHITE,
@@ -83,7 +83,7 @@ 
     protected function getPath(KernelInterface $kernel): string
     {
         $path = $this->argument('namespace');
-        if ($path !== 'auto') {
+        if ($path !== 'auto'){
             return $path;
         }
 
@@ -101,7 +101,7 @@ 
     protected function getNamespace(KernelInterface $kernel): string
     {
         $namespace = $this->argument('namespace');
-        if ($namespace !== 'auto') {
+        if ($namespace !== 'auto'){
             return $namespace;
         }
 

Braces +15 added lines, -7 removed lines

@@ -39,7 +39,8 @@ 
     public function perform(KernelInterface $kernel, FilesInterface $files, DirectoriesInterface $dirs)
     {
         $protoFile = $this->argument('proto');
-        if (!file_exists($protoFile)) {
+        if (!file_exists($protoFile))
+        {
             $this->sprintf("<error>File `%s` not found.</error>", $protoFile);
             return;
         }
@@ -52,19 +53,24 @@ 
 
         $this->sprintf("<info>Compiling <fg=cyan>`%s`</fg=cyan>:</info>\n", $protoFile);
 
-        try {
+        try
+        {
             $result = $compiler->compile($protoFile);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             $this->sprintf("<error>Error:</error> <fg=red>%s</fg=red>\n", $e->getMessage());
             return;
         }
 
-        if ($result === []) {
+        if ($result === [])
+        {
             $this->sprintf("<info>No files were generated.</info>\n", $protoFile);
             return;
         }
 
-        foreach ($result as $file) {
+        foreach ($result as $file)
+        {
             $this->sprintf(
                 "<fg=green>•</fg=green> %s%s%s\n",
                 Color::LIGHT_WHITE,
@@ -83,7 +89,8 @@ 
     protected function getPath(KernelInterface $kernel): string
     {
         $path = $this->argument('namespace');
-        if ($path !== 'auto') {
+        if ($path !== 'auto')
+        {
             return $path;
         }
 
@@ -101,7 +108,8 @@ 
     protected function getNamespace(KernelInterface $kernel): string
     {
         $namespace = $this->argument('namespace');
-        if ($namespace !== 'auto') {
+        if ($namespace !== 'auto')
+        {
             return $namespace;
         }
 

src/Command/Encrypter/KeyCommand.php

Spacing +4 added lines, -4 removed lines

@@ -58,21 +58,21 @@
         );
 
         $file = $this->option('mount');
-        if ($file === null) {
+        if ($file === null){
             return;
         }
 
-        if (!$files->exists($file)) {
+        if (!$files->exists($file)){
             $this->sprintf("<error>Unable to find `%s`</error>", $file);
             return;
         }
 
         $content = $files->read($file);
 
-        try {
+        try{
             $content = str_replace($this->option('placeholder'), $key, $content);
             $content = str_replace($enc->getKey(), $key, $content);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             // current keys is not set
         }
 

Braces +9 added lines, -4 removed lines

@@ -58,21 +58,26 @@
         );
 
         $file = $this->option('mount');
-        if ($file === null) {
+        if ($file === null)
+        {
             return;
         }
 
-        if (!$files->exists($file)) {
+        if (!$files->exists($file))
+        {
             $this->sprintf("<error>Unable to find `%s`</error>", $file);
             return;
         }
 
         $content = $files->read($file);
 
-        try {
+        try
+        {
             $content = str_replace($this->option('placeholder'), $key, $content);
             $content = str_replace($enc->getKey(), $key, $content);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             // current keys is not set
         }
 

src/Command/Cycle/MigrateCommand.php

Spacing +6 added lines, -6 removed lines

@@ -48,13 +48,13 @@ 
         GenerateMigrations $migrations,
         Migrator $migrator,
         Console $console
-    ) {
-        if (!$this->verifyConfigured()) {
+    ){
+        if (!$this->verifyConfigured()){
             return;
         }
 
-        foreach ($migrator->getMigrations() as $migration) {
-            if ($migration->getState()->getStatus() !== State::STATUS_EXECUTED) {
+        foreach ($migrator->getMigrations() as $migration){
+            if ($migration->getState()->getStatus() !== State::STATUS_EXECUTED){
                 $this->writeln("<fg=red>Outstanding migrations found, run `migrate` first.</fg=red>");
                 return;
             }
@@ -69,10 +69,10 @@ 
 
         $memory->saveData('cycle', $schema);
 
-        if ($show->hasChanges()) {
+        if ($show->hasChanges()){
             (new Compiler())->compile($registry, [$migrations]);
 
-            if ($this->option('run')) {
+            if ($this->option('run')){
                 $console->run('migrate', [], $this->output);
             }
         }

Braces +10 added lines, -5 removed lines

@@ -49,12 +49,15 @@ 
         Migrator $migrator,
         Console $console
     ) {
-        if (!$this->verifyConfigured()) {
+        if (!$this->verifyConfigured())
+        {
             return;
         }
 
-        foreach ($migrator->getMigrations() as $migration) {
-            if ($migration->getState()->getStatus() !== State::STATUS_EXECUTED) {
+        foreach ($migrator->getMigrations() as $migration)
+        {
+            if ($migration->getState()->getStatus() !== State::STATUS_EXECUTED)
+            {
                 $this->writeln("<fg=red>Outstanding migrations found, run `migrate` first.</fg=red>");
                 return;
             }
@@ -69,10 +72,12 @@ 
 
         $memory->saveData('cycle', $schema);
 
-        if ($show->hasChanges()) {
+        if ($show->hasChanges())
+        {
             (new Compiler())->compile($registry, [$migrations]);
 
-            if ($this->option('run')) {
+            if ($this->option('run'))
+            {
                 $console->run('migrate', [], $this->output);
             }
         }