spiral / framework

src/Broadcasting/src/TopicRegistry.php

Spacing +7 added lines, -7 removed lines

@@ -10,7 +10,7 @@ 
 
     public function __construct(array $topics = [])
     {
-        foreach ($topics as $topic => $callback) {
+        foreach ($topics as $topic => $callback){
             $this->register($topic, $callback);
         }
     }
@@ -22,8 +22,8 @@ 
 
     public function findCallback(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;
             }
         }
@@ -34,13 +34,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';
     }
 }

Braces +10 added lines, -5 removed lines

@@ -10,7 +10,8 @@ 
 
     public function __construct(array $topics = [])
     {
-        foreach ($topics as $topic => $callback) {
+        foreach ($topics as $topic => $callback)
+        {
             $this->register($topic, $callback);
         }
     }
@@ -22,8 +23,10 @@ 
 
     public function findCallback(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;
             }
         }
@@ -34,9 +37,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 => $_) {
+            foreach ($variables as $key => $_)
+            {
                 $replaces['{' . $key . '}'] = '(?P<' . $key . '>[^\/\.]+)';
             }
         }

src/Broadcasting/src/Config/BroadcastConfig.php

Spacing +6 added lines, -6 removed lines

@@ -53,11 +53,11 @@ 
      */
     public function getDefaultConnection(): string
     {
-        if (empty($this->config['default'])) {
+        if (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');
         }
 
@@ -66,7 +66,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)
             );
@@ -74,19 +74,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']];
         }
 

Braces +12 added lines, -6 removed lines

@@ -53,11 +53,13 @@ 
      */
     public function getDefaultConnection(): string
     {
-        if (empty($this->config['default'])) {
+        if (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');
         }
 
@@ -66,7 +68,8 @@ 
 
     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)
             );
@@ -74,19 +77,22 @@ 
 
         $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']];
         }
 

src/Broadcasting/src/Event/Authorized.php

Spacing +1 added lines, -1 removed lines

@@ -12,6 +12,6 @@
     public function __construct(
         public AuthorizationStatus $status,
         public readonly ServerRequestInterface $request
-    ) {
+    ){
     }
 }

src/Broadcasting/src/Driver/NullBroadcast.php

Spacing +1 added lines, -1 removed lines

@@ -8,7 +8,7 @@
 
 final class NullBroadcast implements BroadcastInterface
 {
-    public function publish(iterable|string|\Stringable $topics, iterable|string $messages): void
+    public function publish(iterable | string | \Stringable $topics, iterable | string $messages): void
     {
         // Do nothing
     }

src/Broadcasting/src/Driver/LogBroadcast.php

Spacing +4 added lines, -4 removed lines

@@ -12,17 +12,17 @@
     public function __construct(
         private readonly LoggerInterface $logger,
         private readonly string $level = LogLevel::INFO
-    ) {
+    ){
     }
 
-    public function publish(iterable|string|\Stringable $topics, iterable|string $messages): void
+    public function publish(iterable | string | \Stringable $topics, iterable | string $messages): void
     {
         $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);
         }
     }
 }

Braces +2 added lines, -1 removed lines

@@ -20,7 +20,8 @@
         $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);
         }

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(fn (string|\Stringable $topic) => (string) $topic, $topics);
+        return \array_map(fn (string | \Stringable $topic) => (string)$topic, $topics);
     }
 
     /**
@@ -24,7 +24,7 @@ 
      * @param iterable<T>|T $entries
      * @return array<T>
      */
-    protected function toArray(iterable|string|\Stringable $entries): array
+    protected function toArray(iterable | string | \Stringable $entries): array
     {
         return match (true) {
             \is_array($entries) => $entries,

src/Broadcasting/src/Bootloader/BroadcastingBootloader.php

Spacing +1 added lines, -1 removed lines

@@ -27,7 +27,7 @@
 
     public function __construct(
         private readonly ConfiguratorInterface $config
-    ) {
+    ){
     }
 
     public function registerDriverAlias(string $driverClass, string $alias): void

src/Broadcasting/src/BroadcastInterface.php

Spacing +1 added lines, -1 removed lines

@@ -26,5 +26,5 @@
      * @param MessagesList $messages
      * @throws BroadcastException
      */
-    public function publish(iterable|string|\Stringable $topics, iterable|string $messages): void;
+    public function publish(iterable | string | \Stringable $topics, iterable | string $messages): void;
 }

src/Broadcasting/src/Middleware/AuthorizationMiddleware.php

Spacing +6 added lines, -6 removed lines

@@ -22,20 +22,20 @@ 
         private readonly ResponseFactoryInterface $responseFactory,
         private readonly ?string $authorizationPath = null,
         private readonly ?EventDispatcherInterface $dispatcher = null
-    ) {
+    ){
     }
 
     public function process(
         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) {
+        if ($this->broadcast instanceof GuardInterface){
             $status = $this->broadcast->authorize($request);
-        } else {
+        }else{
             $status = new AuthorizationStatus(
                 success: true,
                 topics: null
@@ -44,11 +44,11 @@ 
 
         $this->dispatcher?->dispatch(new Authorized($status, $request));
 
-        if ($status->response !== null) {
+        if ($status->response !== null){
             return $status->response;
         }
 
-        if (!$status->success) {
+        if (!$status->success){
             return $this->responseFactory->createResponse(403);
         }
 

Braces +11 added lines, -5 removed lines

@@ -29,13 +29,17 @@ 
         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) {
+        if ($this->broadcast instanceof GuardInterface)
+        {
             $status = $this->broadcast->authorize($request);
-        } else {
+        }
+        else
+        {
             $status = new AuthorizationStatus(
                 success: true,
                 topics: null
@@ -44,11 +48,13 @@ 
 
         $this->dispatcher?->dispatch(new Authorized($status, $request));
 
-        if ($status->response !== null) {
+        if ($status->response !== null)
+        {
             return $status->response;
         }
 
-        if (!$status->success) {
+        if (!$status->success)
+        {
             return $this->responseFactory->createResponse(403);
         }