From 6ac27387151cd74c6bf3516237051a9ca1539eaf Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Tue, 25 Oct 2022 11:49:38 +0800
Subject: [PATCH 01/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index 6480134..422bb60 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -2,9 +2,11 @@
 
 namespace {{ namespace }};
 
+use GatewayWorker\BusinessWorker;
+
 class {{ class }}
 {
-    public static function onWorkerStart($worker)
+    public static function onWorkerStart(BusinessWorker $worker)
     {
         create_laravel_application_for_worker($worker);
     }
@@ -12,11 +14,11 @@ class {{ class }}
     public static function onMessage()
     {
         var_dump(config('app.debug'));
-        var_dump(func_get_args());
+        var_dump($args = func_get_args());
     }
 
-    public static function onWorkerStop($connection)
+    public static function onWorkerStop(BusinessWorker $worker)
     {
-        $connection->close();
+        var_dump(sprintf('%s #%s stop', $worker->name, $worker->id));
     }
 }

From 8d8727c2616dbeb00aa2ac08433d7e9e5ee2bdfb Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Tue, 25 Oct 2022 11:51:20 +0800
Subject: [PATCH 02/22] Update Sockets.stub

---
 src/Commands/stubs/Sockets.stub | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/src/Commands/stubs/Sockets.stub b/src/Commands/stubs/Sockets.stub
index 8887c20..e0fe2b8 100644
--- a/src/Commands/stubs/Sockets.stub
+++ b/src/Commands/stubs/Sockets.stub
@@ -2,13 +2,15 @@
 
 namespace {{ namespace }};
 
+use GatewayWorker\Gateway;
+
 class {{ class }}
 {
-    public static function onWorkerStart($connection)
+    public static function onWorkerStart(Gateway $worker)
     {
     }
 
-    public static function onWorkerStop($connection)
+    public static function onWorkerStop(Gateway $worker)
     {
     }
     
@@ -20,4 +22,4 @@ class {{ class }}
     {
         $connection->close();
     }
-}
\ No newline at end of file
+}

From 32f723120b28857a8a2a4f409aa7f6a420f9ef2c Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Tue, 25 Oct 2022 11:53:39 +0800
Subject: [PATCH 03/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index 422bb60..fe0325e 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -13,7 +13,7 @@ class {{ class }}
 
     public static function onMessage()
     {
-        var_dump(config('app.debug'));
+        var_dump('debug mode enable? ' . config('app.debug'));
         var_dump($args = func_get_args());
     }
 

From c63afe66e1c8acbef50a80b60312f24f9bb295ea Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Tue, 25 Oct 2022 12:06:22 +0800
Subject: [PATCH 04/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 17 ++++++++++++++++-
 1 file changed, 16 insertions(+), 1 deletion(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index fe0325e..54375ea 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -13,8 +13,23 @@ class {{ class }}
 
     public static function onMessage()
     {
+        $args = func_get_args();
+
+        [$clientId, $message] = $args;
+
+        try {
+            $data = json_decode(strval($message), true) ?? [];
+        } catch (\Throwable $e) {
+            $data = [];
+        }
+
+        if (!is_array($data)) {
+            $data = [];
+        }
+
         var_dump('debug mode enable? ' . config('app.debug'));
-        var_dump($args = func_get_args());
+        var_dump(sprintf('client_id %s send to server message: %s', $clientId, $message));
+        var_dump('receive data: '.var_export($data, true));
     }
 
     public static function onWorkerStop(BusinessWorker $worker)

From a94fa4231b4d3da365dfd5ba9a7d05b5ebcf5d66 Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Tue, 25 Oct 2022 12:43:57 +0800
Subject: [PATCH 05/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index 54375ea..2233ae2 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -2,6 +2,7 @@
 
 namespace {{ namespace }};
 
+use GatewayWorker\Lib\Gateway;
 use GatewayWorker\BusinessWorker;
 
 class {{ class }}
@@ -30,6 +31,9 @@ class {{ class }}
         var_dump('debug mode enable? ' . config('app.debug'));
         var_dump(sprintf('client_id %s send to server message: %s', $clientId, $message));
         var_dump('receive data: '.var_export($data, true));
+
+        Gateway::bindUid($client_id, $uid = uniqid());
+        Gateway::sendToUid($uid, 'you said: '.$message);
     }
 
     public static function onWorkerStop(BusinessWorker $worker)

From bdc2f1e3f079ec25583a39a1b67f45e72d01bc86 Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Tue, 25 Oct 2022 13:06:23 +0800
Subject: [PATCH 06/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index 2233ae2..118da4b 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -16,7 +16,7 @@ class {{ class }}
     {
         $args = func_get_args();
 
-        [$clientId, $message] = $args;
+        [$client_id, $message] = $args;
 
         try {
             $data = json_decode(strval($message), true) ?? [];
@@ -29,7 +29,7 @@ class {{ class }}
         }
 
         var_dump('debug mode enable? ' . config('app.debug'));
-        var_dump(sprintf('client_id %s send to server message: %s', $clientId, $message));
+        var_dump(sprintf('client_id %s send to server message: %s', $client_id, $message));
         var_dump('receive data: '.var_export($data, true));
 
         Gateway::bindUid($client_id, $uid = uniqid());

From b0beab2aaba74498eb8e4b9c79c2fbe06a65342b Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Tue, 25 Oct 2022 13:47:20 +0800
Subject: [PATCH 07/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index 118da4b..6eaada6 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -5,6 +5,11 @@ namespace {{ namespace }};
 use GatewayWorker\Lib\Gateway;
 use GatewayWorker\BusinessWorker;
 
+/**
+ * @https://github.com/mouyong/laravel-octane-workerman/#websockets
+ *
+ * @link ws://localhost/ws
+ */
 class {{ class }}
 {
     public static function onWorkerStart(BusinessWorker $worker)

From 762da10b3c85caf7b2249785b2222c25e0ea9ad7 Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Tue, 25 Oct 2022 13:48:04 +0800
Subject: [PATCH 08/22] Update workerman.php

---
 config/workerman.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/config/workerman.php b/config/workerman.php
index b6b20ff..8add4a1 100644
--- a/config/workerman.php
+++ b/config/workerman.php
@@ -70,7 +70,7 @@
         'host' => '0.0.0.0',
         'port' => 7400,
         'name' => env('APP_NAME', 'laravel-workerman') . ' BusinessWorker',
-        'count' => cpu_count() * 2,
+        'count' => 1 || cpu_count() * 2, // 每个进程相当于一个游戏大区的概念
         'registerAddress' => '127.0.0.1:7100',
         'onWorkerStart' => null,
         'onWorkerStop' => null,

From 96a3e24879ecbe0f6d23a02472bc180f3e420227 Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Tue, 25 Oct 2022 13:48:39 +0800
Subject: [PATCH 09/22] Update workerman.php

---
 config/workerman.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/config/workerman.php b/config/workerman.php
index 8add4a1..64d0a6c 100644
--- a/config/workerman.php
+++ b/config/workerman.php
@@ -70,7 +70,7 @@
         'host' => '0.0.0.0',
         'port' => 7400,
         'name' => env('APP_NAME', 'laravel-workerman') . ' BusinessWorker',
-        'count' => 1 || cpu_count() * 2, // 每个进程相当于一个游戏大区的概念
+        'count' => 1 || cpu_count() * 2, // 每个进程相当于一个游戏大区的概念，默认 1 个进程
         'registerAddress' => '127.0.0.1:7100',
         'onWorkerStart' => null,
         'onWorkerStop' => null,

From be0dd38197c7e0a76034c3fc335fe8bc1b7cef2f Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Wed, 26 Oct 2022 08:13:49 +0800
Subject: [PATCH 10/22] Update README.md

---
 README.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/README.md b/README.md
index 1fd457f..ff408cf 100644
--- a/README.md
+++ b/README.md
@@ -110,7 +110,7 @@ location /ws {
     proxy_set_header Connection 'Upgrade';
 }
 ```
-test connection to websocket
+test connection to websocket using blow code or in these website: 1. https://websocketking.com/ 2. http://www.websocket-test.com/
 
 ```
 var ws = new WebSocket('ws://127.0.0.1:7000/ws')

From 9eddd514618d1dbbbf0da08b19ad129eaf571b6e Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Wed, 2 Nov 2022 01:03:47 +0800
Subject: [PATCH 11/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index 6eaada6..aa22c08 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -17,6 +17,12 @@ class {{ class }}
         create_laravel_application_for_worker($worker);
     }
 
+    public static function onConnect(string $client_id)
+    {
+        // 建立连接
+        Gateway::sendToAll(sprintf('client_id %s connect', $client_id));
+    }
+
     public static function onMessage()
     {
         $args = func_get_args();
@@ -41,6 +47,12 @@ class {{ class }}
         Gateway::sendToUid($uid, 'you said: '.$message);
     }
 
+    public static function onClose(string $client_id)
+    {
+        // 清理数据
+        Gateway::sendToAll(sprintf('client_id %s exit', $client_id));
+    }
+
     public static function onWorkerStop(BusinessWorker $worker)
     {
         var_dump(sprintf('%s #%s stop', $worker->name, $worker->id));

From 6985e1487702c6018c8e853ced0f216c223671f0 Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Wed, 2 Nov 2022 01:05:28 +0800
Subject: [PATCH 12/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index aa22c08..4bc3a8f 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -20,7 +20,7 @@ class {{ class }}
     public static function onConnect(string $client_id)
     {
         // 建立连接
-        Gateway::sendToAll(sprintf('client_id %s connect', $client_id));
+        var_dump(sprintf('client_id #%s connect', $client_id));
     }
 
     public static function onMessage()
@@ -50,7 +50,7 @@ class {{ class }}
     public static function onClose(string $client_id)
     {
         // 清理数据
-        Gateway::sendToAll(sprintf('client_id %s exit', $client_id));
+        var_dump(sprintf('client_id #%s disconnect', $client_id));
     }
 
     public static function onWorkerStop(BusinessWorker $worker)

From 1421a67298f81608a9af437f3db12ad299afb5dd Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Wed, 2 Nov 2022 01:30:35 +0800
Subject: [PATCH 13/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 89 +++++++++++++++++++++++++++++-----
 1 file changed, 76 insertions(+), 13 deletions(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index 4bc3a8f..6e57486 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -12,6 +12,33 @@ use GatewayWorker\BusinessWorker;
  */
 class {{ class }}
 {
+    public static $whiteEvent = [
+        'pong',
+        'login',
+        'chat.send',
+    ];
+
+    public static function encode(array $message = [])
+    {
+        return json_encode($message, JSON_UNESCAPED_SLASHES|JSON_UNESCAPED_UNICODE|JSON_PRETTY_PRINT);
+    }
+
+    public static function decode(string $message)
+    {
+        $data = json_decode($message, true) ?? [];
+        if (json_last_error()) {
+            info('json 解析错误 code: '.json_last_error() ." reason: ". json_last_error_msg(). ' message: '.$message);
+
+            $data = [];
+        }
+
+        if (!is_array($data)) {
+            $data = [];
+        }
+
+        return $data;
+    }
+
     public static function onWorkerStart(BusinessWorker $worker)
     {
         create_laravel_application_for_worker($worker);
@@ -26,25 +53,61 @@ class {{ class }}
     public static function onMessage()
     {
         $args = func_get_args();
-
         [$client_id, $message] = $args;
+        $data = Events::decode($message);
 
-        try {
-            $data = json_decode(strval($message), true) ?? [];
-        } catch (\Throwable $e) {
-            $data = [];
-        }
-
-        if (!is_array($data)) {
-            $data = [];
-        }
-
+        dump($_SERVER);
+        dump($_SESSION);
         var_dump('debug mode enable? ' . config('app.debug'));
         var_dump(sprintf('client_id %s send to server message: %s', $client_id, $message));
-        var_dump('receive data: '.var_export($data, true));
+        var_dump('receive data: ' . var_export($data, true));
 
         Gateway::bindUid($client_id, $uid = uniqid());
-        Gateway::sendToUid($uid, 'you said: '.$message);
+        Gateway::sendToUid($uid, 'you said: ' . $message);
+        
+        $eventType = $data['type'] ?? null;
+
+        $uid = Gateway::getUidByClientId($client_id);
+
+        // 检验用户是否登录
+        $player = $_SESSION['uid'] ?? null;
+        if (!in_array($eventType, Events::$whiteEvent)) {
+            if (!$player) {
+                return Gateway::sendToClient($client_id, downlink(Events::LOGIN_RESP, null, 403, 'Please login.'));
+            }
+        }
+        
+        switch ($eventType) {
+                // 维持客户端在线状态
+            case 'pong':
+                $_SESSION['tick_time'] = date('Y-m-d H:i:s', time());
+                break;
+            case 'login':
+                $token = data_get($data, 'data.token');
+                if (!$token) {
+                    return Gateway::sendToClient($client_id, downlink(Events::LOGIN_RESP, null, 500, 'Please login'));
+                }
+
+                $_SESSION['uid'] = uniqid();
+                break;
+            case 'chat.send':
+                $to_user = $data['data']['to_user'] ?? null;
+                $content = $data['data']['content'] ?? null;
+
+                if (!$to_user) {
+                    return Gateway::sendToClient($client_id, downlink(Events::CHAT_SEND_RESP, null, 400, 'Please select chat_room'));
+                }
+
+                if (!$content) {
+                    return Gateway::sendToClient($client_id, downlink(Events::CHAT_SEND_RESP, null, 400, 'Please input message'));
+                }
+
+                Gateway::sendToGroup($to_user, $content);
+                break;
+            default:
+                Gateway::sendToClient($client_id, '非法请求');
+                break;
+        }
     }
 
     public static function onClose(string $client_id)

From bded1ae4ab3a61492b19875be856bada6fef7105 Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Wed, 2 Nov 2022 01:31:50 +0800
Subject: [PATCH 14/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index 6e57486..fb82de3 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -91,8 +91,8 @@ class {{ class }}
                 $_SESSION['uid'] = uniqid();
                 break;
             case 'chat.send':
-                $to_user = $data['data']['to_user'] ?? null;
-                $content = $data['data']['content'] ?? null;
+                $to_user = data_get($data, 'data.to_user');
+                $content = data_get($data, 'data.content');
 
                 if (!$to_user) {
                     return Gateway::sendToClient($client_id, downlink(Events::CHAT_SEND_RESP, null, 400, 'Please select chat_room'));

From a1cac7df86a69d6376c8c0a9bc4c51b6ae6bac9f Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Wed, 2 Nov 2022 01:33:23 +0800
Subject: [PATCH 15/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index fb82de3..6c2452d 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -70,9 +70,9 @@ class {{ class }}
         $uid = Gateway::getUidByClientId($client_id);
 
         // 检验用户是否登录
-        $player = $_SESSION['uid'] ?? null;
+        $user = $_SESSION['uid'] ?? null;
         if (!in_array($eventType, Events::$whiteEvent)) {
-            if (!$player) {
+            if (!$user) {
                 return Gateway::sendToClient($client_id, downlink(Events::LOGIN_RESP, null, 403, 'Please login.'));
             }
         }

From 1b3e5173d35ecb72d8d2ae9e0202320a26e870ff Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Wed, 2 Nov 2022 01:41:21 +0800
Subject: [PATCH 16/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 27 +++++++++++++++++----------
 1 file changed, 17 insertions(+), 10 deletions(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index 6c2452d..a1b7071 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -56,16 +56,16 @@ class {{ class }}
         [$client_id, $message] = $args;
         $data = Events::decode($message);
 
-        dump($_SERVER);
-        dump($_SESSION);
-        var_dump('debug mode enable? ' . config('app.debug'));
-        var_dump(sprintf('client_id %s send to server message: %s', $client_id, $message));
-        var_dump('receive data: ' . var_export($data, true));
-
-        Gateway::bindUid($client_id, $uid = uniqid());
-        Gateway::sendToUid($uid, 'you said: ' . $message);
+        // dump($_SERVER);
+        // dump($_SESSION);
+        // var_dump('debug mode enable? ' . config('app.debug'));
+        // var_dump(sprintf('client_id %s send to server message: %s', $client_id, $message));
+        // var_dump('receive data: ' . var_export($data, true));
+
+        // Gateway::bindUid($client_id, $uid = uniqid());
+        // Gateway::sendToUid($uid, 'you said: ' . $message);
         
-        $eventType = $data['type'] ?? null;
+        $eventType = $data['event_type'] ?? $data['type'] ?? null;
 
         $uid = Gateway::getUidByClientId($client_id);
 
@@ -88,7 +88,14 @@ class {{ class }}
                     return Gateway::sendToClient($client_id, downlink(Events::LOGIN_RESP, null, 500, 'Please login'));
                 }
 
-                $_SESSION['uid'] = uniqid();
+                $_SESSION['userInfo'] = [];
+                $_SESSION['userInfo']['uid'] = uniqid();
+                Gateway::updateSession($client_id, [
+                    'userInfo' => [
+                        'userName' => uniqid(),
+                    ],
+                ]);
+                Gateway::bindUid($client_id, $_SESSION['userInfo']['uid']);
                 break;
             case 'chat.send':
                 $to_user = data_get($data, 'data.to_user');

From 817240fe60fdb8cee647d9ce336c8eb820958077 Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Wed, 2 Nov 2022 09:05:02 +0800
Subject: [PATCH 17/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index a1b7071..e572649 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -41,6 +41,8 @@ class {{ class }}
 
     public static function onWorkerStart(BusinessWorker $worker)
     {
+        var_dump(sprintf('%s #%s start', $worker->name, $worker->id));
+
         create_laravel_application_for_worker($worker);
     }
 

From 715bfe3438e765ea1a5d18c88b215d0c3ef47d60 Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Wed, 2 Nov 2022 09:06:40 +0800
Subject: [PATCH 18/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index e572649..417c1b2 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -41,7 +41,7 @@ class {{ class }}
 
     public static function onWorkerStart(BusinessWorker $worker)
     {
-        var_dump(sprintf('%s #%s start', $worker->name, $worker->id));
+        dump(sprintf('%s #%s start', $worker->name, $worker->id));
 
         create_laravel_application_for_worker($worker);
     }
@@ -49,7 +49,7 @@ class {{ class }}
     public static function onConnect(string $client_id)
     {
         // 建立连接
-        var_dump(sprintf('client_id #%s connect', $client_id));
+        dump(sprintf('client_id #%s connect', $client_id));
     }
 
     public static function onMessage()
@@ -60,9 +60,9 @@ class {{ class }}
 
         // dump($_SERVER);
         // dump($_SESSION);
-        // var_dump('debug mode enable? ' . config('app.debug'));
-        // var_dump(sprintf('client_id %s send to server message: %s', $client_id, $message));
-        // var_dump('receive data: ' . var_export($data, true));
+        // dump('debug mode enable? ' . config('app.debug'));
+        // dump(sprintf('client_id %s send to server message: %s', $client_id, $message));
+        // dump('receive data: ' . var_export($data, true));
 
         // Gateway::bindUid($client_id, $uid = uniqid());
         // Gateway::sendToUid($uid, 'you said: ' . $message);
@@ -122,11 +122,11 @@ class {{ class }}
     public static function onClose(string $client_id)
     {
         // 清理数据
-        var_dump(sprintf('client_id #%s disconnect', $client_id));
+        dump(sprintf('client_id #%s disconnect', $client_id));
     }
 
     public static function onWorkerStop(BusinessWorker $worker)
     {
-        var_dump(sprintf('%s #%s stop', $worker->name, $worker->id));
+        dump(sprintf('%s #%s stop', $worker->name, $worker->id));
     }
 }

From 8f07e1976ced9530108d5815365201074e23bf32 Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Wed, 2 Nov 2022 09:07:04 +0800
Subject: [PATCH 19/22] Update CustomProcess.stub

---
 src/Commands/stubs/CustomProcess.stub | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/Commands/stubs/CustomProcess.stub b/src/Commands/stubs/CustomProcess.stub
index 996198b..74d4ea1 100644
--- a/src/Commands/stubs/CustomProcess.stub
+++ b/src/Commands/stubs/CustomProcess.stub
@@ -14,24 +14,24 @@ class {{ class }}
     {
         $this->worker = $worker;
 
-        var_dump("worker {$worker->id} start");
+        dump("worker {$worker->id} start");
     }
 
     public function onWorkerStop(Worker $worker)
     {
-        var_dump("worker {$worker->id} stop");
+        dump("worker {$worker->id} stop");
     }
 
     public function onConnect(TcpConnection $connection)
     {
         $this->connection = $connection;
 
-        var_dump("client connect to worker_id {$this->worker->id} successful, current connection_id is {$connection->id}");
+        dump("client connect to worker_id {$this->worker->id} successful, current connection_id is {$connection->id}");
     }
 
     public function onMessage(TcpConnection $connection, $data)
     {
-        var_dump($message = "the worker_id {$this->worker->id} of connection_id {$connection->id} receive message from client: " . $data);
+        dump($message = "the worker_id {$this->worker->id} of connection_id {$connection->id} receive message from client: " . $data);
 
         $connection->send($message);
     }
@@ -40,6 +40,6 @@ class {{ class }}
     {
         $connection->close();
 
-        var_dump("the worker_id {$this->worker->id} of connection_id {$connection->id} closed");
+        dump("the worker_id {$this->worker->id} of connection_id {$connection->id} closed");
     }
 }

From ca0a1f266ecfc3792afbdc748a79207e1ecd1e3e Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Thu, 3 Nov 2022 11:11:47 +0800
Subject: [PATCH 20/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index 417c1b2..e41150b 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -39,6 +39,21 @@ class {{ class }}
         return $data;
     }
 
+    public static function sendToClient(string $client_id, string $message)
+    {
+        return Gateway::sendToClient($client_id, $message);
+    }
+
+    public static function sendToGroup(string $group_name, string $message)
+    {
+        return Gateway::sendToGroup($group_name, $message);
+    }
+
+    public static function sendToAll(string $message)
+    {
+        return Gateway::sendToAll($message);
+    }
+
     public static function onWorkerStart(BusinessWorker $worker)
     {
         dump(sprintf('%s #%s start', $worker->name, $worker->id));

From 834465067a1957de3c4f8959fa91716b9a8a186c Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Fri, 4 Nov 2022 00:18:20 +0800
Subject: [PATCH 21/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index e41150b..0b7975a 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -44,9 +44,9 @@ class {{ class }}
         return Gateway::sendToClient($client_id, $message);
     }
 
-    public static function sendToGroup(string $group_name, string $message)
+    public static function sendToGroup(string $group, string $message)
     {
-        return Gateway::sendToGroup($group_name, $message);
+        return Gateway::sendToGroup($group, $message);
     }
 
     public static function sendToAll(string $message)

From 331057f9d736f1d1bdce37f1d10b29cc9bc38b71 Mon Sep 17 00:00:00 2001
From: mouyong <mouyong@users.noreply.github.com>
Date: Mon, 7 Nov 2022 21:17:31 +0800
Subject: [PATCH 22/22] Update Events.stub

---
 src/Commands/stubs/Events.stub | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Commands/stubs/Events.stub b/src/Commands/stubs/Events.stub
index 0b7975a..c73ac20 100644
--- a/src/Commands/stubs/Events.stub
+++ b/src/Commands/stubs/Events.stub
@@ -56,9 +56,9 @@ class {{ class }}
 
     public static function onWorkerStart(BusinessWorker $worker)
     {
-        dump(sprintf('%s #%s start', $worker->name, $worker->id));
-
         create_laravel_application_for_worker($worker);
+
+        dump(sprintf('%s #%s start', $worker->name, $worker->id));
     }
 
     public static function onConnect(string $client_id)