spiral / framework

src/Http/RrDispacher.php

Spacing +8 added lines, -8 removed lines

@@ -49,7 +49,7 @@ 
         FinalizerInterface $finalizer,
         ContainerInterface $container,
         FactoryInterface $factory
-    ) {
+    ){
         $this->env = $env;
         $this->finalizer = $finalizer;
         $this->container = $container;
@@ -75,12 +75,12 @@ 
 
         /** @var Http $http */
         $http = $this->container->get(Http::class);
-        while ($request = $client->acceptRequest()) {
-            try {
+        while ($request = $client->acceptRequest()){
+            try{
                 $client->respond($http->handle($request));
-            } catch (\Throwable $e) {
+            }catch (\Throwable $e){
                 $this->handleException($client, $e);
-            } finally {
+            }finally{
                 $this->finalizer->finalize(false);
             }
         }
@@ -94,17 +94,17 @@ 
     {
         $handler = new HtmlHandler();
 
-        try {
+        try{
             /** @var SnapshotInterface $snapshot */
             $snapshot = $this->container->get(SnapshotterInterface::class)->register($e);
             error_log($snapshot->getMessage());
 
             // 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){
             error_log((string)$e);
         }
 

Braces +17 added lines, -7 removed lines

@@ -75,12 +75,18 @@ 
 
         /** @var Http $http */
         $http = $this->container->get(Http::class);
-        while ($request = $client->acceptRequest()) {
-            try {
+        while ($request = $client->acceptRequest())
+        {
+            try
+            {
                 $client->respond($http->handle($request));
-            } catch (\Throwable $e) {
+            }
+            catch (\Throwable $e)
+            {
                 $this->handleException($client, $e);
-            } finally {
+            }
+            finally
+            {
                 $this->finalizer->finalize(false);
             }
         }
@@ -94,17 +100,21 @@ 
     {
         $handler = new HtmlHandler();
 
-        try {
+        try
+        {
             /** @var SnapshotInterface $snapshot */
             $snapshot = $this->container->get(SnapshotterInterface::class)->register($e);
             error_log($snapshot->getMessage());
 
             // 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)
+        {
             error_log((string)$e);
         }
 

src/Http/SapiDispatcher.php

Spacing +6 added lines, -6 removed lines

@@ -62,12 +62,12 @@ 
         $http = $this->container->get(Http::class);
         $emitter = $emitter ?? $this->container->get(EmitterInterface::class);
 
-        try {
+        try{
             $response = $http->handle($this->initRequest());
             $emitter->emit($response);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             $this->handleException($emitter, $e);
-        } finally {
+        }finally{
             $this->finalizer->finalize(false);
         }
     }
@@ -88,16 +88,16 @@ 
     {
         $handler = new HtmlHandler();
 
-        try {
+        try{
             /** @var SnapshotInterface $snapshot */
             $this->container->get(SnapshotterInterface::class)->register($e);
 
             // 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){
             // nothing to report
         }
 

Braces +15 added lines, -6 removed lines

@@ -62,12 +62,17 @@ 
         $http = $this->container->get(Http::class);
         $emitter = $emitter ?? $this->container->get(EmitterInterface::class);
 
-        try {
+        try
+        {
             $response = $http->handle($this->initRequest());
             $emitter->emit($response);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             $this->handleException($emitter, $e);
-        } finally {
+        }
+        finally
+        {
             $this->finalizer->finalize(false);
         }
     }
@@ -88,16 +93,20 @@ 
     {
         $handler = new HtmlHandler();
 
-        try {
+        try
+        {
             /** @var SnapshotInterface $snapshot */
             $this->container->get(SnapshotterInterface::class)->register($e);
 
             // 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)
+        {
             // nothing to report
         }
 

src/Debug/StateCollector/EnvironmentCollector.php

Spacing +2 added lines, -2 removed lines

@@ -43,8 +43,8 @@
     {
         $state->setTag('php', phpversion());
 
-        if ($this->container->get(DispatcherInterface::class)) {
-            switch (get_class($this->container->get(DispatcherInterface::class))) {
+        if ($this->container->get(DispatcherInterface::class)){
+            switch (get_class($this->container->get(DispatcherInterface::class))){
                 case RrDispacher::class:
                     $state->setTag('dispatcher', 'roadrunner');
                     break;

Braces +4 added lines, -2 removed lines

@@ -43,8 +43,10 @@
     {
         $state->setTag('php', phpversion());
 
-        if ($this->container->get(DispatcherInterface::class)) {
-            switch (get_class($this->container->get(DispatcherInterface::class))) {
+        if ($this->container->get(DispatcherInterface::class))
+        {
+            switch (get_class($this->container->get(DispatcherInterface::class)))
+            {
                 case RrDispacher::class:
                     $state->setTag('dispatcher', 'roadrunner');
                     break;

src/Debug/StateCollector/HttpCollector.php

Spacing +3 added lines, -3 removed lines

@@ -39,7 +39,7 @@ 
      */
     public function populate(StateInterface $state): void
     {
-        if (!$this->request === null) {
+        if (!$this->request === null){
             return;
         }
 
@@ -48,11 +48,11 @@ 
 
         $state->setVariable('headers', $this->request->getHeaders());
 
-        if ($this->request->getQueryParams() !== []) {
+        if ($this->request->getQueryParams() !== []){
             $state->setVariable('query', $this->request->getQueryParams());
         }
 
-        if ($this->request->getParsedBody() !== null) {
+        if ($this->request->getParsedBody() !== null){
             $state->setVariable('data', $this->request->getParsedBody());
         }
     }

Braces +6 added lines, -3 removed lines

@@ -39,7 +39,8 @@ 
      */
     public function populate(StateInterface $state): void
     {
-        if (!$this->request === null) {
+        if (!$this->request === null)
+        {
             return;
         }
 
@@ -48,11 +49,13 @@ 
 
         $state->setVariable('headers', $this->request->getHeaders());
 
-        if ($this->request->getQueryParams() !== []) {
+        if ($this->request->getQueryParams() !== [])
+        {
             $state->setVariable('query', $this->request->getQueryParams());
         }
 
-        if ($this->request->getParsedBody() !== null) {
+        if ($this->request->getParsedBody() !== null)
+        {
             $state->setVariable('data', $this->request->getParsedBody());
         }
     }

src/Bootloader/SnapshotsBootloader.php

Spacing +2 added lines, -2 removed lines

@@ -46,9 +46,9 @@
         DirectoriesInterface $dirs,
         FilesInterface $files,
         LoggerInterface $logger = null
-    ) {
+    ){
         return new FileSnapshooter(
-            $dirs->get('runtime') . '/snapshots/',
+            $dirs->get('runtime').'/snapshots/',
             $env->get('SNAPSHOT_MAX_FILES', self::MAX_SNAPSHOTS),
             $env->get('SNAPSHOT_VERBOSITY', HandlerInterface::VERBOSITY_VERBOSE),
             new PlainHandler(),

src/Http/ErrorHandler/PlainRenderer.php

Spacing +2 added lines, -2 removed lines

@@ -40,9 +40,9 @@
     public function renderException(Request $request, int $code, string $message): Response
     {
         $response = $this->responseFactory->createResponse($code);
-        if ($request->getHeaderLine('Accept') == 'application/json') {
+        if ($request->getHeaderLine('Accept') == 'application/json'){
             $response->getBody()->write(json_encode(['status' => $code, 'error' => $message]));
-        } else {
+        }else{
             $response->getBody()->write("Error code: {$code}");
         }
 

Braces +5 added lines, -2 removed lines

@@ -40,9 +40,12 @@
     public function renderException(Request $request, int $code, string $message): Response
     {
         $response = $this->responseFactory->createResponse($code);
-        if ($request->getHeaderLine('Accept') == 'application/json') {
+        if ($request->getHeaderLine('Accept') == 'application/json')
+        {
             $response->getBody()->write(json_encode(['status' => $code, 'error' => $message]));
-        } else {
+        }
+        else
+        {
             $response->getBody()->write("Error code: {$code}");
         }
 

tests/Framework/GRPC/DispatcherTest.php

Spacing +13 added lines, -13 removed lines

@@ -23,14 +23,14 @@ 
     public function setUp(): void
     {
         exec('protoc 2>&1', $out);
-        if (strpos(join("\n", $out), '--php_out') === false) {
+        if (strpos(join("\n", $out), '--php_out') === false){
             $this->markTestSkipped('Protoc binary is missing');
         }
 
         parent::setUp();
 
         $fs = new Files();
-        $proto = $fs->normalizePath($this->app->dir('app') . 'proto/service.proto');
+        $proto = $fs->normalizePath($this->app->dir('app').'proto/service.proto');
 
         // protoc can't figure relative paths
         $proto = str_replace('Framework/../', '', $proto);
@@ -39,7 +39,7 @@ 
             'proto' => $proto
         ]);
 
-        file_put_contents($this->app->dir('app') . 'src/Service/EchoService.php', GenerateTest::SERVICE);
+        file_put_contents($this->app->dir('app').'src/Service/EchoService.php', GenerateTest::SERVICE);
     }
 
     public function tearDown(): void
@@ -48,12 +48,12 @@ 
 
         $fs = new Files();
 
-        if ($fs->isDirectory($this->app->dir('app') . 'src/Service')) {
-            $fs->deleteDirectory($this->app->dir('app') . 'src/Service');
+        if ($fs->isDirectory($this->app->dir('app').'src/Service')){
+            $fs->deleteDirectory($this->app->dir('app').'src/Service');
         }
 
-        if ($fs->isDirectory($this->app->dir('app') . 'src/GPBMetadata')) {
-            $fs->deleteDirectory($this->app->dir('app') . 'src/GPBMetadata');
+        if ($fs->isDirectory($this->app->dir('app').'src/GPBMetadata')){
+            $fs->deleteDirectory($this->app->dir('app').'src/GPBMetadata');
         }
     }
 
@@ -79,7 +79,7 @@ 
         $msg->setMsg('hello');
 
         $w->shouldReceive('receive')->once()->with(
-            \Mockery::on(function (&$context) {
+            \Mockery::on(function (&$context){
                 $context = '{
                   "service": "service.Echo",
                   "method": "Ping",
@@ -91,7 +91,7 @@ 
         )->andReturn($msg->serializeToString());
 
         $w->shouldReceive('send')->once()->with(
-            \Mockery::on(function ($out) {
+            \Mockery::on(function ($out){
                 $msg = new Message();
                 $msg->mergeFromString($out);
                 $this->assertSame('hello', $msg->getMsg());
@@ -103,7 +103,7 @@ 
 
         // one command only
         $w->shouldReceive('receive')->once()->with(
-            \Mockery::on(function (&$context) {
+            \Mockery::on(function (&$context){
                 $context = null;
                 return true;
             })
@@ -123,7 +123,7 @@ 
         $msg->setMsg('hello');
 
         $w->shouldReceive('receive')->once()->with(
-            \Mockery::on(function (&$context) {
+            \Mockery::on(function (&$context){
                 $context = '{
                   "service": "service.Echo",
                   "method": "Invalid",
@@ -135,7 +135,7 @@ 
         )->andReturn($msg->serializeToString());
 
         $w->shouldReceive('error')->once()->with(
-            \Mockery::on(function ($out) {
+            \Mockery::on(function ($out){
                 $this->assertContains('Method `Invalid` not found', $out);
                 return true;
             })
@@ -143,7 +143,7 @@ 
 
         // one command only
         $w->shouldReceive('receive')->once()->with(
-            \Mockery::on(function (&$context) {
+            \Mockery::on(function (&$context){
                 $context = null;
                 return true;
             })

Braces +18 added lines, -9 removed lines

@@ -23,7 +23,8 @@ 
     public function setUp(): void
     {
         exec('protoc 2>&1', $out);
-        if (strpos(join("\n", $out), '--php_out') === false) {
+        if (strpos(join("\n", $out), '--php_out') === false)
+        {
             $this->markTestSkipped('Protoc binary is missing');
         }
 
@@ -48,11 +49,13 @@ 
 
         $fs = new Files();
 
-        if ($fs->isDirectory($this->app->dir('app') . 'src/Service')) {
+        if ($fs->isDirectory($this->app->dir('app') . 'src/Service'))
+        {
             $fs->deleteDirectory($this->app->dir('app') . 'src/Service');
         }
 
-        if ($fs->isDirectory($this->app->dir('app') . 'src/GPBMetadata')) {
+        if ($fs->isDirectory($this->app->dir('app') . 'src/GPBMetadata'))
+        {
             $fs->deleteDirectory($this->app->dir('app') . 'src/GPBMetadata');
         }
     }
@@ -79,7 +82,8 @@ 
         $msg->setMsg('hello');
 
         $w->shouldReceive('receive')->once()->with(
-            \Mockery::on(function (&$context) {
+            \Mockery::on(function (&$context)
+            {
                 $context = '{
                   "service": "service.Echo",
                   "method": "Ping",
@@ -91,7 +95,8 @@ 
         )->andReturn($msg->serializeToString());
 
         $w->shouldReceive('send')->once()->with(
-            \Mockery::on(function ($out) {
+            \Mockery::on(function ($out)
+            {
                 $msg = new Message();
                 $msg->mergeFromString($out);
                 $this->assertSame('hello', $msg->getMsg());
@@ -103,7 +108,8 @@ 
 
         // one command only
         $w->shouldReceive('receive')->once()->with(
-            \Mockery::on(function (&$context) {
+            \Mockery::on(function (&$context)
+            {
                 $context = null;
                 return true;
             })
@@ -123,7 +129,8 @@ 
         $msg->setMsg('hello');
 
         $w->shouldReceive('receive')->once()->with(
-            \Mockery::on(function (&$context) {
+            \Mockery::on(function (&$context)
+            {
                 $context = '{
                   "service": "service.Echo",
                   "method": "Invalid",
@@ -135,7 +142,8 @@ 
         )->andReturn($msg->serializeToString());
 
         $w->shouldReceive('error')->once()->with(
-            \Mockery::on(function ($out) {
+            \Mockery::on(function ($out)
+            {
                 $this->assertContains('Method `Invalid` not found', $out);
                 return true;
             })
@@ -143,7 +151,8 @@ 
 
         // one command only
         $w->shouldReceive('receive')->once()->with(
-            \Mockery::on(function (&$context) {
+            \Mockery::on(function (&$context)
+            {
                 $context = null;
                 return true;
             })

tests/Framework/Http/WebsocketsTest.php

Spacing +9 added lines, -9 removed lines

@@ -38,7 +38,7 @@ 
 
     public function testAllowServerAccess(): void
     {
-        $this->init(static function () {
+        $this->init(static function (){
             return true;
         });
 
@@ -50,7 +50,7 @@ 
 
     public function testDenyServerAccess(): void
     {
-        $this->init(static function () {
+        $this->init(static function (){
             return false;
         });
 
@@ -62,7 +62,7 @@ 
 
     public function testServerAccessWithDependency(): void
     {
-        $this->init(static function (ServerRequestInterface $request) {
+        $this->init(static function (ServerRequestInterface $request){
             return $request instanceof ServerRequestInterface;
         });
 
@@ -124,7 +124,7 @@ 
 
     public function testTopicAccessOK(): void
     {
-        $this->init(null, function () {
+        $this->init(null, function (){
             return true;
         });
 
@@ -136,7 +136,7 @@ 
 
     public function testTopicWildcardAccessFail(): void
     {
-        $this->init(null, function () {
+        $this->init(null, function (){
             return true;
         });
 
@@ -151,7 +151,7 @@ 
         $this->init(
             null,
             null,
-            function () {
+            function (){
                 return true;
             }
         );
@@ -167,7 +167,7 @@ 
         $this->init(
             null,
             null,
-            function ($id) {
+            function ($id){
                 return $id === '1';
             }
         );
@@ -183,7 +183,7 @@ 
         $this->init(
             null,
             null,
-            function ($id) {
+            function ($id){
                 return $id === '1';
             }
         );
@@ -204,7 +204,7 @@ 
             'CYCLE_AUTH'                 => true,
             'RR_BROADCAST_PATH'          => '/ws/',
             'WS_SERVER_CALLBACK'         => null,
-            'WS_TOPIC_CALLBACK'          => function (AuthContextInterface $authContext) {
+            'WS_TOPIC_CALLBACK'          => function (AuthContextInterface $authContext){
                 return $authContext->getToken() !== null;
             },
             'WS_TOPIC_WILDCARD_CALLBACK' => null,

Braces +18 added lines, -9 removed lines

@@ -38,7 +38,8 @@ 
 
     public function testAllowServerAccess(): void
     {
-        $this->init(static function () {
+        $this->init(static function ()
+        {
             return true;
         });
 
@@ -50,7 +51,8 @@ 
 
     public function testDenyServerAccess(): void
     {
-        $this->init(static function () {
+        $this->init(static function ()
+        {
             return false;
         });
 
@@ -62,7 +64,8 @@ 
 
     public function testServerAccessWithDependency(): void
     {
-        $this->init(static function (ServerRequestInterface $request) {
+        $this->init(static function (ServerRequestInterface $request)
+        {
             return $request instanceof ServerRequestInterface;
         });
 
@@ -124,7 +127,8 @@ 
 
     public function testTopicAccessOK(): void
     {
-        $this->init(null, function () {
+        $this->init(null, function ()
+        {
             return true;
         });
 
@@ -136,7 +140,8 @@ 
 
     public function testTopicWildcardAccessFail(): void
     {
-        $this->init(null, function () {
+        $this->init(null, function ()
+        {
             return true;
         });
 
@@ -151,7 +156,8 @@ 
         $this->init(
             null,
             null,
-            function () {
+            function ()
+            {
                 return true;
             }
         );
@@ -167,7 +173,8 @@ 
         $this->init(
             null,
             null,
-            function ($id) {
+            function ($id)
+            {
                 return $id === '1';
             }
         );
@@ -183,7 +190,8 @@ 
         $this->init(
             null,
             null,
-            function ($id) {
+            function ($id)
+            {
                 return $id === '1';
             }
         );
@@ -204,7 +212,8 @@ 
             'CYCLE_AUTH'                 => true,
             'RR_BROADCAST_PATH'          => '/ws/',
             'WS_SERVER_CALLBACK'         => null,
-            'WS_TOPIC_CALLBACK'          => function (AuthContextInterface $authContext) {
+            'WS_TOPIC_CALLBACK'          => function (AuthContextInterface $authContext)
+            {
                 return $authContext->getToken() !== null;
             },
             'WS_TOPIC_WILDCARD_CALLBACK' => null,

tests/Framework/HttpTest.php

Spacing +2 added lines, -2 removed lines

@@ -45,7 +45,7 @@ 
         array $headers = []
     ): ResponseInterface {
         $r = $this->request($uri, 'GET', [], $headers, []);
-        foreach ($attributes as $k => $v) {
+        foreach ($attributes as $k => $v){
             $r = $r->withAttribute($k, $v);
         }
 
@@ -86,7 +86,7 @@ 
     protected function fetchCookies(array $header)
     {
         $result = [];
-        foreach ($header as $line) {
+        foreach ($header as $line){
             $cookie = explode('=', $line);
             $result[$cookie[0]] = rawurldecode(substr($cookie[1], 0, strpos($cookie[1], ';')));
         }

Braces +4 added lines, -2 removed lines

@@ -45,7 +45,8 @@ 
         array $headers = []
     ): ResponseInterface {
         $r = $this->request($uri, 'GET', [], $headers, []);
-        foreach ($attributes as $k => $v) {
+        foreach ($attributes as $k => $v)
+        {
             $r = $r->withAttribute($k, $v);
         }
 
@@ -86,7 +87,8 @@ 
     protected function fetchCookies(array $header)
     {
         $result = [];
-        foreach ($header as $line) {
+        foreach ($header as $line)
+        {
             $cookie = explode('=', $line);
             $result[$cookie[0]] = rawurldecode(substr($cookie[1], 0, strpos($cookie[1], ';')));
         }