From 31da4bfca14cbec78ba8f6c2541f71a4cd874a94 Mon Sep 17 00:00:00 2001 From: devlikepro Date: Fri, 13 Jun 2025 16:32:59 +0700 Subject: [PATCH] [core] WEBJS - message.edited fix #1041 --- src/core/engines/webjs/session.webjs.core.ts | 21 ++++++++++++++++++++ 1 file changed, 21 insertions(+) diff --git a/src/core/engines/webjs/session.webjs.core.ts b/src/core/engines/webjs/session.webjs.core.ts index a3139306..786c4dd3 100644 --- a/src/core/engines/webjs/session.webjs.core.ts +++ b/src/core/engines/webjs/session.webjs.core.ts @@ -111,6 +111,7 @@ import { StatusRequest, TextStatus } from '@waha/structures/status.dto'; import { EnginePayload, WAMessageAckBody, + WAMessageEditedBody, WAMessageRevokedBody, } from '@waha/structures/webhooks.dto'; import { PaginatorInMemory } from '@waha/utils/Paginator'; @@ -1435,6 +1436,26 @@ export class WhatsappSessionWebJSCore extends WhatsappSession { ); this.events2.get(WAHAEvents.MESSAGE_REACTION).switch(messagesReaction$); + const messageEdit$ = fromEvent( + this.whatsapp, + Events.MESSAGE_EDIT, + (message, newBody, prevBody) => { + return { message, newBody, prevBody }; + }, + ); + const messagesEdit$ = messageEdit$.pipe( + map((event): WAMessageEditedBody => { + const message = this.toWAMessage(event.message); + return { + message: message, + body: event.newBody, + originalMessageId: message._data?.id?.id, + _data: event, + }; + }), + ); + this.events2.get(WAHAEvents.MESSAGE_EDITED).switch(messagesEdit$); + const messageAckWEBJS$ = fromEvent( this.whatsapp, Events.MESSAGE_ACK,