spiral / framework

src/Bridge/DataGrid/src/Writer/PostgresQueryWriter.php

Spacing +5 added lines, -5 removed lines

@@ -31,11 +31,11 @@ 
      */
     public function write($source, SpecificationInterface $specification, Compiler $compiler)
     {
-        if (!$this->targetAcceptable($source)) {
+        if (!$this->targetAcceptable($source)){
             return null;
         }
 
-        if ($specification instanceof Specification\Filter\Postgres\ILike) {
+        if ($specification instanceof Specification\Filter\Postgres\ILike){
             return $source->where(
                 $specification->getExpression(),
                 'ILIKE',
@@ -56,7 +56,7 @@ 
             class_exists(SelectQuery::class)
             && $target instanceof SelectQuery
             && $target->getDriver() instanceof PostgresDriver
-        ) {
+        ){
             return true;
         }
 
@@ -64,7 +64,7 @@ 
             class_exists(Select::class)
             && $target instanceof Select
             && $target->buildQuery()->getDriver() instanceof PostgresDriver
-        ) {
+        ){
             return true;
         }
 
@@ -79,7 +79,7 @@ 
      */
     protected function fetchValue($value)
     {
-        if ($value instanceof Specification\ValueInterface) {
+        if ($value instanceof Specification\ValueInterface){
             throw new CompilerException('Value expects user input, none given');
         }
 

Braces +6 added lines, -3 removed lines

@@ -31,11 +31,13 @@ 
      */
     public function write($source, SpecificationInterface $specification, Compiler $compiler)
     {
-        if (!$this->targetAcceptable($source)) {
+        if (!$this->targetAcceptable($source))
+        {
             return null;
         }
 
-        if ($specification instanceof Specification\Filter\Postgres\ILike) {
+        if ($specification instanceof Specification\Filter\Postgres\ILike)
+        {
             return $source->where(
                 $specification->getExpression(),
                 'ILIKE',
@@ -79,7 +81,8 @@ 
      */
     protected function fetchValue($value)
     {
-        if ($value instanceof Specification\ValueInterface) {
+        if ($value instanceof Specification\ValueInterface)
+        {
             throw new CompilerException('Value expects user input, none given');
         }
 

src/Boot/tests/ConfigsTest.php

Spacing +2 added lines, -2 removed lines

@@ -23,7 +23,7 @@ 
     {
         $core = TestCore::init([
             'root'   => __DIR__,
-            'config' => __DIR__ . '/config'
+            'config' => __DIR__.'/config'
         ]);
 
         /** @var TestConfig $config */
@@ -36,7 +36,7 @@ 
     {
         $core = TestCore::init([
             'root'   => __DIR__,
-            'config' => __DIR__ . '/config',
+            'config' => __DIR__.'/config',
         ]);
 
         /** @var ConfiguratorInterface $config */

src/Boot/src/Bootloader/ConfigurationBootloader.php

Spacing +1 added lines, -1 removed lines

@@ -59,7 +59,7 @@
 
     public function addLoader(string $ext, FileLoaderInterface $loader): void
     {
-        if (!isset($this->loaders[$ext]) || get_class($this->loaders[$ext]) !== get_class($loader)) {
+        if (!isset($this->loaders[$ext]) || get_class($this->loaders[$ext]) !== get_class($loader)){
             $this->loaders[$ext] = $loader;
             $this->container->bindSingleton(ConfigManager::class, $this->createConfigManager());
         }

Braces +2 added lines, -1 removed lines

@@ -59,7 +59,8 @@
 
     public function addLoader(string $ext, FileLoaderInterface $loader): void
     {
-        if (!isset($this->loaders[$ext]) || get_class($this->loaders[$ext]) !== get_class($loader)) {
+        if (!isset($this->loaders[$ext]) || get_class($this->loaders[$ext]) !== get_class($loader))
+        {
             $this->loaders[$ext] = $loader;
             $this->container->bindSingleton(ConfigManager::class, $this->createConfigManager());
         }

src/Bridge/Stempler/tests/BaseTest.php

Spacing +3 added lines, -3 removed lines

@@ -51,8 +51,8 @@ 
             DirectoriesInterface::class,
             new Directories(
                 [
-                    'app'   => __DIR__ . '/fixtures',
-                    'cache' => __DIR__ . '/cache'
+                    'app'   => __DIR__.'/fixtures',
+                    'cache' => __DIR__.'/cache'
                 ]
             )
         );
@@ -61,7 +61,7 @@ 
         $this->container->bind(
             ConfiguratorInterface::class,
             new ConfigManager(
-                new DirectoryLoader(__DIR__ . '/config/', [
+                new DirectoryLoader(__DIR__.'/config/', [
                     'php'  => $this->container->get(PhpLoader::class),
                     'json' => $this->container->get(JsonLoader::class),
                 ]),

src/Framework/Http/LegacyRrDispatcher.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/Debug/StateCollector/EnvironmentCollector.php

Spacing +2 added lines, -2 removed lines

@@ -43,8 +43,8 @@
     {
         $state->setTag('php', phpversion());
 
-        if ($this->container->has(DispatcherInterface::class)) {
-            switch (get_class($this->container->get(DispatcherInterface::class))) {
+        if ($this->container->has(DispatcherInterface::class)){
+            switch (get_class($this->container->get(DispatcherInterface::class))){
                 case LegacyRrDispatcher::class:
                     $state->setTag('dispatcher', 'roadrunner');
                     break;

Braces +4 added lines, -2 removed lines

@@ -43,8 +43,10 @@
     {
         $state->setTag('php', phpversion());
 
-        if ($this->container->has(DispatcherInterface::class)) {
-            switch (get_class($this->container->get(DispatcherInterface::class))) {
+        if ($this->container->has(DispatcherInterface::class))
+        {
+            switch (get_class($this->container->get(DispatcherInterface::class)))
+            {
                 case LegacyRrDispatcher::class:
                     $state->setTag('dispatcher', 'roadrunner');
                     break;

src/Framework/Bootloader/Server/LegacyRoadRunnerBootloader.php

Spacing +12 added lines, -12 removed lines

@@ -39,15 +39,15 @@ 
      */
     public function boot(Container $container)
     {
-        $container->bindSingleton(RPC::class, function (EnvironmentInterface $env) {
+        $container->bindSingleton(RPC::class, function (EnvironmentInterface $env){
             return $this->rpc($env);
         });
 
-        $container->bindSingleton(Worker::class, function (EnvironmentInterface $env) {
+        $container->bindSingleton(Worker::class, function (EnvironmentInterface $env){
             return $this->worker($env);
         });
 
-        $container->bindSingleton(MetricsInterface::class, function (RPC $rpc) {
+        $container->bindSingleton(MetricsInterface::class, function (RPC $rpc){
             return new Metrics($rpc);
         });
     }
@@ -60,21 +60,21 @@ 
     {
         $conn = $env->get('RR_RPC', self::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);
         }
 
@@ -89,25 +89,25 @@ 
     {
         $conn = $env->get('RR_RELAY', self::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 +26 added lines, -12 removed lines

@@ -39,15 +39,18 @@ 
      */
     public function boot(Container $container)
     {
-        $container->bindSingleton(RPC::class, function (EnvironmentInterface $env) {
+        $container->bindSingleton(RPC::class, function (EnvironmentInterface $env)
+        {
             return $this->rpc($env);
         });
 
-        $container->bindSingleton(Worker::class, function (EnvironmentInterface $env) {
+        $container->bindSingleton(Worker::class, function (EnvironmentInterface $env)
+        {
             return $this->worker($env);
         });
 
-        $container->bindSingleton(MetricsInterface::class, function (RPC $rpc) {
+        $container->bindSingleton(MetricsInterface::class, function (RPC $rpc)
+        {
             return new Metrics($rpc);
         });
     }
@@ -60,21 +63,26 @@ 
     {
         $conn = $env->get('RR_RPC', self::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);
         }
 
@@ -89,25 +97,31 @@ 
     {
         $conn = $env->get('RR_RELAY', self::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/ServerBootloader.php

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
      */
     private function isLegacy(): bool
     {
-        if (\class_exists(InstalledVersions::class)) {
+        if (\class_exists(InstalledVersions::class)){
             $version = InstalledVersions::getVersion('spiral/roadrunner');
 
             return \str_starts_with($version, '1.');

Braces +2 added lines, -1 removed lines

@@ -42,7 +42,8 @@
      */
     private function isLegacy(): bool
     {
-        if (\class_exists(InstalledVersions::class)) {
+        if (\class_exists(InstalledVersions::class))
+        {
             $version = InstalledVersions::getVersion('spiral/roadrunner');
 
             return \str_starts_with($version, '1.');

src/Framework/Bootloader/Jobs/JobsBootloader.php

Spacing +4 added lines, -4 removed lines

@@ -47,12 +47,12 @@
     {
         $kernel->addDispatcher($jobs);
 
-        if (\class_exists(LegacyRPC::class)) {
-            $container->bindSingleton(QueueInterface::class, function (LegacyRPC $rpc, JobRegistry $registry) {
+        if (\class_exists(LegacyRPC::class)){
+            $container->bindSingleton(QueueInterface::class, function (LegacyRPC $rpc, JobRegistry $registry){
                 return new JobQueue($rpc, $registry);
             });
-        } else {
-            $container->bindSingleton(QueueInterface::class, function (RPC $rpc, JobRegistry $registry) {
+        }else{
+            $container->bindSingleton(QueueInterface::class, function (RPC $rpc, JobRegistry $registry){
                 return new JobQueue($rpc, $registry);
             });
         }

Braces +9 added lines, -4 removed lines

@@ -47,12 +47,17 @@
     {
         $kernel->addDispatcher($jobs);
 
-        if (\class_exists(LegacyRPC::class)) {
-            $container->bindSingleton(QueueInterface::class, function (LegacyRPC $rpc, JobRegistry $registry) {
+        if (\class_exists(LegacyRPC::class))
+        {
+            $container->bindSingleton(QueueInterface::class, function (LegacyRPC $rpc, JobRegistry $registry)
+            {
                 return new JobQueue($rpc, $registry);
             });
-        } else {
-            $container->bindSingleton(QueueInterface::class, function (RPC $rpc, JobRegistry $registry) {
+        }
+        else
+        {
+            $container->bindSingleton(QueueInterface::class, function (RPC $rpc, JobRegistry $registry)
+            {
                 return new JobQueue($rpc, $registry);
             });
         }