消息监听器

Author: MiaowFISH

.gitignore

@@ -1,6 +1,7 @@
 # Packages
 node_modules
 yarn.lock
+yarn-error.log
 
 # Docs site
 site

.hdic.config.js

@@ -0,0 +1,3 @@
+export default {
+  
+}

hdic.ts

@@ -3,14 +3,7 @@ import { Bot, Session } from './src/medic.js'
 import { app } from './src/index.js'
 
 // 消息相关，At Image Text 是消息元素
-import {
-  At,
-  Image,
-  Text,
-  createChain,
-  reply,
-  sendGroupMessage,
-} from './src/message.js'
+import { At, Image, Text, createChain, reply, sendGroupMessage } from './src/message.js'
 
 // 文件扩展
 import * as fs from './src/extensions/fs.js'
@@ -22,9 +15,14 @@ import http from './src/extensions/http.js'
 import { Plugin } from './src/types/plugin.js'
 import './src/plugins/jrrp.js'
 
+// 事件监听器
+import EventEmitter, { once } from './src/extensions/events.js'
+const Event = new EventEmitter()
+globalThis.Event = Event
+
 import { InnerMode } from './src/utils/helper.js'
 let innerMode = new InnerMode()
-async function main(session: Session) {
+async function messageHandler(session: Session) {
   globalThis.client = session.client
 
   // 消息中断器示例
@@ -46,59 +44,32 @@ async function main(session: Session) {
     }
   }
   // 消息中断器示例结束
-
-  // 插件系统
-  if (globalThis.plugins && globalThis.plugins.length > 0) {
-    globalThis.plugins.forEach(async (p: Plugin) => {
-      if (p.enable) {
-        try {
-          await p.action(session)
-        } catch (e) {
-          console.log(e)
-        }
-      }
-    })
-  }
-  if (session.msg === 'help' || session.msg === '菜单') {
-    let menu = ''
-    if (globalThis.plugins && globalThis.plugins.length > 0) {
-      globalThis.plugins.forEach((p: Plugin) => {
-        if (p.enable) {
-          menu += p.info.name + '\n    ' + p.info.description + '\n'
-        }
-      })
-      reply(menu)
-    } else {
-      reply('没有菜单呢')
-    }
-  }
-  // 插件系统结束
 }
 
 $.on('message.group', async (message) => {
   let session = new Session(message, 'GroupMessage')
-  try {
-    await main(session)
-  } catch (e) {
-    console.warn('MEJS运行失败: ' + e)
-  }
+  Event.emit('message', session)
+  Event.emit('message.group', session)
 })
 
-$.on('message.friend', async (message: typeof globalThis.message) => {
+$.on('message.friend', async (message) => {
   let session = new Session(message, 'FriendMessage')
-  main(session)
+  Event.emit('message', session)
+  Event.emit('message.friend', session)
 })
 
-$.on('message.temp', async (message: typeof globalThis.message) => {
+$.on('message.temp', async (message) => {
   let session = new Session(message, 'FriendMessage')
-  main(session)
+  Event.emit('message', session)
+  Event.emit('message.temp', session)
 })
 
 // Bot 上线事件
 $.on('online', (bot: typeof globalThis.bot) => {
   console.log(`${bot.uin} 已上线`)
   try {
     globalThis.bot = new Bot()
+    bot = globalThis.bot
   } catch (e) {
     console.log(e)
   }
@@ -112,3 +83,7 @@ while (true) {
     break
   }
 }
+
+Event.on('message', async (session: Session) => {
+  await messageHandler(session)
+})

package.json

@@ -13,7 +13,9 @@
     "docs:type": "typedoc"
   },
   "dependencies": {
+    "@types/java": "^0.9.2",
     "minimist": "^1.2.5",
+    "node-java": "^1.0.1",
     "typescript": "^4.6.2"
   },
   "devDependencies": {

src/command.ts

@@ -0,0 +1,25 @@
+import EventEmitter from './extensions/events'
+import parser from './extensions/commander.js'
+let Event = new EventEmitter()
+class Command {
+  command: any
+  compulsory: any
+  optional: any[]
+  constructor(cmd) {
+    this.command = cmd
+    this.compulsory = []
+    this.optional = []
+  }
+  option(value: string, tag: string, defaultValue?: string) {
+    return this
+  }
+  action(callback: Function) {
+    Event.on('message.group', async (session) => {
+      await callback()
+    })
+  }
+  prase(cmd: string) {
+    return parser(cmd)
+  }
+}
+function command(cmd) {}

src/example/hdic.txt

@@ -3,9 +3,9 @@
 权限:手机信息
 作者:Miaow
 版本:α
-图标:https://nekohouse.cafe/Yun.png
+图标:https://nekohouse.cafe/yun.png
 简介:这只是一个演示dic,本文件仅供参考，请勿在未知的情况下随意导入
-官网:https://nekohouse.cafe
+官网:https://docs.nekohouse.cafe
 开机:喵喵起床
 关机:喵喵睡觉