spiral / framework

monorepo-builder.php

Braces +2 added lines, -1 removed lines

@@ -17,7 +17,8 @@
  *
  * @see https://github.com/symplify/symplify/issues/2061
  */
-register_shutdown_function(static function () {
+register_shutdown_function(static function ()
+{
     $dest = json_decode(file_get_contents(__DIR__ . '/composer.json'), true);
 
     $result = [

src/Bridge/Dotenv/src/Bootloader/DotenvBootloader.php

Braces +4 added lines, -2 removed lines

@@ -26,7 +26,8 @@ 
     {
         $dotenvPath = $env->get('DOTENV_PATH', $dirs->get('root') . '.env');
 
-        if (!file_exists($dotenvPath)) {
+        if (!file_exists($dotenvPath))
+        {
             return;
         }
 
@@ -36,7 +37,8 @@ 
         )
             ->load();
 
-        foreach ($dotenv as $key => $value) {
+        foreach ($dotenv as $key => $value)
+        {
             $env->set($key, $value);
         }
     }

src/Framework/Http/RrDispatcher.php

Braces +17 added lines, -7 removed lines

@@ -80,14 +80,20 @@ 
     {
         /** @var Http $http */
         $http = $this->container->get(Http::class);
-        while ($request = $this->worker->waitRequest()) {
-            try {
+        while ($request = $this->worker->waitRequest())
+        {
+            try
+            {
                 $response = $http->handle($request);
 
                 $this->worker->respond($response);
-            } catch (\Throwable $e) {
+            }
+            catch (\Throwable $e)
+            {
                 $this->worker->respond($this->errorToResponse($e));
-            } finally {
+            }
+            finally
+            {
                 $this->finalizer->finalize(false);
             }
         }
@@ -101,7 +107,8 @@ 
     {
         $handler = new HtmlHandler();
 
-        try {
+        try
+        {
             /** @var SnapshotInterface $snapshot */
             $snapshot = $this->container->get(SnapshotterInterface::class)->register($e);
             \file_put_contents('php://stderr', $snapshot->getMessage());
@@ -109,10 +116,13 @@ 
             // on demand
             $state = $this->container->get(StateInterface::class);
 
-            if ($state !== null) {
+            if ($state !== null)
+            {
                 $handler = $handler->withState($state);
             }
-        } catch (\Throwable | ContainerExceptionInterface $se) {
+        }
+        catch (\Throwable | ContainerExceptionInterface $se)
+        {
             \file_put_contents('php://stderr', (string)$e);
         }
 

src/Jobs/tests/Jobs/ShortCircuitTest.php

Braces +2 added lines, -1 removed lines

@@ -23,7 +23,8 @@
 {
     protected function tearDown(): void
     {
-        if (file_exists(Job::JOB_FILE)) {
+        if (file_exists(Job::JOB_FILE))
+        {
             unlink(Job::JOB_FILE);
         }
     }

src/Jobs/tests/Jobs/BaseTest.php

Braces +4 added lines, -2 removed lines

@@ -35,7 +35,8 @@ 
 
     protected function tearDown(): void
     {
-        if (file_exists((static::JOB)::JOB_FILE)) {
+        if (file_exists((static::JOB)::JOB_FILE))
+        {
             unlink((static::JOB)::JOB_FILE);
         }
     }
@@ -105,7 +106,8 @@ 
     {
         $start = microtime(true);
         $try = 0;
-        while (!file_exists($this->job::JOB_FILE) && $try < 10) {
+        while (!file_exists($this->job::JOB_FILE) && $try < 10)
+        {
             usleep(250000);
             $try++;
         }

src/Jobs/src/JobHandler.php

Braces +5 added lines, -2 removed lines

@@ -43,10 +43,13 @@
         $method = new \ReflectionMethod($this, static::HANDLE_FUNCTION);
         $method->setAccessible(true);
 
-        try {
+        try
+        {
             $parameters = array_merge(['payload' => $payloadData, 'id' => $jobID], $payloadData);
             $method->invokeArgs($this, $this->resolver->resolveArguments($method, $parameters));
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             throw new JobException(
                 sprintf('[%s] %s', get_class($this), $e->getMessage()),
                 $e->getCode(),

src/Jobs/src/Registry/ContainerRegistry.php

Braces +16 added lines, -7 removed lines

@@ -50,13 +50,17 @@ 
      */
     public function getHandler(string $jobType): HandlerInterface
     {
-        try {
+        try
+        {
             $handler = $this->container->get($this->className($jobType));
-        } catch (ContainerException $e) {
+        }
+        catch (ContainerException $e)
+        {
             throw new JobException($e->getMessage(), $e->getCode(), $e);
         }
 
-        if (!$handler instanceof HandlerInterface) {
+        if (!$handler instanceof HandlerInterface)
+        {
             throw new JobException("Unable to resolve job handler for `{$jobType}`");
         }
 
@@ -69,13 +73,17 @@ 
      */
     public function getSerializer(string $jobType): SerializerInterface
     {
-        try {
+        try
+        {
             $handler = $this->getHandler($jobType);
-        } catch (JobException $e) {
+        }
+        catch (JobException $e)
+        {
             return $this->defaultSerializer;
         }
 
-        if ($handler instanceof SerializerInterface) {
+        if ($handler instanceof SerializerInterface)
+        {
             return $handler;
         }
 
@@ -89,7 +97,8 @@ 
     private function className(string $jobType): string
     {
         $names = explode('.', $jobType);
-        $names = array_map(function (string $value) {
+        $names = array_map(function (string $value)
+        {
             return $this->inflector->classify($value);
         }, $names);
 

src/Jobs/src/Consumer.php

Braces +12 added lines, -5 removed lines

@@ -37,18 +37,25 @@
      */
     public function serve(Worker $worker, callable $finalize = null): void
     {
-        while ($body = $worker->receive($context)) {
-            try {
+        while ($body = $worker->receive($context))
+        {
+            try
+            {
                 $context = json_decode($context, true);
                 $handler = $this->registry->getHandler($context['job']);
 
                 $handler->handle($context['job'], $context['id'], $body);
 
                 $worker->send('ok');
-            } catch (\Throwable $e) {
+            }
+            catch (\Throwable $e)
+            {
                 $worker->error((string)$e->getMessage());
-            } finally {
-                if ($finalize !== null) {
+            }
+            finally
+            {
+                if ($finalize !== null)
+                {
                     call_user_func($finalize, $e ?? null);
                 }
             }

src/Jobs/src/ShortCircuit.php

Braces +2 added lines, -1 removed lines

@@ -40,7 +40,8 @@
     public function push(string $jobType, array $payload = [], Options $options = null): string
     {
         $payloadBody = $this->serialize($jobType, $payload);
-        if ($options !== null && $options->getDelay()) {
+        if ($options !== null && $options->getDelay())
+        {
             sleep($options->getDelay());
         }