diff --git a/app.js b/app.js index 29259dc..9919cc8 100644 --- a/app.js +++ b/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 handlers = files - .filter((it) => /\.js$/.test(it)) - .map((it) => { - let fPath = join(__dirname, './handlers', it); - return { - event: it.split('.').slice(0, -1).join('.'), - handler: require(fPath).bind(this, bot), - }; - }); - webhook.registerHanlder(handlers); + // const files = fs.readdirSync('./handlers'); + // const handlers = files + // .filter((it) => /\.js$/.test(it)) + // .map((it) => { + // let fPath = join(__dirname, './handlers', it); + // return { + // event: it.split('.').slice(0, -1).join('.'), + // handler: require(fPath).bind(this, bot), + // }; + // }); + webhook.registerHandler(handlers.map(i => ({ event: i.event, handler: i.handler.bind(this, bot) }))); webhook.startListen(port); logger(`开始监听端口: ${port}`); diff --git a/handlers/index.js b/handlers/index.js new file mode 100644 index 0000000..53083c2 --- /dev/null +++ b/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 +}] \ No newline at end of file diff --git a/http/index.js b/http/index.js index 02b29a7..6a2fbca 100644 --- a/http/index.js +++ b/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); }