feat: add message events for reactions

src/LegacySocket/messages.ts

@@ -143,7 +143,21 @@ const makeMessagesSocket = (config: LegacySocketConfig) => {
 			}
 		}
 
-		const protocolMessage = normalizeMessageContent(message.message)?.protocolMessage
+		const normalizedContent = normalizeMessageContent(message.message)
+		const protocolMessage = normalizedContent?.protocolMessage
+
+		if(normalizedContent.reactionMessage) {
+			const reaction: proto.IReaction = {
+				...normalizedContent.reactionMessage,
+				key: message.key,
+			}
+			const operation = normalizedContent.reactionMessage?.text ? 'add' : 'remove'
+			ev.emit(
+				'messages.reaction',
+				{ reaction, key: normalizedContent.reactionMessage!.key!, operation }
+			)
+		}
+
 		// if it's a message to delete another message
 		if(protocolMessage) {
 			switch (protocolMessage.type) {

src/Socket/messages-recv.ts

@@ -203,6 +203,16 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
 				chatUpdate.ephemeralExpiration = protocolMsg.ephemeralExpiration || null
 				break
 			}
+		} else if(content.reactionMessage) {
+			const reaction: proto.IReaction = {
+				...content.reactionMessage,
+				key: message.key,
+			}
+			const operation = content.reactionMessage?.text ? 'add' : 'remove'
+			ev.emit(
+				'messages.reaction',
+				{ reaction, key: content.reactionMessage!.key!, operation }
+			)
 		} else if(message.messageStubType) {
 			const meJid = authState.creds.me!.id
 			const jid = message.key!.remoteJid!

src/Types/Events.ts

@@ -1,4 +1,5 @@
 import type EventEmitter from 'events'
+import { proto } from '../../WAProto'
 import { AuthenticationCreds } from './Auth'
 import { Chat, PresenceData } from './Chat'
 import { Contact } from './Contact'
@@ -36,6 +37,7 @@ export type BaileysEventMap<T> = {
      * the update will have type: "notify"
      *  */
     'messages.upsert': { messages: WAMessage[], type: MessageUpdateType }
+    'messages.reaction': { key: WAMessageKey, reaction: proto.IReaction, operation: 'add' | 'remove' }
 
     'message-receipt.update': MessageUserReceiptUpdate[]