spiral / framework

tests/app/src/Job/TestJob.php

Braces +3 added lines, -1 removed lines

@@ -13,8 +13,10 @@
 
 class TestJob extends AbstractJob
 {
-    public function do(EnvironmentInterface $env)
+    public function do{
+        (EnvironmentInterface $env)
     {
         $env->set('FIRED', true);
     }
+    }
 }
\ No newline at end of file

src/Bootloader/RrBootloader.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/Command/Cycle/Generator/ShowChanges.php

Spacing +18 added lines, -18 removed lines

@@ -40,11 +40,11 @@ 
         $this->output->writeln("<info>Detecting schema changes:</info>");
 
         $this->changes = [];
-        foreach ($registry->getIterator() as $e) {
-            if ($registry->hasTable($e)) {
+        foreach ($registry->getIterator() as $e){
+            if ($registry->hasTable($e)){
                 $table = $registry->getTableSchema($e);
 
-                if ($table->getComparator()->hasChanges()) {
+                if ($table->getComparator()->hasChanges()){
                     $this->changes[] = [
                         'database' => $registry->getDatabase($e),
                         'table'    => $registry->getTable($e),
@@ -54,13 +54,13 @@ 
             }
         }
 
-        if ($this->changes === []) {
+        if ($this->changes === []){
             $this->output->writeln("<fg=yellow>no database changes has been detected</fg=yellow>");
 
             return $registry;
         }
 
-        foreach ($this->changes as $change) {
+        foreach ($this->changes as $change){
             $this->output->write(sprintf("• <fg=cyan>%s.%s</fg=cyan>", $change['database'], $change['table']));
             $this->describeChanges($change['schema']);
         }
@@ -73,22 +73,22 @@ 
      */
     protected function describeChanges(AbstractTable $table)
     {
-        if (!$this->output->isVerbose()) {
+        if (!$this->output->isVerbose()){
             $this->output->writeln(sprintf(
                 ": <fg=green>%s</fg=green> change(s) detected",
                 $this->numChanges($table)
             ));
 
             return;
-        } else {
+        }else{
             $this->output->write("\n");
         }
 
-        if (!$table->exists()) {
+        if (!$table->exists()){
             $this->output->writeln("    - create table");
         }
 
-        if ($table->getStatus() === AbstractTable::STATUS_DECLARED_DROPPED) {
+        if ($table->getStatus() === AbstractTable::STATUS_DECLARED_DROPPED){
             $this->output->writeln("    - drop table");
             return;
         }
@@ -105,15 +105,15 @@ 
      */
     protected function describeColumns(Comparator $cmp)
     {
-        foreach ($cmp->addedColumns() as $column) {
+        foreach ($cmp->addedColumns() as $column){
             $this->output->writeln("    - add column <fg=yellow>{$column->getName()}</fg=yellow>");
         }
 
-        foreach ($cmp->droppedColumns() as $column) {
+        foreach ($cmp->droppedColumns() as $column){
             $this->output->writeln("    - drop column <fg=yellow>{$column->getName()}</fg=yellow>");
         }
 
-        foreach ($cmp->alteredColumns() as $column) {
+        foreach ($cmp->alteredColumns() as $column){
             $column = $column[0];
             $this->output->writeln("    - alter column <fg=yellow>{$column->getName()}</fg=yellow>");
         }
@@ -124,17 +124,17 @@ 
      */
     protected function describeIndexes(Comparator $cmp)
     {
-        foreach ($cmp->addedIndexes() as $index) {
+        foreach ($cmp->addedIndexes() as $index){
             $index = join(', ', $index->getColumns());
             $this->output->writeln("    - add index on <fg=yellow>[{$index}]</fg=yellow>");
         }
 
-        foreach ($cmp->droppedIndexes() as $index) {
+        foreach ($cmp->droppedIndexes() as $index){
             $index = join(', ', $index->getColumns());
             $this->output->writeln("    - drop index on <fg=yellow>[{$index}]</fg=yellow>");
         }
 
-        foreach ($cmp->alteredIndexes() as $index) {
+        foreach ($cmp->alteredIndexes() as $index){
             $index = $index[0];
             $index = join(', ', $index->getColumns());
             $this->output->writeln("    - alter index on <fg=yellow>[{$index}]</fg=yellow>");
@@ -146,15 +146,15 @@ 
      */
     protected function describeFKs(Comparator $cmp)
     {
-        foreach ($cmp->addedForeignKeys() as $fk) {
+        foreach ($cmp->addedForeignKeys() as $fk){
             $this->output->writeln("    - add foreign key on <fg=yellow>{$fk->getColumn()}</fg=yellow>");
         }
 
-        foreach ($cmp->droppedForeignKeys() as $fk) {
+        foreach ($cmp->droppedForeignKeys() as $fk){
             $this->output->writeln("    - drop foreign key <fg=yellow>{$fk->getColumn()}</fg=yellow>");
         }
 
-        foreach ($cmp->alteredForeignKeys() as $fk) {
+        foreach ($cmp->alteredForeignKeys() as $fk){
             $fk = $fk[0];
             $this->output->writeln("    - alter foreign key <fg=yellow>{$fk->getColumn()}</fg=yellow>");
         }

Braces +37 added lines, -18 removed lines

@@ -40,11 +40,14 @@ 
         $this->output->writeln("<info>Detecting schema changes:</info>");
 
         $this->changes = [];
-        foreach ($registry->getIterator() as $e) {
-            if ($registry->hasTable($e)) {
+        foreach ($registry->getIterator() as $e)
+        {
+            if ($registry->hasTable($e))
+            {
                 $table = $registry->getTableSchema($e);
 
-                if ($table->getComparator()->hasChanges()) {
+                if ($table->getComparator()->hasChanges())
+                {
                     $this->changes[] = [
                         'database' => $registry->getDatabase($e),
                         'table'    => $registry->getTable($e),
@@ -54,13 +57,15 @@ 
             }
         }
 
-        if ($this->changes === []) {
+        if ($this->changes === [])
+        {
             $this->output->writeln("<fg=yellow>no database changes has been detected</fg=yellow>");
 
             return $registry;
         }
 
-        foreach ($this->changes as $change) {
+        foreach ($this->changes as $change)
+        {
             $this->output->write(sprintf("• <fg=cyan>%s.%s</fg=cyan>", $change['database'], $change['table']));
             $this->describeChanges($change['schema']);
         }
@@ -73,22 +78,27 @@ 
      */
     protected function describeChanges(AbstractTable $table)
     {
-        if (!$this->output->isVerbose()) {
+        if (!$this->output->isVerbose())
+        {
             $this->output->writeln(sprintf(
                 ": <fg=green>%s</fg=green> change(s) detected",
                 $this->numChanges($table)
             ));
 
             return;
-        } else {
+        }
+        else
+        {
             $this->output->write("\n");
         }
 
-        if (!$table->exists()) {
+        if (!$table->exists())
+        {
             $this->output->writeln("    - create table");
         }
 
-        if ($table->getStatus() === AbstractTable::STATUS_DECLARED_DROPPED) {
+        if ($table->getStatus() === AbstractTable::STATUS_DECLARED_DROPPED)
+        {
             $this->output->writeln("    - drop table");
             return;
         }
@@ -105,15 +115,18 @@ 
      */
     protected function describeColumns(Comparator $cmp)
     {
-        foreach ($cmp->addedColumns() as $column) {
+        foreach ($cmp->addedColumns() as $column)
+        {
             $this->output->writeln("    - add column <fg=yellow>{$column->getName()}</fg=yellow>");
         }
 
-        foreach ($cmp->droppedColumns() as $column) {
+        foreach ($cmp->droppedColumns() as $column)
+        {
             $this->output->writeln("    - drop column <fg=yellow>{$column->getName()}</fg=yellow>");
         }
 
-        foreach ($cmp->alteredColumns() as $column) {
+        foreach ($cmp->alteredColumns() as $column)
+        {
             $column = $column[0];
             $this->output->writeln("    - alter column <fg=yellow>{$column->getName()}</fg=yellow>");
         }
@@ -124,17 +137,20 @@ 
      */
     protected function describeIndexes(Comparator $cmp)
     {
-        foreach ($cmp->addedIndexes() as $index) {
+        foreach ($cmp->addedIndexes() as $index)
+        {
             $index = join(', ', $index->getColumns());
             $this->output->writeln("    - add index on <fg=yellow>[{$index}]</fg=yellow>");
         }
 
-        foreach ($cmp->droppedIndexes() as $index) {
+        foreach ($cmp->droppedIndexes() as $index)
+        {
             $index = join(', ', $index->getColumns());
             $this->output->writeln("    - drop index on <fg=yellow>[{$index}]</fg=yellow>");
         }
 
-        foreach ($cmp->alteredIndexes() as $index) {
+        foreach ($cmp->alteredIndexes() as $index)
+        {
             $index = $index[0];
             $index = join(', ', $index->getColumns());
             $this->output->writeln("    - alter index on <fg=yellow>[{$index}]</fg=yellow>");
@@ -146,15 +162,18 @@ 
      */
     protected function describeFKs(Comparator $cmp)
     {
-        foreach ($cmp->addedForeignKeys() as $fk) {
+        foreach ($cmp->addedForeignKeys() as $fk)
+        {
             $this->output->writeln("    - add foreign key on <fg=yellow>{$fk->getColumn()}</fg=yellow>");
         }
 
-        foreach ($cmp->droppedForeignKeys() as $fk) {
+        foreach ($cmp->droppedForeignKeys() as $fk)
+        {
             $this->output->writeln("    - drop foreign key <fg=yellow>{$fk->getColumn()}</fg=yellow>");
         }
 
-        foreach ($cmp->alteredForeignKeys() as $fk) {
+        foreach ($cmp->alteredForeignKeys() as $fk)
+        {
             $fk = $fk[0];
             $this->output->writeln("    - alter foreign key <fg=yellow>{$fk->getColumn()}</fg=yellow>");
         }

src/Console/ConsoleDispatcher.php

Spacing +8 added lines, -8 removed lines

@@ -45,7 +45,7 @@ 
         EnvironmentInterface $env,
         FinalizerInterface $finalizer,
         ContainerInterface $container
-    ) {
+    ){
         $this->env = $env;
         $this->finalizer = $finalizer;
         $this->container = $container;
@@ -74,11 +74,11 @@ 
         /** @var Console $console */
         $console = $this->container->get(Console::class);
 
-        try {
+        try{
             $console->start($input ?? new ArgvInput(), $output);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             $this->handleException($e, $output);
-        } finally {
+        }finally{
             $listener->disable();
             $this->finalizer->finalize(false);
         }
@@ -90,9 +90,9 @@ 
      */
     protected function handleException(\Throwable $e, OutputInterface $output)
     {
-        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
         }
 
@@ -107,11 +107,11 @@ 
      */
     private function mapVerbosity(OutputInterface $output): int
     {
-        if ($output->isDebug() || $output->isVeryVerbose()) {
+        if ($output->isDebug() || $output->isVeryVerbose()){
             return ConsoleHandler::VERBOSITY_DEBUG;
         }
 
-        if ($output->isVerbose()) {
+        if ($output->isVerbose()){
             return ConsoleHandler::VERBOSITY_VERBOSE;
         }
 

Braces +17 added lines, -7 removed lines

@@ -74,11 +74,16 @@ 
         /** @var Console $console */
         $console = $this->container->get(Console::class);
 
-        try {
+        try
+        {
             $console->start($input ?? new ArgvInput(), $output);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             $this->handleException($e, $output);
-        } finally {
+        }
+        finally
+        {
             $listener->disable();
             $this->finalizer->finalize(false);
         }
@@ -90,9 +95,12 @@ 
      */
     protected function handleException(\Throwable $e, OutputInterface $output)
     {
-        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
         }
 
@@ -107,11 +115,13 @@ 
      */
     private function mapVerbosity(OutputInterface $output): int
     {
-        if ($output->isDebug() || $output->isVeryVerbose()) {
+        if ($output->isDebug() || $output->isVeryVerbose())
+        {
             return ConsoleHandler::VERBOSITY_DEBUG;
         }
 
-        if ($output->isVerbose()) {
+        if ($output->isVerbose())
+        {
             return ConsoleHandler::VERBOSITY_VERBOSE;
         }
 

src/Http/Middleware/SessionMiddleware.php

Spacing +8 added lines, -8 removed lines

@@ -51,7 +51,7 @@ 
         HttpConfig $httpConfig,
         SessionFactory $factory,
         ScopeInterface $scope
-    ) {
+    ){
         $this->config = $config;
         $this->httpConfig = $httpConfig;
         $this->factory = $factory;
@@ -69,14 +69,14 @@ 
             $this->fetchID($request)
         );
 
-        try {
+        try{
             $response = $this->scope->runScope(
                 [SessionInterface::class => $session],
                 function () use ($session, $request, $handler) {
                     return $handler->handle($request->withAttribute(static::ATTRIBUTE, $session));
                 }
             );
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             $session->abort();
             throw $e;
         }
@@ -95,14 +95,14 @@ 
         Request $request,
         Response $response
     ): Response {
-        if (!$session->isStarted()) {
+        if (!$session->isStarted()){
             return $response;
         }
 
         $session->commit();
 
         //SID changed
-        if ($this->fetchID($request) != $session->getID()) {
+        if ($this->fetchID($request) != $session->getID()){
             return $this->withCookie($request, $response, $session->getID());
         }
 
@@ -119,7 +119,7 @@ 
     protected function fetchID(Request $request): ?string
     {
         $cookies = $request->getCookieParams();
-        if (empty($cookies[$this->config->getCookie()])) {
+        if (empty($cookies[$this->config->getCookie()])){
             return null;
         }
 
@@ -152,8 +152,8 @@ 
     protected function clientSignature(Request $request): string
     {
         $signature = '';
-        foreach (static::SIGNATURE_HEADERS as $header) {
-            $signature .= $request->getHeaderLine($header) . ';';
+        foreach (static::SIGNATURE_HEADERS as $header){
+            $signature .= $request->getHeaderLine($header).';';
         }
 
         return hash('sha256', $signature);

Braces +15 added lines, -7 removed lines

@@ -69,14 +69,18 @@ 
             $this->fetchID($request)
         );
 
-        try {
+        try
+        {
             $response = $this->scope->runScope(
                 [SessionInterface::class => $session],
-                function () use ($session, $request, $handler) {
+                function () use ($session, $request, $handler)
+                {
                     return $handler->handle($request->withAttribute(static::ATTRIBUTE, $session));
                 }
             );
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             $session->abort();
             throw $e;
         }
@@ -95,14 +99,16 @@ 
         Request $request,
         Response $response
     ): Response {
-        if (!$session->isStarted()) {
+        if (!$session->isStarted())
+        {
             return $response;
         }
 
         $session->commit();
 
         //SID changed
-        if ($this->fetchID($request) != $session->getID()) {
+        if ($this->fetchID($request) != $session->getID())
+        {
             return $this->withCookie($request, $response, $session->getID());
         }
 
@@ -119,7 +125,8 @@ 
     protected function fetchID(Request $request): ?string
     {
         $cookies = $request->getCookieParams();
-        if (empty($cookies[$this->config->getCookie()])) {
+        if (empty($cookies[$this->config->getCookie()]))
+        {
             return null;
         }
 
@@ -152,7 +159,8 @@ 
     protected function clientSignature(Request $request): string
     {
         $signature = '';
-        foreach (static::SIGNATURE_HEADERS as $header) {
+        foreach (static::SIGNATURE_HEADERS as $header)
+        {
             $signature .= $request->getHeaderLine($header) . ';';
         }
 

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
         }