chore: mutex upsertMessage call from sendMessage

This commit is contained in:
Adhiraj Singh
2022-11-14 16:46:48 +05:30
parent cd9441fd0e
commit 00d8cf4270

View File

@@ -20,6 +20,7 @@ export const makeMessagesSocket = (config: SocketConfig) => {
const { const {
ev, ev,
authState, authState,
processingMutex,
upsertMessage, upsertMessage,
query, query,
fetchPrivacySettings, fetchPrivacySettings,
@@ -649,7 +650,9 @@ export const makeMessagesSocket = (config: SocketConfig) => {
await relayMessage(jid, fullMsg.message!, { messageId: fullMsg.key.id!, cachedGroupMetadata: options.cachedGroupMetadata, additionalAttributes }) await relayMessage(jid, fullMsg.message!, { messageId: fullMsg.key.id!, cachedGroupMetadata: options.cachedGroupMetadata, additionalAttributes })
if(config.emitOwnEvents) { if(config.emitOwnEvents) {
process.nextTick(() => { process.nextTick(() => {
upsertMessage(fullMsg, 'append') processingMutex.mutex(() => (
upsertMessage(fullMsg, 'append')
))
}) })
} }