Merge pull request #54 from swooletw/develop

Develop

Author: albertcht

config/swoole_http.php

@@ -15,8 +15,8 @@
         'host' => env('SWOOLE_HTTP_HOST', '127.0.0.1'),
         'port' => env('SWOOLE_HTTP_PORT', '1215'),
         'public_path' => base_path('public'),
-        // If use swoole to respond request for static files
-        'handle_static_files' => true,
+        // Determine if to use swoole to respond request for static files
+        'handle_static_files' => env('SWOOLE_HANDLE_STATIC', true),
         'options' => [
             'pid_file' => env('SWOOLE_HTTP_PID_FILE', base_path('storage/logs/swoole_http.pid')),
             'log_file' => env('SWOOLE_HTTP_LOG_FILE', base_path('storage/logs/swoole_http.log')),
@@ -35,7 +35,7 @@
             'max_request' => 3000,
             // Enable coroutine send
             'send_yield' => true,
-            // You must --enable-openssl while compiling Swoole
+            // You must add --enable-openssl while compiling Swoole
             'ssl_cert_file' => null,
             'ssl_key_file' => null,
         ],

routes/websocket.php

@@ -16,8 +16,8 @@
     // called while socket on connect
 });
 
-Websocket::on('close', function ($websocket) {
-    // called while socket on close
+Websocket::on('disconnect', function ($websocket) {
+    // called while socket on disconnect
 });
 
 Websocket::on('example', function ($websocket, $data) {

src/Websocket/Authenticatable.php

@@ -7,6 +7,8 @@
 
 trait Authenticatable
 {
+    protected $userId;
+
     /**
      * Login using current user.
      */
@@ -53,6 +55,26 @@ public function toUserId($userIds)
         return $this;
     }
 
+    /**
+     * Get current auth user id by sender's fd.
+     */
+    public function getUserId()
+    {
+        if (! is_null($this->userId)) {
+            return $this->userId;
+        }
+
+        $rooms = $this->room->getRooms($this->getSender());
+
+        foreach ($rooms as $room) {
+            if (count($explode = explode(static::USER_PREFIX, $room)) === 2) {
+                $this->userId = $explode[1];
+            }
+        }
+
+        return $this->userId;
+    }
+
     /**
      * Check if user object implements AuthenticatableContract.
      */

src/Websocket/CanWebsocket.php

@@ -58,15 +58,24 @@ public function onOpen(Server $server, $swooleRequest)
         $illuminateRequest = Request::make($swooleRequest)->toIlluminate();
 
         try {
+            $this->websocket->reset(true)->setSender($swooleRequest->fd);
+            // set currnt request to sandbox
+            $this->sandbox->setRequest($illuminateRequest);
+            // enable sandbox
+            $application = $this->sandbox->getLaravelApp();
+            $this->sandbox->enable();
             // check if socket.io connection established
             if (! $this->websocketHandler->onOpen($swooleRequest->fd, $illuminateRequest)) {
                 return;
             }
-            $this->websocket->reset(true)->setSender($swooleRequest->fd);
             // trigger 'connect' websocket event
             if ($this->websocket->eventExists('connect')) {
-                $this->callOnConnect($illuminateRequest);
+                // set sandbox container to websocket pipeline
+                $this->websocket->setContainer($application);
+                $this->websocket->call('connect', $illuminateRequest);
             }
+            // disable and recycle sandbox resource
+            $this->sandbox->disable();
         } catch (Exception $e) {
             $this->logServerError($e);
         }
@@ -93,12 +102,18 @@ public function onMessage(Server $server, Frame $frame)
 
             $this->websocket->reset(true)->setSender($frame->fd);
 
+            // enable sandbox
+            $application = $this->sandbox->getLaravelApp();
+            $this->sandbox->enable();
+
             // dispatch message to registered event callback
             if ($this->websocket->eventExists($payload['event'])) {
                 $this->websocket->call($payload['event'], $payload['data']);
             } else {
                 $this->websocketHandler->onMessage($frame);
             }
+            // disable and recycle sandbox resource
+            $this->sandbox->disable();
         } catch (Exception $e) {
             $this->logServerError($e);
         }
@@ -279,27 +294,4 @@ protected function normalizePushData(array $data)
 
         return [$opcode, $sender, $fds, $broadcast, $assigned, $event, $message];
     }
-
-    /**
-     * Call on connect event callback .
-     */
-    protected function callOnConnect($illuminateRequest)
-    {
-        // set currnt request to sandbox
-        $this->sandbox->setRequest($illuminateRequest);
-
-        // get application from sandbox
-        $application = $this->sandbox->getLaravelApp();
-
-        // reset session
-        if (isset($application['session'])) {
-            $application['session']->flush();
-        }
-
-        // set sandbox container to websocket pipeline
-        $this->websocket->setContainer($application);
-        $this->sandbox->enable();
-        $this->websocket->call('connect', $illuminateRequest);
-        $this->sandbox->disable();
-    }
 }

src/Websocket/Websocket.php

@@ -317,6 +317,7 @@ public function reset($force = false)
 
         if ($force) {
             $this->sender = null;
+            $this->userId = null;
         }
 
         return $this;

tests/Websocket/WebsocketTest.php

@@ -193,6 +193,18 @@ public function testToUser()
         $this->assertTrue(in_array(3, $websocket->getTo()));
     }
 
+    public function testGetUserId()
+    {
+        $room = m::mock(RoomContract::class);
+        $room->shouldReceive('getRooms')
+            ->with($sender = 1)
+            ->once()
+            ->andReturn(['uid_1']);
+
+        $websocket = $this->getWebsocket($room)->setSender($sender);
+        $this->assertEquals($sender, $websocket->getUserId());
+    }
+
     public function testReset()
     {
         $websocket = $this->getWebsocket();