mshamaseen / laravel-ratchet

src/Traits/WebSocketMessagesManager.php

Doc Comments +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
     /**
      * @param $request
      * @param ConnectionInterface $from
-     * @param $error
+     * @param string $error
      * @throws WebSocketException
      */
     function error($request,ConnectionInterface $from, $error)

Spacing +8 added lines, -8 removed lines

@@ -25,7 +25,7 @@ 
      * @param $error
      * @throws WebSocketException
      */
-    function error($request,ConnectionInterface $from, $error)
+    function error($request, ConnectionInterface $from, $error)
     {
         echo 'Error: ';
         echo $error."\n";
@@ -36,7 +36,7 @@ 
             'type'=>'error',
             'message'=>$error
         ];
-        $this->sendToWebSocketUser($from,$data);
+        $this->sendToWebSocketUser($from, $data);
         throw new WebSocketException();
     }
 
@@ -44,12 +44,12 @@ 
      * @param ConnectionInterface $conn
      * @param $data
      */
-    function sendToWebSocketUser(ConnectionInterface $conn,$data)
+    function sendToWebSocketUser(ConnectionInterface $conn, $data)
     {
-        if(!is_array($data))
+        if (!is_array($data))
             $data = ['msg'=>$data];
 
-        if(isset($this->route) && $this->route->auth && !array_key_exists('sender',$data))
+        if (isset($this->route) && $this->route->auth && !array_key_exists('sender', $data))
             $data['sender'] = $this->getSenderData();
 
         $conn->send(json_encode($data));
@@ -59,12 +59,12 @@ 
      * @param int $user_id
      * @param array $data
      */
-    function sendToUser($user_id,$data)
+    function sendToUser($user_id, $data)
     {
         $resourceId = $this->userAuthSocketMapper[$user_id];
         /** @var ConnectionInterface $conn */
         $conn = $this->clients[$resourceId]->conn;
-        $this->sendToWebSocketUser($conn,$data);
+        $this->sendToWebSocketUser($conn, $data);
     }
 
     /**
@@ -72,7 +72,7 @@ 
      */
     function sendBack($data)
     {
-       $this->sendToWebSocketUser($this->conn,$data);
+       $this->sendToWebSocketUser($this->conn, $data);
     }
 
     /**

src/Objects/Rooms/Room.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
 
     function hasMember($client)
     {
-        if(array_key_exists($client->id,$this->members))
+        if (array_key_exists($client->id, $this->members))
             return true;
 
         return false;

src/Routes/Routes.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
      * @param $method
      * @param bool $authenticated
      */
-    function make($routeName, $controller, $method,$authenticated = true)
+    function make($routeName, $controller, $method, $authenticated = true)
     {
         $this->routes[$routeName] = (object) [
             'controller'=>$controller,

src/Traits/Validation.php

Spacing +2 added lines, -2 removed lines

@@ -19,9 +19,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));
             }
         }
     }

src/Traits/RoomUtility.php

Spacing +8 added lines, -8 removed lines

@@ -31,7 +31,7 @@ 
         $client = $this->clients[$this->userAuthSocketMapper[\Auth::id()]];
         $room->removeMember($client);
 
-        if(count($room->members) == 0)
+        if (count($room->members) == 0)
         {
             unset($this->receiver->rooms[$room_id]);
         }
@@ -55,16 +55,16 @@ 
      * @param bool $createIfNotExist
      * @return Room
      */
-    function validateRoom($room_id,$createIfNotExist = false)
+    function validateRoom($room_id, $createIfNotExist = false)
     {
-        if(!array_key_exists($room_id,$this->receiver->rooms))
+        if (!array_key_exists($room_id, $this->receiver->rooms))
         {
-            if($createIfNotExist)
+            if ($createIfNotExist)
             {
                 $room = $this->receiver->rooms[$room_id] = new Room($room_id);
                 return $room;
             }
-            $this->error($this->request,$this->conn,'Room is not exist');
+            $this->error($this->request, $this->conn, 'Room is not exist');
         }
     }
 
@@ -78,12 +78,12 @@ 
         /** @var Room $room */
         $room = $this->rooms[$room_id];
         $client = $this->clients[$this->userAuthSocketMapper[\Auth::id()]];
-        if(!$this->hasMember($client))
-            $this->error($this->request,$this->conn,'You can\'t send a message to room which you are not in !');
+        if (!$this->hasMember($client))
+            $this->error($this->request, $this->conn, 'You can\'t send a message to room which you are not in !');
 
         foreach ($room->members as $member)
         {
-            $this->sendToUser($member->id,$message);
+            $this->sendToUser($member->id, $message);
         }
     }
 }
\ No newline at end of file

src/Controllers/RoomController.php

Spacing +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
      */
     function enterRoom($room_id)
     {
-        $this->validateRoom($room_id,true);
+        $this->validateRoom($room_id, true);
 
         $this->addMember($room_id);
     }

src/Controllers/WebSocketController.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
  */
 class WebSocketController
 {
-    use WebSocketMessagesManager,Validation;
+    use WebSocketMessagesManager, Validation;
 
     /**
      * @var Client[]

src/Controllers/ChatController.php

Spacing +4 added lines, -4 removed lines

@@ -20,14 +20,14 @@ 
      */
     function sendMessageToUser()
     {
-        $this->validate($this->request,[
+        $this->validate($this->request, [
             'user_id'=>'required',
             'message' => 'required'
         ]);
         $user_id = $this->request->user_id;
         $message = $this->request->message;
 
-        $this->sendToUser($user_id,$message);
+        $this->sendToUser($user_id, $message);
     }
 
     /**
@@ -35,13 +35,13 @@ 
      */
     function sendMessageToRoom()
     {
-        $this->validate($this->request,[
+        $this->validate($this->request, [
             'room_id'=>'required',
             'message' => 'required'
         ]);
         $room_id = $this->request->room_id;
         $message = $this->request->message;
 
-        $this->sendToRoom($room_id,$message);
+        $this->sendToRoom($room_id, $message);
     }
 }
\ No newline at end of file

src/Receiver.php

Spacing +18 added lines, -18 removed lines

@@ -72,15 +72,15 @@ 
         {
             $msg = json_decode($msg);
 
-            $this->checkForRequiredInMessage($msg,$from);
+            $this->checkForRequiredInMessage($msg, $from);
 
             \Session::setId($msg->session);
 
             \Session::start();
 
             $route = $this->routes[$msg->route];
-            if($route->auth && !\Auth::check())
-                $this->error($msg,$from,'Unauthenticated.');
+            if ($route->auth && !\Auth::check())
+                $this->error($msg, $from, 'Unauthenticated.');
             else
                 $this->userAuthSocketMapper[\Auth::id()] = $from->resourceId;
 
@@ -88,16 +88,16 @@ 
             $method = $route->method;
             $controller = new $class;
 
-            $this->cloneProperties($this,$controller);
+            $this->cloneProperties($this, $controller);
 
             $controller->conn = $from;
             $controller->receiver = $this;
             $controller->request = $msg;
             $controller->route = $route;
 
-            if(!method_exists($controller,$method))
+            if (!method_exists($controller, $method))
             {
-                $this->error($msg,$from,'Method doesnt\'t exist !');
+                $this->error($msg, $from, 'Method doesnt\'t exist !');
             }
 
             $controller->$method();
@@ -106,9 +106,9 @@ 
         {
 
         }
-        catch(ValidationException $exception)
+        catch (ValidationException $exception)
         {
-            $this->sendToWebSocketUser($from,[
+            $this->sendToWebSocketUser($from, [
                 'message'=>$exception->getMessage(),
                 'errors'=> $exception->errors()
             ]);
@@ -143,15 +143,15 @@ 
      * @param $from
      * @throws WebSocketException
      */
-    function checkForRequiredInMessage($msg,$from)
+    function checkForRequiredInMessage($msg, $from)
     {
-        if(!isset($msg->route) || !isset($msg->session))
+        if (!isset($msg->route) || !isset($msg->session))
         {
-            $this->error($msg,$from,'You can\'t send a request without the route and the session id !');
+            $this->error($msg, $from, 'You can\'t send a request without the route and the session id !');
         }
 
-        if(!isset($this->routes[$msg->route]))
-            $this->error($msg,$from,'No such route !');
+        if (!isset($this->routes[$msg->route]))
+            $this->error($msg, $from, 'No such route !');
     }
 
     /**
@@ -167,10 +167,10 @@ 
 
     function mainRoutes()
     {
-        WsRoute::make('initializeWebsocket','Shamaseen\Laravel\Ratchet\Controllers\InitializeController','index');
-        WsRoute::make('room-enter','Shamaseen\Laravel\Ratchet\Controllers\RoomController','enterRoom');
-        WsRoute::make('room-exit','Shamaseen\Laravel\Ratchet\Controllers\RoomController','exitRoom');
-        WsRoute::make('send-to-user','Shamaseen\Laravel\Ratchet\Controllers\ChatController','sendMessageToUser');
-        WsRoute::make('send-to-room','Shamaseen\Laravel\Ratchet\Controllers\ChatController','sendMessageToRoom');
+        WsRoute::make('initializeWebsocket', 'Shamaseen\Laravel\Ratchet\Controllers\InitializeController', 'index');
+        WsRoute::make('room-enter', 'Shamaseen\Laravel\Ratchet\Controllers\RoomController', 'enterRoom');
+        WsRoute::make('room-exit', 'Shamaseen\Laravel\Ratchet\Controllers\RoomController', 'exitRoom');
+        WsRoute::make('send-to-user', 'Shamaseen\Laravel\Ratchet\Controllers\ChatController', 'sendMessageToUser');
+        WsRoute::make('send-to-room', 'Shamaseen\Laravel\Ratchet\Controllers\ChatController', 'sendMessageToRoom');
     }
 }
\ No newline at end of file