From 1cddc8948811d4c588f6913adb3e26236c87cdb4 Mon Sep 17 00:00:00 2001
From: LiaoYijun <lyj@hainatravel.com>
Date: Mon, 23 Dec 2024 16:57:37 +0800
Subject: [PATCH] =?UTF-8?q?perf:=20=E4=BD=BF=E7=94=A8=E5=85=A8=E5=B1=80=20?=
 =?UTF-8?q?Emitter?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 wai-server/core/baileys/index.js | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/wai-server/core/baileys/index.js b/wai-server/core/baileys/index.js
index aa578ed..9aa437b 100644
--- a/wai-server/core/baileys/index.js
+++ b/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": "",