mshamaseen / laravel-ratchet

src/Controllers/ChatController.php

Spacing +6 added lines, -6 removed lines

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

src/Controllers/InitializeController.php

Spacing +1 added lines, -1 removed lines

@@ -18,6 +18,6 @@
     function index()
     {
         echo 'Initializing ..';
-        $this->sendBack(['message'=>'WebSocket Initialized','event'=>'initialize']);
+        $this->sendBack(['message'=>'WebSocket Initialized', 'event'=>'initialize']);
     }
 }
\ No newline at end of file

src/Traits/WebSocketMessagesManager.php

Spacing +11 added lines, -11 removed lines

@@ -25,9 +25,9 @@ 
      * @param $error
      * @throws WebSocketException
      */
-    function error($request,ConnectionInterface $from, $error)
+    function error($request, ConnectionInterface $from, $error)
     {
-        if(env('APP_DEBUG'))
+        if (env('APP_DEBUG'))
         {
             echo 'User error: ';
             echo $error."\n";
@@ -39,7 +39,7 @@ 
             'event'=>'error',
             'message'=>$error
         ];
-        $this->sendToWebSocketUser($from,$data);
+        $this->sendToWebSocketUser($from, $data);
         throw new WebSocketException();
     }
 
@@ -47,17 +47,17 @@ 
      * @param ConnectionInterface $conn
      * @param $data
      */
-    function sendToWebSocketUser(ConnectionInterface $conn,$data)
+    function sendToWebSocketUser(ConnectionInterface $conn, $data)
     {
-        if(!is_array($data))
-            $data = ['msg'=>$data,'event'=>'default'];
+        if (!is_array($data))
+            $data = ['msg'=>$data, 'event'=>'default'];
 
-        if(!isset($data['event']))
+        if (!isset($data['event']))
         {
             $data['event'] = 'default';
         }
 
-        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));
@@ -67,12 +67,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);
     }
 
     /**
@@ -80,7 +80,7 @@ 
      */
     function sendBack($data)
     {
-       $this->sendToWebSocketUser($this->conn,$data);
+       $this->sendToWebSocketUser($this->conn, $data);
     }
 
     /**

Braces +6 added lines, -4 removed lines

@@ -49,16 +49,18 @@
      */
     function sendToWebSocketUser(ConnectionInterface $conn,$data)
     {
-        if(!is_array($data))
-            $data = ['msg'=>$data,'event'=>'default'];
+        if(!is_array($data)) {
+                    $data = ['msg'=>$data,'event'=>'default'];
+        }
 
         if(!isset($data['event']))
         {
             $data['event'] = 'default';
         }
 
-        if(isset($this->route) && $this->route->auth && !array_key_exists('sender',$data))
-            $data['sender'] = $this->getSenderData();
+        if(isset($this->route) && $this->route->auth && !array_key_exists('sender',$data)) {
+                    $data['sender'] = $this->getSenderData();
+        }
 
         $conn->send(json_encode($data));
     }