add isUserIdOnline and logout apis for websocket

Author: albertcht

src/Websocket/Authenticatable.php

@@ -25,6 +25,18 @@ public function loginUsingId($userId)
         return $this->join(static::USER_PREFIX . $userId);
     }
 
+    /**
+     * Logout with current sender's fd.
+     */
+    public function logout()
+    {
+        if (is_null($userId = $this->getUserId())) {
+            return;
+        }
+
+        return $this->leave(static::USER_PREFIX . $userId);
+    }
+
     /**
      * Set multiple recepients' fds by users.
      */
@@ -75,6 +87,14 @@ public function getUserId()
         return $this->userId;
     }
 
+    /**
+     * Check if a user is online by given userId.
+     */
+    public function isUserIdOnline($userId)
+    {
+        return ! empty($this->room->getClients(static::USER_PREFIX . $userId));
+    }
+
     /**
      * Check if user object implements AuthenticatableContract.
      */

src/Websocket/Websocket.php

@@ -296,7 +296,7 @@ protected function getFds()
 
         foreach ($rooms as $room) {
             $clients = $this->room->getClients($room);
-            // rollback fd with wrong type back to fds array
+            // fallback fd with wrong type back to fds array
             if (empty($clients) && is_numeric($room)) {
                 $fds[] = $room;
             } else {

tests/Websocket/WebsocketTest.php

@@ -205,6 +205,33 @@ public function testGetUserId()
         $this->assertEquals($sender, $websocket->getUserId());
     }
 
+    public function testLogout()
+    {
+        $room = m::mock(RoomContract::class);
+        $room->shouldReceive('getRooms')
+            ->with($sender = 1)
+            ->once()
+            ->andReturn(['uid_1']);
+        $room->shouldReceive('delete')
+            ->with($sender, $name = ['uid_1'])
+            ->once();
+
+        $websocket = $this->getWebsocket($room)->setSender($sender);
+        $websocket->logout();
+    }
+
+    public function testIsUserIdOnline()
+    {
+        $room = m::mock(RoomContract::class);
+        $room->shouldReceive('getClients')
+            ->with('uid_1')
+            ->once()
+            ->andReturn([1]);
+
+        $websocket = $this->getWebsocket($room);
+        $this->assertTrue($websocket->isUserIdOnline(1));
+    }
+
     public function testReset()
     {
         $websocket = $this->getWebsocket();