spiral / framework

src/Tokenizer/src/AbstractLocator.php

Spacing +10 added lines, -10 removed lines

@@ -50,10 +50,10 @@ 
         /**
          * @var SplFileInfo
          */
-        foreach ($this->finder->getIterator() as $file) {
+        foreach ($this->finder->getIterator() as $file){
             $reflection = new ReflectionFile((string)$file);
 
-            if ($reflection->hasIncludes()) {
+            if ($reflection->hasIncludes()){
                 //We are not analyzing files which has includes, it's not safe to require such reflections
                 $this->getLogger()->warning(
                     sprintf('File `%s` has includes and excluded from analysis', $file),
@@ -80,8 +80,8 @@ 
      */
     protected function classReflection(string $class): \ReflectionClass
     {
-        $loader = function ($class) {
-            if ($class == LocatorException::class) {
+        $loader = function ($class){
+            if ($class == LocatorException::class){
                 return;
             }
 
@@ -91,12 +91,12 @@ 
         //To suspend class dependency exception
         spl_autoload_register($loader);
 
-        try {
+        try{
             //In some cases reflection can thrown an exception if class invalid or can not be loaded,
             //we are going to handle such exception and convert it soft exception
             return new \ReflectionClass($class);
-        } catch (\Throwable $e) {
-            if ($e instanceof LocatorException && $e->getPrevious() != null) {
+        }catch (\Throwable $e){
+            if ($e instanceof LocatorException && $e->getPrevious() != null){
                 $e = $e->getPrevious();
             }
 
@@ -112,7 +112,7 @@ 
             );
 
             throw new LocatorException($e->getMessage(), $e->getCode(), $e);
-        } finally {
+        }finally{
             spl_autoload_unregister($loader);
         }
     }
@@ -128,13 +128,13 @@ 
     {
         $traits = [];
 
-        while ($class) {
+        while ($class){
             $traits = array_merge(class_uses($class), $traits);
             $class = get_parent_class($class);
         }
 
         //Traits from traits
-        foreach (array_flip($traits) as $trait) {
+        foreach (array_flip($traits) as $trait){
             $traits = array_merge(class_uses($trait), $traits);
         }
 

Braces +22 added lines, -10 removed lines

@@ -50,10 +50,12 @@ 
         /**
          * @var SplFileInfo
          */
-        foreach ($this->finder->getIterator() as $file) {
+        foreach ($this->finder->getIterator() as $file)
+        {
             $reflection = new ReflectionFile((string)$file);
 
-            if ($reflection->hasIncludes()) {
+            if ($reflection->hasIncludes())
+            {
                 //We are not analyzing files which has includes, it's not safe to require such reflections
                 $this->getLogger()->warning(
                     sprintf('File `%s` has includes and excluded from analysis', $file),
@@ -80,8 +82,10 @@ 
      */
     protected function classReflection(string $class): \ReflectionClass
     {
-        $loader = function ($class) {
-            if ($class == LocatorException::class) {
+        $loader = function ($class)
+        {
+            if ($class == LocatorException::class)
+            {
                 return;
             }
 
@@ -91,12 +95,16 @@ 
         //To suspend class dependency exception
         spl_autoload_register($loader);
 
-        try {
+        try
+        {
             //In some cases reflection can thrown an exception if class invalid or can not be loaded,
             //we are going to handle such exception and convert it soft exception
             return new \ReflectionClass($class);
-        } catch (\Throwable $e) {
-            if ($e instanceof LocatorException && $e->getPrevious() != null) {
+        }
+        catch (\Throwable $e)
+        {
+            if ($e instanceof LocatorException && $e->getPrevious() != null)
+            {
                 $e = $e->getPrevious();
             }
 
@@ -112,7 +120,9 @@ 
             );
 
             throw new LocatorException($e->getMessage(), $e->getCode(), $e);
-        } finally {
+        }
+        finally
+        {
             spl_autoload_unregister($loader);
         }
     }
@@ -128,13 +138,15 @@ 
     {
         $traits = [];
 
-        while ($class) {
+        while ($class)
+        {
             $traits = array_merge(class_uses($class), $traits);
             $class = get_parent_class($class);
         }
 
         //Traits from traits
-        foreach (array_flip($traits) as $trait) {
+        foreach (array_flip($traits) as $trait)
+        {
             $traits = array_merge(class_uses($trait), $traits);
         }
 

src/Views/src/ViewManager.php

Spacing +12 added lines, -12 removed lines

@@ -44,15 +44,15 @@ 
             'namespaces' => $config->getNamespaces(),
         ]);
 
-        foreach ($this->config->getDependencies() as $dependency) {
+        foreach ($this->config->getDependencies() as $dependency){
             $this->addDependency($dependency->resolve($factory));
         }
 
-        foreach ($this->config->getEngines() as $engine) {
+        foreach ($this->config->getEngines() as $engine){
             $this->addEngine($engine->resolve($factory));
         }
 
-        if ($this->config->isCacheEnabled()) {
+        if ($this->config->isCacheEnabled()){
             $this->cache = new ViewCache();
         }
     }
@@ -84,7 +84,7 @@ 
     {
         $this->engines[] = $engine->withLoader($this->loader);
 
-        uasort($this->engines, function (EngineInterface $a, EngineInterface $b) {
+        uasort($this->engines, function (EngineInterface $a, EngineInterface $b){
             return strcmp($a->getLoader()->getExtension(), $b->getLoader()->getExtension());
         });
 
@@ -110,7 +110,7 @@ 
      */
     public function compile(string $path): void
     {
-        if ($this->cache !== null) {
+        if ($this->cache !== null){
             $this->cache->resetPath($path);
         }
 
@@ -118,7 +118,7 @@ 
 
         // Rotate all possible context variants and warm up cache
         $generator = new ContextGenerator($this->context);
-        foreach ($generator->generate() as $context) {
+        foreach ($generator->generate() as $context){
             $engine->reset($path, $context);
             $engine->compile($path, $context);
         }
@@ -131,7 +131,7 @@ 
      */
     public function reset(string $path): void
     {
-        if ($this->cache !== null) {
+        if ($this->cache !== null){
             $this->cache->resetPath($path);
         }
 
@@ -139,7 +139,7 @@ 
 
         // Rotate all possible context variants and warm up cache
         $generator = new ContextGenerator($this->context);
-        foreach ($generator->generate() as $context) {
+        foreach ($generator->generate() as $context){
             $engine->reset($path, $context);
         }
     }
@@ -154,13 +154,13 @@ 
      */
     public function get(string $path): ViewInterface
     {
-        if ($this->cache !== null && $this->cache->has($this->context, $path)) {
+        if ($this->cache !== null && $this->cache->has($this->context, $path)){
             return $this->cache->get($this->context, $path);
         }
 
         $view = $this->findEngine($path)->get($path, $this->context);
 
-        if ($this->cache !== null) {
+        if ($this->cache !== null){
             $this->cache->set($this->context, $path, $view);
         }
 
@@ -187,8 +187,8 @@ 
      */
     protected function findEngine(string $path): EngineInterface
     {
-        foreach ($this->engines as $engine) {
-            if ($engine->getLoader()->exists($path)) {
+        foreach ($this->engines as $engine){
+            if ($engine->getLoader()->exists($path)){
                 return $engine;
             }
         }

Braces +24 added lines, -12 removed lines

@@ -44,15 +44,18 @@ 
             'namespaces' => $config->getNamespaces(),
         ]);
 
-        foreach ($this->config->getDependencies() as $dependency) {
+        foreach ($this->config->getDependencies() as $dependency)
+        {
             $this->addDependency($dependency->resolve($factory));
         }
 
-        foreach ($this->config->getEngines() as $engine) {
+        foreach ($this->config->getEngines() as $engine)
+        {
             $this->addEngine($engine->resolve($factory));
         }
 
-        if ($this->config->isCacheEnabled()) {
+        if ($this->config->isCacheEnabled())
+        {
             $this->cache = new ViewCache();
         }
     }
@@ -84,7 +87,8 @@ 
     {
         $this->engines[] = $engine->withLoader($this->loader);
 
-        uasort($this->engines, function (EngineInterface $a, EngineInterface $b) {
+        uasort($this->engines, function (EngineInterface $a, EngineInterface $b)
+        {
             return strcmp($a->getLoader()->getExtension(), $b->getLoader()->getExtension());
         });
 
@@ -110,7 +114,8 @@ 
      */
     public function compile(string $path): void
     {
-        if ($this->cache !== null) {
+        if ($this->cache !== null)
+        {
             $this->cache->resetPath($path);
         }
 
@@ -118,7 +123,8 @@ 
 
         // Rotate all possible context variants and warm up cache
         $generator = new ContextGenerator($this->context);
-        foreach ($generator->generate() as $context) {
+        foreach ($generator->generate() as $context)
+        {
             $engine->reset($path, $context);
             $engine->compile($path, $context);
         }
@@ -131,7 +137,8 @@ 
      */
     public function reset(string $path): void
     {
-        if ($this->cache !== null) {
+        if ($this->cache !== null)
+        {
             $this->cache->resetPath($path);
         }
 
@@ -139,7 +146,8 @@ 
 
         // Rotate all possible context variants and warm up cache
         $generator = new ContextGenerator($this->context);
-        foreach ($generator->generate() as $context) {
+        foreach ($generator->generate() as $context)
+        {
             $engine->reset($path, $context);
         }
     }
@@ -154,13 +162,15 @@ 
      */
     public function get(string $path): ViewInterface
     {
-        if ($this->cache !== null && $this->cache->has($this->context, $path)) {
+        if ($this->cache !== null && $this->cache->has($this->context, $path))
+        {
             return $this->cache->get($this->context, $path);
         }
 
         $view = $this->findEngine($path)->get($path, $this->context);
 
-        if ($this->cache !== null) {
+        if ($this->cache !== null)
+        {
             $this->cache->set($this->context, $path, $view);
         }
 
@@ -187,8 +197,10 @@ 
      */
     protected function findEngine(string $path): EngineInterface
     {
-        foreach ($this->engines as $engine) {
-            if ($engine->getLoader()->exists($path)) {
+        foreach ($this->engines as $engine)
+        {
+            if ($engine->getLoader()->exists($path))
+            {
                 return $engine;
             }
         }

src/Framework/Bootloader/Views/ViewsBootloader.php

Spacing +5 added lines, -5 removed lines

@@ -44,8 +44,8 @@ 
      */
     public function boot(EnvironmentInterface $env, DirectoriesInterface $dirs): void
     {
-        if (!$dirs->has('views')) {
-            $dirs->set('views', $dirs->get('app') . 'views');
+        if (!$dirs->has('views')){
+            $dirs->set('views', $dirs->get('app').'views');
         }
 
         // default view config
@@ -54,7 +54,7 @@ 
             [
                 'cache'        => [
                     'enabled'   => $env->get('VIEW_CACHE', !$env->get('DEBUG', false)),
-                    'directory' => $dirs->get('cache') . 'views',
+                    'directory' => $dirs->get('cache').'views',
                 ],
                 'namespaces'   => [
                     'default' => [$dirs->get('views')],
@@ -71,11 +71,11 @@ 
      */
     public function addDirectory(string $namespace, string $directory): void
     {
-        if (!isset($this->config->getConfig('views')['namespaces'][$namespace])) {
+        if (!isset($this->config->getConfig('views')['namespaces'][$namespace])){
             $this->config->modify('views', new Append('namespaces', $namespace, []));
         }
 
-        $this->config->modify('views', new Append('namespaces.' . $namespace, null, $directory));
+        $this->config->modify('views', new Append('namespaces.'.$namespace, null, $directory));
     }
 
     /**

src/Framework/Bootloader/Http/SessionBootloader.php

Spacing +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
                 'handler'  => new Autowire(
                     FileHandler::class,
                     [
-                        'directory' => $directories->get('runtime') . 'session',
+                        'directory' => $directories->get('runtime').'session',
                         'lifetime'  => 86400,
                     ]
                 ),

src/Framework/Command/Migrate/StatusCommand.php

Spacing +4 added lines, -4 removed lines

@@ -28,18 +28,18 @@ 
      */
     public function perform(FilesInterface $files): void
     {
-        if (!$this->verifyConfigured()) {
+        if (!$this->verifyConfigured()){
             return;
         }
 
-        if (empty($this->migrator->getMigrations())) {
+        if (empty($this->migrator->getMigrations())){
             $this->writeln('<comment>No migrations were found.</comment>');
 
             return;
         }
 
         $table = $this->table(['Migration', 'Created at', 'Executed at']);
-        foreach ($this->migrator->getMigrations() as $migration) {
+        foreach ($this->migrator->getMigrations() as $migration){
             $state = $migration->getState();
 
             $table->addRow(
@@ -48,7 +48,7 @@ 
                     $state->getTimeCreated()->format('Y-m-d H:i:s'),
                     $state->getStatus() == State::STATUS_PENDING
                         ? self::PENDING
-                        : '<info>' . $state->getTimeExecuted()->format('Y-m-d H:i:s') . '</info>',
+                        : '<info>'.$state->getTimeExecuted()->format('Y-m-d H:i:s').'</info>',
                 ]
             );
         }

src/Framework/Command/Translator/ExportCommand.php

Spacing +9 added lines, -9 removed lines

@@ -28,7 +28,7 @@ 
         ['locale', InputArgument::REQUIRED, 'Locale to be dumped'],
         ['path', InputArgument::REQUIRED, 'Export path'],
     ];
-    protected const OPTIONS     = [
+    protected const OPTIONS = [
         ['dumper', 'd', InputOption::VALUE_OPTIONAL, 'Dumper name', 'php'],
         ['fallback', 'f', InputOption::VALUE_NONE, 'Merge messages from fallback catalogue'],
     ];
@@ -39,7 +39,7 @@ 
      */
     public function perform(TranslatorConfig $config, CatalogueManager $manager): void
     {
-        if (!$config->hasDumper($this->option('dumper'))) {
+        if (!$config->hasDumper($this->option('dumper'))){
             $this->writeln("<fg=red>Undefined dumper '{$this->option('dumper')}'.</fg=red>");
 
             return;
@@ -51,7 +51,7 @@ 
             $manager->get($this->argument('locale'))
         );
 
-        if ($this->isVerbose() && !empty($mc->getDomains())) {
+        if ($this->isVerbose() && !empty($mc->getDomains())){
             $this->sprintf(
                 "<info>Exporting domain(s):</info> %s\n",
                 implode(',', $mc->getDomains())
@@ -69,8 +69,8 @@ 
             ]
         );
 
-        $this->writeln('Export successfully completed using <info>' . get_class($dumper) . '</info>');
-        $this->writeln('Output: <comment>' . realpath($this->argument('path')) . '</comment>');
+        $this->writeln('Export successfully completed using <info>'.get_class($dumper).'</info>');
+        $this->writeln('Output: <comment>'.realpath($this->argument('path')).'</comment>');
     }
 
     /**
@@ -89,10 +89,10 @@ 
             $catalogue->getData()
         );
 
-        if ($this->option('fallback')) {
-            foreach ($manager->get($config->getFallbackLocale())->getData() as $domain => $messages) {
-                foreach ($messages as $id => $message) {
-                    if (!$messageCatalogue->defines($id, $domain)) {
+        if ($this->option('fallback')){
+            foreach ($manager->get($config->getFallbackLocale())->getData() as $domain => $messages){
+                foreach ($messages as $id => $message){
+                    if (!$messageCatalogue->defines($id, $domain)){
                         $messageCatalogue->set($id, $message, $domain);
                     }
                 }

src/Framework/Command/Database/ListCommand.php

Spacing +9 added lines, -9 removed lines

@@ -34,13 +34,13 @@ 
      */
     public function perform(DatabaseConfig $config, DatabaseManager $dbal): void
     {
-        if ($this->argument('db')) {
+        if ($this->argument('db')){
             $databases = [$this->argument('db')];
-        } else {
+        }else{
             $databases = array_keys($config->getDatabases());
         }
 
-        if (empty($databases)) {
+        if (empty($databases)){
             $this->writeln('<fg=red>No databases found.</fg=red>');
 
             return;
@@ -58,7 +58,7 @@ 
             ]
         );
 
-        foreach ($databases as $database) {
+        foreach ($databases as $database){
             $database = $dbal->database($database);
 
             /** @var Driver $driver */
@@ -71,12 +71,12 @@ 
                 $database->getPrefix() ?: '<comment>---</comment>',
             ];
 
-            try {
+            try{
                 $driver->connect();
-            } catch (\Exception $exception) {
+            }catch (\Exception $exception){
                 $this->renderException($grid, $header, $exception);
 
-                if ($database->getName() != end($databases)) {
+                if ($database->getName() != end($databases)){
                     $grid->addRow(new TableSeparator());
                 }
 
@@ -85,7 +85,7 @@ 
 
             $header[] = '<info>connected</info>';
             $this->renderTables($grid, $header, $database);
-            if ($database->getName() != end($databases)) {
+            if ($database->getName() != end($databases)){
                 $grid->addRow(new TableSeparator());
             }
         }
@@ -119,7 +119,7 @@ 
      */
     private function renderTables(Table $grid, array $header, Database $database): void
     {
-        foreach ($database->getTables() as $table) {
+        foreach ($database->getTables() as $table){
             $grid->addRow(
                 array_merge(
                     $header,

Braces +20 added lines, -9 removed lines

@@ -34,13 +34,17 @@ 
      */
     public function perform(DatabaseConfig $config, DatabaseManager $dbal): void
     {
-        if ($this->argument('db')) {
+        if ($this->argument('db'))
+        {
             $databases = [$this->argument('db')];
-        } else {
+        }
+        else
+        {
             $databases = array_keys($config->getDatabases());
         }
 
-        if (empty($databases)) {
+        if (empty($databases))
+        {
             $this->writeln('<fg=red>No databases found.</fg=red>');
 
             return;
@@ -58,7 +62,8 @@ 
             ]
         );
 
-        foreach ($databases as $database) {
+        foreach ($databases as $database)
+        {
             $database = $dbal->database($database);
 
             /** @var Driver $driver */
@@ -71,12 +76,16 @@ 
                 $database->getPrefix() ?: '<comment>---</comment>',
             ];
 
-            try {
+            try
+            {
                 $driver->connect();
-            } catch (\Exception $exception) {
+            }
+            catch (\Exception $exception)
+            {
                 $this->renderException($grid, $header, $exception);
 
-                if ($database->getName() != end($databases)) {
+                if ($database->getName() != end($databases))
+                {
                     $grid->addRow(new TableSeparator());
                 }
 
@@ -85,7 +94,8 @@ 
 
             $header[] = '<info>connected</info>';
             $this->renderTables($grid, $header, $database);
-            if ($database->getName() != end($databases)) {
+            if ($database->getName() != end($databases))
+            {
                 $grid->addRow(new TableSeparator());
             }
         }
@@ -119,7 +129,8 @@ 
      */
     private function renderTables(Table $grid, array $header, Database $database): void
     {
-        foreach ($database->getTables() as $table) {
+        foreach ($database->getTables() as $table)
+        {
             $grid->addRow(
                 array_merge(
                     $header,

src/Framework/Domain/GuardInterceptor.php

Spacing +9 added lines, -9 removed lines

@@ -52,7 +52,7 @@ 
     {
         $permission = $this->getPermissions($controller, $action);
 
-        if ($permission !== null && !$this->guard->allows($permission[0], $parameters)) {
+        if ($permission !== null && !$this->guard->allows($permission[0], $parameters)){
             throw new ControllerException($permission[2], $permission[1]);
         }
 
@@ -70,14 +70,14 @@ 
     private function getPermissions(string $controller, string $action): ?array
     {
         $key = sprintf('%s:%s', $controller, $action);
-        if (array_key_exists($key, $this->cache)) {
+        if (array_key_exists($key, $this->cache)){
             return $this->cache[$key];
         }
 
         $this->cache[$key] = null;
-        try {
+        try{
             $method = new \ReflectionMethod($controller, $action);
-        } catch (\ReflectionException $e) {
+        }catch (\ReflectionException $e){
             return null;
         }
 
@@ -95,7 +95,7 @@ 
             Guarded::class
         );
 
-        if ($action === null) {
+        if ($action === null){
             return null;
         }
 
@@ -118,7 +118,7 @@ 
             $guarded->errorMessage ?? sprintf('Unauthorized access `%s`', $guarded->permission ?? $method->getName()),
         ];
 
-        if ($guarded->permission === null && $ns === null) {
+        if ($guarded->permission === null && $ns === null){
             throw new InterceptorException(
                 sprintf(
                     'Unable to apply @Guarded without name or @GuardNamespace on `%s`->`%s`',
@@ -128,16 +128,16 @@ 
             );
         }
 
-        if ($ns !== null) {
+        if ($ns !== null){
             $permission[0] = sprintf('%s.%s', $ns->namespace, $permission[0]);
         }
 
-        if ($this->namespace !== null) {
+        if ($this->namespace !== null){
             // global namespace
             $permission[0] = sprintf('%s.%s', $this->namespace, $permission[0]);
         }
 
-        switch ($guarded->else) {
+        switch ($guarded->else){
             case 'unauthorized':
                 $permission[1] = ControllerException::UNAUTHORIZED;
                 break;

Braces +19 added lines, -9 removed lines

@@ -52,7 +52,8 @@ 
     {
         $permission = $this->getPermissions($controller, $action);
 
-        if ($permission !== null && !$this->guard->allows($permission[0], $parameters)) {
+        if ($permission !== null && !$this->guard->allows($permission[0], $parameters))
+        {
             throw new ControllerException($permission[2], $permission[1]);
         }
 
@@ -70,14 +71,18 @@ 
     private function getPermissions(string $controller, string $action): ?array
     {
         $key = sprintf('%s:%s', $controller, $action);
-        if (array_key_exists($key, $this->cache)) {
+        if (array_key_exists($key, $this->cache))
+        {
             return $this->cache[$key];
         }
 
         $this->cache[$key] = null;
-        try {
+        try
+        {
             $method = new \ReflectionMethod($controller, $action);
-        } catch (\ReflectionException $e) {
+        }
+        catch (\ReflectionException $e)
+        {
             return null;
         }
 
@@ -95,7 +100,8 @@ 
             Guarded::class
         );
 
-        if ($action === null) {
+        if ($action === null)
+        {
             return null;
         }
 
@@ -118,7 +124,8 @@ 
             $guarded->errorMessage ?? sprintf('Unauthorized access `%s`', $guarded->permission ?? $method->getName()),
         ];
 
-        if ($guarded->permission === null && $ns === null) {
+        if ($guarded->permission === null && $ns === null)
+        {
             throw new InterceptorException(
                 sprintf(
                     'Unable to apply @Guarded without name or @GuardNamespace on `%s`->`%s`',
@@ -128,16 +135,19 @@ 
             );
         }
 
-        if ($ns !== null) {
+        if ($ns !== null)
+        {
             $permission[0] = sprintf('%s.%s', $ns->namespace, $permission[0]);
         }
 
-        if ($this->namespace !== null) {
+        if ($this->namespace !== null)
+        {
             // global namespace
             $permission[0] = sprintf('%s.%s', $this->namespace, $permission[0]);
         }
 
-        switch ($guarded->else) {
+        switch ($guarded->else)
+        {
             case 'unauthorized':
                 $permission[1] = ControllerException::UNAUTHORIZED;
                 break;

src/Framework/Broadcast/Middleware/WebsocketsMiddleware.php

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)