franpcode/Baileys
1
0
Fork 0
mirror of https://github.com/FranP-code/Baileys.git synced 2025-10-13 00:32:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: send history sync later

Browse Source
This commit is contained in:
Adhiraj Singh
2022-04-03 00:14:34 +05:30
parent bd682a8485
commit f9ffb0f4c8
1 changed files with 14 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/Socket/messages-recv.ts
View File

@@ -140,13 +140,25 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
})
}
const processMessageLocal = async(message: proto.IWebMessageInfo) => {
const processMessageLocal = async(msg: proto.IWebMessageInfo) => {
const meId = authState.creds.me!.id
// process message and emit events
const newEvents = await processMessage(
message,
msg,
{ historyCache, meId, keyStore: authState.keys, logger, treatCiphertextMessagesAsReal }
)
// send ack for history message
const normalizedContent = !!msg.message ? normalizeMessageContent(msg.message) : undefined
const isAnyHistoryMsg = !!normalizedContent?.protocolMessage?.historySyncNotification
if(isAnyHistoryMsg) {
await sendReceipt(msg.key.remoteJid!, undefined, [msg.key.id], 'hist_sync')
// we only want to sync app state once we've all the history
// restart the app state sync timeout
logger.debug('restarting app sync timeout')
appStateSyncTimeout.start()
}
return newEvents
}
@@ -456,17 +468,6 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
// no type in the receipt => message delivered
await sendReceipt(msg.key.remoteJid!, msg.key.participant, [msg.key.id!], undefined)
// send ack for history message
const normalizedContent = !!msg.message ? normalizeMessageContent(msg.message) : undefined
const isAnyHistoryMsg = !!normalizedContent?.protocolMessage?.historySyncNotification
if(isAnyHistoryMsg) {
await sendReceipt(msg.key.remoteJid!, undefined, [msg.key.id], 'hist_sync')
// we only want to sync app state once we've all the history
// restart the app state sync timeout
logger.debug('restarting app sync timeout')
appStateSyncTimeout.start()
}
if(category === 'peer') {
await sendReceipt(msg.key.remoteJid!, undefined, [msg.key.id], 'peer_msg')
}