mshamaseen / laravel-ratchet

src/Commands/WebSocketService.php

Spacing +2 added lines, -2 removed lines

@@ -51,10 +51,10 @@
                     new Receiver()
                 )
             ),
-            env('WEBSOCKET_PORT',9090)
+            env('WEBSOCKET_PORT', 9090)
         );
 
-        $this->info('Websocket is now running at port '.env('WEBSOCKET_PORT',9090));
+        $this->info('Websocket is now running at port '.env('WEBSOCKET_PORT', 9090));
         $server->run();
     }
 }

src/Receiver.php

Spacing +12 added lines, -12 removed lines

@@ -47,7 +47,7 @@ 
         $this->userAuthSocketMapper = [];
 
         $this->mainRoutes();
-        include base_path() . '/routes/websocket.php';
+        include base_path().'/routes/websocket.php';
         $this->routes = WsRoute::getRoutes();
     }
 
@@ -67,8 +67,8 @@ 
      */
     public function onMessage(ConnectionInterface $from, $msg)
     {
-        $msg = json_decode($msg,true);
-        $this->callRoute($from,$msg);
+        $msg = json_decode($msg, true);
+        $this->callRoute($from, $msg);
     }
 
     function callRoute(ConnectionInterface $from, $msg)
@@ -78,7 +78,7 @@ 
 
             $this->resetSession($msg['session']);
 
-            $this->resetAuth($msg,$from);
+            $this->resetAuth($msg, $from);
 
             $route = $this->routes[$msg['route']];
 
@@ -121,12 +121,12 @@ 
         $routesToCall = $client->onCloseRoutes;
         foreach ($routesToCall as $route)
         {
-            $msg = ['session'=>$client->session,'route'=>$route];
-            $this->callRoute($conn,$msg);
+            $msg = ['session'=>$client->session, 'route'=>$route];
+            $this->callRoute($conn, $msg);
         }
 
         unset($this->clients[$conn->resourceId]);
-        unset($this->userAuthSocketMapper[array_search($conn->resourceId,$this->userAuthSocketMapper)]);
+        unset($this->userAuthSocketMapper[array_search($conn->resourceId, $this->userAuthSocketMapper)]);
 
         echo "Connection {$conn->resourceId} has disconnected\n";
     }
@@ -193,7 +193,7 @@ 
         if ($data = \Session::getHandler()->read($session_id)) {
             $data = @unserialize($data);
 
-            if ($data !== false && ! is_null($data) && is_array($data)) {
+            if ($data !== false && !is_null($data) && is_array($data)) {
                 return $data;
             }
         }
@@ -208,7 +208,7 @@ 
 
     function getUserModel()
     {
-        return \Config::get('laravel-ratchet.userModelNamespace','App\Entities\Users\User');
+        return \Config::get('laravel-ratchet.userModelNamespace', 'App\Entities\Users\User');
     }
 
     function resetSession($session_id)
@@ -225,15 +225,15 @@ 
      * @param ConnectionInterface $from
      * @throws WebSocketException
      */
-    function resetAuth($msg,$from)
+    function resetAuth($msg, $from)
     {
         $data = $this->readFromHandler($msg['session']);
 
-        if(!empty($data))
+        if (!empty($data))
         {
             $user_id = $this->getUserId($data);
             $user = $this->getUserModel()::find($user_id);
-            if(!$user)
+            if (!$user)
             {
                 $this->error($msg, $from, 'There is no such user.');
             }

src/Traits/Validation.php

Spacing +3 added lines, -3 removed lines

@@ -20,9 +20,9 @@ 
     {
         foreach ($required as $input)
         {
-            if(!in_array($input,(array)$this->request))
+            if (!in_array($input, (array) $this->request))
             {
-                $this->error($this->request,$this->conn,$this->requireErrorMessage($input));
+                $this->error($this->request, $this->conn, $this->requireErrorMessage($input));
             }
         }
     }
@@ -50,7 +50,7 @@ 
     public function validate($request, array $rules,
                              array $messages = [], array $customAttributes = [])
     {
-        if($request instanceof Collection)
+        if ($request instanceof Collection)
             $request = $request->toArray();
 
         return $this->getValidationFactory()->make(