spiral / framework

src/Framework/Bootloader/ServerBootloader.php

Spacing +9 added lines, -9 removed lines

@@ -40,21 +40,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);
         }
 
@@ -69,25 +69,25 @@ 
     {
         $conn = $env->get('RR_RELAY', static::WORKER_DEFAULT);
 
-        if ($conn === 'pipes' || empty($conn)) {
+        if ($conn === 'pipes' || empty($conn)){
             return new Worker(new StreamRelay(STDIN, STDOUT));
         }
 
-        if (!preg_match('#^([a-z]+)://([^:]+):?(\d+)?$#i', $conn, $parts)) {
+        if (!preg_match('#^([a-z]+)://([^:]+):?(\d+)?$#i', $conn, $parts)){
             throw new BootException(
                 "Unable to configure Worker 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 Worker 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 +20 added lines, -9 removed lines

@@ -40,21 +40,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);
         }
 
@@ -69,25 +74,31 @@ 
     {
         $conn = $env->get('RR_RELAY', static::WORKER_DEFAULT);
 
-        if ($conn === 'pipes' || empty($conn)) {
+        if ($conn === 'pipes' || empty($conn))
+        {
             return new Worker(new StreamRelay(STDIN, STDOUT));
         }
 
-        if (!preg_match('#^([a-z]+)://([^:]+):?(\d+)?$#i', $conn, $parts)) {
+        if (!preg_match('#^([a-z]+)://([^:]+):?(\d+)?$#i', $conn, $parts))
+        {
             throw new BootException(
                 "Unable to configure Worker 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 Worker 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/Framework/Bootloader/CommandBootloader.php

Spacing +9 added lines, -9 removed lines

@@ -78,35 +78,35 @@ 
      */
     private function configureExtensions(ConsoleBootloader $console, Container $container): void
     {
-        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);
         }
 
-        if ($container->has(RouterInterface::class)) {
+        if ($container->has(RouterInterface::class)){
             $console->addCommand(Router\ListCommand::class);
         }
     }
@@ -135,7 +135,7 @@ 
 
         $console->addCommand(Cycle\SyncCommand::class);
 
-        if ($container->has(Migrator::class)) {
+        if ($container->has(Migrator::class)){
             $console->addCommand(Cycle\MigrateCommand::class);
         }
     }

Braces +18 added lines, -9 removed lines

@@ -78,35 +78,43 @@ 
      */
     private function configureExtensions(ConsoleBootloader $console, Container $container): void
     {
-        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);
         }
 
-        if ($container->has(RouterInterface::class)) {
+        if ($container->has(RouterInterface::class))
+        {
             $console->addCommand(Router\ListCommand::class);
         }
     }
@@ -135,7 +143,8 @@ 
 
         $console->addCommand(Cycle\SyncCommand::class);
 
-        if ($container->has(Migrator::class)) {
+        if ($container->has(Migrator::class))
+        {
             $console->addCommand(Cycle\MigrateCommand::class);
         }
     }

src/Framework/Bootloader/Database/DisconnectsBootloader.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
             function () use ($container): void {
                 /** @var DatabaseManager $dbal */
                 $dbal = $container->get(DatabaseManager::class);
-                foreach ($dbal->getDrivers() as $driver) {
+                foreach ($dbal->getDrivers() as $driver){
                     $driver->disconnect();
                 }
             }

Braces +2 added lines, -1 removed lines

@@ -31,7 +31,8 @@
             function () use ($container): void {
                 /** @var DatabaseManager $dbal */
                 $dbal = $container->get(DatabaseManager::class);
-                foreach ($dbal->getDrivers() as $driver) {
+                foreach ($dbal->getDrivers() as $driver)
+                {
                     $driver->disconnect();
                 }
             }

src/Framework/Bootloader/Database/MigrationsBootloader.php

Spacing +2 added lines, -2 removed lines

@@ -42,8 +42,8 @@
         EnvironmentInterface $env,
         DirectoriesInterface $dirs
     ): void {
-        if (!$dirs->has('migrations')) {
-            $dirs->set('migrations', $dirs->get('app') . 'migrations');
+        if (!$dirs->has('migrations')){
+            $dirs->set('migrations', $dirs->get('app').'migrations');
         }
 
         $config->setDefaults(

Braces +2 added lines, -1 removed lines

@@ -40,7 +40,8 @@
         EnvironmentInterface $env,
         DirectoriesInterface $dirs
     ): void {
-        if (!$dirs->has('migrations')) {
+        if (!$dirs->has('migrations'))
+        {
             $dirs->set('migrations', $dirs->get('app') . 'migrations');
         }
 

src/Framework/Bootloader/Cycle/SchemaBootloader.php

Spacing +5 added lines, -5 removed lines

@@ -85,11 +85,11 @@ 
     public function getGenerators(): array
     {
         $result = [];
-        foreach ($this->generators as $group) {
-            foreach ($group as $generator) {
-                if (is_object($generator) && !$generator instanceof Container\Autowire) {
+        foreach ($this->generators as $group){
+            foreach ($group as $generator){
+                if (is_object($generator) && !$generator instanceof Container\Autowire){
                     $result[] = $generator;
-                } else {
+                }else{
                     $result[] = $this->container->get($generator);
                 }
             }
@@ -105,7 +105,7 @@ 
     protected function schema(MemoryInterface $memory): SchemaInterface
     {
         $schema = $memory->loadData('cycle');
-        if (is_null($schema)) {
+        if (is_null($schema)){
             $schema = (new Compiler())->compile(
                 $this->container->get(Registry::class),
                 $this->getGenerators()

Braces +11 added lines, -5 removed lines

@@ -85,11 +85,16 @@ 
     public function getGenerators(): array
     {
         $result = [];
-        foreach ($this->generators as $group) {
-            foreach ($group as $generator) {
-                if (is_object($generator) && !$generator instanceof Container\Autowire) {
+        foreach ($this->generators as $group)
+        {
+            foreach ($group as $generator)
+            {
+                if (is_object($generator) && !$generator instanceof Container\Autowire)
+                {
                     $result[] = $generator;
-                } else {
+                }
+                else
+                {
                     $result[] = $this->container->get($generator);
                 }
             }
@@ -105,7 +110,8 @@ 
     protected function schema(MemoryInterface $memory): SchemaInterface
     {
         $schema = $memory->loadData('cycle');
-        if (is_null($schema)) {
+        if (is_null($schema))
+        {
             $schema = (new Compiler())->compile(
                 $this->container->get(Registry::class),
                 $this->getGenerators()

src/Framework/Bootloader/Cycle/CycleBootloader.php

Spacing +2 added lines, -2 removed lines

@@ -53,7 +53,7 @@ 
     {
         $finalizer->addFinalizer(
             function () use ($container): void {
-                if ($container->hasInstance(ORMInterface::class)) {
+                if ($container->hasInstance(ORMInterface::class)){
                     $container->get(ORMInterface::class)->getHeap()->clean();
                 }
             }
@@ -75,7 +75,7 @@ 
     ): ORMInterface {
         $orm = new ORM($factory, $schema);
 
-        if ($promiseFactory !== null) {
+        if ($promiseFactory !== null){
             return $orm->withPromiseFactory($promiseFactory);
         }
 

Braces +4 added lines, -2 removed lines

@@ -53,7 +53,8 @@ 
     {
         $finalizer->addFinalizer(
             function () use ($container): void {
-                if ($container->hasInstance(ORMInterface::class)) {
+                if ($container->hasInstance(ORMInterface::class))
+                {
                     $container->get(ORMInterface::class)->getHeap()->clean();
                 }
             }
@@ -75,7 +76,8 @@ 
     ): ORMInterface {
         $orm = new ORM($factory, $schema);
 
-        if ($promiseFactory !== null) {
+        if ($promiseFactory !== null)
+        {
             return $orm->withPromiseFactory($promiseFactory);
         }
 

src/Framework/Bootloader/Http/WebsocketsBootloader.php

Spacing +1 added lines, -1 removed lines

@@ -56,7 +56,7 @@
             ]
         );
 
-        if ($env->get('RR_BROADCAST_PATH', null) !== null) {
+        if ($env->get('RR_BROADCAST_PATH', null) !== null){
             $http->addMiddleware(WebsocketsMiddleware::class);
         }
     }

Braces +2 added lines, -1 removed lines

@@ -56,7 +56,8 @@
             ]
         );
 
-        if ($env->get('RR_BROADCAST_PATH', null) !== null) {
+        if ($env->get('RR_BROADCAST_PATH', null) !== null)
+        {
             $http->addMiddleware(WebsocketsMiddleware::class);
         }
     }

src/Framework/Bootloader/Http/RouterBootloader.php

Spacing +1 added lines, -1 removed lines

@@ -57,7 +57,7 @@
     private function route(ServerRequestInterface $request): RouteInterface
     {
         $route = $request->getAttribute(Router::ROUTE_ATTRIBUTE, null);
-        if ($route === null) {
+        if ($route === null){
             throw new ScopeException('Unable to resolve Route, invalid request scope');
         }
 

Braces +2 added lines, -1 removed lines

@@ -57,7 +57,8 @@
     private function route(ServerRequestInterface $request): RouteInterface
     {
         $route = $request->getAttribute(Router::ROUTE_ATTRIBUTE, null);
-        if ($route === null) {
+        if ($route === null)
+        {
             throw new ScopeException('Unable to resolve Route, invalid request scope');
         }
 

src/Framework/Bootloader/Http/HttpBootloader.php

Spacing +1 added lines, -1 removed lines

@@ -74,7 +74,7 @@
 
         $kernel->addDispatcher($factory->make(SapiDispatcher::class));
 
-        if (class_exists(PSR7Client::class)) {
+        if (class_exists(PSR7Client::class)){
             $kernel->addDispatcher($factory->make(RrDispatcher::class));
         }
     }

Braces +2 added lines, -1 removed lines

@@ -74,7 +74,8 @@
 
         $kernel->addDispatcher($factory->make(SapiDispatcher::class));
 
-        if (class_exists(PSR7Client::class)) {
+        if (class_exists(PSR7Client::class))
+        {
             $kernel->addDispatcher($factory->make(RrDispatcher::class));
         }
     }