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/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

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

src/Coroutine/PDOStatement.php

Spacing +6 added lines, -6 removed lines

@@ -48,7 +48,7 @@ 
 
     public function bindParam($parameter, &$variable, $type = null, $maxlen = null, $driverdata = null)
     {
-        if (! is_string($parameter) && ! is_int($parameter)) {
+        if (!is_string($parameter) && !is_int($parameter)) {
             return false;
         }
 
@@ -60,12 +60,12 @@ 
 
     public function bindValue($parameter, $variable, $type = null)
     {
-        if (! is_string($parameter) && ! is_int($parameter)) {
+        if (!is_string($parameter) && !is_int($parameter)) {
             return false;
         }
 
         if (is_object($variable)) {
-            if (! method_exists($variable, '__toString')) {
+            if (!method_exists($variable, '__toString')) {
                 return false;
             } else {
                 $variable = (string) $variable;
@@ -86,14 +86,14 @@ 
 
     public function execute($inputParameters = null)
     {
-        if (! empty($inputParameters)) {
+        if (!empty($inputParameters)) {
             foreach ($inputParameters as $key => $value) {
                 $this->bindParam($key, $value);
             }
         }
 
         $inputParameters = [];
-        if (! empty($this->statement->bindKeyMap)) {
+        if (!empty($this->statement->bindKeyMap)) {
             foreach ($this->statement->bindKeyMap as $nameKey => $numKey) {
                 $inputParameters[$numKey] = $this->bindMap[$nameKey];
             }
@@ -143,7 +143,7 @@ 
         $fetchArgument = null,
         $ctorArgs = null
     ) {
-        if (! is_array($rawData)) {
+        if (!is_array($rawData)) {
             return false;
         }
         if (empty($rawData)) {