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

feat: debounced app state resync

Browse Source
This commit is contained in:
Adhiraj Singh
2022-03-29 19:59:19 +05:30
parent 6e34f2a0cd
commit ced2f5d5ab
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -2,7 +2,7 @@
import { proto } from '../../WAProto' import { proto } from '../../WAProto'
import { KEY_BUNDLE_TYPE } from '../Defaults' import { KEY_BUNDLE_TYPE } from '../Defaults'
import { BaileysEventMap, MessageUserReceipt, SocketConfig, WAMessageStubType } from '../Types' import { BaileysEventMap, MessageUserReceipt, SocketConfig, WAMessageStubType } from '../Types'
import { decodeMessageStanza, delay, encodeBigEndian, generateSignalPubKey, getStatusFromReceiptType, normalizeMessageContent, xmppPreKey, xmppSignedPreKey } from '../Utils' import { debouncedTimeout, decodeMessageStanza, delay, encodeBigEndian, generateSignalPubKey, getStatusFromReceiptType, normalizeMessageContent, xmppPreKey, xmppSignedPreKey } from '../Utils'
import { makeKeyedMutex, makeMutex } from '../Utils/make-mutex' import { makeKeyedMutex, makeMutex } from '../Utils/make-mutex'
import processMessage from '../Utils/process-message' import processMessage from '../Utils/process-message'
import { areJidsSameUser, BinaryNode, BinaryNodeAttributes, getAllBinaryNodeChildren, getBinaryNodeChildren, isJidGroup, jidDecode, jidEncode, jidNormalizedUser } from '../WABinary' import { areJidsSameUser, BinaryNode, BinaryNodeAttributes, getAllBinaryNodeChildren, getBinaryNodeChildren, isJidGroup, jidDecode, jidEncode, jidNormalizedUser } from '../WABinary'
@@ -36,6 +36,11 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
/** this mutex ensures that each retryRequest will wait for the previous one to finish */ /** this mutex ensures that each retryRequest will wait for the previous one to finish */
const retryMutex = makeMutex() const retryMutex = makeMutex()
const appStateSyncTimeout = debouncedTimeout(
6_000,
() => ws.readyState === ws.OPEN && resyncMainAppState()
)
const msgRetryMap = config.msgRetryCounterMap || { } const msgRetryMap = config.msgRetryCounterMap || { }
const historyCache = new Set<string>() const historyCache = new Set<string>()
@@ -153,8 +158,10 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
{ historyCache, meId, keyStore: authState.keys, logger, treatCiphertextMessagesAsReal } { historyCache, meId, keyStore: authState.keys, logger, treatCiphertextMessagesAsReal }
) )
if(newEvents['chats.set']?.isLatest) { if(isAnyHistoryMsg) {
resyncMainAppState() logger.debug('restarting app sync timeout')
// restart the app state sync timeout
appStateSyncTimeout.start()
} }
return newEvents return newEvents