spiral / framework

src/Framework/Debug/StateCollector/HttpCollector.php

Spacing +3 added lines, -3 removed lines

@@ -39,7 +39,7 @@ 
      */
     public function populate(StateInterface $state): void
     {
-        if ($this->request === null) {
+        if ($this->request === null){
             return;
         }
 
@@ -48,11 +48,11 @@ 
 
         $state->setVariable('headers', $this->request->getHeaders());
 
-        if ($this->request->getQueryParams() !== []) {
+        if ($this->request->getQueryParams() !== []){
             $state->setVariable('query', $this->request->getQueryParams());
         }
 
-        if ($this->request->getParsedBody() !== null) {
+        if ($this->request->getParsedBody() !== null){
             $state->setVariable('data', $this->request->getParsedBody());
         }
     }

Braces +6 added lines, -3 removed lines

@@ -39,7 +39,8 @@ 
      */
     public function populate(StateInterface $state): void
     {
-        if ($this->request === null) {
+        if ($this->request === null)
+        {
             return;
         }
 
@@ -48,11 +49,13 @@ 
 
         $state->setVariable('headers', $this->request->getHeaders());
 
-        if ($this->request->getQueryParams() !== []) {
+        if ($this->request->getQueryParams() !== [])
+        {
             $state->setVariable('query', $this->request->getQueryParams());
         }
 
-        if ($this->request->getParsedBody() !== null) {
+        if ($this->request->getParsedBody() !== null)
+        {
             $state->setVariable('data', $this->request->getParsedBody());
         }
     }

src/Framework/Framework/Kernel.php

Spacing +9 added lines, -9 removed lines

@@ -43,29 +43,29 @@
      */
     protected function mapDirectories(array $directories): array
     {
-        if (!isset($directories['root'])) {
+        if (!isset($directories['root'])){
             throw new BootException('Missing required directory `root`');
         }
 
-        if (!isset($directories['app'])) {
-            $directories['app'] = $directories['root'] . '/app/';
+        if (!isset($directories['app'])){
+            $directories['app'] = $directories['root'].'/app/';
         }
 
         return array_merge(
             [
                 // public root
-                'public'    => $directories['root'] . '/public/',
+                'public'    => $directories['root'].'/public/',
 
                 // vendor libraries
-                'vendor'    => $directories['root'] . '/vendor/',
+                'vendor'    => $directories['root'].'/vendor/',
 
                 // data directories
-                'runtime'   => $directories['root'] . '/runtime/',
-                'cache'     => $directories['root'] . '/runtime/cache/',
+                'runtime'   => $directories['root'].'/runtime/',
+                'cache'     => $directories['root'].'/runtime/cache/',
 
                 // application directories
-                'config'    => $directories['app'] . '/config/',
-                'resources' => $directories['app'] . '/resources/',
+                'config'    => $directories['app'].'/config/',
+                'resources' => $directories['app'].'/resources/',
             ],
             $directories
         );

Braces +4 added lines, -2 removed lines

@@ -43,11 +43,13 @@
      */
     protected function mapDirectories(array $directories): array
     {
-        if (!isset($directories['root'])) {
+        if (!isset($directories['root']))
+        {
             throw new BootException('Missing required directory `root`');
         }
 
-        if (!isset($directories['app'])) {
+        if (!isset($directories['app']))
+        {
             $directories['app'] = $directories['root'] . '/app/';
         }
 

src/Framework/Broadcast/Middleware/WebsocketsMiddleware.php

Spacing +10 added lines, -10 removed lines

@@ -50,7 +50,7 @@ 
         ScopeInterface $scope,
         ResolverInterface $resolver,
         ResponseFactoryInterface $responseFactory
-    ) {
+    ){
         $this->config = $config;
         $this->scope = $scope;
         $this->resolver = $resolver;
@@ -67,13 +67,13 @@ 
      */
     public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
     {
-        if ($request->getUri()->getPath() !== $this->config->getPath()) {
+        if ($request->getUri()->getPath() !== $this->config->getPath()){
             return $handler->handle($request);
         }
 
         // server authorization
-        if ($request->getAttribute('ws:joinServer', null) !== null) {
-            if (!$this->authorizeServer($request)) {
+        if ($request->getAttribute('ws:joinServer', null) !== null){
+            if (!$this->authorizeServer($request)){
                 return $this->responseFactory->createResponse(403);
             }
 
@@ -81,10 +81,10 @@ 
         }
 
         // topic authorization
-        if (is_string($request->getAttribute('ws:joinTopics', null))) {
+        if (is_string($request->getAttribute('ws:joinTopics', null))){
             $topics = explode(',', $request->getAttribute('ws:joinTopics'));
-            foreach ($topics as $topic) {
-                if (!$this->authorizeTopic($request, $topic)) {
+            foreach ($topics as $topic){
+                if (!$this->authorizeTopic($request, $topic)){
                     return $this->responseFactory->createResponse(403);
                 }
             }
@@ -104,7 +104,7 @@ 
     private function authorizeServer(ServerRequestInterface $request): bool
     {
         $callback = $this->config->getServerCallback();
-        if ($callback === null) {
+        if ($callback === null){
             return true;
         }
 
@@ -122,7 +122,7 @@ 
     {
         $parameters = [];
         $callback = $this->config->findTopicCallback($topic, $parameters);
-        if ($callback === null) {
+        if ($callback === null){
             return false;
         }
 
@@ -141,7 +141,7 @@ 
     {
         /** @var \ReflectionFunctionAbstract $reflection */
         $reflection = null;
-        switch (true) {
+        switch (true){
             case $callback instanceof \Closure || is_string($callback):
                 $reflection = new \ReflectionFunction($callback);
                 break;

Braces +20 added lines, -10 removed lines

@@ -67,13 +67,16 @@ 
      */
     public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
     {
-        if ($request->getUri()->getPath() !== $this->config->getPath()) {
+        if ($request->getUri()->getPath() !== $this->config->getPath())
+        {
             return $handler->handle($request);
         }
 
         // server authorization
-        if ($request->getAttribute('ws:joinServer', null) !== null) {
-            if (!$this->authorizeServer($request)) {
+        if ($request->getAttribute('ws:joinServer', null) !== null)
+        {
+            if (!$this->authorizeServer($request))
+            {
                 return $this->responseFactory->createResponse(403);
             }
 
@@ -81,10 +84,13 @@ 
         }
 
         // topic authorization
-        if (is_string($request->getAttribute('ws:joinTopics', null))) {
+        if (is_string($request->getAttribute('ws:joinTopics', null)))
+        {
             $topics = explode(',', $request->getAttribute('ws:joinTopics'));
-            foreach ($topics as $topic) {
-                if (!$this->authorizeTopic($request, $topic)) {
+            foreach ($topics as $topic)
+            {
+                if (!$this->authorizeTopic($request, $topic))
+                {
                     return $this->responseFactory->createResponse(403);
                 }
             }
@@ -104,7 +110,8 @@ 
     private function authorizeServer(ServerRequestInterface $request): bool
     {
         $callback = $this->config->getServerCallback();
-        if ($callback === null) {
+        if ($callback === null)
+        {
             return true;
         }
 
@@ -122,7 +129,8 @@ 
     {
         $parameters = [];
         $callback = $this->config->findTopicCallback($topic, $parameters);
-        if ($callback === null) {
+        if ($callback === null)
+        {
             return false;
         }
 
@@ -141,7 +149,8 @@ 
     {
         /** @var \ReflectionFunctionAbstract $reflection */
         $reflection = null;
-        switch (true) {
+        switch (true)
+        {
             case $callback instanceof \Closure || is_string($callback):
                 $reflection = new \ReflectionFunction($callback);
                 break;
@@ -159,7 +168,8 @@ 
             [
                 ServerRequestInterface::class => $request
             ],
-            function () use ($reflection, $parameters, $callback) {
+            function () use ($reflection, $parameters, $callback)
+            {
                 return call_user_func_array(
                     $callback,
                     $this->resolver->resolveArguments($reflection, $parameters)

src/Framework/Broadcast/Config/WebsocketsConfig.php

Spacing +7 added lines, -7 removed lines

@@ -34,7 +34,7 @@ 
     {
         parent::__construct($config);
 
-        foreach ($config['authorizeTopics'] as $topic => $callback) {
+        foreach ($config['authorizeTopics'] as $topic => $callback){
             $this->patterns[$this->compilePattern($topic)] = $callback;
         }
     }
@@ -62,8 +62,8 @@ 
      */
     public function findTopicCallback(string $topic, array &$matches): ?callable
     {
-        foreach ($this->patterns as $pattern => $callback) {
-            if (preg_match($pattern, $topic, $matches)) {
+        foreach ($this->patterns as $pattern => $callback){
+            if (preg_match($pattern, $topic, $matches)){
                 return $callback;
             }
         }
@@ -78,13 +78,13 @@ 
     private function compilePattern(string $topic): string
     {
         $replaces = [];
-        if (preg_match_all('/\{(\w+):?(.*?)?\}/', $topic, $matches)) {
+        if (preg_match_all('/\{(\w+):?(.*?)?\}/', $topic, $matches)){
             $variables = array_combine($matches[1], $matches[2]);
-            foreach ($variables as $key => $segment) {
-                $replaces['{' . $key . '}'] = '(?P<' . $key . '>[^\/\.]+)';
+            foreach ($variables as $key => $segment){
+                $replaces['{'.$key.'}'] = '(?P<'.$key.'>[^\/\.]+)';
             }
         }
 
-        return '/^' . strtr($topic, $replaces + ['/' => '\\/', '[' => '(?:', ']' => ')?', '.' => '\.']) . '$/iu';
+        return '/^'.strtr($topic, $replaces + ['/' => '\\/', '[' => '(?:', ']' => ')?', '.' => '\.']).'$/iu';
     }
 }

Braces +10 added lines, -5 removed lines

@@ -34,7 +34,8 @@ 
     {
         parent::__construct($config);
 
-        foreach ($config['authorizeTopics'] as $topic => $callback) {
+        foreach ($config['authorizeTopics'] as $topic => $callback)
+        {
             $this->patterns[$this->compilePattern($topic)] = $callback;
         }
     }
@@ -62,8 +63,10 @@ 
      */
     public function findTopicCallback(string $topic, array &$matches): ?callable
     {
-        foreach ($this->patterns as $pattern => $callback) {
-            if (preg_match($pattern, $topic, $matches)) {
+        foreach ($this->patterns as $pattern => $callback)
+        {
+            if (preg_match($pattern, $topic, $matches))
+            {
                 return $callback;
             }
         }
@@ -78,9 +81,11 @@ 
     private function compilePattern(string $topic): string
     {
         $replaces = [];
-        if (preg_match_all('/\{(\w+):?(.*?)?\}/', $topic, $matches)) {
+        if (preg_match_all('/\{(\w+):?(.*?)?\}/', $topic, $matches))
+        {
             $variables = array_combine($matches[1], $matches[2]);
-            foreach ($variables as $key => $segment) {
+            foreach ($variables as $key => $segment)
+            {
                 $replaces['{' . $key . '}'] = '(?P<' . $key . '>[^\/\.]+)';
             }
         }

src/Framework/Cookies/CookieManager.php

Spacing +4 added lines, -4 removed lines

@@ -174,9 +174,9 @@ 
      */
     private function getRequest(): ServerRequestInterface
     {
-        try {
+        try{
             return $this->container->get(ServerRequestInterface::class);
-        } catch (NotFoundExceptionInterface $e) {
+        }catch (NotFoundExceptionInterface $e){
             throw new ScopeException('Unable to receive active request', $e->getCode(), $e);
         }
     }
@@ -188,9 +188,9 @@ 
      */
     private function getCookieQueue(): CookieQueue
     {
-        try {
+        try{
             return $this->container->get(CookieQueue::class);
-        } catch (NotFoundExceptionInterface $e) {
+        }catch (NotFoundExceptionInterface $e){
             throw new ScopeException('Unable to receive cookie queue, invalid request scope', $e->getCode(), $e);
         }
     }

Braces +10 added lines, -4 removed lines

@@ -169,9 +169,12 @@ 
      */
     private function getRequest(): ServerRequestInterface
     {
-        try {
+        try
+        {
             return $this->container->get(ServerRequestInterface::class);
-        } catch (NotFoundExceptionInterface $e) {
+        }
+        catch (NotFoundExceptionInterface $e)
+        {
             throw new ScopeException('Unable to receive active request', $e->getCode(), $e);
         }
     }
@@ -183,9 +186,12 @@ 
      */
     private function getCookieQueue(): CookieQueue
     {
-        try {
+        try
+        {
             return $this->container->get(CookieQueue::class);
-        } catch (NotFoundExceptionInterface $e) {
+        }
+        catch (NotFoundExceptionInterface $e)
+        {
             throw new ScopeException('Unable to receive cookie queue, invalid request scope', $e->getCode(), $e);
         }
     }

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');
         }