spiral / framework

src/AuthHttp/src/Middleware/AuthMiddleware.php

Spacing +6 added lines, -6 removed lines

@@ -35,7 +35,7 @@ 
         private readonly TokenStorageInterface $tokenStorage,
         private readonly TransportRegistry $transportRegistry,
         private readonly ?EventDispatcherInterface $eventDispatcher = null,
-    ) {}
+    ){}
 
     /**
      * @throws \Throwable
@@ -55,14 +55,14 @@ 
 
     private function initContext(Request $request, AuthContextInterface $authContext): AuthContextInterface
     {
-        foreach ($this->transportRegistry->getTransports() as $name => $transport) {
+        foreach ($this->transportRegistry->getTransports() as $name => $transport){
             $tokenID = $transport->fetchToken($request);
-            if ($tokenID === null) {
+            if ($tokenID === null){
                 continue;
             }
 
             $token = $this->tokenStorage->load($tokenID);
-            if ($token === null) {
+            if ($token === null){
                 continue;
             }
 
@@ -76,13 +76,13 @@ 
 
     private function closeContext(Request $request, Response $response, AuthContextInterface $authContext): Response
     {
-        if ($authContext->getToken() === null) {
+        if ($authContext->getToken() === null){
             return $response;
         }
 
         $transport = $this->transportRegistry->getTransport($authContext->getTransport());
 
-        if ($authContext->isClosed()) {
+        if ($authContext->isClosed()){
             $this->tokenStorage->delete($authContext->getToken());
 
             return $transport->removeToken(

Braces +12 added lines, -6 removed lines

@@ -35,7 +35,8 @@ 
         private readonly TokenStorageInterface $tokenStorage,
         private readonly TransportRegistry $transportRegistry,
         private readonly ?EventDispatcherInterface $eventDispatcher = null,
-    ) {}
+    ) {
+}
 
     /**
      * @throws \Throwable
@@ -55,14 +56,17 @@ 
 
     private function initContext(Request $request, AuthContextInterface $authContext): AuthContextInterface
     {
-        foreach ($this->transportRegistry->getTransports() as $name => $transport) {
+        foreach ($this->transportRegistry->getTransports() as $name => $transport)
+        {
             $tokenID = $transport->fetchToken($request);
-            if ($tokenID === null) {
+            if ($tokenID === null)
+            {
                 continue;
             }
 
             $token = $this->tokenStorage->load($tokenID);
-            if ($token === null) {
+            if ($token === null)
+            {
                 continue;
             }
 
@@ -76,13 +80,15 @@ 
 
     private function closeContext(Request $request, Response $response, AuthContextInterface $authContext): Response
     {
-        if ($authContext->getToken() === null) {
+        if ($authContext->getToken() === null)
+        {
             return $response;
         }
 
         $transport = $this->transportRegistry->getTransport($authContext->getTransport());
 
-        if ($authContext->isClosed()) {
+        if ($authContext->isClosed())
+        {
             $this->tokenStorage->delete($authContext->getToken());
 
             return $transport->removeToken(

src/AuthHttp/src/Middleware/AuthTransportMiddleware.php

Spacing +1 added lines, -1 removed lines

@@ -33,7 +33,7 @@
         TokenStorageInterface $tokenStorage,
         TransportRegistry $transportRegistry,
         ?EventDispatcherInterface $eventDispatcher = null,
-    ) {
+    ){
         $this->authMiddleware = new AuthMiddleware(
             $scope,
             $actorProvider,

src/AuthHttp/src/Middleware/AuthTransportWithStorageMiddleware.php

Spacing +1 added lines, -1 removed lines

@@ -34,7 +34,7 @@
         TransportRegistry $transportRegistry,
         ?EventDispatcherInterface $eventDispatcher = null,
         ?string $storage = null,
-    ) {
+    ){
         $this->authMiddleware = new AuthTransportMiddleware(
             $transportName,
             $scope,

src/AuthHttp/src/Exception/TransportException.php

Spacing +1 added lines, -1 removed lines

@@ -4,4 +4,4 @@
 
 namespace Spiral\Auth\Exception;
 
-class TransportException extends AuthException {}
+class TransportException extends AuthException{}

Braces +3 added lines, -1 removed lines

@@ -4,4 +4,6 @@
 
 namespace Spiral\Auth\Exception;
 
-class TransportException extends AuthException {}
+class TransportException extends AuthException
+{
+}

src/Streams/src/StreamWrapper.php

Spacing +28 added lines, -28 removed lines

@@ -42,7 +42,7 @@ 
      */
     public static function register(): void
     {
-        if (self::$registered) {
+        if (self::$registered){
             return;
         }
 
@@ -54,10 +54,10 @@ 
     /**
      * Check if given uri or stream has been allocated.
      */
-    public static function has(StreamInterface|string $file): bool
+    public static function has(StreamInterface | string $file): bool
     {
-        if ($file instanceof StreamInterface) {
-            $file = 'spiral://' . \spl_object_hash($file);
+        if ($file instanceof StreamInterface){
+            $file = 'spiral://'.\spl_object_hash($file);
         }
 
         return isset(self::$uris[$file]);
@@ -72,15 +72,15 @@ 
     public static function getResource(StreamInterface $stream)
     {
         $mode = null;
-        if ($stream->isReadable()) {
+        if ($stream->isReadable()){
             $mode = 'r';
         }
 
-        if ($stream->isWritable()) {
+        if ($stream->isWritable()){
             $mode = !empty($mode) ? 'r+' : 'w';
         }
 
-        if (empty($mode)) {
+        if (empty($mode)){
             throw new WrapperException('Stream is not available in read or write modes');
         }
 
@@ -94,7 +94,7 @@ 
     {
         self::register();
 
-        $uri = 'spiral://' . \spl_object_hash($stream);
+        $uri = 'spiral://'.\spl_object_hash($stream);
         self::$uris[$uri] = $stream;
 
         return $uri;
@@ -106,10 +106,10 @@ 
      *
      * @param string|StreamInterface $file String uri or StreamInterface.
      */
-    public static function release(StreamInterface|string $file): void
+    public static function release(StreamInterface | string $file): void
     {
-        if ($file instanceof StreamInterface) {
-            $file = 'spiral://' . \spl_object_hash($file);
+        if ($file instanceof StreamInterface){
+            $file = 'spiral://'.\spl_object_hash($file);
         }
 
         unset(self::$uris[$file]);
@@ -120,7 +120,7 @@ 
      */
     public function stream_eof(): bool
     {
-        if ($this->stream === null) {
+        if ($this->stream === null){
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -132,7 +132,7 @@ 
      */
     public function stream_open(string $path, string $mode, int $options, ?string &$opened_path): bool
     {
-        if (!isset(self::$uris[$path])) {
+        if (!isset(self::$uris[$path])){
             return false;
         }
 
@@ -147,9 +147,9 @@ 
     /**
      * Read data from StreamInterface.
      */
-    public function stream_read(int $length): string|false
+    public function stream_read(int $length): string | false
     {
-        if ($this->stream === null) {
+        if ($this->stream === null){
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -161,7 +161,7 @@ 
      */
     public function stream_seek(int $offset, int $whence = SEEK_SET): bool
     {
-        if ($this->stream === null) {
+        if ($this->stream === null){
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -179,7 +179,7 @@ 
      */
     public function stream_stat(): array
     {
-        if ($this->stream === null) {
+        if ($this->stream === null){
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -191,7 +191,7 @@ 
      */
     public function stream_tell(): int
     {
-        if ($this->stream === null) {
+        if ($this->stream === null){
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -205,7 +205,7 @@ 
      */
     public function stream_write(string $data): int
     {
-        if ($this->stream === null) {
+        if ($this->stream === null){
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -217,14 +217,14 @@ 
      *
      * @see stat()
      */
-    public function url_stat(string $path, int $flag): array|false
+    public function url_stat(string $path, int $flag): array | false
     {
-        try {
-            if (isset(self::$uris[$path])) {
+        try{
+            if (isset(self::$uris[$path])){
                 return $this->getStreamStats(self::$uris[$path]);
             }
-        } catch (\Throwable $e) {
-            if (($flag & \STREAM_URL_STAT_QUIET) === \STREAM_URL_STAT_QUIET) {
+        }catch (\Throwable $e){
+            if (($flag & \STREAM_URL_STAT_QUIET) === \STREAM_URL_STAT_QUIET){
                 return false;
             }
             \trigger_error($e->getMessage(), \E_USER_ERROR);
@@ -239,12 +239,12 @@ 
     private function getStreamStats(StreamInterface $stream): array
     {
         $mode = $this->mode;
-        if (empty($mode)) {
-            if ($stream->isReadable()) {
+        if (empty($mode)){
+            if ($stream->isReadable()){
                 $mode = 'r';
             }
 
-            if ($stream->isWritable()) {
+            if ($stream->isWritable()){
                 $mode = !empty($mode) ? 'r+' : 'w';
             }
         }
@@ -257,7 +257,7 @@ 
             'uid'     => 0,
             'gid'     => 0,
             'rdev'    => 0,
-            'size'    => (string) $stream->getSize(),
+            'size'    => (string)$stream->getSize(),
             'atime'   => 0,
             'mtime'   => 0,
             'ctime'   => 0,

Braces +41 added lines, -20 removed lines

@@ -42,7 +42,8 @@ 
      */
     public static function register(): void
     {
-        if (self::$registered) {
+        if (self::$registered)
+        {
             return;
         }
 
@@ -56,7 +57,8 @@ 
      */
     public static function has(StreamInterface|string $file): bool
     {
-        if ($file instanceof StreamInterface) {
+        if ($file instanceof StreamInterface)
+        {
             $file = 'spiral://' . \spl_object_hash($file);
         }
 
@@ -72,15 +74,18 @@ 
     public static function getResource(StreamInterface $stream)
     {
         $mode = null;
-        if ($stream->isReadable()) {
+        if ($stream->isReadable())
+        {
             $mode = 'r';
         }
 
-        if ($stream->isWritable()) {
+        if ($stream->isWritable())
+        {
             $mode = !empty($mode) ? 'r+' : 'w';
         }
 
-        if (empty($mode)) {
+        if (empty($mode))
+        {
             throw new WrapperException('Stream is not available in read or write modes');
         }
 
@@ -108,7 +113,8 @@ 
      */
     public static function release(StreamInterface|string $file): void
     {
-        if ($file instanceof StreamInterface) {
+        if ($file instanceof StreamInterface)
+        {
             $file = 'spiral://' . \spl_object_hash($file);
         }
 
@@ -120,7 +126,8 @@ 
      */
     public function stream_eof(): bool
     {
-        if ($this->stream === null) {
+        if ($this->stream === null)
+        {
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -132,7 +139,8 @@ 
      */
     public function stream_open(string $path, string $mode, int $options, ?string &$opened_path): bool
     {
-        if (!isset(self::$uris[$path])) {
+        if (!isset(self::$uris[$path]))
+        {
             return false;
         }
 
@@ -149,7 +157,8 @@ 
      */
     public function stream_read(int $length): string|false
     {
-        if ($this->stream === null) {
+        if ($this->stream === null)
+        {
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -161,7 +170,8 @@ 
      */
     public function stream_seek(int $offset, int $whence = SEEK_SET): bool
     {
-        if ($this->stream === null) {
+        if ($this->stream === null)
+        {
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -179,7 +189,8 @@ 
      */
     public function stream_stat(): array
     {
-        if ($this->stream === null) {
+        if ($this->stream === null)
+        {
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -191,7 +202,8 @@ 
      */
     public function stream_tell(): int
     {
-        if ($this->stream === null) {
+        if ($this->stream === null)
+        {
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -205,7 +217,8 @@ 
      */
     public function stream_write(string $data): int
     {
-        if ($this->stream === null) {
+        if ($this->stream === null)
+        {
             throw new WrapperException('Stream is not opened.');
         }
 
@@ -219,12 +232,17 @@ 
      */
     public function url_stat(string $path, int $flag): array|false
     {
-        try {
-            if (isset(self::$uris[$path])) {
+        try
+        {
+            if (isset(self::$uris[$path]))
+            {
                 return $this->getStreamStats(self::$uris[$path]);
             }
-        } catch (\Throwable $e) {
-            if (($flag & \STREAM_URL_STAT_QUIET) === \STREAM_URL_STAT_QUIET) {
+        }
+        catch (\Throwable $e)
+        {
+            if (($flag & \STREAM_URL_STAT_QUIET) === \STREAM_URL_STAT_QUIET)
+            {
                 return false;
             }
             \trigger_error($e->getMessage(), \E_USER_ERROR);
@@ -239,12 +257,15 @@ 
     private function getStreamStats(StreamInterface $stream): array
     {
         $mode = $this->mode;
-        if (empty($mode)) {
-            if ($stream->isReadable()) {
+        if (empty($mode))
+        {
+            if ($stream->isReadable())
+            {
                 $mode = 'r';
             }
 
-            if ($stream->isWritable()) {
+            if ($stream->isWritable())
+            {
                 $mode = !empty($mode) ? 'r+' : 'w';
             }
         }

src/Streams/src/Exception/WrapperException.php

Spacing +1 added lines, -1 removed lines

@@ -7,4 +7,4 @@
 /**
  * StreamWrapper specific exception.
  */
-class WrapperException extends \RuntimeException {}
+class WrapperException extends \RuntimeException{}

src/SendIt/src/Listener/LoggerListener.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
 {
     public function __construct(
         private readonly LoggerInterface $logger,
-    ) {}
+    ){}
 
     public function onMessageSent(MessageSent $event): void
     {

Braces +2 added lines, -1 removed lines

@@ -14,7 +14,8 @@
 {
     public function __construct(
         private readonly LoggerInterface $logger,
-    ) {}
+    ) {
+}
 
     public function onMessageSent(MessageSent $event): void
     {

src/SendIt/src/MailQueue.php

Spacing +2 added lines, -2 removed lines

@@ -17,13 +17,13 @@
     public function __construct(
         private readonly MailerConfig $config,
         private readonly QueueInterface $queue,
-    ) {}
+    ){}
 
     public function send(MessageInterface ...$message): void
     {
         $options = Options::onQueue($this->config->getQueue());
 
-        foreach ($message as $msg) {
+        foreach ($message as $msg){
             $this->queue->push(
                 self::JOB_NAME,
                 MessageSerializer::pack($msg),

Braces +4 added lines, -2 removed lines

@@ -17,13 +17,15 @@
     public function __construct(
         private readonly MailerConfig $config,
         private readonly QueueInterface $queue,
-    ) {}
+    ) {
+}
 
     public function send(MessageInterface ...$message): void
     {
         $options = Options::onQueue($this->config->getQueue());
 
-        foreach ($message as $msg) {
+        foreach ($message as $msg)
+        {
             $this->queue->push(
                 self::JOB_NAME,
                 MessageSerializer::pack($msg),

src/SendIt/src/MailJob.php

Spacing +7 added lines, -7 removed lines

@@ -21,19 +21,19 @@ 
         private readonly SymfonyMailer $mailer,
         private readonly RendererInterface $renderer,
         private readonly ?EventDispatcherInterface $dispatcher = null,
-    ) {}
+    ){}
 
     /**
      * @throws TransportExceptionInterface
      * @throws InvalidArgumentException
      */
-    public function handle(string $name, string $id, string|array $payload): void
+    public function handle(string $name, string $id, string | array $payload): void
     {
-        if (\is_string($payload)) {
+        if (\is_string($payload)){
             $payload = \json_decode($payload, true, 512, JSON_THROW_ON_ERROR);
         }
 
-        if (!\is_array($payload)) {
+        if (!\is_array($payload)){
             throw new InvalidArgumentException('Mail job payload should be an array.');
         }
 
@@ -41,13 +41,13 @@ 
 
         $email = $this->renderer->render($message);
 
-        if ($email->getFrom() === []) {
+        if ($email->getFrom() === []){
             $email->from(Address::create($this->config->getFromAddress()));
         }
 
-        try {
+        try{
             $this->mailer->send($email);
-        } catch (TransportExceptionInterface $e) {
+        }catch (TransportExceptionInterface $e){
             $this->dispatcher?->dispatch(new MessageNotSent($email, $e));
 
             throw $e;

Braces +13 added lines, -6 removed lines

@@ -21,7 +21,8 @@ 
         private readonly SymfonyMailer $mailer,
         private readonly RendererInterface $renderer,
         private readonly ?EventDispatcherInterface $dispatcher = null,
-    ) {}
+    ) {
+}
 
     /**
      * @throws TransportExceptionInterface
@@ -29,11 +30,13 @@ 
      */
     public function handle(string $name, string $id, string|array $payload): void
     {
-        if (\is_string($payload)) {
+        if (\is_string($payload))
+        {
             $payload = \json_decode($payload, true, 512, JSON_THROW_ON_ERROR);
         }
 
-        if (!\is_array($payload)) {
+        if (!\is_array($payload))
+        {
             throw new InvalidArgumentException('Mail job payload should be an array.');
         }
 
@@ -41,13 +44,17 @@ 
 
         $email = $this->renderer->render($message);
 
-        if ($email->getFrom() === []) {
+        if ($email->getFrom() === [])
+        {
             $email->from(Address::create($this->config->getFromAddress()));
         }
 
-        try {
+        try
+        {
             $this->mailer->send($email);
-        } catch (TransportExceptionInterface $e) {
+        }
+        catch (TransportExceptionInterface $e)
+        {
             $this->dispatcher?->dispatch(new MessageNotSent($email, $e));
 
             throw $e;