spiral / framework

src/Framework/Bootloader/Storage/StorageConfig.php

Spacing +16 added lines, -16 removed lines

@@ -103,8 +103,8 @@ 
      */
     private function bootStorages(array $config): void
     {
-        foreach ($config['buckets'] as $name => $bucket) {
-            if (!\is_string($name)) {
+        foreach ($config['buckets'] as $name => $bucket){
+            if (!\is_string($name)){
                 throw new InvalidArgumentException(
                     \vsprintf('Storage bucket config key must be a string, but %s defined', [
                         \get_debug_type($name),
@@ -113,7 +113,7 @@ 
             }
 
             $serverName = $bucket['server'] ?? null;
-            if (!\is_string($serverName)) {
+            if (!\is_string($serverName)){
                 throw new InvalidArgumentException(
                     \vsprintf('Storage bucket `%s.server` config key required and must be a string, but %s defined', [
                         $name,
@@ -123,7 +123,7 @@ 
             }
 
             $server = $config['servers'][$serverName] ?? null;
-            if (!\is_array($server)) {
+            if (!\is_array($server)){
                 throw new InvalidArgumentException(
                     \vsprintf('Storage bucket `%s` relates to non-existing server `%s`', [
                         $name,
@@ -133,7 +133,7 @@ 
             }
 
             $adapter = $server['adapter'] ?? null;
-            if (!\is_string($adapter)) {
+            if (!\is_string($adapter)){
                 throw new InvalidArgumentException(
                     \vsprintf('Storage server `%s.adapter` config key required and must be a string, but %s defined', [
                         $serverName,
@@ -146,7 +146,7 @@ 
 
             $this->adapters[$name] = $adapter;
 
-            if (isset($bucket['distribution'])) {
+            if (isset($bucket['distribution'])){
                 $this->distributions[$name] = $bucket['distribution'];
             }
         }
@@ -160,7 +160,7 @@ 
      */
     private function createAdapter(string $serverName, array $bucket, array $server): FilesystemAdapter
     {
-        switch ($server['adapter']) {
+        switch ($server['adapter']){
             case 'local':
                 return $this->createLocalAdapter($serverName, $bucket, $server);
 
@@ -184,9 +184,9 @@ 
      */
     private function createS3Adapter(string $serverName, array $bucket, array $server, bool $async): FilesystemAdapter
     {
-        if (!\class_exists(Credentials::class)) {
+        if (!\class_exists(Credentials::class)){
             throw new ConfigException(
-                'Can not create AWS credentials while creating "' . $serverName . '" server. '
+                'Can not create AWS credentials while creating "'.$serverName.'" server. '
                 . 'Perhaps you forgot to install the "league/flysystem-aws-s3-v3" package?'
             );
         }
@@ -206,8 +206,8 @@ 
         $name = $bucket['bucket'] ?? $server['bucket'];
         $visibility = $bucket['visibility'] ?? $server['bucket'] ?? Visibility::VISIBILITY_PUBLIC;
 
-        if ($async) {
-            if (!\class_exists(AsyncAwsS3Adapter::class)) {
+        if ($async){
+            if (!\class_exists(AsyncAwsS3Adapter::class)){
                 throw new InvalidArgumentException(
                     'Can not create async S3 client, please install "league/flysystem-async-aws-s3"'
                 );
@@ -223,7 +223,7 @@ 
             );
         }
 
-        if (!\class_exists(AwsS3V3Adapter::class)) {
+        if (!\class_exists(AwsS3V3Adapter::class)){
             throw new InvalidArgumentException(
                 'Can not create S3 client, please install "league/flysystem-aws-s3-v3"'
             );
@@ -247,7 +247,7 @@ 
      */
     private function createLocalAdapter(string $serverName, array $bucket, array $server): FilesystemAdapter
     {
-        if (!\is_string($server['directory'] ?? null)) {
+        if (!\is_string($server['directory'] ?? null)){
             throw new InvalidArgumentException(
                 \vsprintf('Storage server `%s.directory` config key required and must be a string, but %s defined', [
                     $serverName,
@@ -282,7 +282,7 @@ 
         $adapter = $server['adapter'];
         $isFilesystemAdapter = \is_subclass_of($adapter, FilesystemAdapter::class, true);
 
-        if (!$isFilesystemAdapter) {
+        if (!$isFilesystemAdapter){
             throw new InvalidArgumentException(
                 \vsprintf('Storage server `%s` must be a class string of %s, but `%s` defined', [
                     $serverName,
@@ -292,9 +292,9 @@ 
             );
         }
 
-        try {
+        try{
             return new $adapter(...\array_values($server['options'] ?? []));
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             $message = 'An error occurred while server `%s` initializing: %s';
             throw new InvalidArgumentException(\sprintf($message, $serverName, $e->getMessage()), 0, $e);
         }

Braces +31 added lines, -15 removed lines

@@ -103,8 +103,10 @@ 
      */
     private function bootStorages(array $config): void
     {
-        foreach ($config['buckets'] as $name => $bucket) {
-            if (!\is_string($name)) {
+        foreach ($config['buckets'] as $name => $bucket)
+        {
+            if (!\is_string($name))
+            {
                 throw new InvalidArgumentException(
                     \vsprintf('Storage bucket config key must be a string, but %s defined', [
                         \get_debug_type($name),
@@ -113,7 +115,8 @@ 
             }
 
             $serverName = $bucket['server'] ?? null;
-            if (!\is_string($serverName)) {
+            if (!\is_string($serverName))
+            {
                 throw new InvalidArgumentException(
                     \vsprintf('Storage bucket `%s.server` config key required and must be a string, but %s defined', [
                         $name,
@@ -123,7 +126,8 @@ 
             }
 
             $server = $config['servers'][$serverName] ?? null;
-            if (!\is_array($server)) {
+            if (!\is_array($server))
+            {
                 throw new InvalidArgumentException(
                     \vsprintf('Storage bucket `%s` relates to non-existing server `%s`', [
                         $name,
@@ -133,7 +137,8 @@ 
             }
 
             $adapter = $server['adapter'] ?? null;
-            if (!\is_string($adapter)) {
+            if (!\is_string($adapter))
+            {
                 throw new InvalidArgumentException(
                     \vsprintf('Storage server `%s.adapter` config key required and must be a string, but %s defined', [
                         $serverName,
@@ -146,7 +151,8 @@ 
 
             $this->adapters[$name] = $adapter;
 
-            if (isset($bucket['distribution'])) {
+            if (isset($bucket['distribution']))
+            {
                 $this->distributions[$name] = $bucket['distribution'];
             }
         }
@@ -160,7 +166,8 @@ 
      */
     private function createAdapter(string $serverName, array $bucket, array $server): FilesystemAdapter
     {
-        switch ($server['adapter']) {
+        switch ($server['adapter'])
+        {
             case 'local':
                 return $this->createLocalAdapter($serverName, $bucket, $server);
 
@@ -184,7 +191,8 @@ 
      */
     private function createS3Adapter(string $serverName, array $bucket, array $server, bool $async): FilesystemAdapter
     {
-        if (!\class_exists(Credentials::class)) {
+        if (!\class_exists(Credentials::class))
+        {
             throw new ConfigException(
                 'Can not create AWS credentials while creating "' . $serverName . '" server. '
                 . 'Perhaps you forgot to install the "league/flysystem-aws-s3-v3" package?'
@@ -206,8 +214,10 @@ 
         $name = $bucket['bucket'] ?? $server['bucket'];
         $visibility = $bucket['visibility'] ?? $server['bucket'] ?? Visibility::VISIBILITY_PUBLIC;
 
-        if ($async) {
-            if (!\class_exists(AsyncAwsS3Adapter::class)) {
+        if ($async)
+        {
+            if (!\class_exists(AsyncAwsS3Adapter::class))
+            {
                 throw new InvalidArgumentException(
                     'Can not create async S3 client, please install "league/flysystem-async-aws-s3"'
                 );
@@ -223,7 +233,8 @@ 
             );
         }
 
-        if (!\class_exists(AwsS3V3Adapter::class)) {
+        if (!\class_exists(AwsS3V3Adapter::class))
+        {
             throw new InvalidArgumentException(
                 'Can not create S3 client, please install "league/flysystem-aws-s3-v3"'
             );
@@ -247,7 +258,8 @@ 
      */
     private function createLocalAdapter(string $serverName, array $bucket, array $server): FilesystemAdapter
     {
-        if (!\is_string($server['directory'] ?? null)) {
+        if (!\is_string($server['directory'] ?? null))
+        {
             throw new InvalidArgumentException(
                 \vsprintf('Storage server `%s.directory` config key required and must be a string, but %s defined', [
                     $serverName,
@@ -282,7 +294,8 @@ 
         $adapter = $server['adapter'];
         $isFilesystemAdapter = \is_subclass_of($adapter, FilesystemAdapter::class, true);
 
-        if (!$isFilesystemAdapter) {
+        if (!$isFilesystemAdapter)
+        {
             throw new InvalidArgumentException(
                 \vsprintf('Storage server `%s` must be a class string of %s, but `%s` defined', [
                     $serverName,
@@ -292,9 +305,12 @@ 
             );
         }
 
-        try {
+        try
+        {
             return new $adapter(...\array_values($server['options'] ?? []));
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             $message = 'An error occurred while server `%s` initializing: %s';
             throw new InvalidArgumentException(\sprintf($message, $serverName, $e->getMessage()), 0, $e);
         }

src/Framework/Bootloader/Storage/StorageBootloader.php

Spacing +8 added lines, -8 removed lines

@@ -39,18 +39,18 @@ 
 
         $app->bindInjector(StorageConfig::class, ConfiguratorInterface::class);
 
-        $app->bindSingleton(StorageInterface::class, static function (StorageConfig $config, Container $app) {
+        $app->bindSingleton(StorageInterface::class, static function (StorageConfig $config, Container $app){
             $manager = new Storage($config->getDefaultBucket());
 
             $distributions = $config->getDistributions();
 
-            foreach ($config->getAdapters() as $name => $adapter) {
+            foreach ($config->getAdapters() as $name => $adapter){
                 $resolver = null;
 
-                if (isset($distributions[$name])) {
-                    try {
+                if (isset($distributions[$name])){
+                    try{
                         $cdn = $app->make(CdnInterface::class);
-                    } catch (NotFoundException $e) {
+                    }catch (NotFoundException $e){
                         $message = 'Unable to create distribution for bucket "%s". '
                             . 'Please make sure that bootloader %s is added in your application';
                         $message = \sprintf($message, $name, DistributionBootloader::class);
@@ -67,15 +67,15 @@ 
             return $manager;
         });
 
-        $app->bindSingleton(Storage::class, static function (StorageInterface $manager) {
+        $app->bindSingleton(Storage::class, static function (StorageInterface $manager){
             return $manager;
         });
 
-        $app->bindSingleton(BucketInterface::class, static function (StorageInterface $manager) {
+        $app->bindSingleton(BucketInterface::class, static function (StorageInterface $manager){
             return $manager->bucket();
         });
 
-        $app->bindSingleton(Bucket::class, static function (BucketInterface $storage) {
+        $app->bindSingleton(Bucket::class, static function (BucketInterface $storage){
             return $storage;
         });
     }

Braces +17 added lines, -8 removed lines

@@ -39,18 +39,24 @@ 
 
         $app->bindInjector(StorageConfig::class, ConfiguratorInterface::class);
 
-        $app->bindSingleton(StorageInterface::class, static function (StorageConfig $config, Container $app) {
+        $app->bindSingleton(StorageInterface::class, static function (StorageConfig $config, Container $app)
+        {
             $manager = new Storage($config->getDefaultBucket());
 
             $distributions = $config->getDistributions();
 
-            foreach ($config->getAdapters() as $name => $adapter) {
+            foreach ($config->getAdapters() as $name => $adapter)
+            {
                 $resolver = null;
 
-                if (isset($distributions[$name])) {
-                    try {
+                if (isset($distributions[$name]))
+                {
+                    try
+                    {
                         $cdn = $app->make(CdnInterface::class);
-                    } catch (NotFoundException $e) {
+                    }
+                    catch (NotFoundException $e)
+                    {
                         $message = 'Unable to create distribution for bucket "%s". '
                             . 'Please make sure that bootloader %s is added in your application';
                         $message = \sprintf($message, $name, DistributionBootloader::class);
@@ -67,15 +73,18 @@ 
             return $manager;
         });
 
-        $app->bindSingleton(Storage::class, static function (StorageInterface $manager) {
+        $app->bindSingleton(Storage::class, static function (StorageInterface $manager)
+        {
             return $manager;
         });
 
-        $app->bindSingleton(BucketInterface::class, static function (StorageInterface $manager) {
+        $app->bindSingleton(BucketInterface::class, static function (StorageInterface $manager)
+        {
             return $manager->bucket();
         });
 
-        $app->bindSingleton(Bucket::class, static function (BucketInterface $storage) {
+        $app->bindSingleton(Bucket::class, static function (BucketInterface $storage)
+        {
             return $storage;
         });
     }

src/Distribution/src/Resolver/StaticResolver.php

Spacing +1 added lines, -1 removed lines

@@ -75,6 +75,6 @@
         $prefix = \trim($this->host->getPath(), self::URI_PATH_DELIMITER);
         $file = \trim($file, self::URI_PATH_DELIMITER);
 
-        return self::URI_PATH_DELIMITER . ('' === $prefix ? '' : $prefix . self::URI_PATH_DELIMITER) . $file;
+        return self::URI_PATH_DELIMITER.('' === $prefix ? '' : $prefix.self::URI_PATH_DELIMITER).$file;
     }
 }

src/AuthHttp/tests/HeaderTransportTest.php

Spacing +6 added lines, -6 removed lines

@@ -43,9 +43,9 @@ 
 
         $http->setHandler(
             static function (ServerRequestInterface $request, ResponseInterface $response): void {
-                if ($request->getAttribute('authContext')->getToken() === null) {
+                if ($request->getAttribute('authContext')->getToken() === null){
                     echo 'no token';
-                } else {
+                }else{
                     echo $request->getAttribute('authContext')->getToken()->getID();
                     echo ':';
                     echo json_encode($request->getAttribute('authContext')->getToken()->getPayload());
@@ -67,9 +67,9 @@ 
 
         $http->setHandler(
             static function (ServerRequestInterface $request, ResponseInterface $response): void {
-                if ($request->getAttribute('authContext')->getToken() === null) {
+                if ($request->getAttribute('authContext')->getToken() === null){
                     echo 'no token';
-                } else {
+                }else{
                     echo $request->getAttribute('authContext')->getToken()->getID();
                     echo ':';
                     echo json_encode($request->getAttribute('authContext')->getToken()->getPayload());
@@ -90,9 +90,9 @@ 
 
         $http->setHandler(
             static function (ServerRequestInterface $request, ResponseInterface $response): void {
-                if ($request->getAttribute('authContext')->getToken() === null) {
+                if ($request->getAttribute('authContext')->getToken() === null){
                     echo 'no token';
-                } else {
+                }else{
                     echo $request->getAttribute('authContext')->getToken()->getID();
                     echo ':';
                     echo json_encode($request->getAttribute('authContext')->getToken()->getPayload());

Braces +15 added lines, -6 removed lines

@@ -43,9 +43,12 @@ 
 
         $http->setHandler(
             static function (ServerRequestInterface $request, ResponseInterface $response): void {
-                if ($request->getAttribute('authContext')->getToken() === null) {
+                if ($request->getAttribute('authContext')->getToken() === null)
+                {
                     echo 'no token';
-                } else {
+                }
+                else
+                {
                     echo $request->getAttribute('authContext')->getToken()->getID();
                     echo ':';
                     echo json_encode($request->getAttribute('authContext')->getToken()->getPayload());
@@ -67,9 +70,12 @@ 
 
         $http->setHandler(
             static function (ServerRequestInterface $request, ResponseInterface $response): void {
-                if ($request->getAttribute('authContext')->getToken() === null) {
+                if ($request->getAttribute('authContext')->getToken() === null)
+                {
                     echo 'no token';
-                } else {
+                }
+                else
+                {
                     echo $request->getAttribute('authContext')->getToken()->getID();
                     echo ':';
                     echo json_encode($request->getAttribute('authContext')->getToken()->getPayload());
@@ -90,9 +96,12 @@ 
 
         $http->setHandler(
             static function (ServerRequestInterface $request, ResponseInterface $response): void {
-                if ($request->getAttribute('authContext')->getToken() === null) {
+                if ($request->getAttribute('authContext')->getToken() === null)
+                {
                     echo 'no token';
-                } else {
+                }
+                else
+                {
                     echo $request->getAttribute('authContext')->getToken()->getID();
                     echo ':';
                     echo json_encode($request->getAttribute('authContext')->getToken()->getPayload());

src/AuthHttp/src/Transport/HeaderTransport.php

Spacing +4 added lines, -4 removed lines

@@ -41,7 +41,7 @@ 
      */
     public function fetchToken(Request $request): ?string
     {
-        if ($request->hasHeader($this->header)) {
+        if ($request->hasHeader($this->header)){
             return $this->extractToken($request);
         }
 
@@ -57,7 +57,7 @@ 
         string $tokenID,
         \DateTimeInterface $expiresAt = null
     ): Response {
-        if ($request->hasHeader($this->header) && $this->extractToken($request) === $tokenID) {
+        if ($request->hasHeader($this->header) && $this->extractToken($request) === $tokenID){
             return $response;
         }
 
@@ -80,10 +80,10 @@ 
     {
         $headerLine = $request->getHeaderLine($this->header);
 
-        if ($this->valueFormat !== '%s') {
+        if ($this->valueFormat !== '%s'){
             [$token] = sscanf($headerLine, $this->valueFormat);
 
-            return $token !== null ? (string) $token : null;
+            return $token !== null ? (string)$token : null;
         }
 
         return $headerLine;

Braces +6 added lines, -3 removed lines

@@ -41,7 +41,8 @@ 
      */
     public function fetchToken(Request $request): ?string
     {
-        if ($request->hasHeader($this->header)) {
+        if ($request->hasHeader($this->header))
+        {
             return $this->extractToken($request);
         }
 
@@ -57,7 +58,8 @@ 
         string $tokenID,
         \DateTimeInterface $expiresAt = null
     ): Response {
-        if ($request->hasHeader($this->header) && $this->extractToken($request) === $tokenID) {
+        if ($request->hasHeader($this->header) && $this->extractToken($request) === $tokenID)
+        {
             return $response;
         }
 
@@ -80,7 +82,8 @@ 
     {
         $headerLine = $request->getHeaderLine($this->header);
 
-        if ($this->valueFormat !== '%s') {
+        if ($this->valueFormat !== '%s')
+        {
             [$token] = sscanf($headerLine, $this->valueFormat);
 
             return $token !== null ? (string) $token : null;

src/Framework/Broadcast/Middleware/WebsocketsMiddleware.php

Spacing +10 added lines, -10 removed lines

@@ -58,7 +58,7 @@ 
         ScopeInterface $scope,
         ResolverInterface $resolver,
         ResponseFactoryInterface $responseFactory
-    ) {
+    ){
         $this->config = $config;
         $this->scope = $scope;
         $this->resolver = $resolver;
@@ -75,13 +75,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);
             }
 
@@ -90,9 +90,9 @@ 
 
         // topic authorization
         $topics = $request->getAttribute('ws:joinTopics');
-        if (\is_string($topics)) {
-            foreach (\explode(',', $topics) as $topic) {
-                if (!$this->authorizeTopic($request, $topic)) {
+        if (\is_string($topics)){
+            foreach (\explode(',', $topics) as $topic){
+                if (!$this->authorizeTopic($request, $topic)){
                     return $this->responseFactory->createResponse(403);
                 }
             }
@@ -113,7 +113,7 @@ 
     {
         $callback = $this->config->getServerCallback();
 
-        if ($callback === null) {
+        if ($callback === null){
             return true;
         }
 
@@ -131,7 +131,7 @@ 
     {
         $parameters = [];
         $callback = $this->config->findTopicCallback($topic, $parameters);
-        if ($callback === null) {
+        if ($callback === null){
             return false;
         }
 
@@ -148,7 +148,7 @@ 
      */
     private function invoke(ServerRequestInterface $request, callable $callback, array $parameters = []): bool
     {
-        switch (true) {
+        switch (true){
             case $callback instanceof \Closure:
             case \is_string($callback):
                 $reflection = new \ReflectionFunction($callback);

Braces +20 added lines, -10 removed lines

@@ -75,13 +75,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);
             }
 
@@ -90,9 +93,12 @@ 
 
         // topic authorization
         $topics = $request->getAttribute('ws:joinTopics');
-        if (\is_string($topics)) {
-            foreach (\explode(',', $topics) as $topic) {
-                if (!$this->authorizeTopic($request, $topic)) {
+        if (\is_string($topics))
+        {
+            foreach (\explode(',', $topics) as $topic)
+            {
+                if (!$this->authorizeTopic($request, $topic))
+                {
                     return $this->responseFactory->createResponse(403);
                 }
             }
@@ -113,7 +119,8 @@ 
     {
         $callback = $this->config->getServerCallback();
 
-        if ($callback === null) {
+        if ($callback === null)
+        {
             return true;
         }
 
@@ -131,7 +138,8 @@ 
     {
         $parameters = [];
         $callback = $this->config->findTopicCallback($topic, $parameters);
-        if ($callback === null) {
+        if ($callback === null)
+        {
             return false;
         }
 
@@ -148,7 +156,8 @@ 
      */
     private function invoke(ServerRequestInterface $request, callable $callback, array $parameters = []): bool
     {
-        switch (true) {
+        switch (true)
+        {
             case $callback instanceof \Closure:
             case \is_string($callback):
                 $reflection = new \ReflectionFunction($callback);
@@ -166,7 +175,8 @@ 
                 throw new LogicException('Unable to invoke callable function');
         }
 
-        $scoped = function () use ($reflection, $parameters, $callback) {
+        $scoped = function () use ($reflection, $parameters, $callback)
+        {
             return \call_user_func_array($callback, $this->resolver->resolveArguments($reflection, $parameters));
         };
 

src/Framework/Command/Cycle/Generator/ShowChanges.php

Spacing +18 added lines, -18 removed lines

@@ -42,12 +42,12 @@ 
         $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()) {
-                    $key = $registry->getDatabase($e) . ':' . $registry->getTable($e);
+                if ($table->getComparator()->hasChanges()){
+                    $key = $registry->getDatabase($e).':'.$registry->getTable($e);
                     $this->changes[$key] = [
                         'database' => $registry->getDatabase($e),
                         'table'    => $registry->getTable($e),
@@ -57,13 +57,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']);
         }
@@ -84,7 +84,7 @@ 
      */
     protected function describeChanges(AbstractTable $table): void
     {
-        if (!$this->output->isVerbose()) {
+        if (!$this->output->isVerbose()){
             $this->output->writeln(
                 sprintf(
                     ': <fg=green>%s</fg=green> change(s) detected',
@@ -97,11 +97,11 @@ 
         $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;
         }
@@ -118,15 +118,15 @@ 
      */
     protected function describeColumns(Comparator $cmp): void
     {
-        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>");
         }
@@ -137,17 +137,17 @@ 
      */
     protected function describeIndexes(Comparator $cmp): void
     {
-        foreach ($cmp->addedIndexes() as $index) {
+        foreach ($cmp->addedIndexes() as $index){
             $index = implode(', ', $index->getColumns());
             $this->output->writeln("    - add index on <fg=yellow>[{$index}]</fg=yellow>");
         }
 
-        foreach ($cmp->droppedIndexes() as $index) {
+        foreach ($cmp->droppedIndexes() as $index){
             $index = implode(', ', $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 = implode(', ', $index->getColumns());
             $this->output->writeln("    - alter index on <fg=yellow>[{$index}]</fg=yellow>");
@@ -159,17 +159,17 @@ 
      */
     protected function describeFKs(Comparator $cmp): void
     {
-        foreach ($cmp->addedForeignKeys() as $fk) {
+        foreach ($cmp->addedForeignKeys() as $fk){
             $fkColumns = implode(', ', $fk->getColumns());
             $this->output->writeln("    - add foreign key on <fg=yellow>{$fkColumns}</fg=yellow>");
         }
 
-        foreach ($cmp->droppedForeignKeys() as $fk) {
+        foreach ($cmp->droppedForeignKeys() as $fk){
             $fkColumns = implode(', ', $fk->getColumns());
             $this->output->writeln("    - drop foreign key <fg=yellow>{$fkColumns}</fg=yellow>");
         }
 
-        foreach ($cmp->alteredForeignKeys() as $fk) {
+        foreach ($cmp->alteredForeignKeys() as $fk){
             $fk = $fk[0];
             $fkColumns = implode(', ', $fk->getColumns());
             $this->output->writeln("    - alter foreign key <fg=yellow>{$fkColumns}</fg=yellow>");

Braces +34 added lines, -17 removed lines

@@ -42,11 +42,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())
+                {
                     $key = $registry->getDatabase($e) . ':' . $registry->getTable($e);
                     $this->changes[$key] = [
                         'database' => $registry->getDatabase($e),
@@ -57,13 +60,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']);
         }
@@ -84,7 +89,8 @@ 
      */
     protected function describeChanges(AbstractTable $table): void
     {
-        if (!$this->output->isVerbose()) {
+        if (!$this->output->isVerbose())
+        {
             $this->output->writeln(
                 sprintf(
                     ': <fg=green>%s</fg=green> change(s) detected',
@@ -97,11 +103,13 @@ 
         $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;
         }
@@ -118,15 +126,18 @@ 
      */
     protected function describeColumns(Comparator $cmp): void
     {
-        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>");
         }
@@ -137,17 +148,20 @@ 
      */
     protected function describeIndexes(Comparator $cmp): void
     {
-        foreach ($cmp->addedIndexes() as $index) {
+        foreach ($cmp->addedIndexes() as $index)
+        {
             $index = implode(', ', $index->getColumns());
             $this->output->writeln("    - add index on <fg=yellow>[{$index}]</fg=yellow>");
         }
 
-        foreach ($cmp->droppedIndexes() as $index) {
+        foreach ($cmp->droppedIndexes() as $index)
+        {
             $index = implode(', ', $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 = implode(', ', $index->getColumns());
             $this->output->writeln("    - alter index on <fg=yellow>[{$index}]</fg=yellow>");
@@ -159,17 +173,20 @@ 
      */
     protected function describeFKs(Comparator $cmp): void
     {
-        foreach ($cmp->addedForeignKeys() as $fk) {
+        foreach ($cmp->addedForeignKeys() as $fk)
+        {
             $fkColumns = implode(', ', $fk->getColumns());
             $this->output->writeln("    - add foreign key on <fg=yellow>{$fkColumns}</fg=yellow>");
         }
 
-        foreach ($cmp->droppedForeignKeys() as $fk) {
+        foreach ($cmp->droppedForeignKeys() as $fk)
+        {
             $fkColumns = implode(', ', $fk->getColumns());
             $this->output->writeln("    - drop foreign key <fg=yellow>{$fkColumns}</fg=yellow>");
         }
 
-        foreach ($cmp->alteredForeignKeys() as $fk) {
+        foreach ($cmp->alteredForeignKeys() as $fk)
+        {
             $fk = $fk[0];
             $fkColumns = implode(', ', $fk->getColumns());
             $this->output->writeln("    - alter foreign key <fg=yellow>{$fkColumns}</fg=yellow>");

src/Framework/Bootloader/Http/WebsocketsBootloader.php

Spacing +1 added lines, -1 removed lines

@@ -58,7 +58,7 @@
             'authorizeTopics' => [],
         ]);
 
-        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

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

src/Framework/Domain/GuardPermissionsProvider.php

Spacing +7 added lines, -7 removed lines

@@ -47,7 +47,7 @@ 
     public function getPermission(string $controller, string $action): Permission
     {
         $key = sprintf('%s:%s', $controller, $action);
-        if (!array_key_exists($key, $this->cache)) {
+        if (!array_key_exists($key, $this->cache)){
             $this->cache[$key] = $this->generatePermission($controller, $action);
         }
 
@@ -56,20 +56,20 @@ 
 
     private function generatePermission(string $controller, string $action): Permission
     {
-        try {
+        try{
             $method = new \ReflectionMethod($controller, $action);
-        } catch (\ReflectionException $e) {
+        }catch (\ReflectionException $e){
             return Permission::failed();
         }
 
         $guarded = $this->reader->firstFunctionMetadata($method, Guarded::class);
-        if (!$guarded instanceof Guarded) {
+        if (!$guarded instanceof Guarded){
             return Permission::failed();
         }
 
         $namespace = $this->reader->firstClassMetadata($method->getDeclaringClass(), GuardNamespace::class);
 
-        if ($guarded->permission || ($namespace instanceof GuardNamespace && $namespace->namespace)) {
+        if ($guarded->permission || ($namespace instanceof GuardNamespace && $namespace->namespace)){
             return Permission::ok(
                 $this->makePermission($guarded, $method, $namespace),
                 $this->mapFailureException($guarded),
@@ -92,11 +92,11 @@ 
     private function makePermission(Guarded $guarded, \ReflectionMethod $method, ?GuardNamespace $ns): string
     {
         $permission = [];
-        if ($this->namespace) {
+        if ($this->namespace){
             $permission[] = $this->namespace;
         }
 
-        if ($ns !== null && $ns->namespace) {
+        if ($ns !== null && $ns->namespace){
             $permission[] = $ns->namespace;
         }
 

Braces +15 added lines, -7 removed lines

@@ -47,7 +47,8 @@ 
     public function getPermission(string $controller, string $action): Permission
     {
         $key = sprintf('%s:%s', $controller, $action);
-        if (!array_key_exists($key, $this->cache)) {
+        if (!array_key_exists($key, $this->cache))
+        {
             $this->cache[$key] = $this->generatePermission($controller, $action);
         }
 
@@ -56,20 +57,25 @@ 
 
     private function generatePermission(string $controller, string $action): Permission
     {
-        try {
+        try
+        {
             $method = new \ReflectionMethod($controller, $action);
-        } catch (\ReflectionException $e) {
+        }
+        catch (\ReflectionException $e)
+        {
             return Permission::failed();
         }
 
         $guarded = $this->reader->firstFunctionMetadata($method, Guarded::class);
-        if (!$guarded instanceof Guarded) {
+        if (!$guarded instanceof Guarded)
+        {
             return Permission::failed();
         }
 
         $namespace = $this->reader->firstClassMetadata($method->getDeclaringClass(), GuardNamespace::class);
 
-        if ($guarded->permission || ($namespace instanceof GuardNamespace && $namespace->namespace)) {
+        if ($guarded->permission || ($namespace instanceof GuardNamespace && $namespace->namespace))
+        {
             return Permission::ok(
                 $this->makePermission($guarded, $method, $namespace),
                 $this->mapFailureException($guarded),
@@ -92,11 +98,13 @@ 
     private function makePermission(Guarded $guarded, \ReflectionMethod $method, ?GuardNamespace $ns): string
     {
         $permission = [];
-        if ($this->namespace) {
+        if ($this->namespace)
+        {
             $permission[] = $this->namespace;
         }
 
-        if ($ns !== null && $ns->namespace) {
+        if ($ns !== null && $ns->namespace)
+        {
             $permission[] = $ns->namespace;
         }