From 00d8cf427022d7698a577fcbb98d8561ccade24c Mon Sep 17 00:00:00 2001
From: Adhiraj Singh <adhirajsingh1001@gmail.com>
Date: Mon, 14 Nov 2022 16:46:48 +0530
Subject: [PATCH] chore: mutex upsertMessage call from sendMessage

---
 src/Socket/messages-send.ts | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/Socket/messages-send.ts b/src/Socket/messages-send.ts
index b6f3fa6..cb5e416 100644
--- a/src/Socket/messages-send.ts
+++ b/src/Socket/messages-send.ts
@@ -20,6 +20,7 @@ export const makeMessagesSocket = (config: SocketConfig) => {
 	const {
 		ev,
 		authState,
+		processingMutex,
 		upsertMessage,
 		query,
 		fetchPrivacySettings,
@@ -649,7 +650,9 @@ export const makeMessagesSocket = (config: SocketConfig) => {
 				await relayMessage(jid, fullMsg.message!, { messageId: fullMsg.key.id!, cachedGroupMetadata: options.cachedGroupMetadata, additionalAttributes })
 				if(config.emitOwnEvents) {
 					process.nextTick(() => {
-						upsertMessage(fullMsg, 'append')
+						processingMutex.mutex(() => (
+							upsertMessage(fullMsg, 'append')
+						))
 					})
 				}