move warning to framework

fix an AnnotationParser bug which is stupid

composer.json

@@ -3,7 +3,7 @@
     "description": "High performance QQ robot and web server development framework",
     "minimum-stability": "stable",
     "license": "Apache-2.0",
-    "version": "2.1.0",
+    "version": "2.1.4",
     "extra": {
         "exclude_annotate": [
             "src/ZM"

docs/advanced/inside-class.md

@@ -4,7 +4,7 @@
 
 ## Swoole\Http\Request
 
-此类是 Swoole 内部的一个类，一般在收到 HTTP 请求时，在 `@RequestMapping` 或 `@OnSwooleEvent("request")` 两个注解下可用，用作获取 GET、POST参数，上传到后端的文件、Cookies 等。详见 [Swoole 文档 - Request](http://wiki.swoole.com/#/http_server?id=httprequest) 。
+此类是 Swoole 内部的一个类，一般在收到 HTTP 请求时，在 `@RequestMapping` 或 `@OnRequestEvent()` 两个注解下可用，用作获取 GET、POST参数，上传到后端的文件、Cookies 等。详见 [Swoole 文档 - Request](http://wiki.swoole.com/#/http_server?id=httprequest) 。
 
 ### 属性
 

docs/component/context.md

@@ -26,19 +26,19 @@ public function hello() {
 
 获取 Swoole WebSocker Server 对象。此对象是 Swoole 的对象，详情见 [Swoole 文档](https://wiki.swoole.com/#/websocket_server)。
 
-可以使用的事件：`@OnSwooleEvent("message")`，`@OnSwooleEvent("open")`，`@OnSwooleEvent("close")`，`@OnStart()` 以及所有 HTTP API 发来的事件：`@CQCommand()`，`@CQMessage()` 等。
+可以使用的事件：`@OnMessageEvent()`，`@OnOpenEvent()`，`@OnCloseEvent()`，`@OnStart()` 以及所有 HTTP API 发来的事件：`@CQCommand()`，`@CQMessage()` 等。
 
 ## getFrame() - 获取 WS 数据帧
 
 获取 `\Swoole\Websocket\Frame` 对象，此对象是 Swoole 的对象，详情见 [Swoole 文档](https://wiki.swoole.com/#/websocket_server?id=swoolewebsocketframe)。
 
-可以使用的事件：`@OnSwooleEvent("message")` 以及所有 HTTP API 发来的事件：`@CQCommand()`，`@CQMessage()` 等，
+可以使用的事件：`@OnMessageEvent()` 以及所有 HTTP API 发来的事件：`@CQCommand()`，`@CQMessage()` 等，
 
 ## getFd() - 返回 fd 值
 
 获取当前连入 Swoole 服务器的连接文件描述符 ID。返回 int。一般代表连接号，可用来绑定对应链接。
 
-可以使用的事件：所有 **getFrame()** 可以使用的，`@OnSwooleEvent("open")`，`@OnSwooleEvent("close")`
+可以使用的事件：所有 **getFrame()** 可以使用的，`@OnOpenEvent()`，`@OnCloseEvent()`
 
 !!! tip "提示"
 
@@ -92,13 +92,13 @@ public function onMessage() {
 
 返回 `\Swoole\Http\Request` 对象，可在 `@RequestMapping` 中使用，获取 Cookie，请求头，GET 参数什么的。[Swoole 文档](https://wiki.swoole.com/#/http_server?id=httprequest)。
 
-可以使用的事件：`@RequestMapping()`，`@OnSwooleEvent("request")`，`@OnSwooleEvent("open")`。
+可以使用的事件：`@RequestMapping()`，`@OnRequestEvent()`，`@OnOpenEvent()`。
 
 ## getResponse() - HTTP 响应对象
 
 返回 `\Swoole\Http\Response` 对象的增强版，可在 HTTP 请求相关的事件中使用，返回内容和设置 Cookie 什么的。[Swoole 文档](https://wiki.swoole.com/#/http_server?id=httpresponse)。
 
-可以使用的事件：`@RequestMapping()`，`@OnSwooleEvent("request")`。
+可以使用的事件：`@RequestMapping()`，`@OnRequestEvent()`。
 
 下面是使用以上两个功能的组合示例：
 
@@ -124,7 +124,7 @@ public function ping() {
 
 ## getRobot() - 获取机器人 API 对象
 
-返回当前上下文关联的机器人 API 调用对象 [ZMRobot](机器人API.md)。
+返回当前上下文关联的机器人 API 调用对象 [ZMRobot](robot-api.md)。
 
 可以使用的事件：所有 HTTP API 发来的事件：`@CQCommand()`，`@CQMessage()` 等。
 

docs/event/framework-annotations.md

@@ -4,7 +4,7 @@
 
 ## OnSwooleEvent()
 
-绑定 Swoole 所相关的事件，例如 WebSocket 接入、收到 WS 消息、关闭 WS 连接，HTTP 请求到达等。
+绑定 Swoole 所相关的事件，例如 WebSocket 接入、收到 WS 消息、关闭 WS 连接，HTTP 请求到达等。这个是旧的统一的 Swoole 事件分发注解。请尽量使用上面几个新的注解。
 
 ### 属性
 

docs/update/v2.md

@@ -1,8 +1,34 @@
 # 更新日志（v2 版本）
 
+## v2.1.3
+
+> 更新时间：2021.1.2
+
+- 修复：注解解析器在某种特殊情况下导致的 bug
+
+## v2.1.2
+
+> 更新时间：2021.1.2
+
+- 修复：引入包模式启动时会导致的满屏报错
+
+## v2.1.1
+
+> 更新时间：2021.1.2
+
+- 修复：自定义加载注解选定 composer.json 文件错误的 bug
+
+## v2.1.0
+
+> 更新时间：2021.1.2
+
+- 新增：`@OnOpenEvent`，`@OnCloseEvent`，`@OnMessageEvent`，`@OnRequestEvent`
+- 优化事件分发器，修复一些事件分发过程中的 bug
+- 修复 `@CQBefore` 事件的 bug
+
 ## v2.0.3
 
-> 更新事件：2020.12.31
+> 更新时间：2020.12.31
 
 - 修复：CQBefore 注解事件在 level 低于 200 时无法调用的 bug
 - 修复：CQMetaEvent 注解事件调用时报错的 bug

mkdocs.yml

@@ -52,26 +52,26 @@ copyright: 'Copyright © 2019 - 2020 CrazyBot Team    &n
 nav:
   - 指南:
       - 介绍: index.md
-      - 安装框架: guide/安装.md
-      - 快速上手（机器人篇）: guide/快速上手-机器人.md
-      - 快速上手（HTTP篇）: guide/快速上手-http.md
-      - 选择聊天机器人实例: guide/OneBot实例.md
-      - 基本配置: guide/基本配置.md
-      - 编写模块: guide/编写模块.md
-      - 注册事件响应: guide/注册事件响应.md
+      - 安装框架: guide/installation.md
+      - 快速上手（机器人篇）: guide/quickstart-robot.md
+      - 快速上手（HTTP篇）: guide/quickstart-http.md
+      - 选择聊天机器人实例: guide/onebot-choose.md
+      - 基本配置: guide/basic-config.md
+      - 编写模块: guide/write-module.md
+      - 注册事件响应: guide/register-event.md
   - 事件和注解:
       - 事件和注解: event/index.md
-      - 机器人注解事件: event/机器人注解事件.md
-      - HTTP 路由注解事件: event/路由注解事件.md
-      - 框架核心注解事件: event/框架注解事件.md
-      - 中间件注解: event/中间件.md
-      - 自定义注解: event/自定义注解.md
-      - 事件分发器: event/事件分发器.md
+      - 机器人注解事件: event/robot-annotations.md
+      - HTTP 路由注解事件: event/route-annotations.md
+      - 框架核心注解事件: event/framework-annotations.md
+      - 中间件注解: event/middleware.md
+      - 自定义注解: event/custom-annotations.md
+      - 事件分发器: event/event-dispatcher.md
   - 框架组件:
       - 框架组件: component/index.md
-      - 机器人 API: component/机器人API.md
-      - CQ 码（多媒体消息）: component/CQ码.md
-      - 上下文: component/上下文.md
+      - 机器人 API: component/robot-api.md
+      - CQ 码（多媒体消息）: component/cqcode.md
+      - 上下文: component/context.md
   - 进阶开发:
       - 进阶开发: advanced/index.md
       - 从 v1 升级: advanced/to-v2.md

src/ZM/Annotation/AnnotationParser.php

@@ -88,7 +88,7 @@ class AnnotationParser
 
                     //预处理1：将适用于每一个函数的注解到类注解重新注解到每个函数下面
                     if ($vs instanceof ErgodicAnnotation) {
-                        foreach ($this->annotation_map[$v]["methods"] as $method) {
+                        foreach (($this->annotation_map[$v]["methods"] ?? []) as $method) {
                             $copy = clone $vs;
                             $copy->method = $method->getName();
                             $this->annotation_map[$v]["methods_annotations"][$method->getName()][] = $copy;
@@ -107,7 +107,7 @@ class AnnotationParser
                 }
 
                 //预处理3：处理每个函数上面的特殊注解，就是需要操作一些东西的
-                foreach ($this->annotation_map[$v]["methods_annotations"] as $method_name => $methods_annotations) {
+                foreach (($this->annotation_map[$v]["methods_annotations"] ?? []) as $method_name => $methods_annotations) {
                     foreach ($methods_annotations as $method_anno) {
                         /** @var AnnotationBase $method_anno */
                         $method_anno->class = $v;
@@ -135,11 +135,11 @@ class AnnotationParser
     public function generateAnnotationEvents() {
         $o = [];
         foreach ($this->annotation_map as $module => $obj) {
-            foreach ($obj["class_annotations"] as $class_annotation) {
+            foreach (($obj["class_annotations"] ?? []) as $class_annotation) {
                 if ($class_annotation instanceof ErgodicAnnotation) continue;
                 else $o[get_class($class_annotation)][] = $class_annotation;
             }
-            foreach ($obj["methods_annotations"] as $method_name => $methods_annotations) {
+            foreach (($obj["methods_annotations"] ?? []) as $method_name => $methods_annotations) {
                 foreach ($methods_annotations as $annotation) {
                     $o[get_class($annotation)][] = $annotation;
                 }

src/ZM/Event/ServerEventHandler.php

@@ -75,40 +75,6 @@ class ServerEventHandler
                 /** @noinspection PhpUndefinedFieldInspection */ Event::del(Framework::$server->inotify);
             ZMUtil::stop();
         });
-        set_error_handler(function ($error_no, $error_msg, $error_file, $error_line) {
-            switch ($error_no) {
-                case E_WARNING:
-                    $level_tips = 'PHP Warning: ';
-                    break;
-                case E_NOTICE:
-                    $level_tips = 'PHP Notice: ';
-                    break;
-                case E_DEPRECATED:
-                    $level_tips = 'PHP Deprecated: ';
-                    break;
-                case E_USER_ERROR:
-                    $level_tips = 'User Error: ';
-                    break;
-                case E_USER_WARNING:
-                    $level_tips = 'User Warning: ';
-                    break;
-                case E_USER_NOTICE:
-                    $level_tips = 'User Notice: ';
-                    break;
-                case E_USER_DEPRECATED:
-                    $level_tips = 'User Deprecated: ';
-                    break;
-                case E_STRICT:
-                    $level_tips = 'PHP Strict: ';
-                    break;
-                default:
-                    $level_tips = 'Unkonw Type Error: ';
-                    break;
-            }      // do some handle
-            $error = $level_tips . $error_msg . ' in ' . $error_file . ' on ' . $error_line;
-            Console::warning($error);      // 如果 return false 则错误会继续递交给 PHP 标准错误处理     /
-            return true;
-        }, E_ALL | E_STRICT);
         if (Framework::$argv["watch"]) {
             if (extension_loaded('inotify')) {
                 Console::warning("Enabled File watcher, do not use in production.");
@@ -233,7 +199,7 @@ class ServerEventHandler
 
                 // 开箱即用的Redis
                 $redis = ZMConfig::get("global", "redis_config");
-                if($redis !== null && $redis["host"] != "") {
+                if ($redis !== null && $redis["host"] != "") {
                     if (!extension_loaded("redis")) Console::error("Can not find redis extension.\n");
                     else ZMRedisPool::init($redis);
                 }
@@ -290,12 +256,12 @@ class ServerEventHandler
      */
     public function onMessage($server, Frame $frame) {
 
-        Console::debug("Calling Swoole \"message\" from fd=" . $frame->fd.": ".TermColor::ITALIC.$frame->data.TermColor::RESET);
+        Console::debug("Calling Swoole \"message\" from fd=" . $frame->fd . ": " . TermColor::ITALIC . $frame->data . TermColor::RESET);
         unset(Context::$context[\Swoole\Coroutine::getCid()]);
         $conn = ManagerGM::get($frame->fd);
         set_coroutine_params(["server" => $server, "frame" => $frame, "connection" => $conn]);
         $dispatcher1 = new EventDispatcher(OnMessageEvent::class);
-        $dispatcher1->setRuleFunction(function($v) {
+        $dispatcher1->setRuleFunction(function ($v) {
             return ctx()->getConnection()->getName() == $v->connect_type && eval("return " . $v->getRule() . ";");
         });
 
@@ -341,8 +307,8 @@ class ServerEventHandler
         set_coroutine_params(["request" => $request, "response" => $response]);
 
         $dis1 = new EventDispatcher(OnRequestEvent::class);
-        $dis1->setRuleFunction(function($v) {
-            return eval("return ".$v->getRule().";") ? true : false;
+        $dis1->setRuleFunction(function ($v) {
+            return eval("return " . $v->getRule() . ";") ? true : false;
         });
 
         $dis = new EventDispatcher(OnSwooleEvent::class);
@@ -359,7 +325,6 @@ class ServerEventHandler
         try {
             $dis1->dispatchEvents($request, $response);
             $dis->dispatchEvents($request, $response);
-            var_dump($dis->status);
             if ($dis->status === EventDispatcher::STATUS_NORMAL && $dis1->status === EventDispatcher::STATUS_NORMAL) {
                 $result = HttpUtil::parseUri($request, $response, $request->server["request_uri"], $node, $params);
                 if ($result === true) {
@@ -391,7 +356,7 @@ class ServerEventHandler
                 else
                     $response->end("Internal server error.");
             }
-            Console::error("Internal server exception (500), caused by " . get_class($e).": ".$e->getMessage());
+            Console::error("Internal server exception (500), caused by " . get_class($e) . ": " . $e->getMessage());
             Console::log($e->getTraceAsString(), "gray");
         } catch (Error $e) {
             $response->status(500);
@@ -405,7 +370,7 @@ class ServerEventHandler
                 else
                     $response->end("Internal server error.");
             }
-            Console::error("Internal server error (500), caused by " . get_class($e).": ".$e->getMessage());
+            Console::error("Internal server error (500), caused by " . get_class($e) . ": " . $e->getMessage());
             Console::log($e->getTraceAsString(), "gray");
         }
     }
@@ -426,8 +391,8 @@ class ServerEventHandler
         $conn->setOption("connect_id", strval($request->header["x-self-id"] ?? ""));
 
         $dispatcher1 = new EventDispatcher(OnOpenEvent::class);
-        $dispatcher1->setRuleFunction(function($v) {
-            return ctx()->getConnection()->getName() == $v->connect_type && eval("return ".$v->getRule().";");
+        $dispatcher1->setRuleFunction(function ($v) {
+            return ctx()->getConnection()->getName() == $v->connect_type && eval("return " . $v->getRule() . ";");
         });
 
         $dispatcher = new EventDispatcher(OnSwooleEvent::class);
@@ -473,7 +438,7 @@ class ServerEventHandler
         set_coroutine_params(["server" => $server, "connection" => $conn, "fd" => $fd]);
 
         $dispatcher1 = new EventDispatcher(OnCloseEvent::class);
-        $dispatcher1->setRuleFunction(function($v){
+        $dispatcher1->setRuleFunction(function ($v) {
             return $v->connect_type == ctx()->getConnection()->getName() && eval("return " . $v->getRule() . ";");
         });
 
@@ -570,14 +535,14 @@ class ServerEventHandler
         //加载各个模块的注解类，以及反射
         Console::debug("检索Module中");
         $parser = new AnnotationParser();
-        $path = DataProvider::getWorkingDir()."/src/";
+        $path = DataProvider::getWorkingDir() . "/src/";
         $dir = scandir($path);
         unset($dir[0], $dir[1]);
-        $composer = json_decode(file_get_contents(__DIR__."/../../../composer.json"), true);
-        foreach($dir as $v) {
-            if(is_dir($path."/".$v) && isset($composer["autoload"]["psr-4"][$v."\\"]) && !in_array($composer["autoload"]["psr-4"][$v."\\"], $composer["extra"]["exclude_annotate"])) {
-                Console::verbose("Add ".$v . " to register path");
-                $parser->addRegisterPath(DataProvider::getWorkingDir()."/src/".$v."/", $v);
+        $composer = json_decode(file_get_contents(DataProvider::getWorkingDir() . "/composer.json"), true);
+        foreach ($dir as $v) {
+            if (is_dir($path . "/" . $v) && isset($composer["autoload"]["psr-4"][$v . "\\"]) && !in_array($composer["autoload"]["psr-4"][$v . "\\"], $composer["extra"]["exclude_annotate"] ?? [])) {
+                Console::verbose("Add " . $v . " to register path");
+                $parser->addRegisterPath(DataProvider::getWorkingDir() . "/src/" . $v . "/", $v);
             }
         }
         $parser->registerMods();

src/ZM/Framework.php

@@ -94,6 +94,7 @@ class Framework
                 "version" => ZM_VERSION,
                 "config" => $args["env"] === null ? 'global.php' : $args["env"]
             ];
+            if(APP_VERSION !== "unknown") $out["app_version"] = APP_VERSION;
             if (isset(ZMConfig::get("global", "swoole")["task_worker_num"])) {
                 $out["task_worker_num"] = ZMConfig::get("global", "swoole")["task_worker_num"];
             }
@@ -129,6 +130,40 @@ class Framework
             LightCache::init($r);
             LightCacheInside::init();
             SpinLock::init($r["size"]);
+            set_error_handler(function ($error_no, $error_msg, $error_file, $error_line) {
+                switch ($error_no) {
+                    case E_WARNING:
+                        $level_tips = 'PHP Warning: ';
+                        break;
+                    case E_NOTICE:
+                        $level_tips = 'PHP Notice: ';
+                        break;
+                    case E_DEPRECATED:
+                        $level_tips = 'PHP Deprecated: ';
+                        break;
+                    case E_USER_ERROR:
+                        $level_tips = 'User Error: ';
+                        break;
+                    case E_USER_WARNING:
+                        $level_tips = 'User Warning: ';
+                        break;
+                    case E_USER_NOTICE:
+                        $level_tips = 'User Notice: ';
+                        break;
+                    case E_USER_DEPRECATED:
+                        $level_tips = 'User Deprecated: ';
+                        break;
+                    case E_STRICT:
+                        $level_tips = 'PHP Strict: ';
+                        break;
+                    default:
+                        $level_tips = 'Unkonw Type Error: ';
+                        break;
+                }      // do some handle
+                $error = $level_tips . $error_msg . ' in ' . $error_file . ' on ' . $error_line;
+                Console::warning($error);      // 如果 return false 则错误会继续递交给 PHP 标准错误处理     /
+                return true;
+            }, E_ALL | E_STRICT);
         } catch (Exception $e) {
             Console::error("Framework初始化出现错误，请检查！");
             Console::error($e->getMessage());

src/ZM/Http/Response.php

@@ -94,7 +94,8 @@ class Response
      */
     public function status($http_code, $reason = null) {
         $this->status_code = $http_code;
-        return $this->response->status($http_code, $reason);
+        if (!$this->is_end) return $this->response->status($http_code, $reason);
+        else return false;
     }
 
     public function getStatusCode() {
@@ -107,7 +108,8 @@ class Response
      * @return mixed
      */
     public function setStatusCode($http_code, $reason = null) {
-        return $this->response->setStatusCode($http_code, $reason);
+        if (!$this->is_end) return $this->response->setStatusCode($http_code, $reason);
+        else return false;
     }
 
     /**
@@ -117,7 +119,8 @@ class Response
      * @return mixed
      */
     public function header($key, $value, $ucwords = null) {
-        return $this->response->header($key, $value, $ucwords);
+        if (!$this->is_end) return $this->response->header($key, $value, $ucwords);
+        else return false;
     }
 
     /**
@@ -127,7 +130,7 @@ class Response
      * @return mixed
      */
     public function setHeader($key, $value, $ucwords = null) {
-        return $this->response->setHeader($key, $value, $ucwords);
+        return !$this->is_end ? $this->response->setHeader($key, $value, $ucwords) : false;
     }
 
     /**
@@ -159,13 +162,17 @@ class Response
      * @return mixed
      */
     public function end($content = null) {
-        $this->is_end = true;
-        return $this->response->end($content);
+        if(!$this->is_end) {
+            $this->is_end = true;
+            return $this->response->end($content);
+        } else {
+            return false;
+        }
     }
 
     public function isEnd() { return $this->is_end; }
 
-    public function endWithStatus($status_code = 200, $content = null){
+    public function endWithStatus($status_code = 200, $content = null) {
         $this->status($status_code);
         $this->end($content);
     }

src/ZM/global_defines.php

@@ -1,10 +1,12 @@
 <?php #plain
 
 use ZM\Config\ZMConfig;
+use ZM\Utils\DataProvider;
 
 define("ZM_START_TIME", microtime(true));
 define("ZM_DATA", ZMConfig::get("global", "zm_data"));
 define("ZM_VERSION", json_decode(file_get_contents(__DIR__ . "/../../composer.json"), true)["version"] ?? "unknown");
+define("APP_VERSION", json_decode(file_get_contents(DataProvider::getWorkingDir() . "/composer.json"), true)["version"] ?? "unknown");
 define("CRASH_DIR", ZMConfig::get("global", "crash_dir"));
 @mkdir(ZM_DATA);
 @mkdir(CRASH_DIR);

src/ZM/global_functions.php

@@ -89,6 +89,12 @@ function getAllClasses($dir, $indoor_name) {
         if (is_dir($dir . $v)) $classes = array_merge($classes, getAllClasses($dir . $v . "/", $indoor_name . "\\" . $v));
         elseif (mb_substr($v, -4) == ".php") {
             if(substr(file_get_contents($dir.$v), 6, 6) == "#plain") continue;
+            $composer = json_decode(file_get_contents(DataProvider::getWorkingDir()."/composer.json"), true);
+            foreach($composer["autoload"]["files"] as $fi) {
+                if(realpath(DataProvider::getWorkingDir()."/".$fi) == realpath($dir.$v)) {
+                    continue 2;
+                }
+            }
             $class_name = $indoor_name . "\\" . mb_substr($v, 0, -4);
             $classes [] = $class_name;
         }