swooletw / laravel-swoole

routes/websocket.php

Spacing +3 added lines, -3 removed lines

@@ -12,15 +12,15 @@
 |
 */
 
-Websocket::on('connect', function ($websocket, Request $request) {
+Websocket::on('connect', function($websocket, Request $request) {
     // called while socket on connect
 });
 
-Websocket::on('disconnect', function ($websocket) {
+Websocket::on('disconnect', function($websocket) {
     // called while socket on disconnect
 });
 
-Websocket::on('example', function ($websocket, $data) {
+Websocket::on('example', function($websocket, $data) {
     $websocket->emit('message', $data);
 });
 

routes/laravel_routes.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 |
 */
 
-Route::group(['namespace' => 'SwooleTW\Http\Controllers'], function () {
+Route::group(['namespace' => 'SwooleTW\Http\Controllers'], function() {
     Route::get('socket.io', 'SocketIOController@upgrade');
     Route::post('socket.io', 'SocketIOController@reject');
 });

src/Concerns/ResetApplication.php

Spacing +4 added lines, -4 removed lines

@@ -28,7 +28,7 @@ 
      */
     protected function rebindProviderContainer($provider, $app)
     {
-        $closure = function () use ($app) {
+        $closure = function() use ($app) {
             $this->app = $app;
         };
 
@@ -77,7 +77,7 @@ 
         if ($this->isLaravel()) {
             $router = $app->make('router');
             $request = $this->getRequest();
-            $closure = function () use ($app, $request) {
+            $closure = function() use ($app, $request) {
                 $this->container = $app;
                 if (is_null($request)) {
                     return;
@@ -112,7 +112,7 @@ 
     {
         $view = $app->make('view');
 
-        $closure = function () use ($app) {
+        $closure = function() use ($app) {
             $this->container = $app;
             $this->shared['app'] = $app;
         };
@@ -129,7 +129,7 @@ 
         if ($this->isLaravel()) {
             $kernel = $app->make(Kernel::class);
 
-            $closure = function () use ($app) {
+            $closure = function() use ($app) {
                 $this->app = $app;
             };
 

src/Concerns/WithApplication.php

Spacing +2 added lines, -2 removed lines

@@ -61,7 +61,7 @@ 
      */
     public function getApplication()
     {
-        if (! $this->app instanceof Container) {
+        if (!$this->app instanceof Container) {
             $this->app = $this->loadApplication();
             $this->bootstrap();
         }
@@ -108,7 +108,7 @@ 
     {
         $framework = strtolower($framework);
 
-        if (! in_array($framework, ['laravel', 'lumen'])) {
+        if (!in_array($framework, ['laravel', 'lumen'])) {
             throw new \Exception(sprintf('Not support framework "%s".', $framework));
         }
 

src/Concerns/InteractsWithWebsocket.php

Spacing +9 added lines, -9 removed lines

@@ -54,7 +54,7 @@ 
             // enable sandbox
             $this->app['swoole.sandbox']->enable();
             // check if socket.io connection established
-            if (! $this->websocketHandler->onOpen($swooleRequest->fd, $illuminateRequest)) {
+            if (!$this->websocketHandler->onOpen($swooleRequest->fd, $illuminateRequest)) {
                 return;
             }
             // trigger 'connect' websocket event
@@ -116,7 +116,7 @@ 
      */
     public function onClose($server, $fd, $reactorId)
     {
-        if (! $this->isWebsocket($fd)) {
+        if (!$this->isWebsocket($fd)) {
             return;
         }
 
@@ -147,12 +147,12 @@ 
         $message = $this->parser->encode($event, $message);
 
         // attach sender if not broadcast
-        if (! $broadcast && $sender && ! in_array($sender, $fds)) {
+        if (!$broadcast && $sender && !in_array($sender, $fds)) {
             $fds[] = $sender;
         }
 
         // check if to broadcast all clients
-        if ($broadcast && empty($fds) && ! $assigned) {
+        if ($broadcast && empty($fds) && !$assigned) {
             foreach ($server->connections as $fd) {
                 if ($this->isWebsocket($fd)) {
                     $fds[] = $fd;
@@ -162,7 +162,7 @@ 
 
         // push message to designated fds
         foreach ($fds as $fd) {
-            if (($broadcast && $sender === (integer) $fd) || ! $server->exist($fd)) {
+            if (($broadcast && $sender === (integer) $fd) || !$server->exist($fd)) {
                 continue;
             }
             $server->push($fd, $message, $opcode);
@@ -221,7 +221,7 @@ 
     {
         $handlerClass = $this->container['config']->get('swoole_websocket.handler');
 
-        if (! $handlerClass) {
+        if (!$handlerClass) {
             throw new Exception('Websocket handler is not set in swoole_websocket config');
         }
 
@@ -266,7 +266,7 @@ 
      */
     protected function bindRoom()
     {
-        $this->app->singleton(RoomContract::class, function ($app) {
+        $this->app->singleton(RoomContract::class, function($app) {
             return $this->getWebsocketRoom();
         });
         $this->app->alias(RoomContract::class, 'swoole.room');
@@ -277,7 +277,7 @@ 
      */
     protected function bindWebsocket()
     {
-        $this->app->singleton(Websocket::class, function ($app) {
+        $this->app->singleton(Websocket::class, function($app) {
             return new Websocket($app['swoole.room'], new Pipeline($app));
         });
         $this->app->alias(Websocket::class, 'swoole.websocket');
@@ -290,7 +290,7 @@ 
     {
         $routePath = $this->container['config']->get('swoole_websocket.route_file');
 
-        if (! file_exists($routePath)) {
+        if (!file_exists($routePath)) {
             $routePath = __DIR__ . '/../../routes/websocket.php';
         }
 

src/Concerns/InteractsWithSwooleTable.php

Spacing +1 added lines, -1 removed lines

@@ -49,7 +49,7 @@
      */
     protected function bindSwooleTable()
     {
-        $this->app->singleton(SwooleTable::class, function () {
+        $this->app->singleton(SwooleTable::class, function() {
             return $this->table;
         });
         $this->app->alias(SwooleTable::class, 'swoole.table');

src/Server/Manager.php

Indentation +14 added lines, -14 removed lines

@@ -122,10 +122,10 @@ 
     }
 
     /**
-      * The listener of "managerStart" event.
-      *
-      * @return void
-      */
+     * The listener of "managerStart" event.
+     *
+     * @return void
+     */
     public function onManagerStart()
     {
         $this->setProcessName('manager process');
@@ -357,21 +357,21 @@ 
         swoole_set_process_name($name);
     }
 
-   /**
-    * Indicates if the process is running in macOS.
-    *
-    * @return bool
-    */
+    /**
+     * Indicates if the process is running in macOS.
+     *
+     * @return bool
+     */
     protected function isMacOS()
     {
         return PHP_OS === 'Darwin';
     }
 
-   /**
-    * Indicates if it's in phpunit environment.
-    *
-    * @return bool
-    */
+    /**
+     * Indicates if it's in phpunit environment.
+     *
+     * @return bool
+     */
     protected function isInTesting()
     {
         return defined('IN_PHPUNIT') && IN_PHPUNIT;

Spacing +3 added lines, -3 removed lines

@@ -101,7 +101,7 @@ 
             if (method_exists($this, $listener)) {
                 $this->container['swoole.server']->on($event, [$this, $listener]);
             } else {
-                $this->container['swoole.server']->on($event, function () use ($event) {
+                $this->container['swoole.server']->on($event, function() use ($event) {
                     $event = sprintf('swoole.%s', $event);
 
                     $this->container['events']->fire($event, func_get_args());
@@ -274,7 +274,7 @@ 
      */
     protected function bindSwooleServer()
     {
-        $this->app->singleton(Server::class, function ($app) {
+        $this->app->singleton(Server::class, function($app) {
             return $this->container['swoole.server'];
         });
         $this->app->alias(Server::class, 'swoole.server');
@@ -285,7 +285,7 @@ 
      */
     protected function bindSandbox()
     {
-        $this->app->singleton(Sandbox::class, function ($app) {
+        $this->app->singleton(Sandbox::class, function($app) {
             return new Sandbox($app, $this->framework);
         });
         $this->app->alias(Sandbox::class, 'swoole.sandbox');

src/Server/Sandbox.php

Spacing +6 added lines, -6 removed lines

@@ -42,7 +42,7 @@ 
 
     public function __construct($app = null, $framework = null)
     {
-        if (! $app instanceof Container) {
+        if (!$app instanceof Container) {
             return;
         }
 
@@ -102,7 +102,7 @@ 
      */
     public function initialize()
     {
-        if (! $this->app instanceof Container) {
+        if (!$this->app instanceof Container) {
             throw new SandboxException('A base app has not been set.');
         }
 
@@ -210,7 +210,7 @@ 
      */
     public function run(Request $request)
     {
-        if (! $this->getSnapshot() instanceof Container) {
+        if (!$this->getSnapshot() instanceof Container) {
             throw new SandboxException('Sandbox is not enabled.');
         }
 
@@ -260,7 +260,7 @@ 
             $response->sendContent();
         } elseif ($response instanceof SymfonyResponse) {
             $content = $response->getContent();
-        } elseif (! $isFile = $response instanceof BinaryFileResponse) {
+        } elseif (!$isFile = $response instanceof BinaryFileResponse) {
             $content = (string) $response;
         }
 
@@ -268,7 +268,7 @@ 
         $this->terminate($request, $response);
 
         // append ob content to response
-        if (! $isFile && ob_get_length() > 0) {
+        if (!$isFile && ob_get_length() > 0) {
             if ($isStream) {
                 $response->output = ob_get_contents();
             } else {
@@ -341,7 +341,7 @@ 
      */
     public function enable()
     {
-        if (! $this->config instanceof ConfigContract) {
+        if (!$this->config instanceof ConfigContract) {
             throw new SandboxException('Please initialize after setting base app.');
         }
 

src/LaravelServiceProvider.php

Spacing +2 added lines, -2 removed lines

@@ -13,7 +13,7 @@ 
      */
     protected function registerManager()
     {
-        $this->app->singleton('swoole.manager', function ($app) {
+        $this->app->singleton('swoole.manager', function($app) {
             return new Manager($app, 'laravel');
         });
     }
@@ -25,6 +25,6 @@ 
      */
     protected function bootRoutes()
     {
-        require __DIR__.'/../routes/laravel_routes.php';
+        require __DIR__ . '/../routes/laravel_routes.php';
     }
 }