mshamaseen / laravel-ratchet

src/Receiver.php

Doc Comments +2 added lines, -2 removed lines

@@ -126,7 +126,7 @@ 
 
     /**
      * @param $msg
-     * @param $from
+     * @param ConnectionInterface $from
      * @throws WebSocketException
      */
     function checkForRequiredInMessage($msg,$from)
@@ -141,7 +141,7 @@ 
     }
 
     /**
-     * @param $clonedObject
+     * @param Receiver $clonedObject
      * @param $clone
      */
     function cloneProperties($clonedObject, $clone)

Unused Use Statements -1 removed lines

@@ -13,7 +13,6 @@
 use Shamaseen\Laravel\Ratchet\Exceptions\WebSocketException;
 use Shamaseen\Laravel\Ratchet\Facades\WsRoute;
 use Shamaseen\Laravel\Ratchet\Objects\Clients\Client;
-use Shamaseen\Laravel\Ratchet\Routes\Routes;
 use Ratchet\ConnectionInterface;
 use Ratchet\MessageComponentInterface;
 use Shamaseen\Laravel\Ratchet\Traits\WebSocketMessagesManager;

Spacing +11 added lines, -11 removed lines

@@ -70,14 +70,14 @@ 
         {
             $msg = json_decode($msg);
 
-            $this->checkForRequiredInMessage($msg,$from);
+            $this->checkForRequiredInMessage($msg, $from);
 
             \Session::setId($msg->session);
 
             \Session::start();
 
-            if($this->routes[$msg->route]->auth && !\Auth::check())
-                $this->error($msg,$from,'Unauthenticated.');
+            if ($this->routes[$msg->route]->auth && !\Auth::check())
+                $this->error($msg, $from, 'Unauthenticated.');
             else
                 $this->userAuthSocketMapper[\Auth::id()] = $from->resourceId;
 
@@ -85,13 +85,13 @@ 
             $method = $this->routes[$msg->route]->method;
             $controller = new $class;
 
-            $this->cloneProperties($this,$controller);
+            $this->cloneProperties($this, $controller);
 
             $controller->conn = $from;
 
-            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($msg);
@@ -129,15 +129,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 !');
     }
 
     /**

Braces +9 added lines, -8 removed lines

@@ -76,10 +76,11 @@ 
 
             \Session::start();
 
-            if($this->routes[$msg->route]->auth && !\Auth::check())
-                $this->error($msg,$from,'Unauthenticated.');
-            else
-                $this->userAuthSocketMapper[\Auth::id()] = $from->resourceId;
+            if($this->routes[$msg->route]->auth && !\Auth::check()) {
+                            $this->error($msg,$from,'Unauthenticated.');
+            } else {
+                            $this->userAuthSocketMapper[\Auth::id()] = $from->resourceId;
+            }
 
             $class = $this->routes[$msg->route]->controller;
             $method = $this->routes[$msg->route]->method;
@@ -95,8 +96,7 @@ 
             }
 
             $controller->$method($msg);
-        }
-        catch (WebSocketException $exception)
+        } catch (WebSocketException $exception)
         {
 
         }
@@ -136,8 +136,9 @@ 
             $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 !');
+        }
     }
 
     /**

src/Routes/Routes.php

Doc Comments +3 added lines, -3 removed lines

@@ -24,9 +24,9 @@
     }
 
     /**
-     * @param $routeName
-     * @param $controller
-     * @param $method
+     * @param string $routeName
+     * @param string $controller
+     * @param string $method
      * @param bool $authenticated
      */
     function make($routeName, $controller, $method,$authenticated = true)

Spacing +2 added lines, -2 removed lines

@@ -20,7 +20,7 @@ 
 
     function mainRoutes()
     {
-        $this->make('initializeWebsocket','Shamaseen\Laravel\Ratchet\Controllers\InitializeController','index');
+        $this->make('initializeWebsocket', 'Shamaseen\Laravel\Ratchet\Controllers\InitializeController', 'index');
     }
 
     /**
@@ -29,7 +29,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/WebSocketMessagesManager.php

Doc Comments +1 added lines, -1 removed lines

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

Indentation +1 added lines, -1 removed lines

@@ -63,7 +63,7 @@
      */
     function sendBack($data)
     {
-       $this->sendToWebSocketUser($this->conn,$data);
+        $this->sendToWebSocketUser($this->conn,$data);
     }
 
 }
\ No newline at end of file

Spacing +6 added lines, -6 removed lines

@@ -24,7 +24,7 @@ 
      * @param $error
      * @throws WebSocketException
      */
-    function error($msg,ConnectionInterface $from, $error)
+    function error($msg, ConnectionInterface $from, $error)
     {
         echo 'Error: ';
         echo $error."\n";
@@ -33,7 +33,7 @@ 
             'type'=>'error',
             'message'=>$error
         ];
-        $this->sendToWebSocketUser($from,$data);
+        $this->sendToWebSocketUser($from, $data);
         throw new WebSocketException();
     }
 
@@ -41,7 +41,7 @@ 
      * @param ConnectionInterface $conn
      * @param $data
      */
-    function sendToWebSocketUser(ConnectionInterface $conn,$data)
+    function sendToWebSocketUser(ConnectionInterface $conn, $data)
     {
         $conn->send(json_encode($data));
     }
@@ -50,12 +50,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);
     }
 
     /**
@@ -63,7 +63,7 @@ 
      */
     function sendBack($data)
     {
-       $this->sendToWebSocketUser($this->conn,$data);
+       $this->sendToWebSocketUser($this->conn, $data);
     }
 
 }
\ No newline at end of file

src/Commands/WebSocketService.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,7 @@
                     new Receiver()
                 )
             ),
-            env('CHAT_PORT',8080)
+            env('CHAT_PORT', 8080)
         );
 
         $server->run();

src/Facades/WsRoute.php

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,7 @@
 
 class WsRoute extends \Illuminate\Support\Facades\Facade
 {
-    static function getFacadeAccessor(){
+    static function getFacadeAccessor() {
 
         return 'WsRoute';
     }

src/LaravelRatchetServiceProvider.php

Spacing +2 added lines, -2 removed lines

@@ -28,7 +28,7 @@ 
         $this->publishes([
             __DIR__.'/config' => realpath('config'),
             __DIR__.'/Routes/websocket' => realpath('routes'),
-        ],'laravel-ratchet');
+        ], 'laravel-ratchet');
 
         if ($this->app['config']->get('laravel-ratchet') === null) {
             $this->app['config']->set('laravel-ratchet', require __DIR__.'/config/laravel-ratchet.php');
@@ -42,7 +42,7 @@ 
      */
     public function register()
     {
-        $this->app->bind('WsRoute',function (){
+        $this->app->bind('WsRoute', function() {
             return new Routes();
         });
     }