feat(0.0.4): 修复问题，并发布0.0.4

Author: ruixiaozi

CHANGELOG.md

@@ -3,7 +3,16 @@
 > 次版本：每季度发布一次，向下兼容的功能性新增  
 > 修订版本：每周发布一次(紧急版本随时发布)，向下兼容的问题修正
 
-## 0.0.3 [Current] 
+## 0.0.4 [Current] 
+###### 发布日期：2023-05-23
+###### 兼容性：0.x.x
+
++ 修复InHeader只能大写或者驼峰无法获取请求头的问题
++ BriskControllerError增加setBody方法
++ 修复端口冲突程序处理异常的问题
+
+
+## 0.0.3 
 ###### 发布日期：2023-05-15
 ###### 兼容性：0.x.x
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "brisk-controller",
-  "version": "0.0.3",
+  "version": "0.0.4",
   "description": "fast light brisk controller in nodejs(koa)",
   "main": "lib/index.js",
   "types": "lib/index.d.ts",
@@ -35,15 +35,16 @@
   },
   "homepage": "https://github.com/ruixiaozi/brisk-controller#readme",
   "dependencies": {
-    "brisk-ioc": "0.0.3",
-    "brisk-log": "0.0.3",
-    "brisk-ts-extends": "0.0.3",
+    "brisk-ioc": "0.0.4",
+    "brisk-log": "0.0.4",
+    "brisk-ts-extends": "0.0.4",
     "co-body": "^6.1.0",
     "koa": "2.14.1",
     "koa-cors": "0.0.16",
     "koa-static": "5.0.0",
     "koa2-swagger-ui": "5.6.0",
-    "path-to-regexp": "^6.2.1"
+    "path-to-regexp": "^6.2.1",
+    "portfinder": "^1.0.32"
   },
   "devDependencies": {
     "@commitlint/cli": "16.2.1",

src/core/core.ts

@@ -5,7 +5,7 @@ import cors from 'koa-cors';
 import staticMidware from 'koa-static';
 import path from 'path';
 import { Server } from 'http';
-import net from 'net';
+import { getPortPromise } from 'portfinder';
 import {
   BriskControllerRequestHandler,
   BriskControllerOption,
@@ -223,7 +223,7 @@ function getParameters(ctx: Context, params?: BriskControllerParameter[]) {
         value = (ctx.request as any).pathParams?.[item.name];
         break;
       case BRISK_CONTROLLER_PARAMETER_IS_E.HEADER:
-        value = ctx.request.headers[item.name];
+        value = ctx.request.headers[item.name.toLowerCase()];
         break;
       case BRISK_CONTROLLER_PARAMETER_IS_E.COOKIE:
         value = ctx.cookies.get(item.name);
@@ -327,32 +327,6 @@ export function addRequest(requestPath: string, handler: BriskControllerRequestH
   );
 }
 
-
-export function getPort(port: number): Promise<number> {
-  let testServer = net.createServer().listen(port);
-  return new Promise((resolve, reject) => {
-    testServer.on('listening', () => {
-      testServer.close((err) => {
-        if (err) {
-          logger.error('getPort close error! retry ...', err);
-          resolve(getPort(port));
-          return;
-        }
-        resolve(port);
-      });
-    });
-    testServer.on('error', (err: any) => {
-      if (err.code === 'EADDRINUSE') {
-        logger.warn(`this port ${port} is occupied try another.`);
-        resolve(getPort(port + 1));
-      } else {
-        logger.error('getPort error!', err);
-        reject(err);
-      }
-    });
-  });
-}
-
 /**
  * 开始运行
  * @param port 端口，默认3000
@@ -379,8 +353,12 @@ export async function start(port: number = 3000, option?: BriskControllerOption)
     app.use(staticMidware(path.resolve(option.staticPath)));
   }
 
+  const realPort = await getPortPromise({
+    port,
+  });
+
   if (option?.swagger) {
-    addRequest('/swagger.json', getSwaggerHandler(port, globalBaseUrl), {
+    addRequest('/swagger.json', getSwaggerHandler(realPort, globalBaseUrl), {
       title: 'swagger文件(仅开启swagger后有效)',
       description: '获取swagger.json',
       tag: {
@@ -401,11 +379,11 @@ export async function start(port: number = 3000, option?: BriskControllerOption)
 
   app.use(router);
 
-  const realPort = await getPort(port);
-
   await new Promise((resolve) => {
     server = app.listen(realPort, '0.0.0.0', () => {
-      logger.info(`listen http://localhost:${port}`);
+      logger.info(`listen http://0.0.0.0:${realPort}`);
+      logger.info(`listen http://127.0.0.1:${realPort}`);
+      logger.info(`listen http://localhost:${realPort}`);
       resolve(null);
     });
   });

src/core/router.ts

@@ -24,7 +24,7 @@ export class BriskControllerError extends Error {
 
   status!: number;
 
-  text?: string;
+  text?: string | any;
 
   headers?: BriskControllerHeaders;
 
@@ -41,6 +41,10 @@ export class BriskControllerError extends Error {
     this.status = _status;
   }
 
+  setBody(body: any) {
+    this.text = body;
+  }
+
 }
 
 // 路径、方法名、类型、处理器列表（按顺序执行）