spiral / framework

src/Broadcasting/src/BroadcastManager.php

Spacing +2 added lines, -2 removed lines

@@ -18,7 +18,7 @@ 
     public function __construct(
         FactoryInterface $factory,
         BroadcastConfig $config
-    ) {
+    ){
         $this->factory = $factory;
         $this->config = $config;
     }
@@ -30,7 +30,7 @@ 
         // Replaces alias with real storage name
         $name = $this->config->getAliases()[$name] ?? $name;
 
-        if (isset($this->connections[$name])) {
+        if (isset($this->connections[$name])){
             return $this->connections[$name];
         }
 

src/Broadcasting/src/Driver/AbstractBroadcast.php

Spacing +2 added lines, -2 removed lines

@@ -16,7 +16,7 @@ 
      */
     protected function formatTopics(array $topics): array
     {
-        return array_map(function ($topic) {
+        return array_map(function ($topic){
             return (string)$topic;
         }, $topics);
     }
@@ -28,7 +28,7 @@ 
      */
     protected function toArray($entries): array
     {
-        switch (true) {
+        switch (true){
             case \is_array($entries):
                 return $entries;
 

src/Broadcasting/src/Config/BroadcastConfig.php

Spacing +13 added lines, -13 removed lines

@@ -28,7 +28,7 @@ 
         parent::__construct($config);
 
         $topics = (array)($config['authorize']['topics'] ?? []);
-        foreach ($topics as $topic => $callback) {
+        foreach ($topics as $topic => $callback){
             $this->patterns[$this->compilePattern($topic)] = $callback;
         }
     }
@@ -54,11 +54,11 @@ 
      */
     public function getDefaultConnection(): string
     {
-        if (!isset($this->config['default']) || empty($this->config['default'])) {
+        if (!isset($this->config['default']) || empty($this->config['default'])){
             throw new InvalidArgumentException('Default broadcast connection is not defined.');
         }
 
-        if (!\is_string($this->config['default'])) {
+        if (!\is_string($this->config['default'])){
             throw new InvalidArgumentException('Default broadcast connection config value must be a string');
         }
 
@@ -67,7 +67,7 @@ 
 
     public function getConnectionConfig(string $name): array
     {
-        if (!isset($this->config['connections'][$name])) {
+        if (!isset($this->config['connections'][$name])){
             throw new InvalidArgumentException(
                 sprintf('Config for connection `%s` is not defined.', $name)
             );
@@ -75,19 +75,19 @@ 
 
         $config = $this->config['connections'][$name];
 
-        if (!isset($config['driver'])) {
+        if (!isset($config['driver'])){
             throw new InvalidArgumentException(
                 sprintf('Driver for `%s` connection is not defined.', $name)
             );
         }
 
-        if (!\is_string($config['driver'])) {
+        if (!\is_string($config['driver'])){
             throw new InvalidArgumentException(
                 \sprintf('Driver value for `%s` connection must be a string', $name)
             );
         }
 
-        if (isset($this->config['driverAliases'][$config['driver']])) {
+        if (isset($this->config['driverAliases'][$config['driver']])){
             $config['driver'] = $this->config['driverAliases'][$config['driver']];
         }
 
@@ -96,8 +96,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;
             }
         }
@@ -108,13 +108,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 => $_) {
-                $replaces['{' . $key . '}'] = '(?P<' . $key . '>[^\/\.]+)';
+            foreach ($variables as $key => $_){
+                $replaces['{'.$key.'}'] = '(?P<'.$key.'>[^\/\.]+)';
             }
         }
 
-        return '/^' . strtr($topic, $replaces + ['/' => '\\/', '[' => '(?:', ']' => ')?', '.' => '\.']) . '$/iu';
+        return '/^'.strtr($topic, $replaces + ['/' => '\\/', '[' => '(?:', ']' => ')?', '.' => '\.']).'$/iu';
     }
 }

src/Broadcasting/src/Driver/LogBroadcast.php

Spacing +2 added lines, -2 removed lines

@@ -29,9 +29,9 @@
         $topics = implode(', ', $this->formatTopics($this->toArray($topics)));
 
         /** @var string $message */
-        foreach ($this->toArray($messages) as $message) {
+        foreach ($this->toArray($messages) as $message){
             assert(\is_string($message), 'Message argument must be a type of string');
-            $this->logger->log($this->level, 'Broadcasting on channels [' . $topics . '] with payload: ' . $message);
+            $this->logger->log($this->level, 'Broadcasting on channels ['.$topics.'] with payload: '.$message);
         }
     }
 }

src/Broadcasting/src/Bootloader/WebsocketsBootloader.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
         });
 
 
-        if ($config->getAuthorizationPath() !== null) {
+        if ($config->getAuthorizationPath() !== null){
             $http->addMiddleware(AuthorizationMiddleware::class);
         }
     }

src/Broadcasting/src/Middleware/AuthorizationMiddleware.php

Spacing +3 added lines, -3 removed lines

@@ -23,7 +23,7 @@ 
         BroadcastInterface $broadcast,
         ResponseFactoryInterface $responseFactory,
         ?string $authorizationPath = null
-    ) {
+    ){
         $this->responseFactory = $responseFactory;
         $this->broadcast = $broadcast;
         $this->authorizationPath = $authorizationPath;
@@ -33,14 +33,14 @@ 
         ServerRequestInterface $request,
         RequestHandlerInterface $handler
     ): ResponseInterface {
-        if ($request->getUri()->getPath() !== $this->authorizationPath) {
+        if ($request->getUri()->getPath() !== $this->authorizationPath){
             return $handler->handle($request);
         }
 
         if (
             !$this->broadcast instanceof GuardInterface
             || $this->broadcast->authorize($request)
-        ) {
+        ){
             return $this->responseFactory->createResponse(200);
         }