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/src/Queue.php

Braces +12 added lines, -5 removed lines

@@ -53,13 +53,16 @@ 
      */
     public function push(string $jobType, array $payload = [], Options $options = null): string
     {
-        try {
+        try
+        {
             return $this->rpc->call(self::RR_SERVICE . '.Push', [
                 'job'     => $this->jobName($jobType),
                 'payload' => $this->serialize($jobType, $payload),
                 'options' => $options ?? new Options(),
             ]);
-        } catch (RoadRunnerException | \Throwable $e) {
+        }
+        catch (RoadRunnerException | \Throwable $e)
+        {
             throw new JobException($e->getMessage(), $e->getCode(), $e);
         }
     }
@@ -76,13 +79,16 @@ 
      */
     public function pushAsync(string $jobType, array $payload = [], Options $options = null): bool
     {
-        try {
+        try
+        {
             return $this->rpc->call(self::RR_SERVICE . '.PushAsync', [
                 'job'     => $this->jobName($jobType),
                 'payload' => $this->serialize($jobType, $payload),
                 'options' => $options ?? new Options(),
             ]);
-        } catch (RoadRunnerException | \Throwable $e) {
+        }
+        catch (RoadRunnerException | \Throwable $e)
+        {
             throw new JobException($e->getMessage(), $e->getCode(), $e);
         }
     }
@@ -94,7 +100,8 @@ 
     private function jobName(string $job): string
     {
         $names = explode('\\', $job);
-        $names = array_map(function (string $value) {
+        $names = array_map(function (string $value)
+        {
             return $this->inflector->camelize($value);
         }, $names);
 

src/Jobs/src/JobDispatcher.php

Braces +14 added lines, -6 removed lines

@@ -61,11 +61,14 @@ 
         /** @var ConsumerInterface $consumer */
         $consumer = $this->container->get(ConsumerInterface::class);
 
-        while ($task = $consumer->waitTask()) {
-            try {
+        while ($task = $consumer->waitTask())
+        {
+            try
+            {
                 $instance = $this->container->get($task->getName());
 
-                if (!$instance instanceof HandlerInterface) {
+                if (!$instance instanceof HandlerInterface)
+                {
                     throw new \LogicException(
                         \sprintf('Job should be an instance %s', HandlerInterface::class)
                     );
@@ -73,7 +76,9 @@ 
 
                 $instance->handle($task->getName(), $task->getId(), $task->getPayload());
                 $task->complete();
-            } catch (\Throwable $e) {
+            }
+            catch (\Throwable $e)
+            {
                 $this->handleException($e);
                 $task->fail($e);
             }
@@ -87,9 +92,12 @@ 
      */
     protected function handleException(\Throwable $e): void
     {
-        try {
+        try
+        {
             $this->container->get(SnapshotterInterface::class)->register($e);
-        } catch (\Throwable | ContainerExceptionInterface $se) {
+        }
+        catch (\Throwable | ContainerExceptionInterface $se)
+        {
             // no need to notify when unable to register an exception
         }
     }

src/Jobs/src/Queue/Decorator.php

Braces +2 added lines, -1 removed lines

@@ -128,7 +128,8 @@
      */
     private function getContext(?OptionsInterface $options): QueueInterface
     {
-        if ($options instanceof Options && $options->getPipeline() !== null) {
+        if ($options instanceof Options && $options->getPipeline() !== null)
+        {
             $original = $this->jobs->connect($options->getPipeline());
 
             return new self($this->jobs, $original);

src/Jobs/src/JobsBootloader.php

Braces +6 added lines, -3 removed lines

@@ -40,7 +40,8 @@ 
     {
         $kernel->addDispatcher($jobs);
 
-        if (!$container->has(SerializerInterface::class)) {
+        if (!$container->has(SerializerInterface::class))
+        {
             $this->registerJobsSerializer($container);
         }
 
@@ -79,7 +80,8 @@ 
      */
     private function registerJobsSerializer(Container $container): void
     {
-        $container->bindSingleton(SerializerInterface::class, static function () {
+        $container->bindSingleton(SerializerInterface::class, static function ()
+        {
             return new DefaultSerializer();
         });
     }
@@ -134,7 +136,8 @@ 
     private function registerQueue(Container $container): void
     {
         $container->bindSingleton(Queue::class, static function (JobsInterface $jobs): Queue {
-            foreach ($jobs as $queue) {
+            foreach ($jobs as $queue)
+            {
                 return $queue;
             }
 

src/Jobs/src/JobHandler.php

Braces +5 added lines, -2 removed lines

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