mshamaseen / laravel-ratchet

src/Traits/WebSocketMessagesManager.php

Doc Comments +4 added lines, -1 removed lines

@@ -21,7 +21,7 @@ 
     /**
      * @param $request
      * @param ConnectionInterface $from
-     * @param $error
+     * @param string $error
      * @throws WebSocketException
      */
     function error($request,ConnectionInterface $from, $error)
@@ -101,6 +101,9 @@ 
         ];
     }
 
+    /**
+     * @param integer $user_id
+     */
     function isOnline($user_id)
     {
         if(array_key_exists($user_id,$this->userAuthSocketMapper))

Spacing +13 added lines, -13 removed lines

@@ -24,9 +24,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";
@@ -38,7 +38,7 @@ 
             'event'=>'error',
             'message'=>$error
         ];
-        $this->sendToWebSocketUser($from,$data);
+        $this->sendToWebSocketUser($from, $data);
         throw new WebSocketException();
     }
 
@@ -46,17 +46,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) && !array_key_exists('sender',$data))
+        if (isset($this->route) && !array_key_exists('sender', $data))
             $data['sender'] = $this->getSenderData();
 
         $conn->send(json_encode($data));
@@ -67,9 +67,9 @@ 
      * @param array $data
      * @return bool
      */
-    function sendToUser($user_id,$data)
+    function sendToUser($user_id, $data)
     {
-        if(!$this->isOnline($user_id))
+        if (!$this->isOnline($user_id))
         {
             return false;
         }
@@ -77,7 +77,7 @@ 
         $resourceId = $this->userAuthSocketMapper[$user_id];
         /** @var ConnectionInterface $conn */
         $conn = $this->clients[$resourceId]->conn;
-        $this->sendToWebSocketUser($conn,$data);
+        $this->sendToWebSocketUser($conn, $data);
         return true;
     }
 
@@ -86,7 +86,7 @@ 
      */
     function sendBack($data)
     {
-       $this->sendToWebSocketUser($this->conn,$data);
+       $this->sendToWebSocketUser($this->conn, $data);
     }
 
     /**
@@ -103,7 +103,7 @@ 
 
     function isOnline($user_id)
     {
-        if(array_key_exists($user_id,$this->userAuthSocketMapper))
+        if (array_key_exists($user_id, $this->userAuthSocketMapper))
         {
             return true;
         }