perf: 使用全局 Emitter

wai-server/core/baileys/index.js

@@ -8,13 +8,12 @@ const {
   useMultiFileAuthState,
   downloadMediaMessage
 } = require('@whiskeysockets/baileys');
-const EventEmitter = require('events');
 const { writeFile } = require('fs/promises');
+const waEmitter = require('../emitter');
 
 const generateId = require('../../utils/generateId.util');
 const NodeCache = require('node-cache');
 const P = require('pino');
-const { format } = require('path');
 
 const logger = P({ timestamp: () => `,"time":"${new Date().toJSON()}"` }, P.destination('./wa-logs.txt'))
 logger.level = 'trace'
@@ -40,7 +39,7 @@ const createWhatsApp = async (phone) => {
   // fetch latest version of WA Web
   const { version, isLatest } = await fetchLatestBaileysVersion()
   const waVersion = version.join('.') + ', ' + (isLatest ? 'latest' : 'out')
-  const waEmitter = new EventEmitter();
+  // const waEmitter = new EventEmitter();
 
   const formatPhoneNumber = (number) => {
     if (number.indexOf('@g.us') > -1) {
@@ -179,7 +178,7 @@ const createWhatsApp = async (phone) => {
               }
 
               if (msg.key.fromMe) {
-                waEmitter.emit('message.updated', {
+                waEmitter.emit('message:updated', {
                   "id":  msg.key.id,
                   "wamid": msg.key.id,
                   "status": formatStatus(msg.status),
@@ -201,7 +200,7 @@ const createWhatsApp = async (phone) => {
                   "readTime": formatTimestamp(msg.messageTimestamp),
                 });
               } else {
-                waEmitter.emit('message.received', {
+                waEmitter.emit('message:received', {
                   "id":  msg.key.id,
                   "wamid": msg.key.id,
                   "status": "",