eole-io / sandstone

tests/Integration/WebsocketServerTest.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
     {
         $app = new App\App();
 
-        $app->topic('articles', function ($topicPattern) {
+        $app->topic('articles', function($topicPattern) {
             return new App\ArticleTopic($topicPattern);
         });
 

tests/Integration/App/AppWebsocket.php

Spacing +1 added lines, -1 removed lines

@@ -8,7 +8,7 @@
     {
         parent::__construct($values);
 
-        $this->topic('articles', function ($topicPattern, $arguments) {
+        $this->topic('articles', function($topicPattern, $arguments) {
             $channelName = $arguments['channel'];
 
             return new ArticleTopic($topicPattern, $channelName);

src/Push/ServiceProvider.php

Spacing +2 added lines, -2 removed lines

@@ -16,7 +16,7 @@ 
             $app['sandstone.push.enabled'] = true;
         }
 
-        $app['sandstone.push.event_serializer'] = function () use ($app) {
+        $app['sandstone.push.event_serializer'] = function() use ($app) {
             if (!$app->offsetExists('serializer')) {
                 throw new \RuntimeException('A serializer must be registered');
             }
@@ -24,7 +24,7 @@ 
             return new EventSerializer($app['serializer']);
         };
 
-        $app['sandstone.push.event_forwarder'] = function () use ($app) {
+        $app['sandstone.push.event_forwarder'] = function() use ($app) {
             return new EventForwarder(
                 $app['sandstone.push'],
                 $app['dispatcher'],

src/Serializer/SerializerBuilder.php

Spacing +2 added lines, -2 removed lines

@@ -25,11 +25,11 @@
         return parent::create()
             ->setSerializationContextFactory(array(self::class, 'createDefaultSerializationContext'))
             ->addDefaultHandlers()
-            ->configureListeners(function (EventDispatcher $dispatcher) {
+            ->configureListeners(function(EventDispatcher $dispatcher) {
                 $proxySubscriber = new DoctrineProxySubscriber(false);
                 $dispatcher->addSubscriber($proxySubscriber);
             })
-            ->configureHandlers(function (HandlerRegistryInterface $handlerRegistry) {
+            ->configureHandlers(function(HandlerRegistryInterface $handlerRegistry) {
                 $proxyHandler = new DoctrineProxyHandler();
                 $handlerRegistry->registerSubscribingHandler($proxyHandler);
             })

src/Websocket/Server.php

Spacing +1 added lines, -1 removed lines

@@ -79,7 +79,7 @@
 
         $pushServer->bind("tcp://$pushBind:$pushPort");
 
-        $pushServer->on('message', function ($message) {
+        $pushServer->on('message', function($message) {
             $data = $this->sandstoneApplication['sandstone.push.event_serializer']->deserializeEvent($message);
 
             $this->logger->info('Push message event', ['event' => $data['name']]);

src/Websocket/ServiceProvider.php

Spacing +4 added lines, -4 removed lines

@@ -14,22 +14,22 @@
 {
     public function register(Container $app)
     {
-        $app['sandstone.websocket.routes'] = function () {
+        $app['sandstone.websocket.routes'] = function() {
             return new RouteCollection();
         };
 
-        $app['sandstone.websocket.topics'] = function () use ($app) {
+        $app['sandstone.websocket.topics'] = function() use ($app) {
             return new TopicCollection($app['sandstone.websocket.routes']);
         };
 
-        $app['sandstone.websocket.url_matcher'] = function () use ($app) {
+        $app['sandstone.websocket.url_matcher'] = function() use ($app) {
             return new UrlMatcher(
                 $app['sandstone.websocket.routes'],
                 new RequestContext()
             );
         };
 
-        $app['sandstone.websocket.router'] = function () use ($app) {
+        $app['sandstone.websocket.router'] = function() use ($app) {
             return new TopicRouter($app['sandstone.websocket.url_matcher']);
         };
     }

tests/Integration/PushOnConsoleCommandTest.php

Spacing +2 added lines, -2 removed lines

@@ -14,7 +14,7 @@ 
 
         $app = new App\AppRestApi([
             'debug' => true,
-            'sandstone.push' => function () use ($pushServerMock) {
+            'sandstone.push' => function() use ($pushServerMock) {
                 return $pushServerMock;
             },
         ]);
@@ -24,7 +24,7 @@ 
         $pushServerMock
             ->expects($this->once())
             ->method('send')
-            ->with($this->callback(function ($message) {
+            ->with($this->callback(function($message) {
                 $decodedMessage = unserialize($message);
                 $serializedEvent = '{"propagation_stopped":false,"id":42,"title":"Unicorns spotted in Alaska","url":"http:\/\/unicorn.com\/articles\/unicorns-spotted-alaska"}';
 

tests/Unit/Push/EventForwarderTest.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
         $pushServerMock
             ->expects($this->once())
             ->method('send')
-            ->with($this->callback(function ($message) {
+            ->with($this->callback(function($message) {
                 $decodedMessage = unserialize($message);
                 $serializedEvent = '{"propagation_stopped":false,"id":42,"title":"title","url":"url"}';
 

tests/Unit/Websocket/ApplicationTest.php

Spacing +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
 
         $app->register(new SerializerServiceProvider());
 
-        $app['sandstone.websocket.router'] = function () {
+        $app['sandstone.websocket.router'] = function() {
             $wrongTopic = new WrongTopic('my-topic');
             $topicRouterMock = $this->getMockBuilder(TopicRouter::class)->disableOriginalConstructor()->getMock();