test

app.js

@@ -3,6 +3,7 @@ import { join } from 'path';
 import CreateBot from '#root/bot/index.js';
 import CreateWebhookServer from '#root/http/index.js';
 import logger from '#root/utils/logger.js';
+import handlers from './handlers';
 
 let retryCount = 0;
 
@@ -37,17 +38,17 @@ let retryCount = 0;
   const webhook = new CreateWebhookServer();
 
   logger('开始引入handler函数');
-  const files = fs.readdirSync('./handlers');
+  // const files = fs.readdirSync('./handlers');
-  const handlers = files
+  // const handlers = files
-    .filter((it) => /\.js$/.test(it))
+  //   .filter((it) => /\.js$/.test(it))
-    .map((it) => {
+  //   .map((it) => {
-      let fPath = join(__dirname, './handlers', it);
+  //     let fPath = join(__dirname, './handlers', it);
-      return {
+  //     return {
-        event: it.split('.').slice(0, -1).join('.'),
+  //       event: it.split('.').slice(0, -1).join('.'),
-        handler: require(fPath).bind(this, bot),
+  //       handler: require(fPath).bind(this, bot),
-      };
+  //     };
-    });
+  //   });
-  webhook.registerHanlder(handlers);
+  webhook.registerHandler(handlers.map(i => ({ event: i.event, handler: i.handler.bind(this, bot) })));
 
   webhook.startListen(port);
   logger(`开始监听端口: ${port}`);

handlers/index.js

@@ -0,0 +1,14 @@
+import sendForwardMessage from './sendForwardMessage.js'
+import sendMessage from './sendMessage.js'
+import sendMessage2 from './sendMessage2.js'
+
+export default [{
+  event: 'sendMessage',
+  handler: sendMessage
+}, {
+  event: 'sendForwardMessage',
+  handler: sendForwardMessage
+}, {
+  event: 'sendMessage2',
+  handler: sendMessage2
+}]

http/index.js

@@ -51,7 +51,7 @@ export default class CreateWebhookServer {
       .listen(port || 8080);
   }
 
-  registerHanlder(handlers) {
+  registerHandler(handlers) {
     logger(`${handlers.map((item) => item.event).join('、')}函数已引入`);
     this.handlers.push(...handlers);
   }