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,