spiral / framework

monorepo-builder.php

Spacing +3 added lines, -3 removed lines

@@ -17,8 +17,8 @@ 
  *
  * @see https://github.com/symplify/symplify/issues/2061
  */
-register_shutdown_function(static function () {
-    $dest = json_decode(file_get_contents(__DIR__ . '/composer.json'), true);
+register_shutdown_function(static function (){
+    $dest = json_decode(file_get_contents(__DIR__.'/composer.json'), true);
 
     $result = [
         'name' => 'spiral/framework',
@@ -53,7 +53,7 @@ 
 
     $json = json_encode($result, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES);
 
-    file_put_contents(__DIR__ . '/composer.json', $json . "\n");
+    file_put_contents(__DIR__.'/composer.json', $json."\n");
 });
 
 

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

Spacing +3 added lines, -3 removed lines

@@ -24,9 +24,9 @@ 
      */
     public function boot(DirectoriesInterface $dirs, EnvironmentInterface $env)
     {
-        $dotenvPath = $env->get('DOTENV_PATH', $dirs->get('root') . '.env');
+        $dotenvPath = $env->get('DOTENV_PATH', $dirs->get('root').'.env');
 
-        if (!file_exists($dotenvPath)) {
+        if (!file_exists($dotenvPath)){
             return;
         }
 
@@ -36,7 +36,7 @@ 
         )
             ->load();
 
-        foreach ($dotenv as $key => $value) {
+        foreach ($dotenv as $key => $value){
             $env->set($key, $value);
         }
     }

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

Spacing +8 added lines, -8 removed lines

@@ -58,7 +58,7 @@ 
         PSR7WorkerInterface $worker,
         ContainerInterface $container,
         FinalizerInterface $finalizer
-    ) {
+    ){
         $this->env = $env;
         $this->worker = $worker;
         $this->container = $container;
@@ -80,14 +80,14 @@ 
     {
         /** @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 +101,7 @@ 
     {
         $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 +109,10 @@ 
             // 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);
         }
 

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

Spacing +7 added lines, -7 removed lines

@@ -53,13 +53,13 @@ 
      */
     public function push(string $jobType, array $payload = [], Options $options = null): string
     {
-        try {
-            return $this->rpc->call(self::RR_SERVICE . '.Push', [
+        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 +76,13 @@ 
      */
     public function pushAsync(string $jobType, array $payload = [], Options $options = null): bool
     {
-        try {
-            return $this->rpc->call(self::RR_SERVICE . '.PushAsync', [
+        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 +94,7 @@ 
     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);
 

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

Spacing +7 added lines, -7 removed lines

@@ -39,7 +39,7 @@ 
         ContainerInterface $container,
         FinalizerInterface $finalizer,
         EnvironmentInterface $env
-    ) {
+    ){
         $this->env = $env;
         $this->container = $container;
         $this->finalizer = $finalizer;
@@ -61,11 +61,11 @@ 
         /** @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 +73,7 @@ 
 
                 $instance->handle($task->getName(), $task->getId(), $task->getPayload());
                 $task->complete();
-            } catch (\Throwable $e) {
+            }catch (\Throwable $e){
                 $this->handleException($e);
                 $task->fail($e);
             }
@@ -87,9 +87,9 @@ 
      */
     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
         }
     }

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

Spacing +1 added lines, -1 removed lines

@@ -128,7 +128,7 @@
      */
     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);

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/Options.php

Indentation +1 added lines, -3 removed lines

@@ -103,6 +103,4 @@
         $options = new self();
         $options->base = $options->base->withDelay($delay);
 
-        return $options;
-    }
-}
+        return $options
\ No newline at end of file

Switch Indentation +1 added lines, -3 removed lines

@@ -103,6 +103,4 @@
         $options = new self();
         $options->base = $options->base->withDelay($delay);
 
-        return $options;
-    }
-}
+        return $options
\ No newline at end of file

Spacing +2 added lines, -4 removed lines

@@ -84,7 +84,7 @@ 
     public function jsonSerialize(): array
     {
         return [
-<<<<<<< HEAD
+<< << <<< HEAD
             'delay'    => $this->base->delay ?: null,
             'pipeline' => $this->pipeline
 =======
@@ -103,6 +103,4 @@ 
         $options = new self();
         $options->base = $options->base->withDelay($delay);
 
-        return $options;
-    }
-}
+        return $options
\ No newline at end of file

Braces +1 added lines, -3 removed lines

@@ -103,6 +103,4 @@
         $options = new self();
         $options->base = $options->base->withDelay($delay);
 
-        return $options;
-    }
-}
+        return $options
\ No newline at end of file

Upper-Lower-Casing +1 added lines, -3 removed lines

@@ -103,6 +103,4 @@
         $options = new self();
         $options->base = $options->base->withDelay($delay);
 
-        return $options;
-    }
-}
+        return $options
\ No newline at end of file

src/Jobs/src/JobsBootloader.php

Spacing +3 added lines, -3 removed lines

@@ -40,7 +40,7 @@ 
     {
         $kernel->addDispatcher($jobs);
 
-        if (!$container->has(SerializerInterface::class)) {
+        if (!$container->has(SerializerInterface::class)){
             $this->registerJobsSerializer($container);
         }
 
@@ -79,7 +79,7 @@ 
      */
     private function registerJobsSerializer(Container $container): void
     {
-        $container->bindSingleton(SerializerInterface::class, static function () {
+        $container->bindSingleton(SerializerInterface::class, static function (){
             return new DefaultSerializer();
         });
     }
@@ -134,7 +134,7 @@ 
     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;
             }
 

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

Spacing +2 added lines, -2 removed lines

@@ -40,10 +40,10 @@
         $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);
         }

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);
         }